@replit/river - npm Package Compare versions

Comparing version 0.13.0 to 0.13.1

dist/router/index.d.ts

@@ -1,4 +0,4 @@
-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-169fbf7f.js';
-export { E as Err, O as Ok, m as ProcHandler, k as ProcListing, a as Procedure, p as RiverErrorSchema, c as RiverUncaughtSchema, l as Service, j as ServiceBuilder, n as ServiceContextWithState, o as ServiceContextWithTransportInfo, U as UNCAUGHT_ERROR, V as ValidProcType, s as serializeService } from '../builder-169fbf7f.js';
-import { S as ServerTransport, C as Connection, a as ClientTransport } from '../index-21c1b21d.js';
+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-eef3b061.js';
+export { E as Err, O as Ok, m as ProcHandler, k as ProcListing, a as Procedure, p as RiverErrorSchema, c as RiverUncaughtSchema, l as Service, j as ServiceBuilder, n as ServiceContextWithState, o as ServiceContextWithTransportInfo, U as UNCAUGHT_ERROR, V as ValidProcType, s as serializeService } from '../builder-eef3b061.js';
+import { S as ServerTransport, C as Connection, a as ClientTransport } from '../index-9aa0aabb.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-CBRQM65K.js";
-import "../chunk-MGGIUH5O.js";
+} from "../chunk-JXKTY3GQ.js";
+import "../chunk-SCG5S2EC.js";
 import "../chunk-H4BYJELI.js";
@@ -15,0 +15,0 @@ export {

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

@@ -1,3 +0,3 @@
-import { a as ClientTransport, b as TransportClientId, c as TransportOptions } from '../../../index-21c1b21d.js';
-import { U as UdsConnection } from '../../../connection-dd789651.js';
+import { a as ClientTransport, b as TransportClientId, c as TransportOptions } from '../../../index-9aa0aabb.js';
+import { U as UdsConnection } from '../../../connection-03e650c8.js';
 import '../../../types-3e5768ec.js';
@@ -4,0 +4,0 @@ import '@sinclair/typebox';

dist/transport/impls/uds/client.js

 import {
   UdsConnection
-} from "../../../chunk-CDH7QSB4.js";
+} from "../../../chunk-JXO2SCQB.js";
 import {
   ClientTransport
-} from "../../../chunk-R2IMXRVU.js";
-import "../../../chunk-MGGIUH5O.js";
+} from "../../../chunk-LDUFHGZU.js";
+import "../../../chunk-SCG5S2EC.js";
 import {
@@ -9,0 +9,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-21c1b21d.js';
-import { U as UdsConnection } from '../../../connection-dd789651.js';
+import { S as ServerTransport, b as TransportClientId, c as TransportOptions } from '../../../index-9aa0aabb.js';
+import { U as UdsConnection } from '../../../connection-03e650c8.js';
 import '../../../types-3e5768ec.js';
@@ -5,0 +5,0 @@ import '@sinclair/typebox';

dist/transport/impls/uds/server.js

 import {
   UdsConnection
-} from "../../../chunk-CDH7QSB4.js";
+} from "../../../chunk-JXO2SCQB.js";
 import {
   ServerTransport
-} from "../../../chunk-R2IMXRVU.js";
-import "../../../chunk-MGGIUH5O.js";
+} from "../../../chunk-LDUFHGZU.js";
+import "../../../chunk-SCG5S2EC.js";
 import {
@@ -9,0 +9,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-21c1b21d.js';
-import { W as WebSocketConnection } from '../../../connection-ab681c08.js';
+import { a as ClientTransport, b as TransportClientId, c as TransportOptions } from '../../../index-9aa0aabb.js';
+import { W as WebSocketConnection } from '../../../connection-d052d027.js';
 import '../../../types-3e5768ec.js';
@@ -5,0 +5,0 @@ import '@sinclair/typebox';

dist/transport/impls/ws/client.js

 import {
   WebSocketConnection
-} from "../../../chunk-NPXAAD7M.js";
+} from "../../../chunk-Q7AWJYDQ.js";
 import {
   ClientTransport
-} from "../../../chunk-R2IMXRVU.js";
-import "../../../chunk-MGGIUH5O.js";
+} from "../../../chunk-LDUFHGZU.js";
+import "../../../chunk-SCG5S2EC.js";
 import {
@@ -52,14 +52,10 @@ log
         }
