Initial commit

+DB_HOST=140.210.199.111
+DB_PORT=3306
+DB_USER=root
+DB_PASSWORD=Qnbar123!
+DB_NAME=ai
+
+REDIS_HOST=10.10.1.232
+REDIS_PORT=6379
+REDIS_PASSWORD=qnbarcom
+REDIS_PREFIX=ai_

+FROM php:8.2-cli
+
+# Install dependencies and extensions
+RUN apt-get update && apt-get install -y \
+    git \
+    unzip \
+    libzip-dev \
+    && docker-php-ext-install pcntl posix sockets zip pdo_mysql
+
+# Install Composer
+COPY --from=composer:latest /usr/bin/composer /usr/bin/composer
+
+# Set working directory
+WORKDIR /app
+
+# Copy dependency definition first
+COPY composer.json ./
+
+# Install dependencies (if composer.lock exists it would be better, but we start fresh)
+RUN composer install --no-scripts --no-autoloader
+
+# Copy application source
+COPY . .
+
+# Generate autoloader
+RUN composer dump-autoload --optimize
+
+# Expose WebSocket port
+EXPOSE 8888
+
+# Command to run the Workerman server
+CMD ["php", "start.php", "start"]

+{
+    "name": "moltbot/relay-server",
+    "description": "IoT Relay Server for Clawdbot WeChat Integration",
+    "type": "project",
+    "license": "MIT",
+    "require": {
+        "php": ">=8.0",
+        "workerman/workerman": "^4.1",
+        "firebase/php-jwt": "^6.10",
+        "predis/predis": "^2.3"
+    },
+    "autoload": {
+        "psr-4": {
+            "Moltbot\\Relay\\": "src/"
+        }
+    }
+}

+services:
+  relay:
+    build: .
+    container_name: moltbot-relay
+    ports:
+      - "8888:8888"
+    env_file:
+      - .env
+    environment:
+      - REDIS_HOST=redis
+      - REDIS_PORT=6379
+
+  redis:
+    image: redis:alpine
+    container_name: moltbot-redis
+    ports:
+      - "6379:6379"

+<?php
+require_once __DIR__ . '/vendor/autoload.php';
+
+// Load .env (simple loader since we don't have dotenv lib installed in the basic container, 
+// or relying on docker-compose env injection)
+// Actually docker-compose injects env vars, so getenv() works.
+
+$host = getenv('DB_HOST');
+$user = getenv('DB_USER');
+$pass = getenv('DB_PASSWORD');
+$name = getenv('DB_NAME');
+$port = getenv('DB_PORT') ?: 3306;
+
+echo "Connecting to MySQL at $host...\n";
+
+try {
+    $dsn = "mysql:host=$host;port=$port;charset=utf8mb4";
+    $pdo = new PDO($dsn, $user, $pass, [
+        PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
+        PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC
+    ]);
+
+    echo "Connected successfully.\n";
+
+    // Create Database if not exists
+    $pdo->exec("CREATE DATABASE IF NOT EXISTS `$name` DEFAULT CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci");
+    $pdo->exec("USE `$name`");
+    echo "Selected database '$name'.\n";
+
+    $sql = <<<SQL
+-- Devices Table
+CREATE TABLE IF NOT EXISTS `devices` (
+    `id` VARCHAR(64) NOT NULL COMMENT '设备ID (Device ID)',
+    `secret` VARCHAR(128) NOT NULL COMMENT '连接密钥 (Hash)',
+    `name` VARCHAR(50) DEFAULT NULL COMMENT '设备昵称',
+    `owner_id` BIGINT UNSIGNED DEFAULT NULL COMMENT '绑定用户ID (NULL=未绑定)',
+    `status` ENUM('online', 'offline') DEFAULT 'offline' COMMENT '在线状态',
+    `last_seen` TIMESTAMP NULL DEFAULT NULL COMMENT '最后心跳时间',
+    `created_at` TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+    `updated_at` TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
+    PRIMARY KEY (`id`),
+    KEY `idx_owner` (`owner_id`)
+) ENGINE=InnoDB COMMENT='设备管理表';
+
+-- Users Table
+CREATE TABLE IF NOT EXISTS `users` (
+    `id` BIGINT UNSIGNED NOT NULL AUTO_INCREMENT,
+    `phone` VARCHAR(20) NOT NULL COMMENT '手机号',
+    `password` VARCHAR(255) NOT NULL COMMENT '密码 Hash',
+    `wx_openid` VARCHAR(64) DEFAULT NULL COMMENT '微信 OpenID',
+    `nickname` VARCHAR(50) DEFAULT NULL COMMENT '显示的昵称',
+    `avatar_url` VARCHAR(255) DEFAULT NULL,
+    `created_at` TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+    `updated_at` TIMESTAMP DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
+    PRIMARY KEY (`id`),
+    UNIQUE KEY `uk_phone` (`phone`),
+    UNIQUE KEY `uk_wx_openid` (`wx_openid`)
+) ENGINE=InnoDB COMMENT='用户表';
+
+-- Device Logs Table
+CREATE TABLE IF NOT EXISTS `device_logs` (
+    `id` BIGINT UNSIGNED NOT NULL AUTO_INCREMENT,
+    `device_id` VARCHAR(64) NOT NULL,
+    `level` VARCHAR(10) DEFAULT 'INFO',
+    `message` TEXT NOT NULL,
+    `created_at` TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+    PRIMARY KEY (`id`),
+    KEY `idx_device_time` (`device_id`, `created_at`)
+) ENGINE=InnoDB COMMENT='设备日志表';
+SQL;
+
+    $pdo->exec($sql);
+    echo "Tables created successfully.\n";
+
+    // Insert sample device if not exists
+    $pdo->exec("INSERT IGNORE INTO `devices` (`id`, `secret`, `name`, `status`) VALUES ('dev_test_001', '123456', 'My First Moltbot', 'offline')");
+    echo "Sample data inserted.\n";
+
+} catch (PDOException $e) {
+    echo "Database Error: " . $e->getMessage() . "\n";
+    exit(1);
+}

