@replit/river - npm Package Compare versions

Comparing version 0.23.2 to 0.23.3

dist/logging/index.d.ts

@@ -1,2 +0,2 @@
-export { q as LogFn, L as Logger, M as MessageMetadata, p as bindLogger, n as coloredStringLogger, o as jsonLogger, s as stringLogger } from '../index-72b688b7.js';
+export { q as LogFn, L as Logger, M as MessageMetadata, p as bindLogger, n as coloredStringLogger, o as jsonLogger, s as stringLogger } from '../index-a009d7f6.js';
 import '@sinclair/typebox/value';
@@ -3,0 +3,0 @@ import '@sinclair/typebox';

dist/router/index.d.ts

@@ -1,8 +0,8 @@
-import { A as AnyServiceSchemaMap, I as InstantiatedServiceSchemaMap, P as PayloadType, b as Result, R as RiverError } from '../services-0af830a4.js';
-export { C as Client, E as Err, O as Ok, x as Output, j as ProcErrors, f as ProcHandler, g as ProcInit, h as ProcInput, i as ProcOutput, k as ProcType, a as Procedure, n as ProcedureMap, d as ProcedureResult, o as RPCProcedure, w as ResultUnwrapErr, v as ResultUnwrapOk, u as RiverErrorSchema, c as RiverUncaughtSchema, m as SerializedServerSchema, S as Service, e as ServiceConfiguration, l as ServiceSchema, q as StreamProcedure, p as SubscriptionProcedure, t as UNCAUGHT_ERROR, U as UploadProcedure, V as ValidProcType, r as createClient, s as serializeSchema } from '../services-0af830a4.js';
-import { Static, TSchema } from '@sinclair/typebox';
+import { A as AnyServiceSchemaMap, I as InstantiatedServiceSchemaMap, P as PayloadType, b as Result, R as RiverError } from '../services-ef89f5b0.js';
+export { C as Client, E as Err, O as Ok, x as Output, j as ProcErrors, f as ProcHandler, g as ProcInit, h as ProcInput, i as ProcOutput, k as ProcType, a as Procedure, n as ProcedureMap, d as ProcedureResult, o as RPCProcedure, w as ResultUnwrapErr, v as ResultUnwrapOk, u as RiverErrorSchema, c as RiverUncaughtSchema, m as SerializedServerSchema, S as Service, e as ServiceConfiguration, l as ServiceSchema, q as StreamProcedure, p as SubscriptionProcedure, t as UNCAUGHT_ERROR, U as UploadProcedure, V as ValidProcType, r as createClient, s as serializeSchema } from '../services-ef89f5b0.js';
+import { Static } from '@sinclair/typebox';
 import { ServerTransport } from '../transport/index.js';
 import { Pushable } from 'it-pushable';
-import { C as Connection, c as ServerHandshakeOptions, a as ServiceContext } from '../index-72b688b7.js';
-export { d as ServiceContextWithState, e as ServiceContextWithTransportInfo } from '../index-72b688b7.js';
+import { C as Connection, c as ServerHandshakeOptions, a as ServiceContext } from '../index-a009d7f6.js';
+export { d as ParsedMetadata, e as ServiceContextWithState, f as ServiceContextWithTransportInfo } from '../index-a009d7f6.js';
 import '../types-3e5768ec.js';
@@ -41,9 +41,9 @@ import '@sinclair/typebox/value';
  */
-declare function createServer<Services extends AnyServiceSchemaMap, MetadataSchema extends TSchema = TSchema>(transport: ServerTransport<Connection, MetadataSchema>, services: Services, providedServerOptions?: Partial<{
-    handshakeOptions?: ServerHandshakeOptions<MetadataSchema>;
+declare function createServer<Services extends AnyServiceSchemaMap>(transport: ServerTransport<Connection>, services: Services, providedServerOptions?: Partial<{
+    handshakeOptions?: ServerHandshakeOptions;
     extendedContext?: Omit<ServiceContext, 'state'>;
 }>): Server<Services>;
 
-var version = "0.23.2";
+var version = "0.23.3";
 
 export { PayloadType, version as RIVER_VERSION, Result, RiverError, Server, ServiceContext, createServer };

dist/router/index.js

@@ -11,6 +11,6 @@ import {
   serializeSchema
-} from "../chunk-ZPUDMABQ.js";
+} from "../chunk-JBRQNEBV.js";
 import {
   version
-} from "../chunk-3ZS3RHZF.js";
+} from "../chunk-XZV3HOQW.js";
 import "../chunk-SPP7ACQN.js";
