Skip to content

Commit c92bee9

Browse files
committed
fix(webSockets): better backwards compat hack?
1 parent 9defbb1 commit c92bee9

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

oada/services/http-handler/src/websockets.ts

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -36,8 +36,8 @@ import { Responder } from '@oada/lib-kafka';
3636

3737
import type Change from '@oada/types/oada/change/v2.js';
3838
import type SocketChange from '@oada/types/oada/websockets/change.js';
39-
import type SocketResponse from '@oada/types/oada/websockets/response.js';
4039
import type SocketRequest from '@oada/types/oada/websockets/request.js';
40+
import type SocketResponse from '@oada/types/oada/websockets/response.js';
4141
import type { WriteResponse } from '@oada/write-handler';
4242
import {
4343
// Runtime check for request type
@@ -86,7 +86,8 @@ class Watch {
8686
async sendChange(change: SocketChange) {
8787
trace({ change }, 'Sending change');
8888
// HACK: for backwards compatibility with older clients
89-
change.path_leftover = change.path_leftover ?? [];
89+
change.path_leftover =
90+
change.path_leftover ?? change.requestId.map(() => '');
9091
await this.#send(JSON.stringify(change));
9192
}
9293

0 commit comments

Comments
 (0)