@replit/river - npm Package Compare versions

Comparing version 0.12.0 to 0.12.1

dist/router/index.d.ts

 import { A as AnyService, P as PayloadType, b as Result, R as RiverError, S as ServiceContext, d as ProcType, e as ProcInput, f as ProcOutput, g as ProcErrors, h as ProcHasInit, i as ProcInit } from '../builder-c593de11.js';
 export { E as Err, O as Ok, m as ProcHandler, k as ProcListing, a as Procedure, o as RiverErrorSchema, c as RiverUncaughtSchema, l as Service, j as ServiceBuilder, n as ServiceContextWithState, U as UNCAUGHT_ERROR, V as ValidProcType, s as serializeService } from '../builder-c593de11.js';
-import { T as Transport, C as Connection, b as TransportClientId } from '../index-d91775d9.js';
+import { T as Transport, C as Connection, b as TransportClientId } from '../index-0c0a69f6.js';
 import { Pushable } from 'it-pushable';
@@ -5,0 +5,0 @@ import { Static } from '@sinclair/typebox';

dist/router/index.js

@@ -11,4 +11,4 @@ import {
   serializeService
-} from "../chunk-24O3BKZA.js";
-import "../chunk-WTOIOXB7.js";
+} from "../chunk-55XUAPC6.js";
+import "../chunk-XFFS4UOD.js";
 import "../chunk-H4BYJELI.js";
@@ -15,0 +15,0 @@ export {

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

@@ -1,3 +0,3 @@
-import { a as ClientTransport, b as TransportClientId, c as TransportOptions } from '../../../index-d91775d9.js';
-import { S as StreamConnection } from '../../../connection-2956a1c5.js';
+import { a as ClientTransport, b as TransportClientId, c as TransportOptions } from '../../../index-0c0a69f6.js';
+import { S as StreamConnection } from '../../../connection-bf7811aa.js';
 import '../../../types-3e5768ec.js';
@@ -4,0 +4,0 @@ import '@sinclair/typebox';

dist/transport/impls/stdio/client.js

 import {
   StreamConnection
-} from "../../../chunk-IUDKWAOK.js";
+} from "../../../chunk-M6LY25P2.js";
 import "../../../chunk-5IZ2UHWV.js";
@@ -8,5 +8,5 @@ import "../../../chunk-IIBVKYDB.js";
   ClientTransport
-} from "../../../chunk-ANGOKBE5.js";
+} from "../../../chunk-QEYN2Z6O.js";
 import "../../../chunk-GZ7HCLLM.js";
-import "../../../chunk-WTOIOXB7.js";
+import "../../../chunk-XFFS4UOD.js";
 import {
@@ -13,0 +13,0 @@ log

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

@@ -1,3 +0,3 @@
-import { S as ServerTransport, b as TransportClientId, c as TransportOptions } from '../../../index-d91775d9.js';
-import { S as StreamConnection } from '../../../connection-2956a1c5.js';
+import { S as ServerTransport, b as TransportClientId, c as TransportOptions } from '../../../index-0c0a69f6.js';
+import { S as StreamConnection } from '../../../connection-bf7811aa.js';
 import '../../../types-3e5768ec.js';
@@ -4,0 +4,0 @@ import '@sinclair/typebox';

dist/transport/impls/stdio/server.js

 import {
   StreamConnection
-} from "../../../chunk-IUDKWAOK.js";
+} from "../../../chunk-M6LY25P2.js";
 import "../../../chunk-5IZ2UHWV.js";
@@ -8,5 +8,5 @@ import "../../../chunk-IIBVKYDB.js";
   ServerTransport
-} from "../../../chunk-ANGOKBE5.js";
+} from "../../../chunk-QEYN2Z6O.js";
 import "../../../chunk-GZ7HCLLM.js";
-import "../../../chunk-WTOIOXB7.js";
+import "../../../chunk-XFFS4UOD.js";
 import "../../../chunk-H4BYJELI.js";
@@ -13,0 +13,0 @@

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

