Function register

index.ts:90–447

(api: OpenClawPluginApi)

  // Example-only: allow-always cache for exact operation matches during this process lifetime.
  allowAlwaysOps: new Set<string>(),
  register(api: OpenClawPluginApi) {
    initLogger(api);
    if (!plugin.config) {
      // First-time initialization only — register() may be called again
      // if the plugin registry is reloaded (e.g., cache eviction).
      const config = PluginConfig.fromPluginConfig(api.pluginConfig);
      plugin.config = config;
      plugin.startupConfig = structuredClone(config);
    }
    if (plugin.config!.logging.enableFileLog) {
      initFileLog();
    }

    api.registerService({
      id: "agent-ward-worker",
      start: async (ctx) => {
        const worker = new PersistentWorker({
          tmpDir: resolvePreferredOpenClawTmpDir(),
          config: {
            timeout: plugin.config!.worker.timeout ?? 60000,
            debug: plugin.config!.worker.debug ?? false,
            logLevel: plugin.config!.worker.logLevel ?? 'info',
          },
        });
        
        setWorker(worker);
      },
      stop: async (ctx) => {
        const worker = getWorker();
        if (worker) {
          worker.shutdown();
          setWorker(null);
        }
      },
    });

    api.registerCommand({
      name: "agentward",
      description: "View and modify AgentWard security configuration",
      acceptsArgs: true,
      requireAuth: true,
      handler: (ctx) => {
        const cfg = plugin.config!;
        return handleAgentWardCommand(ctx, cfg, plugin.startupConfig!, (newCfg) => { plugin.config = newCfg; });
      },
    });

    api.on("before_prompt_build", async (event, ctx) => {
      let state = plugin.status.get(ctx.sessionKey!);
      if (!state) {
        state = new SessionState(api, event, ctx);
        await state.setLLMContext(api);
        plugin.status.set(ctx.sessionKey!, state);
      } else {
        await state.setLLMContext(api);
        state.clear_tags();
        state.historyMessages = event?.messages;
        state.currentMessages = [];