@replit/river - npm Package Compare versions

Comparing version 0.21.0 to 0.21.1

dist/logging/index.d.ts

@@ -1,3 +0,3 @@
-export { m as LogFn, L as Logger, M as MessageMetadata, l as bindLogger, j as coloredStringLogger, k as jsonLogger, s as stringLogger } from '../index-3ac92295.js';
+export { m as LogFn, L as Logger, M as MessageMetadata, l as bindLogger, j as coloredStringLogger, k as jsonLogger, s as stringLogger } from '../index-dfad460e.js';
 import '@sinclair/typebox';
 import '../types-3e5768ec.js';

dist/logging/index.js

@@ -6,3 +6,3 @@ import {
   stringLogger
-} from "../chunk-DT5JS6TM.js";
+} from "../chunk-OTQNCLFH.js";
 export {
@@ -9,0 +9,0 @@ bindLogger,

dist/router/index.d.ts

@@ -1,7 +0,7 @@
-import { A as AnyServiceSchemaMap, I as InstantiatedServiceSchemaMap, P as PayloadType, b as Result, R as RiverError, S as ServiceContext } from '../services-8496d6e8.js';
-export { C as Client, E as Err, O as Ok, B as Output, k as ProcErrors, g as ProcHandler, h as ProcInit, i as ProcInput, j as ProcOutput, l as ProcType, a as Procedure, o as ProcedureMap, d as ProcedureResult, p as RPCProcedure, z as ResultUnwrapErr, y as ResultUnwrapOk, x as RiverErrorSchema, c as RiverUncaughtSchema, n as SerializedServerSchema, e as Service, f as ServiceConfiguration, u as ServiceContextWithState, v as ServiceContextWithTransportInfo, m as ServiceSchema, r as StreamProcedure, q as SubscriptionProcedure, w as UNCAUGHT_ERROR, U as UploadProcedure, V as ValidProcType, t as createClient, s as serializeSchema } from '../services-8496d6e8.js';
+import { A as AnyServiceSchemaMap, I as InstantiatedServiceSchemaMap, P as PayloadType, b as Result, R as RiverError, S as ServiceContext } from '../services-9c496c6e.js';
+export { C as Client, E as Err, O as Ok, B as Output, k as ProcErrors, g as ProcHandler, h as ProcInit, i as ProcInput, j as ProcOutput, l as ProcType, a as Procedure, o as ProcedureMap, d as ProcedureResult, p as RPCProcedure, z as ResultUnwrapErr, y as ResultUnwrapOk, x as RiverErrorSchema, c as RiverUncaughtSchema, n as SerializedServerSchema, e as Service, f as ServiceConfiguration, u as ServiceContextWithState, v as ServiceContextWithTransportInfo, m as ServiceSchema, r as StreamProcedure, q as SubscriptionProcedure, w as UNCAUGHT_ERROR, U as UploadProcedure, V as ValidProcType, t as createClient, s as serializeSchema } from '../services-9c496c6e.js';
 import { Static } from '@sinclair/typebox';
 import { ServerTransport } from '../transport/index.js';
 import { Pushable } from 'it-pushable';
-import { C as Connection } from '../index-3ac92295.js';
+import { C as Connection } from '../index-dfad460e.js';
 import '../types-3e5768ec.js';
@@ -39,4 +39,4 @@
 
-var version = "0.21.0";
+var version = "0.21.1";
 
 export { PayloadType, version as RIVER_VERSION, Result, RiverError, Server, ServiceContext, createServer };

dist/router/index.js

@@ -12,5 +12,5 @@ import {
   version
-} from "../chunk-NFV77C2M.js";
+} from "../chunk-NCXUFDVL.js";
 import "../chunk-5WFL722S.js";
-import "../chunk-DT5JS6TM.js";
+import "../chunk-OTQNCLFH.js";
 export {
@@ -17,0 +17,0 @@ Err,

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

@@ -1,4 +0,4 @@
-import { U as UdsConnection } from '../../../connection-d49d5d56.js';
+import { U as UdsConnection } from '../../../connection-975b25c9.js';
 import { ClientTransport, ClientTransportOptions as ProvidedClientTransportOptions } from '../../index.js';
-import { T as TransportClientId } from '../../../index-3ac92295.js';
+import { T as TransportClientId } from '../../../index-dfad460e.js';
 import 'node:net';
@@ -5,0 +5,0 @@ import 'node:stream';

dist/transport/impls/uds/client.js

 import {
   UdsConnection
-} from "../../../chunk-MJR36SUY.js";
+} from "../../../chunk-FDLAPYCK.js";
 import {
   ClientTransport
-} from "../../../chunk-QU2EE6YU.js";
+} from "../../../chunk-JMXO5L2X.js";
 import "../../../chunk-5WFL722S.js";
 import {
   log
-} from "../../../chunk-DT5JS6TM.js";
+} from "../../../chunk-OTQNCLFH.js";
 import "../../../chunk-3AW3IXVD.js";
