@replit/river - npm Package Compare versions

Comparing version 0.25.1 to 0.25.2

dist/router/index.d.ts

@@ -1,12 +0,12 @@
-import { A as AnyServiceSchemaMap, I as InstantiatedServiceSchemaMap, P as PayloadType, b as Result, R as RiverError } from '../services-8d14ae16.js';
-export { C as Client, E as Err, O as Ok, z as Output, j as ProcErrors, f as ProcHandler, g as ProcInit, h as ProcInput, i as ProcOutput, k as ProcType, a as Procedure, p as ProcedureMap, d as ProcedureResult, q as RPCProcedure, y as ResultUnwrapErr, x as ResultUnwrapOk, w as RiverErrorSchema, c as RiverUncaughtSchema, o as SerializedProcedureSchema, m as SerializedServerSchema, n as SerializedServiceSchema, S as Service, e as ServiceConfiguration, l as ServiceSchema, t as StreamProcedure, r as SubscriptionProcedure, v as UNCAUGHT_ERROR, U as UploadProcedure, V as ValidProcType, u as createClient, s as serializeSchema } from '../services-8d14ae16.js';
+import { A as AnyServiceSchemaMap, I as InstantiatedServiceSchemaMap, P as PayloadType, b as Result, R as RiverError } from '../services-4b9e5232.js';
+export { C as Client, E as Err, O as Ok, z as Output, j as ProcErrors, f as ProcHandler, g as ProcInit, h as ProcInput, i as ProcOutput, k as ProcType, a as Procedure, p as ProcedureMap, d as ProcedureResult, q as RPCProcedure, y as ResultUnwrapErr, x as ResultUnwrapOk, w as RiverErrorSchema, c as RiverUncaughtSchema, o as SerializedProcedureSchema, m as SerializedServerSchema, n as SerializedServiceSchema, S as Service, e as ServiceConfiguration, l as ServiceSchema, t as StreamProcedure, r as SubscriptionProcedure, v as UNCAUGHT_ERROR, U as UploadProcedure, V as ValidProcType, u as createClient, s as serializeSchema } from '../services-4b9e5232.js';
 import { Static } from '@sinclair/typebox';
 import { Pushable } from 'it-pushable';
-import { C as Connection, q as ServerHandshakeOptions, n as ServiceContext } from '../handshake-3772d7ca.js';
-export { r as ParsedMetadata, s as ServiceContextWithState, t as ServiceContextWithTransportInfo, u as createClientHandshakeOptions, v as createServerHandshakeOptions } from '../handshake-3772d7ca.js';
-import { S as ServerTransport } from '../server-f0fd2b98.js';
+import { C as Connection, s as ServerHandshakeOptions, o as ServiceContext } from '../handshake-12d57161.js';
+export { t as ParsedMetadata, u as ServiceContextWithState, v as ServiceContextWithTransportInfo, w as createClientHandshakeOptions, x as createServerHandshakeOptions } from '../handshake-12d57161.js';
+import { S as ServerTransport } from '../server-f8228636.js';
 import '../message-e6c560fd.js';
 import '@sinclair/typebox/value';
 import '@opentelemetry/api';
-import '../client-1321630c.js';
+import '../client-edc8e2de.js';
 import '../types-3e5768ec.js';
@@ -48,4 +48,4 @@
 
-var version = "0.25.1";
+var version = "0.25.2";
 
 export { PayloadType, version as RIVER_VERSION, Result, RiverError, Server, ServiceContext, createServer };

dist/router/index.js

@@ -13,6 +13,6 @@ import {
   serializeSchema
-} from "../chunk-SGSRNAWJ.js";
+} from "../chunk-GDHQCPWW.js";
 import {
   version
-} from "../chunk-SZ5NBBX7.js";
+} from "../chunk-EHD2JJBW.js";
 export {
@@ -19,0 +19,0 @@ Err,

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

@@ -1,5 +0,5 @@
-import { C as ClientTransport } from '../../../client-1321630c.js';
+import { C as ClientTransport } from '../../../client-edc8e2de.js';
 import { c as TransportClientId } from '../../../message-e6c560fd.js';
-import { b as ProvidedClientTransportOptions } from '../../../handshake-3772d7ca.js';
-import { W as WebSocketConnection } from '../../../connection-bd907ca6.js';
+import { b as ProvidedClientTransportOptions } from '../../../handshake-12d57161.js';
+import { W as WebSocketConnection } from '../../../connection-ef50ac3a.js';
 import { W as WsLike } from '../../../wslike-e0b32dd5.js';
@@ -6,0 +6,0 @@ import '@sinclair/typebox/value';

dist/transport/impls/ws/client.js

 import {
   ClientTransport
-} from "../../../chunk-5CNNIOAO.js";
+} from "../../../chunk-ONIPHO7J.js";
 import {
   WebSocketConnection
-} from "../../../chunk-MBMEJIPU.js";
-import "../../../chunk-D5O3ERJU.js";
+} from "../../../chunk-ZWMWRM23.js";
+import "../../../chunk-PF74DCPQ.js";
 import "../../../chunk-TAH2GVTJ.js";
