@replit/river - npm Package Compare versions

Comparing version 0.200.0-rc.1 to 0.200.0-rc.2

dist/router/index.d.ts

@@ -1,3 +0,3 @@
-import { j as SerializedServerSchema, A as AnyServiceSchemaMap, I as InstantiatedServiceSchemaMap, C as Connection, k as ServerHandshakeOptions, d as ServiceContext } from '../services-34d97070.js';
-export { L as Client, X as Err, E as ErrResult, H as INVALID_REQUEST_CODE, J as InputReaderErrorSchema, Q as Ok, O as OkResult, _ as Output, f as OutputReaderErrorSchema, M as ParsedMetadata, P as PayloadType, r as ProcErrors, n as ProcHandler, o as ProcInit, p as ProcInput, q as ProcOutput, s as ProcType, c as Procedure, b as ProcedureErrorSchemaType, N as ProcedureHandlerContext, x as ProcedureMap, y as RPCProcedure, R as ReadStream, e as Result, Z as ResultUnwrapErr, Y as ResultUnwrapOk, w as SerializedProcedureSchema, v as SerializedServiceSchema, l as Service, m as ServiceConfiguration, t as ServiceSchema, D as StreamProcedure, z as SubscriptionProcedure, F as UNCAUGHT_ERROR_CODE, G as UNEXPECTED_DISCONNECT_CODE, U as UploadProcedure, V as ValidProcType, W as WriteStream, K as createClient, $ as createClientHandshakeOptions, a0 as createServerHandshakeOptions, u as serializeSchema } from '../services-34d97070.js';
+import { j as SerializedServerSchema, A as AnyServiceSchemaMap, I as InstantiatedServiceSchemaMap, C as Connection, k as ServerHandshakeOptions, d as ServiceContext } from '../services-970f97bb.js';
+export { L as Client, X as Err, E as ErrResult, H as INVALID_REQUEST_CODE, J as InputReaderErrorSchema, Q as Ok, O as OkResult, _ as Output, f as OutputReaderErrorSchema, M as ParsedMetadata, P as PayloadType, r as ProcErrors, n as ProcHandler, o as ProcInit, p as ProcInput, q as ProcOutput, s as ProcType, c as Procedure, b as ProcedureErrorSchemaType, N as ProcedureHandlerContext, x as ProcedureMap, y as RPCProcedure, R as ReadStream, e as Result, Z as ResultUnwrapErr, Y as ResultUnwrapOk, w as SerializedProcedureSchema, v as SerializedServiceSchema, l as Service, m as ServiceConfiguration, t as ServiceSchema, D as StreamProcedure, z as SubscriptionProcedure, F as UNCAUGHT_ERROR_CODE, G as UNEXPECTED_DISCONNECT_CODE, U as UploadProcedure, V as ValidProcType, W as WriteStream, K as createClient, $ as createClientHandshakeOptions, a0 as createServerHandshakeOptions, u as serializeSchema } from '../services-970f97bb.js';
 import { ServerTransport } from '../transport/index.js';
@@ -82,4 +82,4 @@ import '@sinclair/typebox';
 
-var version = "0.200.0-rc.1";
+var version = "0.200.0-rc.2";
 
 export { DiffOptions, PayloadBreakage, ProcedureBreakage, version as RIVER_VERSION, SerializedServerSchema, Server, ServerBreakage, ServiceBreakage, ServiceContext, createServer, diffServerSchema };

dist/router/index.js

@@ -17,6 +17,6 @@ import {
   serializeSchema
-} from "../chunk-45HIR2AS.js";
+} from "../chunk-7CKIN3JT.js";
 import {
   version
-} from "../chunk-XLXRFSRB.js";
+} from "../chunk-S5RL45KH.js";
 export {
@@ -23,0 +23,0 @@ Err,

dist/transport/impls/uds/client.d.ts

@@ -1,4 +0,4 @@
-import { U as UdsConnection } from '../../../connection-c6521735.js';
+import { U as UdsConnection } from '../../../connection-f900e390.js';
 import { T as TransportClientId } from '../../../index-10ebd26a.js';
-import { g as ClientTransport, h as ProvidedClientTransportOptions } from '../../../services-34d97070.js';
+import { g as ClientTransport, h as ProvidedClientTransportOptions } from '../../../services-970f97bb.js';
 import 'node:net';
@@ -5,0 +5,0 @@ import 'node:stream';

dist/transport/impls/uds/client.js

 import {
   UdsConnection
-} from "../../../chunk-WQVOMUNR.js";
+} from "../../../chunk-4VNY34QG.js";
 import {
   ClientTransport
-} from "../../../chunk-W75HU4F6.js";
-import "../../../chunk-AJBZUHSI.js";
+} from "../../../chunk-47TFNAY2.js";
+import "../../../chunk-ONUXWVRC.js";
 import "../../../chunk-QMM35C3H.js";
