Compare commits
2 Commits
feat/fabri
...
353e19c3ec
| Author | SHA1 | Date | |
|---|---|---|---|
| 353e19c3ec | |||
|
|
108963d1f6 |
@@ -1,85 +0,0 @@
|
|||||||
/**
|
|
||||||
* Inject a "start the chat workflow" hint into the agent's system prompt
|
|
||||||
* when this turn was triggered by a message in a fabric channel.
|
|
||||||
*
|
|
||||||
* Two cases:
|
|
||||||
* - no prior chat journal for this (agent, channel) → suggest
|
|
||||||
* `workflow_start chat` (fresh).
|
|
||||||
* - mapping exists → suggest `workflow_start chat from <journalId>`
|
|
||||||
* so the conversation continues in the same linear journal.
|
|
||||||
*
|
|
||||||
* The (channel → journal) mapping is owned by Meridian and exposed via
|
|
||||||
* globalThis.__meridian.getChatJournalForChannel. Meridian writes the
|
|
||||||
* entry the first time the agent starts a chat workflow on a channel
|
|
||||||
* with no `from` argument.
|
|
||||||
*
|
|
||||||
* TODO(phase-2): once Fabric.OpenclawPlugin exposes per-channel type
|
|
||||||
* info (DM / group / triage) via a cross-plugin API, narrow this hook
|
|
||||||
* to xType === 'dm' only. Today we inject for any fabric channel — chat
|
|
||||||
* workflow itself is a no-op outside DMs, but the suggestion is noise.
|
|
||||||
*/
|
|
||||||
const _G = globalThis as Record<string, unknown>;
|
|
||||||
const DEDUP_KEY = '_prismFacetFabricChatDedup';
|
|
||||||
|
|
||||||
interface MeridianBridge {
|
|
||||||
getChatJournalForChannel?: (agentId: string, channelId: string) => Promise<string | null>;
|
|
||||||
}
|
|
||||||
|
|
||||||
interface PromptCtx {
|
|
||||||
agentId?: string;
|
|
||||||
channelId?: string;
|
|
||||||
messageProvider?: string;
|
|
||||||
}
|
|
||||||
|
|
||||||
export function registerFabricChatInjector(api: {
|
|
||||||
on(hook: string, handler: (...args: any[]) => any): void;
|
|
||||||
logger: { info(msg: string): void; warn(msg: string): void };
|
|
||||||
}): void {
|
|
||||||
if (!(_G[DEDUP_KEY] instanceof WeakSet)) _G[DEDUP_KEY] = new WeakSet<object>();
|
|
||||||
const dedup = _G[DEDUP_KEY] as WeakSet<object>;
|
|
||||||
|
|
||||||
api.on('before_prompt_build', async (event: unknown, ctx: PromptCtx) => {
|
|
||||||
if (dedup.has(event as object)) return;
|
|
||||||
dedup.add(event as object);
|
|
||||||
|
|
||||||
const agentId = ctx.agentId || '';
|
|
||||||
const channelId = (ctx.channelId || '').trim();
|
|
||||||
const provider = (ctx.messageProvider || '').toLowerCase();
|
|
||||||
if (!agentId || !channelId) return;
|
|
||||||
if (provider && provider !== 'fabric') return;
|
|
||||||
// Empty provider also accepted — gateway sometimes omits the field
|
|
||||||
// even when the trigger was a fabric channel; channelId presence is
|
|
||||||
// the load-bearing signal.
|
|
||||||
|
|
||||||
let journalId: string | null = null;
|
|
||||||
const meridian = _G['__meridian'] as MeridianBridge | undefined;
|
|
||||||
if (typeof meridian?.getChatJournalForChannel === 'function') {
|
|
||||||
try {
|
|
||||||
journalId = await meridian.getChatJournalForChannel(agentId, channelId);
|
|
||||||
} catch (err) {
|
|
||||||
api.logger.warn(
|
|
||||||
`[prism-facet] fabric-chat-injector: meridian lookup failed for ` +
|
|
||||||
`agent=${agentId} channel=${channelId}: ${String(err)}`,
|
|
||||||
);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
const cmd = journalId
|
|
||||||
? `\`workflow_start\` with \`workflow="chat"\` and \`from="${journalId}"\``
|
|
||||||
: `\`workflow_start\` with \`workflow="chat"\``;
|
|
||||||
|
|
||||||
const continuationLine = journalId
|
|
||||||
? `This channel already has an open chat journal (\`${journalId}\`). Resume it with the \`from\` argument so the conversation history stays in one file.`
|
|
||||||
: `No prior chat journal exists for this channel yet — Meridian will create a fresh one and remember the channel→journal mapping for future turns.`;
|
|
||||||
|
|
||||||
const segment =
|
|
||||||
`# Chat channel context\n` +
|
|
||||||
`\n` +
|
|
||||||
`This turn was triggered by a message in a fabric channel (\`${channelId}\`).\n` +
|
|
||||||
`${continuationLine}\n` +
|
|
||||||
`\n` +
|
|
||||||
`**Next action:** call ${cmd} to enter the chat workflow before doing anything else.\n`;
|
|
||||||
|
|
||||||
return { appendSystemContext: segment };
|
|
||||||
});
|
|
||||||
}
|
|
||||||
@@ -2,7 +2,6 @@ import path from "node:path";
|
|||||||
import { loadRouters } from "./core/router-loader.js";
|
import { loadRouters } from "./core/router-loader.js";
|
||||||
import { initRuleStore } from "./core/rule-store.js";
|
import { initRuleStore } from "./core/rule-store.js";
|
||||||
import { registerBeforePromptBuild } from "./hooks/before-prompt-build.js";
|
import { registerBeforePromptBuild } from "./hooks/before-prompt-build.js";
|
||||||
import { registerFabricChatInjector } from "./hooks/fabric-chat-injector.js";
|
|
||||||
import { registerPromptRulesTool } from "./tools/prompt-rules.js";
|
import { registerPromptRulesTool } from "./tools/prompt-rules.js";
|
||||||
|
|
||||||
interface PluginConfig {
|
interface PluginConfig {
|
||||||
@@ -58,7 +57,6 @@ export default {
|
|||||||
|
|
||||||
// Agent session hooks: register every time (dedup inside handler)
|
// Agent session hooks: register every time (dedup inside handler)
|
||||||
registerBeforePromptBuild(api);
|
registerBeforePromptBuild(api);
|
||||||
registerFabricChatInjector(api);
|
|
||||||
|
|
||||||
// Tools
|
// Tools
|
||||||
registerPromptRulesTool(api, routersDir);
|
registerPromptRulesTool(api, routersDir);
|
||||||
|
|||||||
@@ -1,31 +0,0 @@
|
|||||||
# Hangman-Lab Site Convention — Shell Execution
|
|
||||||
|
|
||||||
This claw (sim or prod) keeps Hangman-Lab site binaries at `~/.openclaw/bin/`
|
|
||||||
and **does not** symlink them into `/usr/local/bin`. Your shell tool's PATH
|
|
||||||
does not include them by default, so calling them with the codex built-in
|
|
||||||
shell yields `command not found`.
|
|
||||||
|
|
||||||
**Rule:** any command that invokes one of these binaries MUST be run through
|
|
||||||
the `pcexec` tool, not the codex built-in shell:
|
|
||||||
|
|
||||||
- `hf` (HarborForge CLI)
|
|
||||||
- `secret-mgr` (per-agent secret store)
|
|
||||||
- `ego-mgr` (per-agent identity store; reads `role`, `position`, `default-username`, etc.)
|
|
||||||
- `fabric-register` (Fabric account provisioning)
|
|
||||||
- `pcguard` (PaddedCell guard)
|
|
||||||
- `lock-mgr`
|
|
||||||
- `tea`
|
|
||||||
|
|
||||||
`pcexec` injects `~/.openclaw/bin` into PATH and also wires the
|
|
||||||
`AGENT_ID`, `AGENT_WORKSPACE`, and `AGENT_VERIFY` env vars that
|
|
||||||
`secret-mgr` / `ego-mgr` need to authenticate as the calling agent.
|
|
||||||
|
|
||||||
## Examples
|
|
||||||
|
|
||||||
- ✅ Call the `pcexec` tool with `command: "hf calendar show --json"`
|
|
||||||
- ✅ Call the `pcexec` tool with `command: "HFT=$(secret-mgr get-secret --key hf-token); hf task list --token \"$HFT\" --json"` (the whole pipeline goes in one `pcexec` call)
|
|
||||||
- ❌ Sending `hf calendar show` to the codex built-in shell → `command not found`
|
|
||||||
|
|
||||||
If a workflow's `Procedure` shows a raw shell snippet involving these CLIs,
|
|
||||||
pass the **whole snippet** as a single `command:` argument to `pcexec` —
|
|
||||||
don't split into multiple non-pcexec calls.
|
|
||||||
@@ -1,11 +0,0 @@
|
|||||||
/**
|
|
||||||
* `always` router — resolves to the constant key `"always"` for every
|
|
||||||
* agent. Pair with a rule like `always:always → <some-prompt.md>` to
|
|
||||||
* inject a prompt fragment into every agent's system prompt
|
|
||||||
* unconditionally (no ego / role / position lookup needed).
|
|
||||||
*/
|
|
||||||
import type { RouterContext } from "../core/router-loader.js";
|
|
||||||
|
|
||||||
export function resolve(_ctx: RouterContext): string {
|
|
||||||
return "always";
|
|
||||||
}
|
|
||||||
@@ -1,3 +0,0 @@
|
|||||||
{
|
|
||||||
"always:always": "/root/.openclaw/plugins/prism-facet/prompts/pcexec-convention.md"
|
|
||||||
}
|
|
||||||
Reference in New Issue
Block a user