feat(BullMQOtel): rename Otel to BullMQOtel and add devDependencies

package.json

@@ -26,18 +26,20 @@
   },
   "homepage": "https://github.com/taskforcesh/bullmq-otel#readme",
   "dependencies": {
+    "@opentelemetry/api": "^1.9.0",
+    "bullmq": "^5.12.12",
+    "typedoc": "^0.26.6",
+    "typescript": "^5.5.4"
+  },
+  "devDependencies": {
     "@commitlint/cli": "^19.4.1",
     "@commitlint/config-conventional": "^19.4.1",
-    "@opentelemetry/api": "^1.9.0",
     "@semantic-release/changelog": "^6.0.3",
     "@semantic-release/commit-analyzer": "^13.0.0",
     "@semantic-release/git": "^10.0.1",
     "@semantic-release/github": "^10.1.7",
     "@semantic-release/npm": "^12.0.1",
-    "@semantic-release/release-notes-generator": "^14.0.1",
-    "bullmq": "^5.12.12",
-    "typedoc": "^0.26.6",
-    "typescript": "^5.5.4"
+    "@semantic-release/release-notes-generator": "^14.0.1"
   },
   "config": {
     "commitizen": {

src/bullMQOtel.ts

@@ -0,0 +1,49 @@
+import { TraceAPI, trace as OtelTrace, PropagationAPI, ContextAPI, context, propagation, Context as OtelContext, Span as OtelSpan } from '@opentelemetry/api';
+import { Carrier, ContextManager, Telemetry, Trace, Tracer } from 'bullmq';
+
+class OTelContextManager implements ContextManager<OtelContext> {
+    private contextAPI: ContextAPI = context;
+
+    getMetadata(ctx: OtelContext) {
+        const metadata: Carrier = {};
+        propagation.inject(ctx, metadata);
+        return metadata;
+    }
+
+    fromMetadata(activeCtx: OtelContext, metadata: Record<string, string>) {
+        const ctx = propagation.extract(activeCtx, metadata);
+        return ctx;
+    }
+
+    with<A extends (...args: any[]) => any>(ctx: OtelContext, fn: A): ReturnType<A> {
+        return this.contextAPI.with(ctx, fn);
+    }
+
+    active(): OtelContext {
+        return this.contextAPI.active();
+    }
+}
+
+class OTelTrace implements Trace<OtelSpan> {
+    getTracer(name: string, version?: string): Tracer {
+        return OtelTrace.getTracer(name, version);
+    }
+
+    setSpan(ctx: OtelContext, span: OtelSpan): OtelContext {
+        return OtelTrace.setSpan(ctx, span);
+    }
+}
+
+export class BullMQOtel implements Telemetry<OtelContext> {
+    trace: OTelTrace;
+    contextManager: OTelContextManager;
+    tracerName: string;
+    propagation: PropagationAPI;
+
+    constructor(tracerName: string) {
+        this.trace = new OTelTrace();
+        this.contextManager = new OTelContextManager();
+        this.tracerName = tracerName;
+        this.propagation = propagation;
+    }
+};

src/index.ts

@@ -1 +1 @@
-export * from './otel';
+export * from './bullMQOtel';