Skip to content

Commit c67be7b

Browse files
committed
PoC working, subscribing to two users events
1 parent 51d503a commit c67be7b

File tree

2 files changed

+10
-5
lines changed

2 files changed

+10
-5
lines changed

.iex.exs

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -16,17 +16,22 @@ defmodule Receiver do
1616

1717
@impl true
1818
def handle_info(:connected, %{server_pid: server_pid} = socket) do
19-
request_id = Nostr.Client.subscribe_author(
19+
_request_id = Nostr.Client.subscribe_author(
2020
server_pid,
2121
"efc83f01c8fb309df2c8866b8c7924cc8b6f0580afdde1d6e16e2b6107c2862c"
2222
)
2323

24+
_request_id = Nostr.Client.subscribe_author(
25+
server_pid,
26+
"d75a0bcc4b494628d51ceab95ca1b34b9b23b1cb3a715beb1c5a8d963d161460"
27+
)
28+
2429
{:noreply, socket}
2530
end
2631

2732
@impl true
28-
def handle_info(message, socket) do
29-
IO.inspect message, label: "From Receiver"
33+
def handle_info({request_id, event}, socket) do
34+
IO.inspect event, label: "#{request_id}"
3035

3136
{:noreply, socket}
3237
end

lib/nostr/client/server.ex

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,12 +22,12 @@ defmodule Nostr.Client.Server do
2222
def handle_frame({type, msg}, %{client_pid: client_pid} = state) do
2323
case type do
2424
:text ->
25-
{_request_id, event} =
25+
{request_id, event} =
2626
msg
2727
|> Jason.decode!()
2828
|> Event.dispatch()
2929

30-
send(client_pid, event)
30+
send(client_pid, {request_id, event})
3131

3232
_ ->
3333
Logger.warn("#{type}: unknown type of frame")

0 commit comments

Comments
 (0)