@@ -17,0 +17,0 @@ export {

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

@@ -1,9 +0,9 @@
-import { U as UdsConnection } from '../../../connection-6eb86e22.js';
+import { U as UdsConnection } from '../../../connection-89a66019.js';
 import { ClientTransport, ClientTransportOptions as ProvidedClientTransportOptions } from '../../index.js';
-import { T as TransportClientId } from '../../../index-72b688b7.js';
+import { T as TransportClientId } from '../../../index-a009d7f6.js';
 import 'node:net';
 import 'node:stream';
 import '../../../types-3e5768ec.js';
+import '@sinclair/typebox/value';
 import '@sinclair/typebox';
-import '@sinclair/typebox/value';
 import '@opentelemetry/api';
@@ -10,0 +10,0 @@

dist/transport/impls/uds/client.js

 import {
   UdsConnection
-} from "../../../chunk-6Z4YTBOM.js";
+} from "../../../chunk-R3EG3FOP.js";
 import {
   ClientTransport
-} from "../../../chunk-LHLQY5FR.js";
-import "../../../chunk-3ZS3RHZF.js";
+} from "../../../chunk-IKT6A32W.js";
+import "../../../chunk-XZV3HOQW.js";
 import {
@@ -9,0 +9,0 @@ log

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-72b688b7.js';
-import { U as UdsConnection } from '../../../connection-6eb86e22.js';
+import { T as TransportClientId } from '../../../index-a009d7f6.js';
+import { U as UdsConnection } from '../../../connection-89a66019.js';
 import '../../../types-3e5768ec.js';
+import '@sinclair/typebox/value';
 import '@sinclair/typebox';
-import '@sinclair/typebox/value';
 import '@opentelemetry/api';
@@ -9,0 +9,0 @@ import 'node:stream';

dist/transport/impls/uds/server.js

 import {
   UdsConnection
-} from "../../../chunk-6Z4YTBOM.js";
+} from "../../../chunk-R3EG3FOP.js";
 import {
   ServerTransport
-} from "../../../chunk-LHLQY5FR.js";
-import "../../../chunk-3ZS3RHZF.js";
+} from "../../../chunk-IKT6A32W.js";
+import "../../../chunk-XZV3HOQW.js";
 import "../../../chunk-SPP7ACQN.js";
@@ -9,0 +9,0 @@ import "../../../chunk-3AW3IXVD.js";

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

 import { ClientTransport, ClientTransportOptions as ProvidedClientTransportOptions } from '../../index.js';
-import { T as TransportClientId } from '../../../index-72b688b7.js';
-import { W as WebSocketConnection } from '../../../connection-a25109b5.js';
+import { T as TransportClientId } from '../../../index-a009d7f6.js';
+import { W as WebSocketConnection } from '../../../connection-4abad643.js';
 import { W as WsLike } from '../../../wslike-e0b32dd5.js';
 import '../../../types-3e5768ec.js';
+import '@sinclair/typebox/value';
 import '@sinclair/typebox';
-import '@sinclair/typebox/value';
 import '@opentelemetry/api';
@@ -9,0 +9,0 @@

dist/transport/impls/ws/client.js

 import {
   WebSocketConnection
-} from "../../../chunk-KPLLLP3F.js";
+} from "../../../chunk-3U43VMW2.js";
 import {
   ClientTransport
-} from "../../../chunk-LHLQY5FR.js";
-import "../../../chunk-3ZS3RHZF.js";
+} from "../../../chunk-IKT6A32W.js";
+import "../../../chunk-XZV3HOQW.js";
 import {
@@ -9,0 +9,0 @@ log

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

@@ -1,5 +0,5 @@
-import { T as TransportClientId } from '../../../index-72b688b7.js';
+import { T as TransportClientId } from '../../../index-a009d7f6.js';
 import { ServerTransport, ServerTransportOptions as ProvidedServerTransportOptions } from '../../index.js';
 import { WebSocketServer } from 'ws';
-import { W as WebSocketConnection } from '../../../connection-a25109b5.js';
+import { W as WebSocketConnection } from '../../../connection-4abad643.js';
 import { W as WsLike } from '../../../wslike-e0b32dd5.js';
@@ -6,0 +6,0 @@ import '@sinclair/typebox/value';

dist/transport/impls/ws/server.js

 import {
   WebSocketConnection
-} from "../../../chunk-KPLLLP3F.js";
+} from "../../../chunk-3U43VMW2.js";
 import {
   ServerTransport
-} from "../../../chunk-LHLQY5FR.js";
-import "../../../chunk-3ZS3RHZF.js";
+} from "../../../chunk-IKT6A32W.js";
+import "../../../chunk-XZV3HOQW.js";
 import "../../../chunk-SPP7ACQN.js";
@@ -9,0 +9,0 @@ import "../../../chunk-3AW3IXVD.js";

dist/transport/index.d.ts

 import { C as Codec } from '../types-3e5768ec.js';
