comet.sh
1defmodule ExampleRecordConsumer do
2 use Drinkup.RecordConsumer, collections: [~r/app\.bsky\.graph\..+/, "app.bsky.feed.post"]
3
4 def handle_create(record) do
5 IO.inspect(record, label: "create")
6 end
7
8 def handle_update(record) do
9 IO.inspect(record, label: "update")
10 end
11
12 def handle_delete(record) do
13 IO.inspect(record, label: "delete")
14 end
15end
16
17defmodule ExampleSupervisor do
18 use Supervisor
19
20 def start_link(args \\ []) do
21 Supervisor.start_link(__MODULE__, arg, name: __MODULE__)
22 end
23
24 @immpl true
25 def init(_arg) do
26 children = [
27 Drinkup,
28 ExampleRecordConsumer
29 ]
30
31 Supervisor.init(children, strategy: :one_for_one)
32 end
33end