AndroidRemoteController/nodejs/run-process.js

#!/usr/bin/env node
/**
 * run-process.js
 * 接收两个参数：ip 数组 (JSON)、脚本名
 * 异步根据每个 ip 执行脚本；执行前先 adb connect 该设备，确保连接成功再跑流程。
 *
 * 调用示例：node run-process.js '["192.168.2.5","192.168.2.6"]' 'RedNoteAIThumbsUp'
 */

const path = require('path')
const fs = require('fs')
const { execSync } = require('child_process')

const projectRoot = path.resolve(path.join(__dirname, '..'))
const staticRoot = process.env.STATIC_ROOT ? path.resolve(process.env.STATIC_ROOT) : path.join(projectRoot, 'static')
const config = require(path.join(projectRoot, 'configs', 'config.js'))
const adbPath = config.adbPath?.path
  ? path.resolve(projectRoot, config.adbPath.path)
  : path.join(projectRoot, 'lib', 'scrcpy-adb', 'adb.exe')
const ADB_PORT = 5555

const ipListJson = process.argv[2]
const scriptName = process.argv[3]
const folderPath = path.resolve(path.join(staticRoot, 'process', scriptName))
const ipList = JSON.parse(ipListJson)

let shouldStop = false
const { parseWorkflow } = require('./ef-compiler/ef-compiler.js')
const actions = parseWorkflow(JSON.parse(fs.readFileSync(path.join(folderPath, 'process.json'), 'utf8'))).actions

const { executeActionSequence } = require('./ef-compiler/ef-compiler.js')
const resolution = { width: 1080, height: 1920 }

/** 对指定 IP 执行 adb connect，确保设备在列表中后再跑流程 */
function ensureDeviceConnected(ip, port) {
  const out = execSync(`"${adbPath}" connect ${ip}:${port}`, { encoding: 'utf-8' }).trim()
  return out.includes('connected') || out.includes('already connected')
}

/** 启动执行：遍历 ip 列表并异步执行脚本；任一台失败则停止全部并返回失败设备 IP */
async function start() {
  let failedIp = null
  const runOne = async (ip) => {
    if (shouldStop) return { ip, success: false, stopped: true }
    const connected = ensureDeviceConnected(ip, ADB_PORT)
    if (!connected) return { ip, success: false }
    const result = await executeActionSequence(actions, `${ip}:${ADB_PORT}`, folderPath, resolution, 1000, null, () => shouldStop)
    if (!result.success) {
      if (!failedIp) { failedIp = ip; shouldStop = true }
    }
    return { ip, success: result.success }
  }

  const results = await Promise.all(ipList.map(ip => runOne(ip)))

  const output = failedIp
    ? { success: false, failedIp, results }
    : { success: true, results }
  process.stdout.write(JSON.stringify(output) + '\n')
  process.exit(failedIp ? 1 : 0)
}

/** 停止执行（SIGTERM/SIGINT 时调用） */
function stop() {
  shouldStop = true
}

process.on('SIGTERM', () => { stop(); process.exit(130) })
process.on('SIGINT', () => { stop(); process.exit(130) })

start()