rename: FAMILY_CONVENTIONS → HERMES_AGENT_CONVENTIONS

[小糯]

package.json

@@ -1,6 +1,6 @@
 {
-  "name": "hermes-harness",
-  "version": "0.1.0",
+  "name": "@shazhou/hermes-harness",
+  "version": "0.1.1",
   "description": "Hermes Agent CLI harness tools",
   "type": "module",
   "bin": {

src/commands/models.ts

@@ -1,10 +1,12 @@
 import { readFileSync, writeFileSync, existsSync } from "fs";
+import { execSync } from "child_process";
 import { homedir } from "os";
 import { join } from "path";
 import { parse, stringify } from "yaml";
 
 const CONFIG_PATH = join(homedir(), ".hermes", "config.yaml");
 const ENV_PATH = join(homedir(), ".hermes", ".env");
+const CFG_PROVIDERS_KEY = "HERMES_CUSTOM_PROVIDERS";
 
 // ── Types ──────────────────────────────────────────────────────────────
 
@@ -36,7 +38,7 @@ interface Config {
   [key: string]: unknown;
 }
 
-const AUXILIARY_TASKS = [
+const DEFAULT_AUXILIARY_TASKS = [
   "vision",
   "web_extract",
   "compression",
@@ -47,6 +49,18 @@ const AUXILIARY_TASKS = [
   "approval",
 ];
 
+function getAuxiliaryTasks(): string[] {
+  try {
+    const config = loadConfig();
+    const aux = config.auxiliary || {};
+    const tasks = Object.keys(aux).filter(
+      (k) => typeof aux[k] === "object" && aux[k]?.provider !== undefined
+    );
+    if (tasks.length > 0) return tasks;
+  } catch {}
+  return DEFAULT_AUXILIARY_TASKS;
+}
+
 // ── Helpers ────────────────────────────────────────────────────────────
 
 function loadConfig(): Config {
@@ -60,10 +74,43 @@ function saveConfig(config: Config) {
   writeFileSync(CONFIG_PATH, stringify(config, { lineWidth: 120 }), "utf-8");
 }
 
+/**
+ * Read all available providers from cfg (central registry).
+ * Falls back to config.yaml custom_providers if cfg unavailable.
+ */
+function getCfgProviders(): CustomProvider[] {
+  try {
+    const raw = execSync(`cfg get ${CFG_PROVIDERS_KEY}`, {
+      encoding: "utf-8",
+      timeout: 5000,
+    }).trim();
+    if (!raw) return [];
+    return JSON.parse(raw) as CustomProvider[];
+  } catch {
+    return [];
+  }
+}
+
+/**
+ * Get providers from cfg (authoritative source).
+ * The config.yaml custom_providers is now only a "currently active" slot.
+ */
+function getAllProviders(): CustomProvider[] {
+  const cfgProviders = getCfgProviders();
+  if (cfgProviders.length > 0) return cfgProviders;
+  // Fallback to config.yaml if cfg has nothing
+  const config = loadConfig();
+  return config.custom_providers || [];
+}
+
 function getCustomProviders(config: Config): CustomProvider[] {
   return config.custom_providers || [];
 }
 
+function findProviderFromRegistry(name: string): CustomProvider | undefined {
+  return getAllProviders().find((p) => p.name === name);
+}
+
 function findProvider(
   config: Config,
   name: string
@@ -111,42 +158,41 @@ function getAuthHeaders(provider: CustomProvider): Record<string, string> {
 
 function providers() {
   const config = loadConfig();
-  const customProviders = getCustomProviders(config);
+  const allProviders = getAllProviders();
   const mainProvider = config.model?.provider || "auto";
   const mainModel = config.model?.default || "(not set)";
 
   console.log(`Main: provider=${mainProvider}  model=${mainModel}\n`);
 
-  if (customProviders.length === 0) {
+  if (allProviders.length === 0) {
     console.log("No custom providers configured.");
     return;
   }
 
-  console.log("Custom providers:\n");
-  for (const p of customProviders) {
+  console.log("Custom providers (from cfg):\n");
+  for (const p of allProviders) {
     const active = p.name === mainProvider || `custom:${p.name}` === mainProvider ? " ◀ active" : "";
     console.log(`  ${p.name}${active}`);
     console.log(`    url: ${p.base_url}`);
     if (p.api_mode) console.log(`    mode: ${p.api_mode}`);
   }
-  console.log(`\nTotal: ${customProviders.length}`);
+  console.log(`\nTotal: ${allProviders.length}`);
 }
 
 // ── list ────────────────────────────────────────────────────────────────
 
 async function list(providerName?: string) {
-  const config = loadConfig();
-  const customProviders = getCustomProviders(config);
+  const allProviders = getAllProviders();
 
   const targets: CustomProvider[] = providerName
-    ? customProviders.filter((p) => p.name === providerName)
-    : customProviders;
+    ? allProviders.filter((p) => p.name === providerName)
+    : allProviders;
 
   if (targets.length === 0) {
     if (providerName) {
       console.error(`Provider not found: ${providerName}`);
       console.error(
-        `Available: ${customProviders.map((p) => p.name).join(", ")}`
+        `Available: ${allProviders.map((p) => p.name).join(", ")}`
       );
     } else {
       console.log("No custom providers configured.");
@@ -208,12 +254,11 @@ async function list(providerName?: string) {
 // ── test ────────────────────────────────────────────────────────────────
 
 async function test(providerName?: string) {
-  const config = loadConfig();
-  const customProviders = getCustomProviders(config);
+  const allProviders = getAllProviders();
 
   const targets: CustomProvider[] = providerName
-    ? customProviders.filter((p) => p.name === providerName)
-    : customProviders;
+    ? allProviders.filter((p) => p.name === providerName)
+    : allProviders;
 
   if (targets.length === 0) {
     if (providerName) {
@@ -299,32 +344,74 @@ function switchConfig(opts: SwitchOptions) {
     // Switch auxiliary tasks
     if (!config.auxiliary) config.auxiliary = {} as Record<string, AuxiliaryEntry>;
 
+    // Look up provider from cfg registry to get base_url & api_key
+    const registryProvider = findProviderFromRegistry(opts.provider);
+    const providerValue = registryProvider ? `custom:${registryProvider.name}` : opts.provider;
+
+    // Ensure custom_providers in config.yaml contains this provider
+    if (registryProvider) {
+      if (!config.custom_providers) config.custom_providers = [];
+      const existing = config.custom_providers.find((p) => p.name === registryProvider.name);
+      if (!existing) {
+        config.custom_providers.push(registryProvider);
+      }
+    }
+
     for (const task of opts.auxTasks) {
       if (!config.auxiliary[task]) {
         config.auxiliary[task] = { provider: "", model: "", timeout: 30 };
       }
-      config.auxiliary[task].provider = opts.provider;
+      config.auxiliary[task].provider = providerValue;
+      if (registryProvider) {
+        config.auxiliary[task].base_url = registryProvider.base_url;
+        const apiKey = getProviderApiKey(registryProvider);
+        if (apiKey) config.auxiliary[task].api_key = apiKey;
+      }
       if (opts.model) {
         config.auxiliary[task].model = opts.model;
       }
-      console.log(`  auxiliary.${task} → provider=${opts.provider}${opts.model ? ` model=${opts.model}` : ""}`);
+      console.log(`  auxiliary.${task} → provider=${providerValue}${opts.model ? ` model=${opts.model}` : ""}`);
     }
   } else {
-    // Switch main provider
-    const providerValue = findProvider(config, opts.provider)
-      ? `custom:${opts.provider}`
-      : opts.provider;
+    // Switch main provider — look up from cfg registry
+    const registryProvider = findProviderFromRegistry(opts.provider);
     
+    if (registryProvider) {
+      // Write this provider into config.yaml custom_providers (replace all)
+      config.custom_providers = [registryProvider];
+      const providerValue = `custom:${registryProvider.name}`;
       if (!config.model) config.model = {};
       config.model.provider = providerValue;
       if (opts.model) {
         config.model.default = opts.model;
       }
       console.log(`  main → provider=${providerValue}${opts.model ? ` model=${opts.model}` : ""}`);
+      console.log(`  config.yaml custom_providers updated with ${registryProvider.name}`);
+    } else {
+      // Standard provider (openrouter, anthropic, etc.)
+      if (!config.model) config.model = {};
+      config.model.provider = opts.provider;
+      if (opts.model) {
+        config.model.default = opts.model;
+      }
+      // Clear custom_providers since switching to standard
+      delete config.custom_providers;
+      console.log(`  main → provider=${opts.provider}${opts.model ? ` model=${opts.model}` : ""}`);
+    }
   }
 
   saveConfig(config);
-  console.log("\nConfig saved. New sessions will use the updated settings.");
+
+  // Restart gateway
+  try {
+    execSync("systemctl --user restart hermes-gateway 2>/dev/null || true", {
+      encoding: "utf-8",
+      timeout: 10000,
+    });
+    console.log("\nConfig saved & gateway restarted.");
+  } catch {
+    console.log("\nConfig saved. Restart gateway manually to apply.");
+  }
 }
 
 async function switchTelegram(opts: SwitchOptions) {
@@ -386,16 +473,19 @@ async function switchTelegram(opts: SwitchOptions) {
   if (result.ok) {
     console.log(`Sent: ${command}`);
     console.log(opts.global ? "Persistent change (--global)." : "Current session only.");
-    // Clean up the command message
+    // Clean up the command message after a delay so hermes can process it
     if (result.result?.message_id) {
+      const msgId = result.result.message_id;
+      setTimeout(async () => {
         await fetch(`https://api.telegram.org/bot${token}/deleteMessage`, {
           method: "POST",
           headers: { "Content-Type": "application/json" },
           body: JSON.stringify({
             chat_id: chatId,
-          message_id: result.result.message_id,
+            message_id: msgId,
           }),
         }).catch(() => {});
+      }, 3000);
     }
   } else {
     console.error(`Telegram API error: ${result.description}`);
@@ -476,9 +566,10 @@ export async function models(args: string[]) {
           i++;
         } else if (args[i] === "--aux" && i + 1 < args.length) {
           const task = args[i + 1];
-          if (!AUXILIARY_TASKS.includes(task)) {
+      const knownTasks = getAuxiliaryTasks();
+      if (!knownTasks.includes(task)) {
         console.error(`Unknown auxiliary task: ${task}`);
-            console.error(`Available: ${AUXILIARY_TASKS.join(", ")}`);
+        console.error(`Available: ${knownTasks.join(", ")}`);
         process.exit(1);
       }
           auxTasks.push(task);

src/commands/personality.ts

@@ -3,7 +3,9 @@ import { homedir } from "os";
 import { join } from "path";
 import { parse, stringify } from "yaml";
 
-const CONFIG_PATH = join(homedir(), ".hermes", "config.yaml");
+const HERMES_HOME = process.env.HERMES_HOME || join(homedir(), ".hermes");
+const CONFIG_PATH = join(HERMES_HOME, "config.yaml");
+const SOUL_PATH = join(HERMES_HOME, "SOUL.md");
 
 interface Config {
   agent?: {
@@ -51,6 +53,30 @@ function getPreview(value: string | PersonalityDict): string {
   return value.description || (value.system_prompt || "").slice(0, 60) + "...";
 }
 
+// --- SOUL.md management ---
+
+function loadConventions(): string {
+  try {
+    const { execSync } = require("child_process");
+    const result = execSync("cfg get HERMES_AGENT_CONVENTIONS", {
+      encoding: "utf-8",
+      timeout: 5000,
+      stdio: ["pipe", "pipe", "pipe"],
+    }).trim();
+    return result || "";
+  } catch {
+    return "";
+  }
+}
+
+function writeSoulMd(personalityPrompt: string) {
+  const conventions = loadConventions();
+  const parts = [personalityPrompt];
+  if (conventions) parts.push(conventions);
+  const content = parts.filter(Boolean).join("\n\n");
+  writeFileSync(SOUL_PATH, content + "\n", "utf-8");
+}
+
 // --- Actions ---
 
 function list() {
@@ -126,6 +152,7 @@ function switchLocal(name: string) {
     if (!config.agent) config.agent = {};
     config.agent.system_prompt = "";
     saveConfig(config);
+    writeSoulMd("");
     console.log("Personality cleared.");
     return;
   }
@@ -140,7 +167,9 @@ function switchLocal(name: string) {
   if (!config.agent) config.agent = {};
   config.agent.system_prompt = prompt;
   saveConfig(config);
+  writeSoulMd(prompt);
   console.log(`Switched to: ${name}`);
+  console.log("SOUL.md updated.");
 }
 
 async function switchTelegram(name: string) {