Skip to content

Commit bbbce0b

Browse files
committed
update: dependencies, adapt to stz changes
1 parent 806eb9c commit bbbce0b

File tree

5 files changed

+49
-48
lines changed

5 files changed

+49
-48
lines changed

package-lock.json

Lines changed: 35 additions & 35 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

package.json

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -33,14 +33,14 @@
3333
"test-inspect": "node inspect x/tests.test.js"
3434
},
3535
"dependencies": {
36-
"@e280/sten": "^0.0.0-5",
37-
"@e280/stz": "^0.0.0-29",
36+
"@e280/sten": "^0.0.0-6",
37+
"@e280/stz": "^0.0.0-34",
3838
"ws": "^8.18.3"
3939
},
4040
"devDependencies": {
41-
"@e280/science": "^0.0.5",
42-
"@e280/scute": "^0.0.0-6",
43-
"@types/node": "^24.1.0",
41+
"@e280/science": "^0.0.6",
42+
"@e280/scute": "^0.0.0-7",
43+
"@types/node": "^24.2.0",
4444
"@types/ws": "^8.18.1",
4545
"http-server": "^14.1.1",
4646
"npm-run-all": "^4.1.5",

s/tools/pingponger.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ export class Pingponger {
4545
this.#pends.set(pingId, {time, deferred})
4646
this.options.send(["ping", pingId])
4747

48-
return deadline(this.options.timeout, "ping timeout", () => deferred.promise)
48+
return deadline(this.options.timeout, () => deferred.promise)
4949
.finally(() => this.#prune())
5050
}
5151

s/transports/messenger/parts/response-waiter.ts

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11

2-
import {deadline, defer, Deferred} from "@e280/stz"
2+
import {deadline, DeadlineError, defer, Deferred} from "@e280/stz"
33

44
import {JsonRpc} from "../../../core/json-rpc.js"
55
import {RemoteError} from "../../../core/errors.js"
@@ -17,7 +17,12 @@ export class ResponseWaiter {
1717
async wait(id: JsonRpc.Id, method: string) {
1818
const deferred = defer<JsonRpc.Response>()
1919
this.pending.set(id, {method, deferred})
20-
return await deadline(this.timeout, `request #${id} ${method}()`, () => deferred.promise)
20+
return await deadline(this.timeout, () => deferred.promise)
21+
.catch(error => {
22+
if (error instanceof DeadlineError)
23+
error.message = `request #${id} ${method}(), ${error.message}`
24+
throw error
25+
})
2126
}
2227

2328
deliverResponse(response: JsonRpc.Response) {

s/transports/messenger/parts/wait-for-socket-open.ts

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -32,10 +32,6 @@ export async function waitForSocketOpen<S extends WebSocket | ws.WebSocket>(
3232
})
3333
})
3434

35-
return deadline(
36-
timeout,
37-
"timed out waiting for socket open",
38-
async() => promise,
39-
)
35+
return deadline(timeout, async() => promise)
4036
}
4137

0 commit comments

Comments
 (0)