-import { O as OpaqueTransportMessage, C as Connection, b as Session, T as TransportClientId, l as PropagationContext, P as PartialTransportMessage, f as ClientHandshakeOptions, c as ServerHandshakeOptions, m as ParsedMetadata, S as SessionOptions } from '../index-72b688b7.js';
-export { h as OpaqueTransportMessageSchema, i as TransportMessage, g as TransportMessageSchema, k as isStreamClose, j as isStreamOpen } from '../index-72b688b7.js';
-import { TSchema } from '@sinclair/typebox';
+import { O as OpaqueTransportMessage, C as Connection, b as Session, T as TransportClientId, m as PropagationContext, P as PartialTransportMessage, g as ClientHandshakeOptions, c as ServerHandshakeOptions, d as ParsedMetadata, S as SessionOptions } from '../index-a009d7f6.js';
+export { i as OpaqueTransportMessageSchema, j as TransportMessage, h as TransportMessageSchema, l as isStreamClose, k as isStreamOpen } from '../index-a009d7f6.js';
 import '@sinclair/typebox/value';
+import '@sinclair/typebox';
 import '@opentelemetry/api';
@@ -246,3 +246,3 @@
 }
-declare abstract class ClientTransport<ConnType extends Connection, HandshakeMetadata extends TSchema = TSchema> extends Transport<ConnType> {
+declare abstract class ClientTransport<ConnType extends Connection> extends Transport<ConnType> {
     /**
@@ -267,5 +267,5 @@ * The options for this transport.
      */
-    handshakeExtensions?: ClientHandshakeOptions<HandshakeMetadata>;
+    handshakeExtensions?: ClientHandshakeOptions;
     constructor(clientId: TransportClientId, providedOptions?: ProvidedClientTransportOptions);
-    extendHandshake(options: ClientHandshakeOptions<HandshakeMetadata>): void;
+    extendHandshake(options: ClientHandshakeOptions): void;
     protected handleConnection(conn: ConnType, to: TransportClientId): void;
@@ -291,3 +291,3 @@ receiveHandshakeResponseMessage(data: Uint8Array, conn: ConnType): Session<ConnType> | false;
 }
-declare abstract class ServerTransport<ConnType extends Connection, CustomMetadataSchema extends TSchema = TSchema> extends Transport<ConnType> {
+declare abstract class ServerTransport<ConnType extends Connection> extends Transport<ConnType> {
     /**
@@ -300,3 +300,3 @@ * The options for this transport.
      */
-    handshakeExtensions?: ServerHandshakeOptions<CustomMetadataSchema>;
+    handshakeExtensions?: ServerHandshakeOptions;
     /**
@@ -307,3 +307,3 @@ * A map of session handshake data for each session.
     constructor(clientId: TransportClientId, providedOptions?: ProvidedServerTransportOptions);
-    extendHandshake(options: ServerHandshakeOptions<CustomMetadataSchema>): void;
+    extendHandshake(options: ServerHandshakeOptions): void;
     protected handleConnection(conn: ConnType): void;
@@ -310,0 +310,0 @@ private validateHandshakeMetadata;

dist/transport/index.js

@@ -8,7 +8,7 @@ import {
   Transport
-} from "../chunk-LHLQY5FR.js";
+} from "../chunk-IKT6A32W.js";
 import {
   OpaqueTransportMessageSchema,
   TransportMessageSchema
-} from "../chunk-3ZS3RHZF.js";
+} from "../chunk-XZV3HOQW.js";
 import "../chunk-SPP7ACQN.js";
@@ -15,0 +15,0 @@ import "../chunk-3AW3IXVD.js";

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-0af830a4.js';
+import { P as PayloadType, R as RiverError, a as Procedure, b as Result, c as RiverUncaughtSchema, d as ProcedureResult } from '../services-ef89f5b0.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 ServiceContext, b as Session } from '../index-72b688b7.js';
+import { P as PartialTransportMessage, C as Connection, O as OpaqueTransportMessage, S as SessionOptions, a as ServiceContext, b as Session } from '../index-a009d7f6.js';
 import NodeWs from 'ws';
@@ -7,0 +7,0 @@ import http from 'node:http';

dist/util/testHelpers.js

@@ -5,10 +5,10 @@ import {
   pushable
-} from "../chunk-ZPUDMABQ.js";
+} from "../chunk-JBRQNEBV.js";
 import {
   Session,
   defaultTransportOptions
-} from "../chunk-LHLQY5FR.js";
+} from "../chunk-IKT6A32W.js";
 import {
   coerceErrorString
-} from "../chunk-3ZS3RHZF.js";
+} from "../chunk-XZV3HOQW.js";
 import "../chunk-SPP7ACQN.js";
@@ -15,0 +15,0 @@ import "../chunk-3AW3IXVD.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.23.2",
+  "version": "0.23.3",
   "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

Lines of code

14844

increased by0.05%

Worsened metrics

Total package byte prevSize

1478186

decreased by-0.15%

No dependency changes