+# Relay Server 部署打包脚本
+# 运行: .\package-deploy.ps1
+
+$DeployDir = "$PSScriptRoot\deploy-package"
+$ZipFile = "$PSScriptRoot\relay-server-deploy.zip"
+
+Write-Host "=== 打包 Relay Server 部署文件 ===" -ForegroundColor Cyan
+
+# 创建部署目录
+if (Test-Path $DeployDir) { Remove-Item $DeployDir -Recurse -Force }
+New-Item -ItemType Directory -Path $DeployDir | Out-Null
+
+# 复制必要文件
+$files = @(
+    ".env",
+    "composer.json",
+    "docker-compose.yml",
+    "Dockerfile",
+    "migrate.php",
+    "start.php"
+)
+
+foreach ($file in $files) {
+    Copy-Item "$PSScriptRoot\$file" "$DeployDir\" -Force
+    Write-Host "  + $file" -ForegroundColor Green
+}
+
+# 创建部署说明
+$readme = @"
+# Relay Server 部署指南
+
+## 1. 上传整个目录到服务器
+   scp -r . user@server:/opt/moltbot-relay
+
+## 2. 修改 .env 配置
+   - DB_HOST: 数据库地址
+   - DB_PASSWORD: 数据库密码
+   - REDIS_HOST: Redis 地址（使用 docker 内部网络可设为 redis）
+
+## 3. 启动服务
+   cd /opt/moltbot-relay
+   docker-compose up -d --build
+
+## 4. 查看日志
+   docker-compose logs -f
+
+## 5. 开放防火墙
+   firewall-cmd --permanent --add-port=8888/tcp
+   firewall-cmd --reload
+
+## 6. 修改本地插件配置
+   编辑 ~/.clawdbot/clawdbot.json:
+   {
+     "channels": {
+       "wechat": {
+         "enabled": true,
+         "relayUrl": "ws://服务器IP:8888"
+       }
+     }
+   }
+"@
+$readme | Set-Content "$DeployDir\README.md" -Encoding UTF8
+
+# 打包成 zip
+if (Test-Path $ZipFile) { Remove-Item $ZipFile -Force }
+Compress-Archive -Path "$DeployDir\*" -DestinationPath $ZipFile
+
+Write-Host ""
+Write-Host "=== 打包完成 ===" -ForegroundColor Green
+Write-Host "部署包: $ZipFile" -ForegroundColor Yellow
+Write-Host ""
+Write-Host "将 zip 文件上传到服务器后解压并运行 docker-compose up -d --build" -ForegroundColor White
+
+# 清理临时目录
+Remove-Item $DeployDir -Recurse -Force

