We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d2735a8 commit 9d011a4Copy full SHA for 9d011a4
rivetkit-typescript/packages/rivetkit/src/drivers/engine/actor-driver.ts
@@ -545,8 +545,15 @@ export class EngineActorDriver implements ActorDriver {
545
});
546
}
547
548
- websocket.addEventListener("message", (event) => {
+ websocket.addEventListener("message", (event: RivetMessageEvent) => {
549
wsHandlerPromise.then((x) => x.onMessage?.(event, wsContext));
550
+
551
+ invariant(event.rivetRequestId, "missing rivetRequestId");
552
+ invariant(event.rivetMessageIndex, "missing rivetMessageIndex");
553
+ this.#runner.sendWebsocketMessageAck(
554
+ event.rivetRequestId,
555
+ event.rivetMessageIndex,
556
+ );
557
558
559
websocket.addEventListener("close", (event) => {
0 commit comments