Upload 2 files

start-openclaw.sh

@@ -0,0 +1,184 @@
+#!/bin/bash
+# OpenClaw 主启动脚本
+# 功能：恢复配置 → 生成配置文件 → 启动服务
+
+set -e  # 遇到错误立即退出
+
+# 配置环境
+OPENCLAW_DIR="/root/.openclaw"
+CONFIG_FILE="$OPENCLAW_DIR/openclaw.json"
+SYNC_SCRIPT="/usr/local/bin/sync.py"
+LOG_FILE="/var/log/openclaw-startup.log"
+
+# 日志函数
+log() {
+    echo "[$(date '+%Y-%m-%d %H:%M:%S')] $1" >> "$LOG_FILE"
+    echo "$1"
+}
+
+# 错误处理函数
+error_exit() {
+    log "错误: $1"
+    exit 1
+}
+
+# 确保目录存在
+ensure_directories() {
+    log "创建必要的目录结构..."
+    mkdir -p "$OPENCLAW_DIR"
+    mkdir -p "$OPENCLAW_DIR/agents/main/agent"
+    mkdir -p "$OPENCLAW_DIR/agents/main/sessions"
+    mkdir -p "$OPENCLAW_DIR/credentials"
+    mkdir -p "$(dirname "$LOG_FILE")"
+}
+
+# 从环境变量生成 OpenClaw 配置文件[6,7](@ref)
+generate_config() {
+    log "生成 OpenClaw 配置文件..."
+    
+    # 获取环境变量，设置默认值
+    local PORT="${PORT:-18789}"
+    local GATEWAY_PASSWORD="${OPENCLAW_GATEWAY_PASSWORD:-openclaw}"
+    local NVIDIA_API_KEY="${NVAPI_KEY}"
+    local MODEL_ID="${MODEL_ID:-moonshotai/kimi-k2.5}"
+    
+    if [ -z "$NVIDIA_API_KEY" ]; then
+        log "警告: NVAPI_KEY 环境变量未设置，NVIDIA 模型将不可用"
+    fi
+    
+    # 创建配置文件
+    cat > "$CONFIG_FILE" << EOF
+{
+  "gateway": {
+    "mode": "local",
+    "bind": "lan",
+    "port": $PORT,
+    "trustedProxies": ["0.0.0.0/0"],
+    "auth": {
+      "mode": "token",
+      "token": "$GATEWAY_PASSWORD"
+    },
+    "controlUi": {
+      "allowInsecureAuth": true
+    }
+  },
+  "models": {
+    "providers": {
+      "nvidia": {
+        "baseUrl": "https://integrate.api.nvidia.com/v1",
+        "apiKey": "$NVIDIA_API_KEY",
+        "api": "openai-completions",
+        "models": [
+          {
+            "id": "$MODEL_ID",
+            "name": "Kimi k2.5",
+            "reasoning": false,
+            "input": ["text"],
+            "contextWindow": 200000,
+            "maxTokens": 8192
+          }
+        ]
+      }
+    }
+  },
+  "agents": {
+    "defaults": {
+      "maxConcurrent": 4,
+      "subagents": {
+        "maxConcurrent": 8
+      }
+    }
+  },
+  "meta": {
+    "generatedOn": "$(date -Iseconds)",
+    "source": "auto-generated"
+  }
+}
+EOF
+
+    # 设置正确的文件权限
+    chmod 600 "$CONFIG_FILE"
+    chmod 700 "$OPENCLAW_DIR"
+    
+    log "OpenClaw 配置文件已生成: $CONFIG_FILE"
+}
+
+# 启动数据同步服务
+start_sync_service() {
+    log "启动配置同步服务..."
+    
+    if [ -f "$SYNC_SCRIPT" ]; then
+        # 首次同步：从Dataset恢复配置
+        if python3 "$SYNC_SCRIPT" download; then
+            log "配置恢复成功"
+            
+            # 如果Dataset中有配置，使用Dataset的配置
+            if [ -f "$CONFIG_FILE" ]; then
+                log "使用Dataset中的配置文件"
+                return
+            fi
+        else
+            log "配置恢复失败，将使用新配置"
+        fi
+    else
+        log "同步脚本不存在: $SYNC_SCRIPT"
+    fi
+    
+    # 生成新的配置文件
+    generate_config
+}
+
+# 启动 OpenClaw 网关服务
+start_openclaw() {
+    local PORT="${PORT:-18789}"
+    
+    log "启动 OpenClaw 网关服务..."
+    
+    # 检查配置文件是否存在
+    if [ ! -f "$CONFIG_FILE" ]; then
+        error_exit "配置文件不存在: $CONFIG_FILE"
+    fi
+    
+    # 验证配置文件语法
+    if ! python3 -m json.tool "$CONFIG_FILE" > /dev/null 2>&1; then
+        error_exit "配置文件语法错误"
+    fi
+    
+    log "=== OpenClaw 启动配置 ==="
+    log "端口: $PORT"
+    log "配置文件: $CONFIG_FILE"
+    log "日志文件: $LOG_FILE"
+    log "=========================="
+    
+    # 启动网关服务[6](@ref)
+    exec openclaw gateway run \
+        --port "$PORT" \
+        --allow-unconfigured \
+        --token "${OPENCLAW_GATEWAY_PASSWORD:-openclaw}"
+}
+
+# 主执行流程
+main() {
+    log "=== 开始 OpenClaw 启动流程 ==="
+    
+    # 执行步骤
+    ensure_directories
+    start_sync_service
+    
+    # 如果同步脚本存在，启动后台同步服务
+    if [ -f "$SYNC_SCRIPT" ]; then
+        log "启动后台同步服务..."
+        python3 "$SYNC_SCRIPT" sync &
+        SYNC_PID=$!
+        log "后台同步服务已启动 (PID: $SYNC_PID)"
+    fi
+    
+    # 启动 OpenClaw
+    start_openclaw
+}
+
+# 捕获信号，确保优雅退出
+trap 'log "收到退出信号，正在关闭..."' TERM INT
+
+# 运行主函数
+main

