@@ -167,6 +167,7 @@ async function startRunner(): Promise<
167167 fetch : async (
168168 runner : Runner ,
169169 actorId : string ,
170+ _gatewayId : ArrayBuffer ,
170171 _requestId : ArrayBuffer ,
171172 request : Request ,
172173 ) => {
@@ -215,6 +216,7 @@ async function startRunner(): Promise<
215216 runner : Runner ,
216217 actorId : string ,
217218 ws : WebSocket ,
219+ _gatewayId : ArrayBuffer ,
218220 _requestId : ArrayBuffer ,
219221 _request : Request ,
220222 ) => {
@@ -239,7 +241,8 @@ async function startRunner(): Promise<
239241 websocketId ,
240242 ( event as any ) . rivetMessageIndex ,
241243 ) ;
242- runner . sendWebsocketMessageAck (
244+ runner . sendHibernatableWebSocketMessageAck (
245+ ( event as any ) . rivetGatewayId ,
243246 ( event as any ) . rivetRequestId ,
244247 ( event as any ) . rivetMessageIndex ,
245248 ) ;
@@ -256,13 +259,15 @@ async function startRunner(): Promise<
256259 } ) ;
257260 } ) ;
258261 } ,
259- getActorHibernationConfig ( actorId , requestId ) {
260- const websocketId = Buffer . from ( requestId ) . toString ( "base64" ) ;
261- return {
262- enabled : true ,
263- lastMsgIndex : websocketLastMsgIndexes . get ( websocketId ) ,
264- } ;
265- } ,
262+ // TODO:
263+ hibernatableWebSocket : undefined as any ,
264+ // getActorHibernationConfig(actorId, gatewayId, requestId) {
265+ // const websocketId = Buffer.from(requestId).toString("base64");
266+ // return {
267+ // enabled: true,
268+ // lastMsgIndex: websocketLastMsgIndexes.get(websocketId),
269+ // };
270+ // },
266271 } ;
267272
268273 const runner = new Runner ( config ) ;
0 commit comments