Socket
Socket
Sign inDemoInstall

@effect/rpc

Package Overview
Dependencies
Maintainers
3
Versions
253
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@effect/rpc - npm Package Compare versions

Comparing version 0.17.1 to 0.18.0

dist/cjs/Client.js

137

package.json
{
"name": "@effect/rpc",
"version": "0.17.1",
"version": "0.18.0",
"description": "",
"main": "dist/effect-rpc.cjs.js",
"module": "dist/effect-rpc.esm.js",
"publishConfig": {
"access": "public"
},
"license": "MIT",
"repository": {

@@ -14,98 +10,79 @@ "type": "git",

},
"homepage": "https://github.com/effect-ts/rpc",
"preconstruct": {
"entrypoints": [
"*.ts"
],
"distFilenameStrategy": "full",
"exports": {
"importConditionDefaultExport": "default"
}
},
"effect": {
"generateIndex": true,
"includeInternal": true
},
"keywords": [],
"sideEffects": false,
"author": "Effect contributors",
"license": "MIT",
"sideEffects": false,
"devDependencies": {
"@effect/schema": "^0.47.1",
"effect": "2.0.0-next.54"
},
"peerDependencies": {
"@effect/schema": "^0.47.1",
"effect": "2.0.0-next.54"
"@effect/schema": "^0.48.0",
"effect": "2.0.0-next.55"
},
"files": [
"src",
"dist",
"internal",
"Client",
"Error",
"Resolver",
"Router",
"Schema",
"SchemaC",
"Server"
],
"main": "./dist/cjs/index.js",
"module": "./dist/esm/index.js",
"types": "./dist/dts/index.d.ts",
"exports": {
"./package.json": "./package.json",
".": {
"types": "./dist/declarations/src/index.d.ts",
"module": "./dist/effect-rpc.esm.js",
"import": "./dist/effect-rpc.cjs.mjs",
"default": "./dist/effect-rpc.cjs.js"
"types": "./dist/dts/index.d.ts",
"import": "./dist/esm/index.js",
"default": "./dist/cjs/index.js"
},
"./package.json": "./package.json",
"./Client": {
"types": "./dist/declarations/src/Client.d.ts",
"module": "./Client/dist/effect-rpc-Client.esm.js",
"import": "./Client/dist/effect-rpc-Client.cjs.mjs",
"default": "./Client/dist/effect-rpc-Client.cjs.js"
"types": "./dist/dts/Client.d.ts",
"import": "./dist/esm/Client.js",
"default": "./dist/cjs/Client.js"
},
"./Error": {
"types": "./dist/declarations/src/Error.d.ts",
"module": "./Error/dist/effect-rpc-Error.esm.js",
"import": "./Error/dist/effect-rpc-Error.cjs.mjs",
"default": "./Error/dist/effect-rpc-Error.cjs.js"
"types": "./dist/dts/Error.d.ts",
"import": "./dist/esm/Error.js",
"default": "./dist/cjs/Error.js"
},
"./Resolver": {
"types": "./dist/declarations/src/Resolver.d.ts",
"module": "./Resolver/dist/effect-rpc-Resolver.esm.js",
"import": "./Resolver/dist/effect-rpc-Resolver.cjs.mjs",
"default": "./Resolver/dist/effect-rpc-Resolver.cjs.js"
"types": "./dist/dts/Resolver.d.ts",
"import": "./dist/esm/Resolver.js",
"default": "./dist/cjs/Resolver.js"
},
"./Router": {
"types": "./dist/declarations/src/Router.d.ts",
"module": "./Router/dist/effect-rpc-Router.esm.js",
"import": "./Router/dist/effect-rpc-Router.cjs.mjs",
"default": "./Router/dist/effect-rpc-Router.cjs.js"
"types": "./dist/dts/Router.d.ts",
"import": "./dist/esm/Router.js",
"default": "./dist/cjs/Router.js"
},
"./Schema": {
"types": "./dist/declarations/src/Schema.d.ts",
"module": "./Schema/dist/effect-rpc-Schema.esm.js",
"import": "./Schema/dist/effect-rpc-Schema.cjs.mjs",
"default": "./Schema/dist/effect-rpc-Schema.cjs.js"
"types": "./dist/dts/Schema.d.ts",
"import": "./dist/esm/Schema.js",
"default": "./dist/cjs/Schema.js"
},
"./SchemaC": {
"types": "./dist/declarations/src/SchemaC.d.ts",
"module": "./SchemaC/dist/effect-rpc-SchemaC.esm.js",
"import": "./SchemaC/dist/effect-rpc-SchemaC.cjs.mjs",
"default": "./SchemaC/dist/effect-rpc-SchemaC.cjs.js"
"types": "./dist/dts/SchemaC.d.ts",
"import": "./dist/esm/SchemaC.js",
"default": "./dist/cjs/SchemaC.js"
},
"./Server": {
"types": "./dist/declarations/src/Server.d.ts",
"module": "./Server/dist/effect-rpc-Server.esm.js",
"import": "./Server/dist/effect-rpc-Server.cjs.mjs",
"default": "./Server/dist/effect-rpc-Server.cjs.js"
"types": "./dist/dts/Server.d.ts",
"import": "./dist/esm/Server.js",
"default": "./dist/cjs/Server.js"
}
},
"scripts": {
"example": "ts-node --project tsconfig.examples.json",
"lint": "eslint src/**/*.ts test/**/*.ts",
"tc": "tsc --noEmit",
"test": "vitest",
"coverage": "vitest run --coverage"
"typesVersions": {
"*": {
"Client": [
"./dist/dts/Client.d.ts"
],
"Error": [
"./dist/dts/Error.d.ts"
],
"Resolver": [
"./dist/dts/Resolver.d.ts"
],
"Router": [
"./dist/dts/Router.d.ts"
],
"Schema": [
"./dist/dts/Schema.d.ts"
],
"SchemaC": [
"./dist/dts/SchemaC.d.ts"
],
"Server": [
"./dist/dts/Server.d.ts"
]
}
}
}

@@ -5,7 +5,7 @@ /**

import type { Effect } from "effect/Effect"
import type { RpcError } from "./Error"
import * as internal from "./internal/client"
import type { RpcResolver } from "./Resolver"
import type { RpcSchema, RpcService } from "./Schema"
import type { UndecodedRpcResponse } from "./Server"
import type { RpcError } from "./Error.js"
import * as internal from "./internal/client.js"
import type { RpcResolver } from "./Resolver.js"
import type { RpcSchema, RpcService } from "./Schema.js"
import type { UndecodedRpcResponse } from "./Server.js"
/**

@@ -12,0 +12,0 @@ * Represents an RPC method signature.

@@ -7,4 +7,4 @@ /**

import type * as ROA from "effect/ReadonlyArray"
import type { SchemaC } from "./SchemaC"
import { withConstructorTagged } from "./SchemaC"
import type { SchemaC } from "./SchemaC.js"
import { withConstructorTagged } from "./SchemaC.js"

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

/**
* @since 1.0.0
*/
export * as Client from "@effect/rpc/Client"
export * as Client from "./Client.js"

@@ -9,3 +9,3 @@ /**

*/
export * as Error from "@effect/rpc/Error"
export * as Error from "./Error.js"

@@ -15,3 +15,3 @@ /**

*/
export * as Resolver from "@effect/rpc/Resolver"
export * as Resolver from "./Resolver.js"

@@ -21,3 +21,3 @@ /**

*/
export * as Router from "@effect/rpc/Router"
export * as Router from "./Router.js"

@@ -27,3 +27,3 @@ /**

*/
export * as Schema from "@effect/rpc/Schema"
export * as Schema from "./Schema.js"

@@ -33,3 +33,3 @@ /**

*/
export * as SchemaC from "@effect/rpc/SchemaC"
export * as SchemaC from "./SchemaC.js"

@@ -39,2 +39,2 @@ /**

*/
export * as Server from "@effect/rpc/Server"
export * as Server from "./Server.js"

@@ -5,10 +5,10 @@ import type * as Schema from "@effect/schema/Schema"

import { pipe } from "effect/Function"
import type * as client from "../Client"
import { RpcError } from "../Error"
import type { RpcResolver } from "../Resolver"
import type { RpcSchema, RpcService } from "../Schema"
import { hash as schemaHash, RpcServiceErrorId, RpcServiceId } from "../Schema"
import * as codec from "./codec"
import * as resolverInternal from "./resolver"
import * as schemaInternal from "./schema"
import type * as client from "../Client.js"
import { RpcError } from "../Error.js"
import type { RpcResolver } from "../Resolver.js"
import type { RpcSchema, RpcService } from "../Schema.js"
import { hash as schemaHash, RpcServiceErrorId, RpcServiceId } from "../Schema.js"
import * as codec from "./codec.js"
import * as resolverInternal from "./resolver.js"
import * as schemaInternal from "./schema.js"

@@ -15,0 +15,0 @@ const unsafeDecode = <const S extends RpcService.DefinitionWithId>(schemas: S) => {

@@ -5,3 +5,3 @@ import type { ParseOptions } from "@effect/schema/AST"

import * as Either from "effect/Either"
import { RpcDecodeFailure, RpcEncodeFailure } from "../Error"
import { RpcDecodeFailure, RpcEncodeFailure } from "../Error.js"

@@ -8,0 +8,0 @@ /** @internal */

@@ -9,5 +9,5 @@ import * as Schema from "@effect/schema/Schema"

import * as Resolver from "effect/RequestResolver"
import type { RpcError, RpcTransportError } from "../Error"
import type * as resolver from "../Resolver"
import * as Codec from "./codec"
import type { RpcError, RpcTransportError } from "../Error.js"
import type * as resolver from "../Resolver.js"
import * as Codec from "./codec.js"

@@ -22,4 +22,4 @@ const requestProto: Request.Request<any, any> = {

},
[Equal.symbol](this: resolver.RpcRequest, that: resolver.RpcRequest) {
return this.hash === that.hash
[Equal.symbol](this: resolver.RpcRequest, that: Equal.Equal) {
return this.hash === (that as resolver.RpcRequest).hash
}

@@ -26,0 +26,0 @@ }

@@ -6,5 +6,5 @@ import type { Tag } from "effect/Context"

import * as Layer from "effect/Layer"
import type { RpcHandler, RpcHandlers, RpcRouter } from "../Router"
import type { RpcService } from "../Schema"
import { makeUndecodedClient } from "./server"
import type { RpcHandler, RpcHandlers, RpcRouter } from "../Router.js"
import type { RpcService } from "../Schema.js"
import { makeUndecodedClient } from "./server.js"

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

@@ -7,5 +7,5 @@ import * as AST from "@effect/schema/AST"

import * as Option from "effect/Option"
import type { RpcEncodeFailure } from "../Error"
import type * as schema from "../Schema"
import * as Codec from "./codec"
import type { RpcEncodeFailure } from "../Error.js"
import type * as schema from "../Schema.js"
import * as Codec from "./codec.js"

@@ -12,0 +12,0 @@ type JsonArray = ReadonlyArray<Json>

@@ -14,9 +14,9 @@ import * as Schema from "@effect/schema/Schema"

import * as Tracer from "effect/Tracer"
import { type RpcEncodeFailure, type RpcError, RpcNotFound, RpcTransportError } from "../Error"
import type { RpcRequest, RpcResponse } from "../Resolver"
import type { RpcHandler, RpcHandlers, RpcRouter } from "../Router"
import type { RpcRequestSchema, RpcSchema, RpcService } from "../Schema"
import type { RpcUndecodedClient } from "../Server"
import * as codec from "./codec"
import { methodCodecs, methodSchemas, rawClientCodecs } from "./schema"
import { type RpcEncodeFailure, type RpcError, RpcNotFound, RpcTransportError } from "../Error.js"
import type { RpcRequest, RpcResponse } from "../Resolver.js"
import type { RpcHandler, RpcHandlers, RpcRouter } from "../Router.js"
import type { RpcRequestSchema, RpcSchema, RpcService } from "../Schema.js"
import type { RpcUndecodedClient } from "../Server.js"
import * as codec from "./codec.js"
import { methodCodecs, methodSchemas, rawClientCodecs } from "./schema.js"

@@ -181,3 +181,3 @@ const schemaHandlersMap = <H extends RpcHandlers>(

return Effect.map(
Effect.zip(Ref.make(Option.none()), Effect.scope),
Effect.zip(Ref.make(Option.none<Runtime.Runtime<unknown>>()), Effect.scope),
([runtimeRef, scope]) => handler(runtimeRef, scope)

@@ -184,0 +184,0 @@ )

@@ -7,5 +7,5 @@ /**

import type * as Resolver from "effect/RequestResolver"
import type { RpcError, RpcTransportError } from "./Error"
import * as internal from "./internal/resolver"
import type { RpcSchema } from "./Schema"
import type { RpcError, RpcTransportError } from "./Error.js"
import * as internal from "./internal/resolver.js"
import type { RpcSchema } from "./Schema.js"

@@ -12,0 +12,0 @@ /**

@@ -8,5 +8,5 @@ /**

import type { Layer } from "effect/Layer"
import * as internal from "./internal/router"
import type { RpcSchema, RpcService } from "./Schema"
import type { RpcUndecodedClient } from "./Server"
import * as internal from "./internal/router.js"
import type { RpcSchema, RpcService } from "./Schema.js"
import type { RpcUndecodedClient } from "./Server.js"

@@ -13,0 +13,0 @@ /**

@@ -5,5 +5,5 @@ /**

import * as Schema from "@effect/schema/Schema"
import * as internal from "./internal/schema"
import type { Json } from "./internal/schema"
import type { RpcRequest } from "./Resolver"
import * as internal from "./internal/schema.js"
import type { Json } from "./internal/schema.js"
import type { RpcRequest } from "./Resolver.js"

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

@@ -88,7 +88,6 @@ /**

self,
(input) =>
({
_tag: tag,
...input
}) as A
(input) => (({
_tag: tag,
...input
}) as A)
)

@@ -95,0 +94,0 @@ )

@@ -7,7 +7,7 @@ /**

import type { Scope } from "effect/Scope"
import type { RpcDecodeFailure, RpcEncodeFailure } from "./Error"
import * as internal from "./internal/server"
import type { RpcResponse } from "./Resolver"
import type { RpcHandler, RpcHandlers, RpcRouter } from "./Router"
import type { RpcRequestSchema, RpcSchema, RpcService } from "./Schema"
import type { RpcDecodeFailure, RpcEncodeFailure } from "./Error.js"
import * as internal from "./internal/server.js"
import type { RpcResponse } from "./Resolver.js"
import type { RpcHandler, RpcHandlers, RpcRouter } from "./Router.js"
import type { RpcRequestSchema, RpcSchema, RpcService } from "./Schema.js"

@@ -14,0 +14,0 @@ /**

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc