fix(traces): separate entrypoints

Author: jog1t

frontend/src/components/actors/actor-inspector-context.tsx

@@ -3,7 +3,7 @@ import type { Unsubscribe } from "nanoevents";
 import type { UpgradeWebSocketArgs } from "@/actor/router-websocket-endpoints";
 import type { AnyActorInstance, RivetMessageEvent } from "@/mod";
 import type { ToClient } from "@/schemas/actor-inspector/mod";
-import { encodeReadRangeWire } from "@rivetkit/traces";
+import { encodeReadRangeWire } from "@rivetkit/traces/encoding";
 import {
 	CURRENT_VERSION as INSPECTOR_CURRENT_VERSION,
 	TO_CLIENT_VERSIONED as toClient,

frontend/src/components/actors/actor-traces.tsx

@@ -7,6 +7,8 @@
 			"@/*": ["./src/*"],
 			"@rivetkit/workflow-engine": ["../workflow-engine/src/index.ts"],
 			"@rivetkit/traces": ["../traces/src/index.ts"],
+			"@rivetkit/traces/encoding": ["../traces/src/encoding.ts"],
+			"@rivetkit/traces/otlp": ["../traces/src/otlp-entry.ts"],
 			// Used for test fixtures
 			"rivetkit": ["./src/mod.ts"],
 			"rivetkit/utils": ["./src/utils.ts"]

pnpm-lock.yaml

@@ -21,22 +21,32 @@
 				"default": "./dist/tsup/index.cjs"
 			}
 		},
-		"./reader": {
+		"./encoding": {
 			"import": {
-				"types": "./dist/tsup/reader.d.ts",
-				"default": "./dist/tsup/reader.js"
+				"types": "./dist/tsup/encoding.d.ts",
+				"default": "./dist/tsup/encoding.js"
 			},
 			"require": {
-				"types": "./dist/tsup/reader.d.cts",
-				"default": "./dist/tsup/reader.cjs"
+				"types": "./dist/tsup/encoding.d.cts",
+				"default": "./dist/tsup/encoding.cjs"
+			}
+		},
+		"./otlp": {
+			"import": {
+				"types": "./dist/tsup/otlp-entry.d.ts",
+				"default": "./dist/tsup/otlp-entry.js"
+			},
+			"require": {
+				"types": "./dist/tsup/otlp-entry.d.cts",
+				"default": "./dist/tsup/otlp-entry.cjs"
 			}
 		}
 	},
 	"engines": {
 		"node": ">=18.0.0"
 	},
 	"scripts": {
-		"build": "pnpm run compile:bare && tsup src/index.ts src/reader.ts",
+		"build": "pnpm run compile:bare && tsup src/index.ts src/encoding.ts src/otlp-entry.ts",
 		"compile:bare": "tsx scripts/compile-bare.ts compile schemas/v1.bare -o dist/schemas/v1.ts",
 		"check-types": "pnpm run compile:bare && tsc --noEmit",
 		"test": "pnpm run compile:bare && vitest run"

rivetkit-typescript/packages/rivetkit/src/inspector/handler.ts

@@ -0,0 +1,18 @@
+import {
+	CURRENT_VERSION,
+	READ_RANGE_VERSIONED,
+	type ReadRangeWire,
+} from "../schemas/versioned.js";
+
+export type { ReadRangeWire };
+
+export function encodeReadRangeWire(wire: ReadRangeWire): Uint8Array {
+	return READ_RANGE_VERSIONED.serializeWithEmbeddedVersion(
+		wire,
+		CURRENT_VERSION,
+	);
+}
+
+export function decodeReadRangeWire(bytes: Uint8Array): ReadRangeWire {
+	return READ_RANGE_VERSIONED.deserializeWithEmbeddedVersion(bytes);
+}

rivetkit-typescript/packages/rivetkit/tsconfig.json

@@ -1,11 +1,6 @@
 export {
 	createTraces,
 } from "./traces.js";
-export {
-	decodeReadRangeWire,
-	encodeReadRangeWire,
-	readRangeWireToOtlp,
-} from "./read-range.js";
 export type {
 	EndSpanOptions,
 	EventOptions,

rivetkit-typescript/packages/traces/package.json

@@ -0,0 +1,18 @@
+export { readRangeWireToOtlp } from "./read-range.js";
+export {
+	anyValueFromCborBytes,
+	anyValueFromJs,
+	base64FromBytes,
+	hexFromBytes,
+	type OtlpAnyValue,
+	type OtlpExportTraceServiceRequestJson,
+	type OtlpInstrumentationScope,
+	type OtlpKeyValue,
+	type OtlpResource,
+	type OtlpResourceSpans,
+	type OtlpScopeSpans,
+	type OtlpSpan,
+	type OtlpSpanEvent,
+	type OtlpSpanLink,
+	type OtlpSpanStatus,
+} from "./otlp.js";

rivetkit-typescript/packages/traces/src/encoding.ts

@@ -1,7 +1,5 @@
 import { decode as decodeCbor } from "cbor-x";
 import {
-	CURRENT_VERSION,
-	READ_RANGE_VERSIONED,
 	type Attributes,
 	type Chunk,
 	type ReadRangeWire,
@@ -87,17 +85,6 @@ function spanKey(spanId: Uint8Array | SpanId): string {
 	return hexFromBytes(normalizeBytes(spanId));
 }
 
-export function encodeReadRangeWire(wire: ReadRangeWire): Uint8Array {
-	return READ_RANGE_VERSIONED.serializeWithEmbeddedVersion(
-		wire,
-		CURRENT_VERSION,
-	);
-}
-
-export function decodeReadRangeWire(bytes: Uint8Array): ReadRangeWire {
-	return READ_RANGE_VERSIONED.deserializeWithEmbeddedVersion(bytes);
-}
-
 export function readRangeWireToOtlp(
 	wire: ReadRangeWire,
 	resource?: OtlpResource,