-import "../../../chunk-YM5Y4NAT.js";
-import "../../../chunk-SZ5NBBX7.js";
+import "../../../chunk-Q3PZBJXR.js";
+import "../../../chunk-EHD2JJBW.js";
 import "../../../chunk-4PVU7J25.js";
@@ -12,0 +12,0 @@

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

 import { c as TransportClientId } from '../../../message-e6c560fd.js';
 import { WebSocketServer } from 'ws';
-import { W as WebSocketConnection } from '../../../connection-bd907ca6.js';
+import { W as WebSocketConnection } from '../../../connection-ef50ac3a.js';
 import { W as WsLike } from '../../../wslike-e0b32dd5.js';
-import { S as ServerTransport } from '../../../server-f0fd2b98.js';
-import { c as ProvidedServerTransportOptions } from '../../../handshake-3772d7ca.js';
+import { S as ServerTransport } from '../../../server-f8228636.js';
+import { c as ProvidedServerTransportOptions } from '../../../handshake-12d57161.js';
 import '@sinclair/typebox/value';
@@ -8,0 +8,0 @@ import '@sinclair/typebox';

dist/transport/impls/ws/server.js

 import {
   ServerTransport
-} from "../../../chunk-PCBPPTXH.js";
+} from "../../../chunk-QXMZJ7LF.js";
 import {
   WebSocketConnection
-} from "../../../chunk-MBMEJIPU.js";
-import "../../../chunk-D5O3ERJU.js";
+} from "../../../chunk-ZWMWRM23.js";
+import "../../../chunk-PF74DCPQ.js";
 import "../../../chunk-TAH2GVTJ.js";
-import "../../../chunk-YM5Y4NAT.js";
-import "../../../chunk-SZ5NBBX7.js";
+import "../../../chunk-Q3PZBJXR.js";
+import "../../../chunk-EHD2JJBW.js";
 import "../../../chunk-4PVU7J25.js";
@@ -12,0 +12,0 @@

dist/transport/index.d.ts

@@ -1,4 +0,4 @@
-export { b as ClientTransportOptions, C as Connection, j as EventHandler, E as EventMap, i as EventTypes, k as ProtocolError, l as ProtocolErrorType, c as ServerTransportOptions, S as Session, h as SessionConnected, f as SessionConnecting, g as SessionHandshaking, e as SessionNoConnection, d as SessionState, T as Transport, P as TransportOptions, a as TransportStatus } from '../handshake-3772d7ca.js';
-export { C as ClientTransport } from '../client-1321630c.js';
-export { S as ServerTransport, a as SessionWaitingForHandshake } from '../server-f0fd2b98.js';
+export { b as ClientTransportOptions, C as Connection, j as EventHandler, E as EventMap, i as EventTypes, k as ProtocolError, l as ProtocolErrorType, c as ServerTransportOptions, S as Session, h as SessionConnected, f as SessionConnecting, g as SessionHandshaking, e as SessionNoConnection, d as SessionState, T as Transport, P as TransportOptions, a as TransportStatus } from '../handshake-12d57161.js';
+export { C as ClientTransport } from '../client-edc8e2de.js';
+export { S as ServerTransport, a as SessionWaitingForHandshake } from '../server-f8228636.js';
 export { b as OpaqueTransportMessage, O as OpaqueTransportMessageSchema, c as TransportClientId, a as TransportMessage, T as TransportMessageSchema, d as isStreamClose, i as isStreamOpen } from '../message-e6c560fd.js';
@@ -5,0 +5,0 @@ import '@sinclair/typebox';

dist/transport/index.js

 import {
   ClientTransport
-} from "../chunk-5CNNIOAO.js";
+} from "../chunk-ONIPHO7J.js";
 import {
   ServerTransport
-} from "../chunk-PCBPPTXH.js";
+} from "../chunk-QXMZJ7LF.js";
 import {
@@ -11,11 +11,11 @@ Connection,
   Transport
-} from "../chunk-D5O3ERJU.js";
+} from "../chunk-PF74DCPQ.js";
 import "../chunk-TAH2GVTJ.js";
 import {
   SessionState
-} from "../chunk-YM5Y4NAT.js";
+} from "../chunk-Q3PZBJXR.js";
 import {
   OpaqueTransportMessageSchema,
   TransportMessageSchema
-} from "../chunk-SZ5NBBX7.js";
+} from "../chunk-EHD2JJBW.js";
 import "../chunk-4PVU7J25.js";
