Skip to content

Commit 9bd8b5f

Browse files
committed
match as per master
1 parent f90c1b8 commit 9bd8b5f

File tree

2 files changed

+27
-0
lines changed

2 files changed

+27
-0
lines changed
Lines changed: 19 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,19 @@
1+
{.push raises: [].}
2+
3+
import system, std/json
4+
import ./json_base_event
5+
import ../../waku/api/types
6+
7+
type JsonConnectionStatusChangeEvent* = ref object of JsonEvent
8+
status*: ConnectionStatus
9+
10+
proc new*(
11+
T: type JsonConnectionStatusChangeEvent, status: ConnectionStatus
12+
): T =
13+
return JsonConnectionStatusChangeEvent(
14+
eventType: "node_health_change",
15+
status: status
16+
)
17+
18+
method `$`*(event: JsonConnectionStatusChangeEvent): string =
19+
$(%*event)

library/libwaku.nim

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,9 +7,11 @@ import
77
./events/json_message_event,
88
./events/json_topic_health_change_event,
99
./events/json_connection_change_event,
10+
./events/json_connection_status_change_event,
1011
../waku/factory/app_callbacks,
1112
waku/factory/waku,
1213
waku/node/waku_node,
14+
waku/node/health_monitor/health_status,
1315
./declare_lib
1416

1517
################################################################################
@@ -61,10 +63,16 @@ proc waku_new(
6163
callEventCallback(ctx, "onConnectionChange"):
6264
$JsonConnectionChangeEvent.new($peerId, peerEvent)
6365

66+
proc onConnectionStatusChange(ctx: ptr FFIContext): ConnectionStatusChangeHandler =
67+
return proc(status: ConnectionStatus) {.async.} =
68+
callEventCallback(ctx, "onConnectionStatusChange"):
69+
$JsonConnectionStatusChangeEvent.new(status)
70+
6471
let appCallbacks = AppCallbacks(
6572
relayHandler: onReceivedMessage(ctx),
6673
topicHealthChangeHandler: onTopicHealthChange(ctx),
6774
connectionChangeHandler: onConnectionChange(ctx),
75+
connectionStatusChangeHandler: onConnectionStatusChange(ctx)
6876
)
6977

7078
ffi.sendRequestToFFIThread(

0 commit comments

Comments
 (0)