Merge pull request #25 from comet-ml/vincentkoc-code/opik-created-from

Add created_from metadata to OpenClaw traces

Author: jverre

src/service.test.ts

@@ -291,6 +291,7 @@ describe("opik service", () => {
           threadId: "session-1",
           input: expect.objectContaining({ prompt: "Hello", systemPrompt: "You are helpful" }),
           metadata: expect.objectContaining({
+            created_from: "openclaw",
             provider: "openai",
             model: "gpt-4",
             channel: "telegram",
@@ -1571,6 +1572,7 @@ describe("opik service", () => {
 
       expect(metadata.model).toBe("gpt-4");
       expect(metadata.provider).toBe("openai");
+      expect(metadata.created_from).toBe("openclaw");
       expect(metadata.channel).toBe("discord");
       expect(metadata.channelId).toBe("discord");
       expect(metadata.trigger).toBe("cron");

src/service.ts

@@ -17,6 +17,7 @@ import {
   DEFAULT_STALE_SWEEP_INTERVAL_MS,
   DEFAULT_STALE_TRACE_TIMEOUT_MS,
   MAX_FLUSH_RETRY_DELAY_MS,
+  OPIK_CREATED_FROM,
   OPIK_PLUGIN_ID,
 } from "./service/constants.js";
 import {
@@ -258,6 +259,7 @@ export function createOpikService(
 
     const agentEnd = active.agentEnd;
     const metadata: Record<string, unknown> = {
+      created_from: OPIK_CREATED_FROM,
       ...active.costMeta,
       success: agentEnd?.success,
       durationMs: agentEnd?.durationMs,

src/service/constants.ts

@@ -4,6 +4,7 @@ export const DEFAULT_FLUSH_RETRY_COUNT = 2;
 export const DEFAULT_FLUSH_RETRY_BASE_DELAY_MS = 250;
 export const MAX_FLUSH_RETRY_DELAY_MS = 5000;
 export const OPIK_PLUGIN_ID = "opik-openclaw";
+export const OPIK_CREATED_FROM = "openclaw";
 
 export const LOCAL_ATTACHMENT_UPLOAD_MAGIC_ID = "BEMinIO";
 export const ATTACHMENT_UPLOAD_PART_SIZE_BYTES = 8 * 1024 * 1024;

src/service/hooks/llm.ts

@@ -1,6 +1,7 @@
 import type { OpenClawPluginApi } from "openclaw/plugin-sdk";
 import type { Opik, Span, Trace } from "opik";
 import type { ActiveTrace } from "../../types.js";
+import { OPIK_CREATED_FROM } from "../constants.js";
 import {
   mapUsageToOpikTokens,
   normalizeProvider,
@@ -63,6 +64,7 @@ export function registerLlmHooks(deps: LlmHooksDeps): void {
         threadId: sessionKey,
         input: sanitizedTraceInput,
         metadata: {
+          created_from: OPIK_CREATED_FROM,
           provider: normalizedProvider,
           model: event.model,
           sessionId: event.sessionId,