@replit/river - npm Package Compare versions

Comparing version 0.17.2 to 0.17.3

dist/router/index.d.ts

 import { TUnion, Static } from '@sinclair/typebox';
-import { e as ProcedureMap, P as PayloadType, c as RiverUncaughtSchema, U as Unbranded, B as Branded, A as AnyProcedure, R as RiverError, b as Result, S as ServiceContext } from '../procedures-1a298406.js';
-export { E as Err, O as Ok, a as Procedure, d as ProcedureResult, f as RPCProcedure, m as RiverErrorSchema, j as ServiceContextWithState, k as ServiceContextWithTransportInfo, i as StreamProcedure, h as SubscriptionProcedure, l as UNCAUGHT_ERROR, g as UploadProcedure, V as ValidProcType } from '../procedures-1a298406.js';
-import { d as ServerTransport, C as Connection, a as ClientTransport, b as TransportClientId } from '../index-8df0bdfb.js';
+import { e as ProcedureMap, P as PayloadType, c as RiverUncaughtSchema, U as Unbranded, B as Branded, A as AnyProcedure, R as RiverError, b as Result, S as ServiceContext } from '../procedures-79a5f07e.js';
+export { E as Err, O as Ok, a as Procedure, d as ProcedureResult, f as RPCProcedure, m as RiverErrorSchema, j as ServiceContextWithState, k as ServiceContextWithTransportInfo, i as StreamProcedure, h as SubscriptionProcedure, l as UNCAUGHT_ERROR, g as UploadProcedure, V as ValidProcType } from '../procedures-79a5f07e.js';
+import { d as ServerTransport, C as Connection, a as ClientTransport, b as TransportClientId } from '../index-80f87385.js';
 import { Pushable } from 'it-pushable';
@@ -6,0 +6,0 @@ import '../types-3e5768ec.js';

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

@@ -1,3 +0,3 @@
-import { a as ClientTransport, c as ProvidedClientTransportOptions, b as TransportClientId } from '../../../index-8df0bdfb.js';
-import { U as UdsConnection } from '../../../connection-0767dc6b.js';
+import { a as ClientTransport, c as ProvidedClientTransportOptions, b as TransportClientId } from '../../../index-80f87385.js';
+import { U as UdsConnection } from '../../../connection-713c8c66.js';
 import '../../../types-3e5768ec.js';
@@ -4,0 +4,0 @@ import '@sinclair/typebox';

dist/transport/impls/uds/client.js

 import {
   UdsConnection
-} from "../../../chunk-4A7FDC2C.js";
+} from "../../../chunk-Q7OSVPZ5.js";
 import {
   ClientTransport
-} from "../../../chunk-F6KWMEPR.js";
+} from "../../../chunk-7WY3Z5ZN.js";
 import "../../../chunk-VH3NGOXQ.js";
@@ -8,0 +8,0 @@ import {

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

 import { Server, Socket } from 'node:net';
-import { d as ServerTransport, b as TransportClientId, e as ProvidedTransportOptions } from '../../../index-8df0bdfb.js';
-import { U as UdsConnection } from '../../../connection-0767dc6b.js';
+import { d as ServerTransport, b as TransportClientId, e as ProvidedTransportOptions } from '../../../index-80f87385.js';
+import { U as UdsConnection } from '../../../connection-713c8c66.js';
 import '../../../types-3e5768ec.js';
@@ -5,0 +5,0 @@ import '@sinclair/typebox';

dist/transport/impls/uds/server.js

 import {
   UdsConnection
-} from "../../../chunk-4A7FDC2C.js";
+} from "../../../chunk-Q7OSVPZ5.js";
 import {
   ServerTransport
-} from "../../../chunk-F6KWMEPR.js";
+} from "../../../chunk-7WY3Z5ZN.js";
 import "../../../chunk-VH3NGOXQ.js";
-import {
-  log
-} from "../../../chunk-H4BYJELI.js";
+import "../../../chunk-H4BYJELI.js";
 import "../../../chunk-GZ7HCLLM.js";
@@ -20,5 +18,2 @@
     server.addListener("connection", this.connectionHandler);
-    server.on("listening", () => {
-      log?.info(`${this.clientId} -- server is listening`);
-    });
   }
@@ -25,0 +20,0 @@ connectionHandler = (sock) => {

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

 import WebSocket from 'isomorphic-ws';
-import { a as ClientTransport, b as TransportClientId, c as ProvidedClientTransportOptions } from '../../../index-8df0bdfb.js';
-import { W as WebSocketConnection } from '../../../connection-f31edbcd.js';
+import { a as ClientTransport, b as TransportClientId, c as ProvidedClientTransportOptions } from '../../../index-80f87385.js';
+import { W as WebSocketConnection } from '../../../connection-b79329de.js';
 import '../../../types-3e5768ec.js';
@@ -5,0 +5,0 @@ import '@sinclair/typebox';

dist/transport/impls/ws/client.js

 import {
   WebSocketConnection
-} from "../../../chunk-MSAS5CVJ.js";
+} from "../../../chunk-F3LFO3GU.js";
 import {
   ClientTransport
-} from "../../../chunk-F6KWMEPR.js";
+} from "../../../chunk-7WY3Z5ZN.js";
 import "../../../chunk-VH3NGOXQ.js";
