Skip to content

Commit 93d8556

Browse files
committed
debugging on ci
- add random port - add more logging
1 parent cbbbac9 commit 93d8556

File tree

2 files changed

+16
-2
lines changed

2 files changed

+16
-2
lines changed

testmodule/providers/jsonrpc/rpc_mock.nim

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,15 +6,18 @@ import std/tables
66
import pkg/stew/byteutils
77
import pkg/json_rpc/rpcserver except `%`, `%*`
88
import pkg/json_rpc/errors
9-
9+
import std/random
1010

1111
type MockRpcHttpServer* = ref object
1212
filters*: Table[string, bool]
1313
newFilterCounter*: int
1414
srv: RpcHttpServer
1515

1616
proc new*(_: type MockRpcHttpServer): MockRpcHttpServer =
17-
MockRpcHttpServer(filters: initTable[string, bool](), newFilterCounter: 0, srv: newRpcHttpServer(["127.0.0.1:65080"]))
17+
let port = rand(65000..<66000)
18+
let srv = newRpcHttpServer(["127.0.0.1:" & port])
19+
let filters = initTable[string, bool]()
20+
MockRpcHttpServer(filters: filters, newFilterCounter: 0, srv: srv)
1821

1922
proc invalidateFilter*(server: MockRpcHttpServer, id: string) =
2023
server.filters[id] = false

testmodule/providers/jsonrpc/testJsonRpcSubscriptions.nim

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -128,18 +128,29 @@ suite "HTTP polling subscriptions - filter not found":
128128
await mockServer.stop()
129129

130130
test "filter not found error recreates filter":
131+
echo "1"
131132
let filter = EventFilter(address: Address.example, topics: @[array[32, byte].example])
133+
echo "2"
132134
let emptyHandler = proc(log: Log) = discard
135+
echo "3"
133136

134137
check mockServer.newFilterCounter == 0
138+
echo "4"
135139
let jsonId = await subscriptions.subscribeLogs(filter, emptyHandler)
140+
echo "5"
136141
let id = string.fromJson(jsonId).tryGet
142+
echo "6"
137143
check mockServer.newFilterCounter == 1
144+
echo "7"
138145

139146
await sleepAsync(50.millis)
147+
echo "8"
140148
mockServer.invalidateFilter(id)
149+
echo "9"
141150
await sleepAsync(50.millis)
151+
echo "10"
142152
check mockServer.newFilterCounter == 2
153+
echo "11"
143154

144155
test "recreated filter can be still unsubscribed using the original id":
145156
let filter = EventFilter(address: Address.example, topics: @[array[32, byte].example])

0 commit comments

Comments
 (0)