+<?php
+use Workerman\Worker;
+use Workerman\Timer;
+
+require_once __DIR__ . '/vendor/autoload.php';
+
+// Define Heartbeat Interval
+define('HEARTBEAT_TIME', 30);
+
+// Create a WebSocket worker
+$ws_worker = new Worker("websocket://0.0.0.0:8888");
+
+// Emulate simple routing/state for now
+// In production, use Redis for distributed state
+$ws_worker->count = 1; // Single process for dev simplicity
+
+// Redis Connection
+$redis = null;
+try {
+    $redis_host = getenv('REDIS_HOST') ?: '127.0.0.1';
+    $redis_port = getenv('REDIS_PORT') ?: 6379;
+    $redis_auth = getenv('REDIS_PASSWORD');
+    $redis_prefix = getenv('REDIS_PREFIX') ?: 'ai_';
+
+    $params = [
+        'scheme' => 'tcp',
+        'host' => $redis_host,
+        'port' => $redis_port,
+    ];
+
+    if ($redis_auth) {
+        $params['password'] = $redis_auth;
+    }
+
+    // Predis Client
+    $redis = new Predis\Client($params, ['prefix' => $redis_prefix]);
+    $redis->connect();
+    echo "✅ Connected to Redis at $redis_host ($redis_prefix)\n";
+} catch (Exception $e) {
+    echo "⚠️ Redis Connection Failed: " . $e->getMessage() . "\n";
+}
+
+// Store connections (Memory for now, can move to Redis later)
+$clients = []; // ClientID -> Connection
+$devices = []; // DeviceID -> Connection
+
+$ws_worker->onWorkerStart = function ($worker) {
+    echo "Relay Server Started on 0.0.0.0:8888\n";
+
+    // Heartbeat check
+    Timer::add(10, function () use ($worker) {
+        $time_now = time();
+        foreach ($worker->connections as $connection) {
+            // Check if connection is alive possibly? 
+            // Workerman handles basic disconnects, but we can enforce ping logic here if needed
+        }
+    });
+};
+
+$ws_worker->onConnect = function ($connection) {
+    echo "New connection: " . $connection->id . "\n";
+    $connection->authVerified = false;
+};
+
+$ws_worker->onMessage = function ($connection, $data) use (&$clients, &$devices) {
+    $msg = json_decode($data, true);
+    if (!$msg || !isset($msg['type'])) {
+        return;
+    }
+
+    // 1. Authenticate / Register
+    if ($msg['type'] === 'register') {
+        if ($msg['role'] === 'device') {
+            // Device 注册
+            $deviceId = $msg['id']; // TODO: Add secret validation
+            $devices[$deviceId] = $connection;
+            $connection->deviceId = $deviceId;
+            $connection->role = 'device';
+            $connection->authVerified = true;
+            $connection->send(json_encode(['type' => 'ack', 'status' => 'registered']));
+            echo "Device Registered: $deviceId\n";
+        } elseif ($msg['role'] === 'client') {
+            // Mini Program 注册
+            // TODO: Validate Token
+            $clientId = $msg['id'];
+            $clients[$clientId] = $connection;
+            $connection->clientId = $clientId;
+            $connection->role = 'client';
+            $connection->authVerified = true;
+            $connection->send(json_encode(['type' => 'ack', 'status' => 'connected']));
+            echo "Client Connected: $clientId\n";
+        }
+        return;
+    }
+
+    if (!$connection->authVerified) {
+        $connection->close();
+        return;
+    }
+
+    // 2. Proxy Logic
+
+    // Client -> Device
+    if ($msg['type'] === 'proxy' && $connection->role === 'client') {
+        $targetDeviceId = $msg['targetDeviceId'] ?? null;
+        if ($targetDeviceId && isset($devices[$targetDeviceId])) {
+            $payload = $msg['payload'];
+            // Wrap it so device knows who sent it
+            $forwardMsg = [
+                'type' => 'cmd:execute',
+                'fromClientId' => $connection->clientId,
+                'payload' => $payload
+            ];
+            $devices[$targetDeviceId]->send(json_encode($forwardMsg));
+            echo "Forwarded msg from Client {$connection->clientId} to Device {$targetDeviceId}\n";
+        } else {
+            $connection->send(json_encode(['type' => 'error', 'msg' => 'Device offline or not found']));
+        }
+    }
+
+    // Device -> Client
+    if ($msg['type'] === 'proxy_response' && $connection->role === 'device') {
+        $targetClientId = $msg['targetClientId'] ?? null;
+        if ($targetClientId && isset($clients[$targetClientId])) {
+            $payload = $msg['payload'];
+            $forwardMsg = [
+                'type' => 'response',
+                'fromDeviceId' => $connection->deviceId,
+                'payload' => $payload
+            ];
+            $clients[$targetClientId]->send(json_encode($forwardMsg));
+            echo "Forwarded response from Device {$connection->deviceId} to Client {$targetClientId}\n";
+        }
+    }
+};
+
+$ws_worker->onClose = function ($connection) use (&$clients, &$devices) {
+    if (isset($connection->role)) {
+        if ($connection->role === 'device' && isset($connection->deviceId)) {
+            unset($devices[$connection->deviceId]);
+            echo "Device disconnected: {$connection->deviceId}\n";
+        } elseif ($connection->role === 'client' && isset($connection->clientId)) {
+            unset($clients[$connection->clientId]);
+            echo "Client disconnected: {$connection->clientId}\n";
+        }
+    }
+};
+
+Worker::runAll();