@@ -12,0 +12,0 @@

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

 import { Server, Socket } from 'node:net';
 import { ServerTransport, ServerTransportOptions as ProvidedServerTransportOptions } from '../../index.js';
-import { T as TransportClientId } from '../../../index-3ac92295.js';
-import { U as UdsConnection } from '../../../connection-d49d5d56.js';
+import { T as TransportClientId } from '../../../index-dfad460e.js';
+import { U as UdsConnection } from '../../../connection-975b25c9.js';
 import '../../../types-3e5768ec.js';
@@ -6,0 +6,0 @@ import '@sinclair/typebox';

dist/transport/impls/uds/server.js

 import {
   UdsConnection
-} from "../../../chunk-MJR36SUY.js";
+} from "../../../chunk-FDLAPYCK.js";
 import {
   ServerTransport
-} from "../../../chunk-QU2EE6YU.js";
+} from "../../../chunk-JMXO5L2X.js";
 import "../../../chunk-5WFL722S.js";
-import "../../../chunk-DT5JS6TM.js";
+import "../../../chunk-OTQNCLFH.js";
 import "../../../chunk-3AW3IXVD.js";
@@ -10,0 +10,0 @@

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

 import { ClientTransport, ClientTransportOptions as ProvidedClientTransportOptions } from '../../index.js';
-import { T as TransportClientId } from '../../../index-3ac92295.js';
-import { W as WebSocketConnection } from '../../../connection-8a71dbe2.js';
+import { T as TransportClientId } from '../../../index-dfad460e.js';
+import { W as WebSocketConnection } from '../../../connection-76c5ed01.js';
 import '../../../types-3e5768ec.js';
@@ -5,0 +5,0 @@ import '@sinclair/typebox';

dist/transport/impls/ws/client.js

 import {
   WebSocketConnection
-} from "../../../chunk-2ERP6FUE.js";
+} from "../../../chunk-3Y7AB5EB.js";
 import {
   ClientTransport
-} from "../../../chunk-QU2EE6YU.js";
+} from "../../../chunk-JMXO5L2X.js";
 import "../../../chunk-5WFL722S.js";
 import {
   log
-} from "../../../chunk-DT5JS6TM.js";
+} from "../../../chunk-OTQNCLFH.js";
 import "../../../chunk-3AW3IXVD.js";
@@ -12,0 +12,0 @@

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

@@ -1,6 +0,6 @@
-import { T as TransportClientId } from '../../../index-3ac92295.js';
+import { T as TransportClientId } from '../../../index-dfad460e.js';
 import { ServerTransport, ServerTransportOptions as ProvidedServerTransportOptions } from '../../index.js';
 import { WebSocketServer } from 'ws';
 import WebSocket from 'agnostic-ws';
-import { W as WebSocketConnection } from '../../../connection-8a71dbe2.js';
+import { W as WebSocketConnection } from '../../../connection-76c5ed01.js';
 import '@sinclair/typebox';
@@ -7,0 +7,0 @@ import '../../../types-3e5768ec.js';

dist/transport/impls/ws/server.js

 import {
   WebSocketConnection
-} from "../../../chunk-2ERP6FUE.js";
+} from "../../../chunk-3Y7AB5EB.js";
 import {
   ServerTransport
-} from "../../../chunk-QU2EE6YU.js";
+} from "../../../chunk-JMXO5L2X.js";
 import "../../../chunk-5WFL722S.js";
-import "../../../chunk-DT5JS6TM.js";
+import "../../../chunk-OTQNCLFH.js";
 import "../../../chunk-3AW3IXVD.js";
@@ -10,0 +10,0 @@

dist/transport/index.d.ts

 import { C as Codec } from '../types-3e5768ec.js';