sync.py

@@ -0,0 +1,193 @@
+#!/usr/bin/env python3
+"""
+OpenClaw 配置同步脚本
+功能：从 Hugging Face Dataset 拉取配置，并定时推送变更回 Dataset
+作者：根据用户需求生成
+日期：2026-02-08
+"""
+
+import os
+import json
+import time
+import logging
+import hashlib
+from pathlib import Path
+from huggingface_hub import HfApi, Repository, snapshot_download
+
+# 配置日志
+logging.basicConfig(
+    level=logging.INFO,
+    format='%(asctime)s - %(levelname)s - %(message)s'
+)
+logger = logging.getLogger(__name__)
+
+class OpenClawConfigSync:
+    def __init__(self):
+        self.hf_token = os.getenv('HF_TOKEN', '')
+        self.dataset_repo = os.getenv('HF_DATASET', '')
+        self.local_config_dir = Path('/root/.openclaw')
+        self.sync_interval = 300  # 5分钟同步一次
+        
+        if not self.hf_token or not self.dataset_repo:
+            logger.error('HF_TOKEN 或 HF_DATASET 环境变量未设置')
+            raise ValueError('缺少必要的环境变量')
+        
+        self.api = HfApi(token=self.hf_token)
+        self.repo_dir = Path('/tmp/openclaw_dataset')
+        
+    def calculate_file_hash(self, file_path):
+        """计算文件MD5哈希值用于比较变更[1,2](@ref)"""
+        hash_md5 = hashlib.md5()
+        try:
+            with open(file_path, "rb") as f:
+                for chunk in iter(lambda: f.read(4096), b""):
+                    hash_md5.update(chunk)
+            return hash_md5.hexdigest()
+        except Exception as e:
+            logger.error(f"计算文件哈希失败 {file_path}: {e}")
+            return None
+    
+    def ensure_local_dir(self):
+        """确保本地配置目录存在"""
+        self.local_config_dir.mkdir(parents=True, exist_ok=True)
+    
+    def download_from_dataset(self):
+        """从Dataset拉取最新配置[8](@ref)"""
+        try:
+            logger.info(f'从Dataset拉取配置: {self.dataset_repo}')
+            
+            # 下载Dataset内容
+            snapshot_dir = snapshot_download(
+                repo_id=self.dataset_repo,
+                token=self.hf_token,
+                local_dir=self.repo_dir,
+                allow_patterns=['*.json', '*.yaml', '*.yml'],
+                force_download=True
+            )
+            
+            config_src = Path(snapshot_dir)
+            if not config_src.exists():
+                logger.warning('Dataset中未找到配置文件，将使用默认配置')
+                return False
+            
+            # 复制配置文件到本地目录
+            for config_file in config_src.glob('*'):
+                if config_file.is_file():
+                    dest_file = self.local_config_dir / config_file.name
+                    # 备份原文件
+                    if dest_file.exists():
+                        backup_file = dest_file.with_suffix(f'.bak{int(time.time())}')
+                        dest_file.rename(backup_file)
+                    
+                    import shutil
+                    shutil.copy2(config_file, dest_file)
+                    logger.info(f'已恢复配置: {config_file.name}')
+            
+            return True
+            
+        except Exception as e:
+            logger.error(f'从Dataset拉取配置失败: {e}')
+            return False
+    
+    def upload_to_dataset(self):
+        """推送配置变更回Dataset[8](@ref)"""
+        try:
+            logger.info('推送配置变更到Dataset')
+            
+            # 克隆Dataset仓库
+            repo = Repository(
+                local_dir=self.repo_dir,
+                repo_id=self.dataset_repo,
+                token=self.hf_token,
+                clone_from=self.dataset_repo
+            )
+            
+            # 复制更新的配置文件
+            for config_file in self.local_config_dir.glob('*'):
+                if config_file.suffix in ['.json', '.yaml', '.yml']:
+                    dest_file = self.repo_dir / config_file.name
+                    import shutil
+                    shutil.copy2(config_file, dest_file)
+            
+            # 提交并推送变更
+            repo.git_add(auto_lfs_track=True)
+            repo.git_commit(f"自动同步配置 {time.strftime('%Y-%m-%d %H:%M:%S')}")
+            repo.git_push()
+            
+            logger.info('配置已成功推送到Dataset')
+            return True
+            
+        except Exception as e:
+            logger.error(f'推送配置到Dataset失败: {e}')
+            return False
+    
+    def config_changed(self):
+        """检查配置是否有变更"""
+        try:
+            for config_file in self.local_config_dir.glob('*.json'):
+                current_hash = self.calculate_file_hash(config_file)
+                # 这里可以比较当前哈希与上次保存的哈希值
+                # 简化处理：总是返回True，确保定期备份
+                return True
+        except Exception as e:
+            logger.error(f'检查配置变更失败: {e}')
+        
+        return True
+    
+    def run_sync(self, mode='download'):
+        """运行同步流程"""
+        self.ensure_local_dir()
+        
+        if mode == 'download':
+            return self.download_from_dataset()
+        elif mode == 'upload':
+            if self.config_changed():
+                return self.upload_to_dataset()
+            else:
+                logger.info('配置无变更，跳过上传')
+                return True
+        return False
+    
+    def start_periodic_sync(self):
+        """启动定时同步服务"""
+        logger.info('启动定时同步服务')
+        while True:
+            try:
+                time.sleep(self.sync_interval)
+                self.run_sync('upload')
+            except Exception as e:
+                logger.error(f'定时同步失败: {e}')
+                time.sleep(60)  # 出错后等待1分钟再重试
+
+def main():
+    """主函数"""
+    import sys
+    
+    if len(sys.argv) != 2 or sys.argv[1] not in ['download', 'upload', 'sync']:
+        print('用法: python sync.py [download|upload|sync]')
+        sys.exit(1)
+    
+    mode = sys.argv[1]
+    
+    try:
+        sync = OpenClawConfigSync()
+        
+        if mode == 'download':
+            sync.run_sync('download')
+        elif mode == 'upload':
+            sync.run_sync('upload')
+        elif mode == 'sync':
+            # 后台运行定时同步
+            import threading
+            sync.run_sync('download')
+            sync_thread = threading.Thread(target=sync.start_periodic_sync)
+            sync_thread.daemon = True
+            sync_thread.start()
+            sync_thread.join()
+            
+    except Exception as e:
+        logger.error(f'同步服务失败: {e}')
+        sys.exit(1)
+
+if __name__ == '__main__':
+    main()