@@ -8,0 +8,0 @@ import {

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

@@ -1,5 +0,5 @@
-import { d as ServerTransport, b as TransportClientId, e as ProvidedTransportOptions } from '../../../index-8df0bdfb.js';
+import { d as ServerTransport, b as TransportClientId, e as ProvidedTransportOptions } from '../../../index-80f87385.js';
 import { WebSocketServer } from 'ws';
 import { WebSocket } from 'isomorphic-ws';
-import { W as WebSocketConnection } from '../../../connection-f31edbcd.js';
+import { W as WebSocketConnection } from '../../../connection-b79329de.js';
 import '../../../types-3e5768ec.js';
@@ -6,0 +6,0 @@ import '@sinclair/typebox';

dist/transport/impls/ws/server.js

 import {
   WebSocketConnection
-} from "../../../chunk-MSAS5CVJ.js";
+} from "../../../chunk-F3LFO3GU.js";
 import {
   ServerTransport
-} from "../../../chunk-F6KWMEPR.js";
+} from "../../../chunk-7WY3Z5ZN.js";
 import "../../../chunk-VH3NGOXQ.js";
@@ -8,0 +8,0 @@ import "../../../chunk-H4BYJELI.js";

dist/transport/index.d.ts

@@ -1,3 +0,3 @@
-export { a as ClientTransport, c as ClientTransportOptions, C as Connection, n as EventHandler, E as EventMap, m as EventTypes, O as OpaqueTransportMessage, i as OpaqueTransportMessageSchema, o as ProtocolError, p as ProtocolErrorType, d as ServerTransport, f as Session, T as Transport, b as TransportClientId, j as TransportMessage, h as TransportMessageSchema, e as TransportOptions, g as TransportStatus, l as isStreamClose, k as isStreamOpen } from '../index-8df0bdfb.js';
+export { a as ClientTransport, c as ClientTransportOptions, C as Connection, n as EventHandler, E as EventMap, m as EventTypes, O as OpaqueTransportMessage, i as OpaqueTransportMessageSchema, o as ProtocolError, p as ProtocolErrorType, d as ServerTransport, f as Session, T as Transport, b as TransportClientId, j as TransportMessage, h as TransportMessageSchema, e as TransportOptions, g as TransportStatus, l as isStreamClose, k as isStreamOpen } from '../index-80f87385.js';
 import '../types-3e5768ec.js';
 import '@sinclair/typebox';

dist/transport/index.js

@@ -9,3 +9,3 @@ import "../chunk-RPIDSIQG.js";
   Transport
-} from "../chunk-F6KWMEPR.js";
+} from "../chunk-7WY3Z5ZN.js";
 import {
@@ -12,0 +12,0 @@ OpaqueTransportMessageSchema,

dist/util/testHelpers.d.ts

 import { Static } from '@sinclair/typebox';
-import { P as PayloadType, R as RiverError, a as Procedure, S as ServiceContext, b as Result, c as RiverUncaughtSchema, d as ProcedureResult } from '../procedures-1a298406.js';
-import { P as PartialTransportMessage, T as Transport, C as Connection, O as OpaqueTransportMessage, S as SessionOptions } from '../index-8df0bdfb.js';
+import { P as PayloadType, R as RiverError, a as Procedure, S as ServiceContext, b as Result, c as RiverUncaughtSchema, d as ProcedureResult } from '../procedures-79a5f07e.js';
+import { P as PartialTransportMessage, T as Transport, C as Connection, O as OpaqueTransportMessage, S as SessionOptions } from '../index-80f87385.js';
 import * as it_pushable from 'it-pushable';
@@ -5,0 +5,0 @@ import WebSocket from 'isomorphic-ws';

dist/util/testHelpers.js

@@ -9,3 +9,3 @@ import {
   defaultTransportOptions
-} from "../chunk-F6KWMEPR.js";
+} from "../chunk-7WY3Z5ZN.js";
 import {
@@ -12,0 +12,0 @@ coerceErrorString

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.17.2",
+  "version": "0.17.3",
   "type": "module",
@@ -85,3 +85,3 @@ "exports": {
     "test": "vitest --test-timeout=500",
-    "test:single": "vitest run --test-timeout=500",
+    "test:single": "vitest run --test-timeout=500 --reporter=dot",
     "test:flake": "./flake.sh",
@@ -88,0 +88,0 @@ "bench": "vitest bench"

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

402582

increased by0.01%

Worsened metrics

Lines of code

11533

decreased by-0.03%

No dependency changes