-import { O as OpaqueTransportMessage, C as Connection, a as Session, T as TransportClientId, P as PartialTransportMessage, S as SessionOptions, f as ClientHandshakeOptions, g as ServerHandshakeOptions } from '../index-3ac92295.js';
-export { H as HandshakeRequestMetadata, d as OpaqueTransportMessageSchema, b as ParsedHandshakeMetadata, e as TransportMessage, c as TransportMessageSchema, h as isStreamClose, i as isStreamOpen } from '../index-3ac92295.js';
+import { O as OpaqueTransportMessage, C as Connection, a as Session, T as TransportClientId, P as PartialTransportMessage, S as SessionOptions, f as ClientHandshakeOptions, g as ServerHandshakeOptions } from '../index-dfad460e.js';
+export { H as HandshakeRequestMetadata, d as OpaqueTransportMessageSchema, b as ParsedHandshakeMetadata, e as TransportMessage, c as TransportMessageSchema, h as isStreamClose, i as isStreamOpen } from '../index-dfad460e.js';
 import '@sinclair/typebox';
@@ -5,0 +5,0 @@

dist/transport/index.js

@@ -8,3 +8,3 @@ import {
   Transport
-} from "../chunk-QU2EE6YU.js";
+} from "../chunk-JMXO5L2X.js";
 import {
@@ -14,3 +14,3 @@ OpaqueTransportMessageSchema,
 } from "../chunk-5WFL722S.js";
-import "../chunk-DT5JS6TM.js";
+import "../chunk-OTQNCLFH.js";
 import "../chunk-3AW3IXVD.js";
@@ -17,0 +17,0 @@ export {

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 '../services-8496d6e8.js';
+import { P as PayloadType, R as RiverError, a as Procedure, S as ServiceContext, b as Result, c as RiverUncaughtSchema, d as ProcedureResult } from '../services-9c496c6e.js';
 import { Transport } from '../transport/index.js';
 import * as it_pushable from 'it-pushable';
-import { P as PartialTransportMessage, C as Connection, O as OpaqueTransportMessage, S as SessionOptions, a as Session } from '../index-3ac92295.js';
+import { P as PartialTransportMessage, C as Connection, O as OpaqueTransportMessage, S as SessionOptions, a as Session } from '../index-dfad460e.js';
 import * as ws from 'ws';
@@ -50,6 +50,9 @@ import http from 'node:http';
 declare function asClientUpload<State extends object, I extends PayloadType, O extends PayloadType, E extends RiverError, Init extends PayloadType | null = null>(state: State, proc: Procedure<State, 'upload', I, O, E, Init>, init?: Init extends PayloadType ? Static<Init> : null, extendedContext?: Omit<ServiceContext, 'state'>, session?: Session<Connection>): readonly [it_pushable.Pushable<Static<I>, void, unknown>, Promise<{
-    ok: boolean;
+    ok: true;
+    payload: unknown;
+} | {
+    ok: false;
     payload: {
-        code: string;
-        message: string;
+        readonly code: "UNCAUGHT_ERROR";
+        readonly message: string;
     };
@@ -56,0 +59,0 @@ } | ProcedureResult<O, E>>];

dist/util/testHelpers.js

 import {
+  Err,
   UNCAUGHT_ERROR,
   pushable
-} from "../chunk-NFV77C2M.js";
+} from "../chunk-NCXUFDVL.js";
 import {
   Session,
   defaultTransportOptions
-} from "../chunk-QU2EE6YU.js";
+} from "../chunk-JMXO5L2X.js";
 import {
   coerceErrorString
 } from "../chunk-5WFL722S.js";
-import "../chunk-DT5JS6TM.js";
+import "../chunk-OTQNCLFH.js";
 import "../chunk-3AW3IXVD.js";
@@ -73,9 +74,3 @@
   const errorMsg = coerceErrorString(err);
-  return {
-    ok: false,
-    payload: {
-      code: UNCAUGHT_ERROR,
-      message: errorMsg
-    }
-  };
+  return Err({ code: UNCAUGHT_ERROR, message: errorMsg });
 }
@@ -82,0 +77,0 @@ var testingSessionOptions = defaultTransportOptions;

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.21.0",
+  "version": "0.21.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

Improved metrics

Total package byte prevSize

1455614

increased by0.41%

Number of downloads

14490

increased by27.27%

Lines of code

14700

increased by0.34%

Published versions last two months

1

increased byInfinity%

Published versions last year

124

increased by0.81%

No dependency changes