@@ -1,3 +0,3 @@
-import { a as ClientTransport, b as TransportClientId, c as TransportOptions } from '../../../index-d91775d9.js';
-import { U as UdsConnection } from '../../../connection-cd963ed5.js';
+import { a as ClientTransport, b as TransportClientId, c as TransportOptions } from '../../../index-0c0a69f6.js';
+import { U as UdsConnection } from '../../../connection-d880aa4a.js';
 import '../../../types-3e5768ec.js';
@@ -4,0 +4,0 @@ import '@sinclair/typebox';

dist/transport/impls/uds/client.js

 import {
   UdsConnection
-} from "../../../chunk-XOTIAXAH.js";
+} from "../../../chunk-TKINU53F.js";
 import "../../../chunk-IIBVKYDB.js";
 import {
   ClientTransport
-} from "../../../chunk-ANGOKBE5.js";
+} from "../../../chunk-QEYN2Z6O.js";
 import "../../../chunk-GZ7HCLLM.js";
-import "../../../chunk-WTOIOXB7.js";
+import "../../../chunk-XFFS4UOD.js";
 import {
@@ -11,0 +11,0 @@ log

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

 import { Server, Socket } from 'node:net';
-import { S as ServerTransport, b as TransportClientId, c as TransportOptions } from '../../../index-d91775d9.js';
-import { U as UdsConnection } from '../../../connection-cd963ed5.js';
+import { S as ServerTransport, b as TransportClientId, c as TransportOptions } from '../../../index-0c0a69f6.js';
+import { U as UdsConnection } from '../../../connection-d880aa4a.js';
 import '../../../types-3e5768ec.js';
@@ -5,0 +5,0 @@ import '@sinclair/typebox';

dist/transport/impls/uds/server.js

 import {
   UdsConnection
-} from "../../../chunk-XOTIAXAH.js";
+} from "../../../chunk-TKINU53F.js";
 import "../../../chunk-IIBVKYDB.js";
 import {
   ServerTransport
-} from "../../../chunk-ANGOKBE5.js";
+} from "../../../chunk-QEYN2Z6O.js";
 import "../../../chunk-GZ7HCLLM.js";
-import "../../../chunk-WTOIOXB7.js";
+import "../../../chunk-XFFS4UOD.js";
 import {
@@ -11,0 +11,0 @@ log

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

 import WebSocket from 'isomorphic-ws';
-import { a as ClientTransport, b as TransportClientId, c as TransportOptions } from '../../../index-d91775d9.js';
-import { W as WebSocketConnection } from '../../../connection-aaea7c88.js';
+import { a as ClientTransport, b as TransportClientId, c as TransportOptions } from '../../../index-0c0a69f6.js';
+import { W as WebSocketConnection } from '../../../connection-eb10d250.js';
 import '../../../types-3e5768ec.js';
@@ -5,0 +5,0 @@ import '@sinclair/typebox';

dist/transport/impls/ws/client.js

 import {
   WebSocketConnection
-} from "../../../chunk-4HOR4NUO.js";
+} from "../../../chunk-RDTTKCGV.js";
 import {
   ClientTransport
-} from "../../../chunk-ANGOKBE5.js";
+} from "../../../chunk-QEYN2Z6O.js";
 import "../../../chunk-GZ7HCLLM.js";
-import "../../../chunk-WTOIOXB7.js";
+import "../../../chunk-XFFS4UOD.js";
 import {
@@ -60,4 +60,10 @@ log
         };
+        const onError = (evt) => {
+          ws.removeEventListener("error", onError);
+          ws.removeEventListener("close", onClose);
+          resolve({ err: evt.message });
+        };
         ws.addEventListener("open", onOpen);
         ws.addEventListener("close", onClose);