@@ -22,0 +22,0 @@ export {

dist/util/testHelpers.d.ts

 import { Static } from '@sinclair/typebox';
-import { P as PayloadType, R as RiverError, a as Procedure, b as Result, c as RiverUncaughtSchema, d as ProcedureResult } from '../services-8d14ae16.js';
-import { T as Transport, C as Connection, m as SessionOptions, e as SessionNoConnection, n as ServiceContext, S as Session } from '../handshake-3772d7ca.js';
+import { P as PayloadType, R as RiverError, a as Procedure, b as Result, c as RiverUncaughtSchema, d as ProcedureResult } from '../services-4b9e5232.js';
+import { T as Transport, C as Connection, m as SessionOptions, n as ClientTransportOptions, e as SessionNoConnection, o as ServiceContext, S as Session } from '../handshake-12d57161.js';
 import * as it_pushable from 'it-pushable';
@@ -9,3 +9,3 @@ import { P as PartialTransportMessage, b as OpaqueTransportMessage } from '../message-e6c560fd.js';
 import { W as WsLike } from '../wslike-e0b32dd5.js';
-import '../client-1321630c.js';
+import '../client-edc8e2de.js';
 import '../types-3e5768ec.js';
@@ -56,2 +56,3 @@ import '@sinclair/typebox/value';
 declare const testingSessionOptions: SessionOptions;
+declare const testingClientSessionOptions: ClientTransportOptions;
 declare function dummySession(): SessionNoConnection;
@@ -75,2 +76,2 @@ declare function asClientRpc<State extends object, I extends PayloadType, O extends PayloadType, E extends RiverError, Init extends PayloadType | null = null>(state: State, proc: Procedure<State, 'rpc', I, O, E, Init>, extendedContext?: Omit<ServiceContext, 'state'>, session?: Session<Connection>): (msg: Static<I>) => Promise<Result<Static<O>, Static<E> | Static<typeof RiverUncaughtSchema>>>;
 
-export { asClientRpc, asClientStream, asClientSubscription, asClientUpload, closeAllConnections, createDummyTransportMessage, createLocalWebSocketClient, createWebSocketServer, dummySession, getTransportConnections, iterNext, numberOfConnections, onWsServerReady, payloadToTransportMessage, testingSessionOptions, waitForMessage };
+export { asClientRpc, asClientStream, asClientSubscription, asClientUpload, closeAllConnections, createDummyTransportMessage, createLocalWebSocketClient, createWebSocketServer, dummySession, getTransportConnections, iterNext, numberOfConnections, onWsServerReady, payloadToTransportMessage, testingClientSessionOptions, testingSessionOptions, waitForMessage };

dist/util/testHelpers.js

@@ -5,11 +5,12 @@ import {
   pushable
-} from "../chunk-SGSRNAWJ.js";
+} from "../chunk-GDHQCPWW.js";
 import {
   SessionStateGraph,
+  defaultClientTransportOptions,
   defaultTransportOptions
-} from "../chunk-YM5Y4NAT.js";
+} from "../chunk-Q3PZBJXR.js";
 import {
   coerceErrorString,
   generateId
-} from "../chunk-SZ5NBBX7.js";
+} from "../chunk-EHD2JJBW.js";
 import "../chunk-4PVU7J25.js";
@@ -77,2 +78,3 @@
 var testingSessionOptions = defaultTransportOptions;
+var testingClientSessionOptions = defaultClientTransportOptions;
 function dummySession() {
@@ -176,2 +178,3 @@ return SessionStateGraph.entrypoints.NoConnection(
   payloadToTransportMessage,
+  testingClientSessionOptions,
   testingSessionOptions,
@@ -178,0 +181,0 @@ waitForMessage

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.25.1",
+  "version": "0.25.2",
   "type": "module",
@@ -76,12 +76,2 @@ "exports": {
   },
-  "engines": {
-    "node": ">=16"
-  },
-  "keywords": [
-    "rpc",
-    "websockets",
-    "jsonschema"
-  ],
-  "author": "Jacky Zhao",
-  "license": "MIT",
   "scripts": {
@@ -95,2 +85,3 @@ "check": "tsc --noEmit && npm run format && npm run lint",
     "build": "rm -rf dist && tsup && du -sh dist",
+    "prepack": "npm run build",
     "release": "npm publish --access public",
@@ -102,3 +93,13 @@ "test:ui": "echo \"remember to go to /__vitest__ in the webview\" && vitest --ui --api.host 0.0.0.0 --api.port 3000",
     "bench": "vitest bench"
-  }
-}
+  },
+  "engines": {
+    "node": ">=16"
+  },
+  "keywords": [
+    "rpc",
+    "websockets",
+    "jsonschema"
+  ],
+  "author": "Jacky Zhao",
+  "license": "MIT"
+}

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

1394123

increased by2.69%

Lines of code

14429

increased by3.22%

No dependency changes