@effect/rpc - npm Package Compare versions

Comparing version 0.3.0 to 0.3.1

internal/client.js

@@ -8,3 +8,2 @@ "use strict";
 var Effect = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Effect"));
-var Tracer = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Tracer"));
 var _Error = /*#__PURE__*/require("@effect/rpc/Error");
@@ -63,3 +62,3 @@ var _Resolver = /*#__PURE__*/require("@effect/rpc/Resolver");
       const hash = resolverInternal.requestHash(method, input, spanPrefix);
-      return Tracer.useSpan(`${spanPrefix}.${method}`, span => Effect.catchAll(e => Effect.flatMap(parseError(e), Effect.fail))(Effect.flatMap(parseOutput)(Effect.flatMap(input => Effect.request(resolverInternal.RpcRequest({
+      return Effect.useSpan(`${spanPrefix}.${method}`, span => Effect.catchAll(e => Effect.flatMap(parseError(e), Effect.fail))(Effect.flatMap(parseOutput)(Effect.flatMap(input => Effect.request(resolverInternal.RpcRequest({
         payload: {
@@ -78,3 +77,3 @@ _tag: method,
   const hash = resolverInternal.requestHash(method, undefined, spanPrefix);
-  return Tracer.useSpan(`${spanPrefix}.${method}`, span => Effect.catchAll(e => Effect.flatMap(parseError(e), Effect.fail))(Effect.flatMap(parseOutput)(Effect.request(resolverInternal.RpcRequest({
+  return Effect.useSpan(`${spanPrefix}.${method}`, span => Effect.catchAll(e => Effect.flatMap(parseError(e), Effect.fail))(Effect.flatMap(parseOutput)(Effect.request(resolverInternal.RpcRequest({
     payload: {
@@ -81,0 +80,0 @@ _tag: method,

internal/server.js

@@ -7,2 +7,3 @@ "use strict";
 exports.router = exports.makeUndecodedClient = exports.handlerRaw = exports.handler = exports.handleSingleWithSchema = exports.handleSingle = void 0;
+var Context = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Context"));
 var Either = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Either"));
@@ -14,3 +15,2 @@ var Option = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/data/Option"));
 var _Scope = /*#__PURE__*/require("@effect/io/Scope");
-var Tracer = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/io/Tracer"));
 var _Error = /*#__PURE__*/require("@effect/rpc/Error");
@@ -39,3 +39,3 @@ var codec = /*#__PURE__*/_interopRequireWildcard( /*#__PURE__*/require("@effect/rpc/internal/codec"));
   const hasSetup = ("__setup" in router.handlers);
-  const handler = (contextRef, scope) => request => Tracer.withSpan(`${router.options.spanPrefix}.${request._tag}`, {
+  const handler = (contextRef, scope) => request => Effect.withSpan(`${router.options.spanPrefix}.${request._tag}`, {
     parent: {
@@ -45,3 +45,4 @@ _tag: "ExternalSpan",
       spanId: request.spanId,
-      traceId: request.traceId
+      traceId: request.traceId,
+      context: Context.empty()
     }
@@ -141,3 +142,3 @@ })(Either.match(error => Effect.succeed({
       ...acc,
-      [method]: Tracer.withSpan(`${options.spanPrefix}.undecoded.${method}`)(Effect.flatMap(codec.encode(schema.output))(definition))
+      [method]: Effect.withSpan(`${options.spanPrefix}.undecoded.${method}`)(Effect.flatMap(codec.encode(schema.output))(definition))
     };
@@ -149,3 +150,3 @@ }
     ...acc,
-    [method]: input => Tracer.withSpan(`${options.spanPrefix}.undecoded.${method}`)(Effect.flatMap(encodeOutput)(Effect.flatMap(definition)(decodeInput(input))))
+    [method]: input => Effect.withSpan(`${options.spanPrefix}.undecoded.${method}`)(Effect.flatMap(encodeOutput)(Effect.flatMap(definition)(decodeInput(input))))
   };
@@ -152,0 +153,0 @@ }, {});

package.json

 {
   "name": "@effect/rpc",
-  "version": "0.3.0",
+  "version": "0.3.1",
   "license": "MIT",
@@ -10,5 +10,5 @@ "repository": {
   "dependencies": {
-    "@effect/data": "^0.12.7",
-    "@effect/io": "^0.26.0",
-    "@effect/schema": "^0.20.2"
+    "@effect/data": "^0.12.10",
+    "@effect/io": "^0.29.2",
+    "@effect/schema": "^0.23.0"
   },
@@ -15,0 +15,0 @@ "publishConfig": {

src/internal/client.ts

 import { pipe } from "@effect/data/Function"
 import * as Effect from "@effect/io/Effect"
-import * as Tracer from "@effect/io/Tracer"
 import type * as client from "@effect/rpc/Client"
@@ -163,3 +162,3 @@ import { RpcError } from "@effect/rpc/Error"
       const hash = resolverInternal.requestHash(method, input, spanPrefix)
-      return Tracer.useSpan(`${spanPrefix}.${method}`, (span) =>
+      return Effect.useSpan(`${spanPrefix}.${method}`, (span) =>
         pipe(
@@ -192,3 +191,3 @@ encodeInput(input),
 
-  return Tracer.useSpan(`${spanPrefix}.${method}`, (span) =>
+  return Effect.useSpan(`${spanPrefix}.${method}`, (span) =>
     pipe(
@@ -195,0 +194,0 @@ Effect.request(

src/internal/server.ts

@@ -1,2 +0,2 @@
-import type { Context } from "@effect/data/Context"
+import * as Context from "@effect/data/Context"
 import * as Either from "@effect/data/Either"
@@ -75,3 +75,3 @@ import { pipe } from "@effect/data/Function"
   const handler =
-    (contextRef?: Ref.Ref<Option.Option<Context<unknown>>>, scope?: Scope) =>
+    (contextRef?: Ref.Ref<Option.Option<Context.Context<unknown>>>, scope?: Scope) =>
     (request: RpcRequest.Payload) =>
@@ -159,3 +159,3 @@ pipe(
         ),
-        Tracer.withSpan(`${router.options.spanPrefix}.${request._tag}`, {
+        Effect.withSpan(`${router.options.spanPrefix}.${request._tag}`, {
           parent: {
@@ -166,2 +166,3 @@ _tag: "ExternalSpan",
             traceId: request.traceId,
+            context: Context.empty(),
           },
@@ -341,3 +342,3 @@ }),
             Effect.flatMap(codec.encode(schema.output)),
-            Tracer.withSpan(`${options.spanPrefix}.undecoded.${method}`),
+            Effect.withSpan(`${options.spanPrefix}.undecoded.${method}`),
           ),
@@ -357,3 +358,3 @@ }
             Effect.flatMap(encodeOutput),
-            Tracer.withSpan(`${options.spanPrefix}.undecoded.${method}`),
+            Effect.withSpan(`${options.spanPrefix}.undecoded.${method}`),
           ),
@@ -360,0 +361,0 @@ }

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

Worsened metrics

Total package byte prevSize

272174

decreased by-0.01%

Dependency changes

• + Added@effect/io@0.29.5(transitive)

• + Added@effect/schema@0.23.0(transitive)

• - Removed@effect/io@0.26.2(transitive)

• - Removed@effect/schema@0.20.3(transitive)

• Updated@effect/data@^0.12.10

• Updated@effect/io@^0.29.2

• Updated@effect/schema@^0.23.0