@effect/rpc
Advanced tools
Comparing version 0.17.1 to 0.18.0
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 @@ /** |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Major refactor
Supply chain riskPackage has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.
Found 1 instance in 1 package
No website
QualityPackage does not have a website.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Environment variable access
Supply chain riskPackage accesses environment variables, which may be a sign of credential stuffing or data theft.
Found 1 instance in 1 package
294543
0
0
109
5177
2
1