-import "../../../chunk-75B5D7MR.js";
-import "../../../chunk-XLXRFSRB.js";
+import "../../../chunk-NQWDT6GS.js";
+import "../../../chunk-S5RL45KH.js";
 import "../../../chunk-4PVU7J25.js";
@@ -12,0 +12,0 @@

dist/transport/impls/uds/server.d.ts

 import { Server, Socket } from 'node:net';
 import { T as TransportClientId } from '../../../index-10ebd26a.js';
-import { U as UdsConnection } from '../../../connection-c6521735.js';
+import { U as UdsConnection } from '../../../connection-f900e390.js';
 import { ServerTransport } from '../../index.js';
-import { i as ProvidedServerTransportOptions } from '../../../services-34d97070.js';
+import { i as ProvidedServerTransportOptions } from '../../../services-970f97bb.js';
 import '@sinclair/typebox/value';
@@ -7,0 +7,0 @@ import '@sinclair/typebox';

dist/transport/impls/uds/server.js

 import {
   ServerTransport
-} from "../../../chunk-LH2VHMQM.js";
+} from "../../../chunk-CZP4LK3F.js";
 import {
   UdsConnection
-} from "../../../chunk-WQVOMUNR.js";
-import "../../../chunk-AJBZUHSI.js";
+} from "../../../chunk-4VNY34QG.js";
+import "../../../chunk-ONUXWVRC.js";
 import "../../../chunk-QMM35C3H.js";
-import "../../../chunk-75B5D7MR.js";
-import "../../../chunk-XLXRFSRB.js";
+import "../../../chunk-NQWDT6GS.js";
+import "../../../chunk-S5RL45KH.js";
 import "../../../chunk-4PVU7J25.js";
@@ -12,0 +12,0 @@

dist/transport/impls/ws/client.d.ts

@@ -1,4 +0,4 @@
-import { g as ClientTransport, h as ProvidedClientTransportOptions } from '../../../services-34d97070.js';
+import { g as ClientTransport, h as ProvidedClientTransportOptions } from '../../../services-970f97bb.js';
 import { T as TransportClientId } from '../../../index-10ebd26a.js';
-import { W as WebSocketConnection } from '../../../connection-0638316b.js';
+import { W as WebSocketConnection } from '../../../connection-3f117047.js';
 import { W as WsLike } from '../../../wslike-e0b32dd5.js';
@@ -5,0 +5,0 @@ import '@sinclair/typebox';

dist/transport/impls/ws/client.js

 import {
   WebSocketConnection
-} from "../../../chunk-EMIERCU7.js";
+} from "../../../chunk-DJCW3SKT.js";
 import {
   ClientTransport
-} from "../../../chunk-W75HU4F6.js";
-import "../../../chunk-AJBZUHSI.js";
+} from "../../../chunk-47TFNAY2.js";
+import "../../../chunk-ONUXWVRC.js";
 import "../../../chunk-QMM35C3H.js";
-import "../../../chunk-75B5D7MR.js";
-import "../../../chunk-XLXRFSRB.js";
+import "../../../chunk-NQWDT6GS.js";
+import "../../../chunk-S5RL45KH.js";
 import "../../../chunk-4PVU7J25.js";
@@ -12,0 +12,0 @@

dist/transport/impls/ws/server.d.ts

 import { T as TransportClientId } from '../../../index-10ebd26a.js';
 import { WebSocketServer } from 'ws';
-import { W as WebSocketConnection } from '../../../connection-0638316b.js';
+import { W as WebSocketConnection } from '../../../connection-3f117047.js';
 import { W as WsLike } from '../../../wslike-e0b32dd5.js';
 import { ServerTransport } from '../../index.js';
-import { i as ProvidedServerTransportOptions } from '../../../services-34d97070.js';
+import { i as ProvidedServerTransportOptions } from '../../../services-970f97bb.js';
 import '@sinclair/typebox/value';
@@ -8,0 +8,0 @@ import '@sinclair/typebox';

dist/transport/impls/ws/server.js

 import {
   ServerTransport
-} from "../../../chunk-LH2VHMQM.js";
+} from "../../../chunk-CZP4LK3F.js";
 import {
   WebSocketConnection
-} from "../../../chunk-EMIERCU7.js";
-import "../../../chunk-AJBZUHSI.js";
+} from "../../../chunk-DJCW3SKT.js";
+import "../../../chunk-ONUXWVRC.js";
 import "../../../chunk-QMM35C3H.js";
-import "../../../chunk-75B5D7MR.js";
-import "../../../chunk-XLXRFSRB.js";
+import "../../../chunk-NQWDT6GS.js";
+import "../../../chunk-S5RL45KH.js";
 import "../../../chunk-4PVU7J25.js";
@@ -12,0 +12,0 @@

dist/transport/index.d.ts

@@ -1,3 +0,3 @@
-import { C as Connection, T as Transport, a1 as ServerTransportOptions, k as ServerHandshakeOptions, a as Session, M as ParsedMetadata, i as ProvidedServerTransportOptions } from '../services-34d97070.js';
-export { g as ClientTransport, h as ClientTransportOptions, a6 as EventHandler, a4 as EventMap, a5 as EventTypes, a7 as ProtocolError, a8 as ProtocolErrorType, a3 as TransportOptions, a2 as TransportStatus } from '../services-34d97070.js';
+import { C as Connection, T as Transport, a1 as ServerTransportOptions, k as ServerHandshakeOptions, a as Session, M as ParsedMetadata, i as ProvidedServerTransportOptions } from '../services-970f97bb.js';
+export { g as ClientTransport, h as ClientTransportOptions, a6 as EventHandler, a4 as EventMap, a5 as EventTypes, a7 as ProtocolError, a8 as ProtocolErrorType, a3 as TransportOptions, a2 as TransportStatus } from '../services-970f97bb.js';
 import { T as TransportClientId } from '../index-10ebd26a.js';
@@ -4,0 +4,0 @@ export { O as OpaqueTransportMessage, g as OpaqueTransportMessageSchema, c as TransportMessage, f as TransportMessageSchema, h as isStreamClose, i as isStreamOpen } from '../index-10ebd26a.js';

dist/transport/index.js

 import {
   ServerTransport
-} from "../chunk-LH2VHMQM.js";
+} from "../chunk-CZP4LK3F.js";
 import {
   ClientTransport
-} from "../chunk-W75HU4F6.js";
+} from "../chunk-47TFNAY2.js";
 import {
   ProtocolError,
   Transport
-} from "../chunk-AJBZUHSI.js";
+} from "../chunk-ONUXWVRC.js";
 import "../chunk-QMM35C3H.js";
@@ -15,7 +15,7 @@ import {
   Session
-} from "../chunk-75B5D7MR.js";
+} from "../chunk-NQWDT6GS.js";
 import {
   OpaqueTransportMessageSchema,
   TransportMessageSchema
-} from "../chunk-XLXRFSRB.js";
+} from "../chunk-S5RL45KH.js";
 import "../chunk-4PVU7J25.js";
@@ -22,0 +22,0 @@ export {

dist/util/testHelpers.d.ts

 import { Static } from '@sinclair/typebox';
-import { B as BaseErrorSchemaType, R as ReadStream, O as OkResult, E as ErrResult, T as Transport, C as Connection, S as SessionOptions, a as Session, P as PayloadType, b as ProcedureErrorSchemaType, c as Procedure, d as ServiceContext, e as Result, f as OutputReaderErrorSchema, W as WriteStream } from '../services-34d97070.js';
+import { B as BaseErrorSchemaType, R as ReadStream, O as OkResult, E as ErrResult, T as Transport, C as Connection, S as SessionOptions, a as Session, P as PayloadType, b as ProcedureErrorSchemaType, c as Procedure, d as ServiceContext, e as Result, f as OutputReaderErrorSchema, W as WriteStream } from '../services-970f97bb.js';
 import { P as PartialTransportMessage, O as OpaqueTransportMessage } from '../index-10ebd26a.js';
@@ -4,0 +4,0 @@ import NodeWs from 'ws';

dist/util/testHelpers.js

@@ -7,10 +7,10 @@ import {
   WriteStreamImpl
-} from "../chunk-45HIR2AS.js";
+} from "../chunk-7CKIN3JT.js";
 import {
   Session,
   defaultTransportOptions
-} from "../chunk-75B5D7MR.js";
+} from "../chunk-NQWDT6GS.js";
 import {
   coerceErrorString
-} from "../chunk-XLXRFSRB.js";
+} from "../chunk-S5RL45KH.js";
 import "../chunk-4PVU7J25.js";
@@ -120,9 +120,9 @@
       reader.pushValue(v);
-    },
-    () => {
-      void Promise.resolve().then(() => {
-        reader.triggerClose();
-      });
     }
   );
+  writer.onClose(() => {
+    void Promise.resolve().then(() => {
+      reader.triggerClose();
+    });
+  });
   return { reader, writer };
@@ -136,12 +136,10 @@ }
   });
-  const writer = new WriteStreamImpl(
-    (v) => {
-      reader.pushValue(Ok(v));
-    },
-    () => {
-      void Promise.resolve().then(() => {
-        reader.triggerClose();
-      });
-    }
-  );
+  const writer = new WriteStreamImpl((v) => {
+    reader.pushValue(Ok(v));
+  });
+  writer.onClose(() => {
+    void Promise.resolve().then(() => {
+      reader.triggerClose();
+    });
+  });
   return { reader, writer };
@@ -148,0 +146,0 @@ }

package.json

 {
   "name": "@replit/river",
   "description": "It's like tRPC but... with JSON Schema Support, duplex streaming and support for service multiplexing. Transport agnostic!",
-  "version": "0.200.0-rc.1",
+  "version": "0.200.0-rc.2",
   "type": "module",
@@ -6,0 +6,0 @@ "exports": {

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

1700598

increased by0.3%

Lines of code

17994

increased by0.22%

No dependency changes