+        ws.addEventListener("error", onError);
       }).catch((e) => {
@@ -64,0 +70,0 @@ const reason = e instanceof Error ? e.message : "unknown reason";

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

@@ -1,5 +0,5 @@
-import { S as ServerTransport, b as TransportClientId, c as TransportOptions } from '../../../index-d91775d9.js';
+import { S as ServerTransport, b as TransportClientId, c as TransportOptions } from '../../../index-0c0a69f6.js';
 import { WebSocketServer } from 'ws';
 import { WebSocket } from 'isomorphic-ws';
-import { W as WebSocketConnection } from '../../../connection-aaea7c88.js';
+import { W as WebSocketConnection } from '../../../connection-eb10d250.js';
 import '../../../types-3e5768ec.js';
@@ -6,0 +6,0 @@ import '@sinclair/typebox';

dist/transport/impls/ws/server.js

 import {
   WebSocketConnection
-} from "../../../chunk-4HOR4NUO.js";
+} from "../../../chunk-RDTTKCGV.js";
 import {
   ServerTransport
-} from "../../../chunk-ANGOKBE5.js";
+} from "../../../chunk-QEYN2Z6O.js";
 import "../../../chunk-GZ7HCLLM.js";
-import "../../../chunk-WTOIOXB7.js";
+import "../../../chunk-XFFS4UOD.js";
 import {
@@ -10,0 +10,0 @@ log

dist/transport/index.d.ts

@@ -1,3 +0,3 @@
-export { a as ClientTransport, C as Connection, k as EventHandler, E as EventMap, j as EventTypes, O as OpaqueTransportMessage, f as OpaqueTransportMessageSchema, S as ServerTransport, d as Session, T as Transport, b as TransportClientId, g as TransportMessage, e as TransportMessageSchema, h as isStreamClose, i as isStreamOpen } from '../index-d91775d9.js';
+export { a as ClientTransport, C as Connection, k as EventHandler, E as EventMap, j as EventTypes, O as OpaqueTransportMessage, f as OpaqueTransportMessageSchema, S as ServerTransport, d as Session, T as Transport, b as TransportClientId, g as TransportMessage, e as TransportMessageSchema, h as isStreamClose, i as isStreamOpen } from '../index-0c0a69f6.js';
 import '../types-3e5768ec.js';
 import '@sinclair/typebox';

dist/transport/index.js

@@ -8,3 +8,3 @@ import "../chunk-5IZ2UHWV.js";
   Transport
-} from "../chunk-ANGOKBE5.js";
+} from "../chunk-QEYN2Z6O.js";
 import "../chunk-GZ7HCLLM.js";
@@ -14,3 +14,3 @@ import {
   TransportMessageSchema
-} from "../chunk-WTOIOXB7.js";
+} from "../chunk-XFFS4UOD.js";
 import "../chunk-H4BYJELI.js";
@@ -17,0 +17,0 @@ export {

dist/util/testHelpers.d.ts

 import * as it_pushable from 'it-pushable';
 import WebSocket from 'isomorphic-ws';
 import http from 'node:http';
-import { P as PartialTransportMessage, T as Transport, C as Connection, O as OpaqueTransportMessage } from '../index-d91775d9.js';
+import { P as PartialTransportMessage, T as Transport, C as Connection, O as OpaqueTransportMessage } from '../index-0c0a69f6.js';
 import { P as PayloadType, R as RiverError, a as Procedure, S as ServiceContext, b as Result, c as RiverUncaughtSchema } from '../builder-c593de11.js';
@@ -6,0 +6,0 @@ import { Static } from '@sinclair/typebox';

dist/util/testHelpers.js

 import {
   UNCAUGHT_ERROR,
   pushable
-} from "../chunk-24O3BKZA.js";
+} from "../chunk-55XUAPC6.js";
 import {
   coerceErrorString
-} from "../chunk-WTOIOXB7.js";
+} from "../chunk-XFFS4UOD.js";
 import "../chunk-H4BYJELI.js";
@@ -9,0 +9,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.12.0",
+  "version": "0.12.1",
   "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

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

395364

increased by1.18%

Lines of code

11546

increased by1.5%

Number of medium supply chain risk alerts

1

decreased by-50%

No dependency changes