export flattenErrorType

replit · Aug 19, 2024 · 3296099 · 3296099
1 parent bf3dc0a
commit 3296099
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 2 deletions.
diff --git a/__tests__/e2e.test.ts b/__tests__/e2e.test.ts
@@ -100,6 +100,7 @@ describe.each(testMatrix())(
 
       // test
       const result = await client.fallible.divide.rpc({ a: 10, b: 2 });
+
       expect(result).toStrictEqual({ ok: true, payload: { result: 5 } });
       const result2 = await client.fallible.divide.rpc({ a: 10, b: 0 });
       expect(result2).toStrictEqual({

diff --git a/router/client.ts b/router/client.ts
@@ -281,7 +281,7 @@ function handleProc(
   procedureName: string,
   abortSignal?: AbortSignal,
 ): AnyProcReturn {
-  const session = transport.getOrCreateSession(serverId);
+  const session = transport._getOrCreateSession(serverId);
   const sessionScopedSend = transport.getSessionBoundSendFn(
     serverId,
     session.id,

diff --git a/router/index.ts b/router/index.ts
@@ -28,6 +28,7 @@ export type {
   SubscriptionProcedure,
   StreamProcedure,
   ProcedureErrorSchemaType,
+  flattenErrorType,
 } from './procedures';
 export type { Writable, Readable } from './streams';
 export {

diff --git a/util/testHelpers.ts b/util/testHelpers.ts
@@ -211,7 +211,7 @@ export function getClientSendFn(
   clientTransport: ClientTransport<Connection>,
   serverTransport: ServerTransport<Connection>,
 ) {
-  const session = clientTransport.getOrCreateSession(serverTransport.clientId);
+  const session = clientTransport._getOrCreateSession(serverTransport.clientId);
   return clientTransport.getSessionBoundSendFn(
     serverTransport.clientId,
     session.id,