Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More

@replit/river

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@replit/river - npm Package Compare versions

Comparing version 0.23.12 to 0.23.13

import {
BinaryCodec,
NaiveJsonCodec
} from "../chunk-3AW3IXVD.js";
} from "../chunk-4PVU7J25.js";
// codec/binary.ts
import { decode, encode } from "@msgpack/msgpack";
var BinaryCodec = {
toBuffer(obj) {
return encode(obj, { ignoreUndefined: true });
},
fromBuffer: (buff) => {
try {
const res = decode(buff);
if (typeof res !== "object") {
return null;
}
return res;
} catch {
return null;
}
}
};
export {

@@ -6,0 +24,0 @@ BinaryCodec,

@@ -1,4 +0,4 @@

export { g as LogFn, L as Logger, M as MessageMetadata, j as coloredStringLogger, k as jsonLogger, s as stringLogger } from '../index-60f03cb7.js';
export { g as LogFn, L as Logger, M as MessageMetadata, j as coloredStringLogger, k as jsonLogger, s as stringLogger } from '../index-ea74cdbb.js';
import '@sinclair/typebox/value';
import '@sinclair/typebox';
import '@opentelemetry/api';

@@ -1,10 +0,12 @@

import { S as SerializedServerSchema, A as AnyServiceSchemaMap, I as InstantiatedServiceSchemaMap, P as PayloadType, b as Result, R as RiverError } from '../services-ca72c9f8.js';
export { C as Client, E as Err, O as Ok, z as Output, k as ProcErrors, g as ProcHandler, h as ProcInit, i as ProcInput, j as ProcOutput, l 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, n as SerializedServiceSchema, e as Service, f as ServiceConfiguration, m 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-ca72c9f8.js';
import { S as SerializedServerSchema, A as AnyServiceSchemaMap, I as InstantiatedServiceSchemaMap, P as PayloadType, b as Result, R as RiverError } from '../services-f406b3aa.js';
export { C as Client, E as Err, O as Ok, z as Output, k as ProcErrors, g as ProcHandler, h as ProcInit, i as ProcInput, j as ProcOutput, l 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, n as SerializedServiceSchema, e as Service, f as ServiceConfiguration, m 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-f406b3aa.js';
import { Static } from '@sinclair/typebox';
import { d as ServerTransport, C as Connection, f as ServerHandshakeOptions, b as ServiceContext } from '../transport-47af1c81.js';
export { g as ParsedMetadata, h as ServiceContextWithState, i as ServiceContextWithTransportInfo, j as createClientHandshakeOptions, k as createServerHandshakeOptions } from '../transport-47af1c81.js';
import { Pushable } from 'it-pushable';
import '../index-60f03cb7.js';
import { C as Connection, m as ServerHandshakeOptions, i as ServiceContext } from '../handshake-e428d1c8.js';
export { n as ParsedMetadata, o as ServiceContextWithState, p as ServiceContextWithTransportInfo, q as createClientHandshakeOptions, r as createServerHandshakeOptions } from '../handshake-e428d1c8.js';
import { S as ServerTransport } from '../server-ebf80863.js';
import '../index-ea74cdbb.js';
import '@sinclair/typebox/value';
import '@opentelemetry/api';
import '../client-dd5c9dd0.js';
import '../types-3e5768ec.js';

@@ -84,4 +86,4 @@

var version = "0.23.12";
var version = "0.23.13";
export { DiffOptions, PayloadBreakage, PayloadType, ProcedureBreakage, version as RIVER_VERSION, Result, RiverError, SerializedServerSchema, Server, ServerBreakage, ServiceBreakage, ServiceContext, createServer, diffServerSchema };

@@ -14,6 +14,6 @@ import {

serializeSchema
} from "../chunk-XZ6IOBM5.js";
} from "../chunk-KFTGQ3QC.js";
import {
version
} from "../chunk-7RUKEUKE.js";
} from "../chunk-ES4XO2XD.js";
export {

@@ -20,0 +20,0 @@ Err,

@@ -1,10 +0,11 @@

import { U as UdsConnection } from '../../../connection-581558f8.js';
import { c as ClientTransport, P as ProvidedClientTransportOptions } from '../../../transport-47af1c81.js';
import { T as TransportClientId } from '../../../index-60f03cb7.js';
import { U as UdsConnection } from '../../../connection-40318f22.js';
import { c as TransportClientId } from '../../../index-ea74cdbb.js';
import { C as ClientTransport } from '../../../client-dd5c9dd0.js';
import { b as ProvidedClientTransportOptions } from '../../../handshake-e428d1c8.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';
import '../../../types-3e5768ec.js';

@@ -11,0 +12,0 @@ declare class UnixDomainSocketClientTransport extends ClientTransport<UdsConnection> {

import {
UdsConnection
} from "../../../chunk-H6KTH6W6.js";
} from "../../../chunk-4QZOW4DH.js";
import {
ClientTransport
} from "../../../chunk-VRU4IKRT.js";
import "../../../chunk-7RUKEUKE.js";
} from "../../../chunk-S4DUN7KK.js";
import "../../../chunk-XM656KMN.js";
import "../../../chunk-6LCL2ZZF.js";
import "../../../chunk-3AW3IXVD.js";
import "../../../chunk-2FNLANTJ.js";
import "../../../chunk-ES4XO2XD.js";
import "../../../chunk-4PVU7J25.js";

@@ -11,0 +13,0 @@ // transport/impls/uds/client.ts

import { Server, Socket } from 'node:net';
import { d as ServerTransport, e as ProvidedServerTransportOptions } from '../../../transport-47af1c81.js';
import { T as TransportClientId } from '../../../index-60f03cb7.js';
import { U as UdsConnection } from '../../../connection-581558f8.js';
import '../../../types-3e5768ec.js';
import { c as TransportClientId } from '../../../index-ea74cdbb.js';
import { U as UdsConnection } from '../../../connection-40318f22.js';
import { S as ServerTransport } from '../../../server-ebf80863.js';
import { c as ProvidedServerTransportOptions } from '../../../handshake-e428d1c8.js';
import '@sinclair/typebox/value';
import '@sinclair/typebox';
import '@sinclair/typebox/value';
import '@opentelemetry/api';
import 'node:stream';
import '../../../types-3e5768ec.js';

@@ -11,0 +12,0 @@ declare class UnixDomainSocketServerTransport extends ServerTransport<UdsConnection> {

import {
ServerTransport
} from "../../../chunk-ZUKDZY54.js";
import {
UdsConnection
} from "../../../chunk-H6KTH6W6.js";
import {
ServerTransport
} from "../../../chunk-VRU4IKRT.js";
import "../../../chunk-7RUKEUKE.js";
} from "../../../chunk-4QZOW4DH.js";
import "../../../chunk-XM656KMN.js";
import "../../../chunk-6LCL2ZZF.js";
import "../../../chunk-3AW3IXVD.js";
import "../../../chunk-2FNLANTJ.js";
import "../../../chunk-ES4XO2XD.js";
import "../../../chunk-4PVU7J25.js";

@@ -11,0 +13,0 @@ // transport/impls/uds/server.ts

@@ -1,9 +0,10 @@

import { c as ClientTransport, P as ProvidedClientTransportOptions } from '../../../transport-47af1c81.js';
import { T as TransportClientId } from '../../../index-60f03cb7.js';
import { W as WebSocketConnection } from '../../../connection-8debd45f.js';
import { C as ClientTransport } from '../../../client-dd5c9dd0.js';
import { c as TransportClientId } from '../../../index-ea74cdbb.js';
import { b as ProvidedClientTransportOptions } from '../../../handshake-e428d1c8.js';
import { W as WebSocketConnection } from '../../../connection-39816c00.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';
import '../../../types-3e5768ec.js';

@@ -10,0 +11,0 @@ /**

import {
WebSocketConnection
} from "../../../chunk-HDBVL7EF.js";
} from "../../../chunk-SX6HI63Q.js";
import {
ClientTransport
} from "../../../chunk-VRU4IKRT.js";
import "../../../chunk-7RUKEUKE.js";
} from "../../../chunk-S4DUN7KK.js";
import "../../../chunk-XM656KMN.js";
import "../../../chunk-6LCL2ZZF.js";
import "../../../chunk-3AW3IXVD.js";
import "../../../chunk-2FNLANTJ.js";
import "../../../chunk-ES4XO2XD.js";
import "../../../chunk-4PVU7J25.js";

@@ -11,0 +13,0 @@ // transport/impls/ws/client.ts

@@ -1,6 +0,7 @@

import { T as TransportClientId } from '../../../index-60f03cb7.js';
import { d as ServerTransport, e as ProvidedServerTransportOptions } from '../../../transport-47af1c81.js';
import { c as TransportClientId } from '../../../index-ea74cdbb.js';
import { WebSocketServer } from 'ws';
import { W as WebSocketConnection } from '../../../connection-8debd45f.js';
import { W as WebSocketConnection } from '../../../connection-39816c00.js';
import { W as WsLike } from '../../../wslike-e0b32dd5.js';
import { S as ServerTransport } from '../../../server-ebf80863.js';
import { c as ProvidedServerTransportOptions } from '../../../handshake-e428d1c8.js';
import '@sinclair/typebox/value';

@@ -7,0 +8,0 @@ import '@sinclair/typebox';

import {
ServerTransport
} from "../../../chunk-ZUKDZY54.js";
import {
WebSocketConnection
} from "../../../chunk-HDBVL7EF.js";
import {
ServerTransport
} from "../../../chunk-VRU4IKRT.js";
import "../../../chunk-7RUKEUKE.js";
} from "../../../chunk-SX6HI63Q.js";
import "../../../chunk-XM656KMN.js";
import "../../../chunk-6LCL2ZZF.js";
import "../../../chunk-3AW3IXVD.js";
import "../../../chunk-2FNLANTJ.js";
import "../../../chunk-ES4XO2XD.js";
import "../../../chunk-4PVU7J25.js";

@@ -11,0 +13,0 @@ // transport/impls/ws/server.ts

@@ -1,3 +0,5 @@

export { c as ClientTransport, P as ClientTransportOptions, C as Connection, p as EventHandler, E as EventMap, o as EventTypes, q as ProtocolError, r as ProtocolErrorType, d as ServerTransport, e as ServerTransportOptions, a as Session, T as Transport, m as TransportOptions, n as TransportStatus } from '../transport-47af1c81.js';
export { O as OpaqueTransportMessage, e as OpaqueTransportMessageSchema, T as TransportClientId, c as TransportMessage, d as TransportMessageSchema, f as isStreamClose, i as isStreamOpen } from '../index-60f03cb7.js';
export { b as ClientTransportOptions, C as Connection, e as EventHandler, E as EventMap, d as EventTypes, f as ProtocolError, g as ProtocolErrorType, c as ServerTransportOptions, S as Session, T as Transport, P as TransportOptions, a as TransportStatus } from '../handshake-e428d1c8.js';
export { C as ClientTransport } from '../client-dd5c9dd0.js';
export { S as ServerTransport } from '../server-ebf80863.js';
export { b as OpaqueTransportMessage, O as OpaqueTransportMessageSchema, c as TransportClientId, a as TransportMessage, T as TransportMessageSchema, d as isStreamClose, i as isStreamOpen } from '../index-ea74cdbb.js';
import '../types-3e5768ec.js';

@@ -4,0 +6,0 @@ import '@sinclair/typebox';

import {
ClientTransport,
Connection,
ServerTransport
} from "../chunk-ZUKDZY54.js";
import {
ClientTransport
} from "../chunk-S4DUN7KK.js";
import {
ProtocolError,
ServerTransport,
Session,
Transport
} from "../chunk-VRU4IKRT.js";
} from "../chunk-XM656KMN.js";
import "../chunk-6LCL2ZZF.js";
import {
Connection,
Session
} from "../chunk-2FNLANTJ.js";
import {
OpaqueTransportMessageSchema,
TransportMessageSchema
} from "../chunk-7RUKEUKE.js";
import "../chunk-6LCL2ZZF.js";
import "../chunk-3AW3IXVD.js";
} from "../chunk-ES4XO2XD.js";
import "../chunk-4PVU7J25.js";
export {

@@ -16,0 +22,0 @@ ClientTransport,

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-ca72c9f8.js';
import { T as Transport, C as Connection, S as SessionOptions, a as Session, b as ServiceContext } from '../transport-47af1c81.js';
import { P as PayloadType, R as RiverError, a as Procedure, b as Result, c as RiverUncaughtSchema, d as ProcedureResult } from '../services-f406b3aa.js';
import * as it_pushable from 'it-pushable';
import { P as PartialTransportMessage, O as OpaqueTransportMessage } from '../index-60f03cb7.js';
import { P as PartialTransportMessage, b as OpaqueTransportMessage } from '../index-ea74cdbb.js';
import { T as Transport, C as Connection, h as SessionOptions, S as Session, i as ServiceContext } from '../handshake-e428d1c8.js';
import NodeWs from 'ws';

@@ -10,5 +10,6 @@ import http from 'node:http';

import { W as WsLike } from '../wslike-e0b32dd5.js';
import '../types-3e5768ec.js';
import '../client-dd5c9dd0.js';
import '@sinclair/typebox/value';
import '@opentelemetry/api';
import '../types-3e5768ec.js';

@@ -15,0 +16,0 @@ /**

@@ -5,12 +5,11 @@ import {

pushable
} from "../chunk-XZ6IOBM5.js";
} from "../chunk-KFTGQ3QC.js";
import {
Session,
defaultTransportOptions
} from "../chunk-VRU4IKRT.js";
} from "../chunk-2FNLANTJ.js";
import {
coerceErrorString
} from "../chunk-7RUKEUKE.js";
import "../chunk-6LCL2ZZF.js";
import "../chunk-3AW3IXVD.js";
} from "../chunk-ES4XO2XD.js";
import "../chunk-4PVU7J25.js";

@@ -17,0 +16,0 @@ // util/testHelpers.ts

{
"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.12",
"version": "0.23.13",
"type": "module",

@@ -6,0 +6,0 @@ "exports": {

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet

Sorry, the diff of this file is not supported yet