@@ -12,19 +12,24 @@ import { EndpointHandlerPayload, ErrorCode } from '@powersync/lib-services-frame
1212 * @param  responder a mock responder 
1313 * @returns  
1414 */ 
15- async  function  handleRoute ( path : string ,  endpoints : ReactiveEndpoint [ ] ,  responder : SocketResponder ,  request ?: Partial < ReactiveStreamRequest > )  { 
15+ async  function  handleRoute ( 
16+   path : string , 
17+   endpoints : ReactiveEndpoint [ ] , 
18+   responder : SocketResponder , 
19+   request ?: Partial < ReactiveStreamRequest > 
20+ )  { 
1621  return  handleReactiveStream < { } > ( 
1722    { } , 
1823    { 
1924      payload : { 
2025        data : Buffer . from ( serialize ( { } ) ) , 
21-         metadata : Buffer . from ( serialize ( {  path } ) ) , 
26+         metadata : Buffer . from ( serialize ( {  path } ) ) 
2227      } , 
2328      initialN : 1 , 
2429      dataMimeType : 'application/bson' , 
2530      metadataMimeType : 'application/bson' , 
2631      responder, 
27-       ...request , 
32+       ...request 
2833    } , 
2934    createMockObserver ( ) , 
3035    new  AbortController ( ) , 
@@ -145,21 +150,21 @@ describe('Requests', () => {
145150    const  path  =  '/test-route' ; 
146151
147152    const  fn  =  vi . fn ( async  ( p : EndpointHandlerPayload < any ,  any > )  =>  { 
148-       expect ( p . params ) . toStrictEqual ( { ' hello' 'world' } ) ; 
153+       expect ( p . params ) . toStrictEqual ( {   hello : 'world'   } ) ; 
149154      return  undefined ; 
150155    } ) ; 
151156
152157    await  handleReactiveStream < { } > ( 
153158      { } , 
154159      { 
155160        payload : { 
156-           data : Buffer . from ( encodeJson ( { ' hello' 'world' } ) ) , 
157-           metadata : Buffer . from ( encodeJson ( {  path } ) ) , 
161+           data : Buffer . from ( encodeJson ( {   hello : 'world'   } ) ) , 
162+           metadata : Buffer . from ( encodeJson ( {  path } ) ) 
158163        } , 
159164        metadataMimeType : 'application/json' , 
160165        dataMimeType : 'application/json' , 
161166        initialN : 1 , 
162-         responder, 
167+         responder
163168      } , 
164169      createMockObserver ( ) , 
165170      new  AbortController ( ) , 
@@ -169,7 +174,7 @@ describe('Requests', () => {
169174          { 
170175            path, 
171176            type : RS_ENDPOINT_TYPE . STREAM , 
172-             handler : fn , 
177+             handler : fn 
173178          } 
174179        ] , 
175180        metaDecoder : async  ( buffer )  =>  { 
0 commit comments