openclaw-integration.js

#!/usr/bin/env node

/**
 * Skill Evolution Plugin - OpenClaw 集成示例
 * 
 * 这个示例展示了如何将 Skill Evolution Plugin 集成到 OpenClaw 中
 */

const { SkillEvolutionPlugin } = require('../src/index');

// 创建全局插件实例
const evolutionPlugin = new SkillEvolutionPlugin({
  enabled: true,
  logPath: '~/.openclaw/skills',
  threshold: 3
});

/**
 * 模拟 OpenClaw 的 Skill 执行器
 * 
 * 这是伪代码，展示集成思路
 */
class MockSkillExecutor {
  constructor() {
    this.currentSkillName = null;
    this.currentUserRequest = null;
    this.currentSessionId = null;
  }

  /**
   * 执行 Skill
   */
  async executeSkill(skillName, userRequest, steps) {
    console.log(`\n📝 执行 Skill: ${skillName}`);
    console.log(`   用户请求：${userRequest}`);
    console.log('');

    this.currentSkillName = skillName;
    this.currentUserRequest = userRequest;

    // 1. 开始监控
    this.currentSessionId = evolutionPlugin.startMonitoring(skillName, userRequest);

    try {
      // 2. 执行每个步骤
      for (const step of steps) {
        await this.executeTool(step.tool, step.params);
      }

      // 3. 结束监控
      evolutionPlugin.stopMonitoring(this.currentSessionId, 'success');
      console.log('\n✅ Skill 执行完成');
      
    } catch (error) {
      // 执行失败
      evolutionPlugin.stopMonitoring(this.currentSessionId, 'failed');
      console.log(`\n❌ Skill 执行失败：${error.message}`);
      throw error;
    } finally {
      // 清理
      this.currentSessionId = null;
      this.currentSkillName = null;
      this.currentUserRequest = null;
    }
  }

  /**
   * 执行工具调用
   */
  async executeTool(toolName, params) {
    console.log(`   🔧 执行：${toolName}(${JSON.stringify(params)})`);

    // 模拟执行
    const result = await this.mockExecute(toolName, params);

    // 记录工具调用
    evolutionPlugin.recordToolCall(this.currentSessionId, toolName, params, result);

    if (!result.success) {
      throw new Error(result.error || 'Tool execution failed');
    }

    console.log(`      ✓ 成功`);
    return result;
  }

  /**
   * 模拟工具执行（实际应该调用 OpenClaw 的工具）
   */
  async mockExecute(toolName, params) {
    // 模拟延迟
    await new Promise(resolve => setTimeout(resolve, 100));

    // 模拟成功
    if (toolName === 'agent-browser.open') {
      return { success: true };
    }

    if (toolName === 'agent-browser.snapshot') {
      return { 
        success: true, 
        elements: ['@e1', '@e2', '@e5'] 
      };
    }

    if (toolName === 'agent-browser.fill') {
      return { success: true };
    }

    if (toolName === 'agent-browser.click') {
      // 模拟第 3、4、5 次执行时元素找不到的问题
      const executionCount = this.getExecutionCount();
      if (executionCount >= 3 && params.ref === '@e3') {
        return { 
          success: false, 
          error: 'Element not found' 
        };
      }
      return { success: true };
    }

    return { success: true };
  }

  /**
   * 获取执行次数（用于模拟）
   */
  getExecutionCount() {
    const fs = require('fs');
    const path = require('path');
    const homeDir = process.env.HOME || process.env.USERPROFILE;
    const logFile = path.join(homeDir, '.openclaw/skills/agent-browser/.evolution/execution-log.jsonl');
    
    if (!fs.existsSync(logFile)) {
      return 1;
    }

    const content = fs.readFileSync(logFile, 'utf-8');
    const lines = content.trim().split('\n').filter(line => line.trim());
    return lines.length + 1;
  }
}

/**
 * 主函数 - 演示集成
 */
async function main() {
  const chalkImport = require('chalk');
  const chalk = chalkImport.default || chalkImport;

  console.log(chalk.green('═══════════════════════════════════════════════════════════'));
  console.log(chalk.green('  Skill Evolution Plugin - OpenClaw 集成示例'));
  console.log(chalk.green('═══════════════════════════════════════════════════════════'));

  const executor = new MockSkillExecutor();

  // 模拟 5 次 Skill 执行
  const steps = [
    { tool: 'agent-browser.open', params: { url: 'https://example.com/login' } },
    { tool: 'agent-browser.snapshot', params: {} },
    { tool: 'agent-browser.fill', params: { ref: '@e1', text: 'test' } },
    { tool: 'agent-browser.click', params: { ref: '@e3' } }
  ];

  for (let i = 1; i <= 5; i++) {
    console.log(chalk.blue(`\n${'═'.repeat(60)}`));
    console.log(chalk.blue(`第 ${i} 次执行`));
    console.log(chalk.blue('═'.repeat(60)));

    try {
      await executor.executeSkill('agent-browser', '帮我登录 example.com', steps);
    } catch (error) {
      // 忽略错误，继续下一次
    }
  }

  // 生成报告
  console.log(chalk.green('\n═══════════════════════════════════════════════════════════'));
  console.log(chalk.green('  生成进化报告'));
  console.log(chalk.green('═══════════════════════════════════════════════════════════'));

  const report = evolutionPlugin.generateReport('agent-browser');
  console.log(report);

  console.log(chalk.green('集成示例完成！'));
  console.log('');
  console.log(chalk.gray('这个示例展示了如何将 Skill Evolution Plugin 集成到 OpenClaw 的 Skill 执行器中。'));
  console.log(chalk.gray('实际集成时，需要修改 OpenClaw 的 SkillExecutor.js 文件。'));
  console.log('');
  console.log(chalk.gray('详见：integration/README.md'));
}

// 运行示例
main().catch(console.error);