-        const onOpen = () => {
-          ws.removeEventListener("open", onOpen);
+        ws.onopen = () => {
           resolve({ ws });
         };
-        const onClose = (evt) => {
-          ws.removeEventListener("close", onClose);
+        ws.onclose = (evt) => {
           resolve({ err: evt.reason });
         };
-        const onError = (evt) => {
+        ws.onerror = (evt) => {
           const err = evt.error;
-          ws.removeEventListener("error", onError);
-          ws.removeEventListener("close", onClose);
           resolve({
@@ -69,5 +65,2 @@ err: err?.code ?? "unexpected disconnect"
         };
-        ws.addEventListener("open", onOpen);
-        ws.addEventListener("close", onClose);
-        ws.addEventListener("error", onError);
       }).catch((e) => {
@@ -74,0 +67,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-21c1b21d.js';
+import { S as ServerTransport, b as TransportClientId, c as TransportOptions } from '../../../index-9aa0aabb.js';
 import { WebSocketServer } from 'ws';
 import { WebSocket } from 'isomorphic-ws';
-import { W as WebSocketConnection } from '../../../connection-ab681c08.js';
+import { W as WebSocketConnection } from '../../../connection-d052d027.js';
 import '../../../types-3e5768ec.js';
@@ -6,0 +6,0 @@ import '@sinclair/typebox';

dist/transport/impls/ws/server.js

 import {
   WebSocketConnection
-} from "../../../chunk-NPXAAD7M.js";
+} from "../../../chunk-Q7AWJYDQ.js";
 import {
   ServerTransport
-} from "../../../chunk-R2IMXRVU.js";
-import "../../../chunk-MGGIUH5O.js";
+} from "../../../chunk-LDUFHGZU.js";
+import "../../../chunk-SCG5S2EC.js";
 import {
@@ -9,0 +9,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-21c1b21d.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-9aa0aabb.js';
 import '../types-3e5768ec.js';
 import '@sinclair/typebox';

dist/transport/index.js

@@ -8,7 +8,7 @@ import "../chunk-5IZ2UHWV.js";
   Transport
-} from "../chunk-R2IMXRVU.js";
+} from "../chunk-LDUFHGZU.js";
 import {
   OpaqueTransportMessageSchema,
   TransportMessageSchema
-} from "../chunk-MGGIUH5O.js";
+} from "../chunk-SCG5S2EC.js";
 import "../chunk-H4BYJELI.js";
@@ -15,0 +15,0 @@ import "../chunk-GZ7HCLLM.js";

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-21c1b21d.js';
-import { P as PayloadType, R as RiverError, a as Procedure, S as ServiceContext, b as Result, c as RiverUncaughtSchema } from '../builder-169fbf7f.js';
+import { P as PartialTransportMessage, T as Transport, C as Connection, O as OpaqueTransportMessage } from '../index-9aa0aabb.js';
+import { P as PayloadType, R as RiverError, a as Procedure, S as ServiceContext, b as Result, c as RiverUncaughtSchema } from '../builder-eef3b061.js';
 import { Static } from '@sinclair/typebox';
@@ -7,0 +7,0 @@ import net from 'node:net';

dist/util/testHelpers.js

 import {
   UNCAUGHT_ERROR,
   pushable
-} from "../chunk-CBRQM65K.js";
+} from "../chunk-JXKTY3GQ.js";
 import "../chunk-5IZ2UHWV.js";
@@ -9,6 +9,6 @@ import {
   defaultSessionOptions
-} from "../chunk-R2IMXRVU.js";
+} from "../chunk-LDUFHGZU.js";
 import {
   coerceErrorString
-} from "../chunk-MGGIUH5O.js";
+} from "../chunk-SCG5S2EC.js";
 import "../chunk-H4BYJELI.js";
@@ -15,0 +15,0 @@ import "../chunk-GZ7HCLLM.js";

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.13.0",
+  "version": "0.13.1",
   "type": "module",
@@ -6,0 +6,0 @@ "exports": {

README.md

@@ -13,2 +13,4 @@ # river - Long-lived Streaming Remote Procedure Calls
 
+See [PROTOCOL.md](./PROTOCOL.md) for more information on the protocol.
+
 ## Installation
@@ -15,0 +17,0 @@

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

Number of lines in readme file

181

increased by1.12%

Worsened metrics

Total package byte prevSize

341325

decreased by-0.19%

Lines of code

10054

decreased by-0.22%

No dependency changes