From d932bb81d044ef5d746efc6e089d22d8c9b7a6ef Mon Sep 17 00:00:00 2001
From: ywkj <tabvim.dev@gmail.com>
Date: Mon, 20 Apr 2026 07:46:41 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E9=81=A5=E6=B5=8B=E6=94=B9=E7=94=A8=20T?=
 =?UTF-8?q?ELEMETRY=5FENDPOINT=EF=BC=8C=E4=B8=8D=E5=A4=8D=E7=94=A8=20hookU?=
 =?UTF-8?q?rl?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

hookUrl 是 agent 业务回调，不用于 debug。新增独立的 TELEMETRY_ENDPOINT
指向 3202 /api/v1/tasks/telemetry，fire-and-forget 上报执行结果到 Loki。

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
---
 scripts/run.ts | 53 +++++++++++---------------------------------------
 1 file changed, 11 insertions(+), 42 deletions(-)

diff --git a/scripts/run.ts b/scripts/run.ts
index 118bd7e..3009a11 100644
--- a/scripts/run.ts
+++ b/scripts/run.ts
@@ -1,7 +1,6 @@
 #!/usr/bin/env bun
 import type { Command } from '../src/index.ts';
 import { run } from '../src/index.ts';
-import { createSkillClient } from '../src/auth-cli.ts';
 
 const SKILL_NAME = 'my-skill'; // TODO: replace with actual skill name
 
@@ -16,14 +15,14 @@ Config: ~/.openclaw/.env  (CLIENT_KEY)
 `);
 }
 
-async function reportHook(
-  hookUrl: string,
-  hookToken: string | undefined,
-  payload: object,
-): Promise<void> {
-  const headers: Record<string, string> = { 'Content-Type': 'application/json' };
-  if (hookToken) headers['Authorization'] = `Bearer ${hookToken}`;
-  await fetch(hookUrl, { method: 'POST', headers, body: JSON.stringify(payload) });
+function reportTelemetry(payload: object): void {
+  const endpoint = process.env.TELEMETRY_ENDPOINT;
+  if (!endpoint) return;
+  fetch(endpoint, {
+    method: 'POST',
+    headers: { 'Content-Type': 'application/json' },
+    body: JSON.stringify(payload),
+  }).catch(() => {});
 }
 
 async function main(): Promise<void> {
@@ -45,19 +44,6 @@ async function main(): Promise<void> {
   if (positionals.length < 1) { printUsage(); process.exit(1); }
 
   const command = positionals[0] as Command;
-
-  // Exchange CLIENT_KEY for session — gives us hookUrl for telemetry
-  let hookUrl: string | undefined;
-  let hookToken: string | undefined;
-  try {
-    const client = createSkillClient({ dryRun });
-    const session = await client.session();
-    hookUrl = session.hookUrl;
-    hookToken = session.hookToken;
-  } catch {
-    // Auth failure is non-fatal for telemetry; skill still runs
-  }
-
   const startMs = Date.now();
   let result: Awaited<ReturnType<typeof run>>;
 
@@ -65,30 +51,13 @@ async function main(): Promise<void> {
     result = await run(command, positionals.slice(1), dryRun);
   } catch (err) {
     const error = err instanceof Error ? err.message : String(err);
-    const failed = { status: 'failed' as const, command, dryRun, error };
-    console.log(JSON.stringify(failed, null, 2));
-
-    if (hookUrl && !dryRun) {
-      reportHook(hookUrl, hookToken, {
-        skill: SKILL_NAME, command, status: 'failed',
-        durationMs: Date.now() - startMs, error,
-      }).catch(() => {});
-    }
+    console.log(JSON.stringify({ status: 'failed', command, dryRun, error }, null, 2));
+    if (!dryRun) reportTelemetry({ skill: SKILL_NAME, command, status: 'failed', durationMs: Date.now() - startMs, error });
     process.exit(1);
   }
 
   console.log(JSON.stringify(result, null, 2));
-
-  // Fire-and-forget telemetry — never delays output
-  if (hookUrl && !dryRun) {
-    reportHook(hookUrl, hookToken, {
-      skill: SKILL_NAME,
-      command,
-      status: result.status,
-      durationMs: Date.now() - startMs,
-      error: (result as any).error,
-    }).catch(() => {});
-  }
+  if (!dryRun) reportTelemetry({ skill: SKILL_NAME, command, status: result.status, durationMs: Date.now() - startMs, error: (result as any).error });
 }
 
 main().catch((err) => {