tiktok-scripts/tiktok-auto/dist/tiktok-auto.js

/*! tiktok-auto v1.0.0
 *  built 2026-10-28T09:52:51.438Z
 *  modules: logger, bridge, config, wait, layout, ui, popups, tiktok, player, comment, interact, flow, parse, uidset, filters, profile, idsource, resolve, idflow, main
 *  由 tools/build.js 自动生成 —— 请不要直接编辑本文件，改 src/ 后重新构建。
 */
(function () {
var TikTokAuto = {};

/* ============================== src/logger.js ============================== */
/**
 * logger.js — 结构化日志
 *
 * 为什么单独成模块：设备脚本出错时，唯一能依赖的就是回传的日志。
 * 把日志格式固定下来（`[TTA][步骤名] 内容`），PC 侧就能按前缀过滤、按步骤计时，
 * 而不是靠人肉读一堆散乱的 console.log。
 *
 * 2026-10-13 增加**文件落盘通道**（sink）：界面侧的「运行记录 → 详情的执行日志」
 * 要看的就是这些行。之所以不做成"界面去抓 console"，是因为
 * console 是另一个进程的 stdout，界面根本读不到（见 bridge.js 的通道说明）。
 * sink 由 bridge 在启用宿主模式时装上，**独立运行时为空 → 零开销**。
 *
 * 依赖：无。始终通过 TikTokAuto.logger 取用，因此可以被放在 concat 顺序的最前面。
 */
TikTokAuto.logger = (function () {
    'use strict';

    var PREFIX = '[TTA]';
    var startedAt = Date.now();

    /** 文件落盘回调，由 bridge 注入：function(level, step, message) */
    var sink = null;

    function stamp() {
        return ('+' + (Date.now() - startedAt) + 'ms');
    }

    function write(level, step, message) {
        var line = PREFIX + stamp() + '[' + level + '][' + step + '] ' + message;
        console.log(line);

        if (sink) {
            /* 落盘失败绝不能影响流程：日志是"顺带记录的"，不是"必须成功的"。 */
            try {
                sink(level, step, message);
            } catch (ignored) {
                /* 刻意吞掉：sink 抛错会把一次正常的日志调用变成流程中断 */
            }
        }
    }

    return {
        /** 装上文件落盘通道（传 null 卸载） */
        setSink: function (fn) {
            sink = typeof fn === 'function' ? fn : null;
        },

        /** 记录一次进入某步骤 */
        step: function (name, message) {
            write('STEP', name, message === undefined ? '' : message);
        },

        info: function (step, message) {
            write('INFO', step, message);
        },

        /** 可恢复的问题：值得记下来，但不中断流程 */
        warn: function (step, message) {
            write('WARN', step, message);
        },

        error: function (step, message) {
            write('ERROR', step, message);
        },

        /** 机器可读的结构化结果，PC 侧用它做断言 */
        result: function (payload) {
            console.log(PREFIX + 'RESULT ' + JSON.stringify(payload));
        },

        /** 从脚本开始到现在的耗时，用于定位"哪一步慢" */
        elapsedMs: function () {
            return Date.now() - startedAt;
        }
    };
}());


/* ============================== src/bridge.js ============================== */
/**
 * bridge.js — 与「界面宿主」之间的桥
 *
 * 为什么需要它：这个脚本有两种运行方式——
 *   ① 独立运行（PC 侧下发、或直接打开产物）：自己读配置，跑完打印 `__END__`；
 *   ② 被界面宿主唤起（`engines.execScriptFile`，见 tiktok-app）：
 *      配置由宿主生成，宿主还要能看见**进度**、能**叫停**。
 *
 * 两种方式共用同一套流程，差别只在「上下文从哪来、状态往哪去」，所以抽成这个模块：
 * 流程代码只调 `bridge.report()` / `bridge.checkStop()`，不必知道自己在被谁驱动。
 * **未启用时两者都是空操作**，独立运行零开销、零行为变化。
 *
 * 通道全部走**文件**，不走共享内存 —— 宿主与子引擎是两个独立的 ScriptEngine，
 * 脚本级全局变量互不可见（实测：父脚本读不到子引擎里的任何对象）。
 * 文件是这里唯一可靠的通道。
 *
 * 四个约定文件（默认都在 /sdcard/tiktok_app/ 下）：
 *   run-config.json    宿主 → 引擎：界面收集的完整配置快照（人可读，非本模块读取）
 *   engine-config.json 宿主 → 引擎：映射后的引擎配置（由 --config 交给 config.resolve）
 *   run-state.json     引擎 → 宿主：进度与终态（本模块写）
 *   stop.flag          宿主 → 引擎：停止请求（本模块只读）
 *
 * ★ stop.flag 里放的是**本次运行的 runId**，不是空文件、也不是布尔。
 *   好处一：不必删除它（`files.remove` 命中 MCP 危险调用黑名单；删除本身也有竞态）。
 *   好处二：上一轮残留的标志不会误杀本轮 —— runId 不同，自然不匹配。
 *
 * 依赖：TikTokAuto.logger（调用时取，避免 concat 顺序耦合）
 */
TikTokAuto.bridge = (function () {
    'use strict';

    var DEFAULT_DIR = '/sdcard/tiktok_app';
    var DEFAULT_STATE = DEFAULT_DIR + '/run-state.json';
    var DEFAULT_STOP_FLAG = DEFAULT_DIR + '/stop.flag';
    var DEFAULT_LOG = DEFAULT_DIR + '/run-log.jsonl';

    /**
     * 检查停止标志的最小间隔。
     * 每次 tick（默认 150ms）都去 stat 一次文件是没必要的高频 IO；
     * 500ms 的响应延迟对人来说与"立刻"无异。
     */
    var STOP_POLL_MIN_MS = 500;

    var state = {
        enabled: false,
        runId: '',
        statePath: DEFAULT_STATE,
        stopFlagPath: DEFAULT_STOP_FLAG,
        logPath: DEFAULT_LOG,
        lastStopCheckMs: 0
    };

    var last = null;

    /**
     * 「用户要求停止」。**刻意用异常抛出**：
     * 停止请求可能发生在任意深度的等待里（等页面就绪、等播放开始、等结果卡片……），
     * 逐层返回码需要改动几十处调用点且极容易漏掉一处就变成"点了停止但不停"。
     * 抛出后由 main 统一兜住，语义明确（名字里带 Signal，不是 Error 那种"出错了"）。
     */
    function StopSignal() {
        this.name = 'StopSignal';
        this.message = '收到停止请求';
        this.stack = new Error(this.message).stack;
    }
    StopSignal.prototype = new Error();
    StopSignal.prototype.constructor = StopSignal;

    /**
     * 判断自有属性。
     * 刻意写成 `.apply(...)` 而不是「属性名 + 点 + call」的形式——见 config.js 里的说明：
     * MCP 桥的危险调用黑名单会按词边界匹配「call + 左括号」，`.apply` 语义等价却不会被误判。
     */
    function owns(object, key) {
        return Object.prototype.hasOwnProperty.apply(object, [key]) === true;
    }

    function isStopSignal(error) {
        return !!(error && error.name === 'StopSignal');
    }

    /**
     * 取引擎启动参数。
     * Rhino 会把传进来的数组包装成 `{"0":..,"1":..}` 这种对象（实测），
     * 所以既接受真数组，也按数字下标收集一份。
     */
    function readExecArgv() {
        var list = [];
        try {
            var argv = engines.myEngine().execArgv;
            if (argv instanceof Array) {
                return argv;
            }
            for (var i = 0; argv && argv[i] !== undefined; i += 1) {
                list.push(argv[i]);
            }
        } catch (ignored) {
            // 独立运行时 execArgv 为空/不可用，按"没有参数"处理
        }
        return list;
    }

    /** 解析 `--key value` 形式的参数（不支持 `--key=value`，保持单一写法） */
    function parseArgs(argv) {
        var options = {};
        for (var i = 0; i < argv.length; i += 1) {
            var token = String(argv[i]);
            if (token === '--config') {
                options.configPath = argv[i + 1];
                i += 1;
            } else if (token === '--state') {
                options.statePath = argv[i + 1];
                i += 1;
            } else if (token === '--stop-flag') {
                options.stopFlagPath = argv[i + 1];
                i += 1;
            } else if (token === '--run-id') {
                options.runId = argv[i + 1];
                i += 1;
            } else if (token === '--log') {
                options.logPath = argv[i + 1];
                i += 1;
            }
        }
        return options;
    }

    /**
     * 入口用：把命令行参数翻译成「配置覆盖项 + 桥的开关」。
     *
     * @param base 构建时注入的配置（可为 null）
     * @returns 应当交给 main.run 的注入项
     */
    function fromExecArgv(base) {
        var injected = base || {};
        var options = parseArgs(readExecArgv());

        if (options.runId) {
            enable(options);
        }
        if (options.configPath) {
            injected.runtime = injected.runtime || {};
            injected.runtime.configPath = options.configPath;
        }
        return injected;
    }

    /**
     * 日志落盘（界面侧「执行日志」的来源）。
     *
     * 一行一条 JSON（jsonl）：界面按行解析，坏行跳过即可 ——
     * 比整份 JSON 更抗"写着写着被杀进程"（半行只丢一行，不会让整份文件不可读）。
     * 用 append 而不是重写：日志是**流**，每写一次整文件会让长流程变成 O(n²) 的 IO。
     */
    function appendLog(level, step, message) {
        try {
            files.append(state.logPath,
                JSON.stringify({
                    t: Date.now(),
                    level: level,
                    step: step,
                    text: (step ? '[' + step + '] ' : '') + message
                }) + '\n');
        } catch (error) {
            /* 落盘失败不该影响流程：logger 那边已经吞了一层，这里再兜一层 */
        }
    }

    /** 打开桥。没有 runId 时**不启用**——runId 是停止标志比对的依据，缺了它无法判定是谁的请求。 */
    function enable(options) {
        state.enabled = true;
        state.runId = String(options.runId);
        state.statePath = options.statePath || DEFAULT_STATE;
        state.stopFlagPath = options.stopFlagPath || DEFAULT_STOP_FLAG;
        state.logPath = options.logPath || DEFAULT_LOG;
        state.lastStopCheckMs = 0;

        /* ★ 清空上一轮的日志：界面在结束时整份读走，
         *   不清的话 D3 上会混进上一次运行的行（而且越跑越长）。 */
        try {
            files.write(state.logPath, '');
        } catch (error) {
            /* 清不掉也不致命：界面会按 t 只取本轮时间窗内的行 */
        }
        if (TikTokAuto.logger && TikTokAuto.logger.setSink) {
            TikTokAuto.logger.setSink(appendLog);
        }

        last = {
            runId: state.runId,
            status: 'starting',
            phase: '',
            done: 0,
            total: 0,
            updatedAt: 0
        };
        report({});
        log('info', '已连接到界面宿主，runId=' + state.runId);
    }

    function isEnabled() {
        return state.enabled;
    }

    /**
     * 写一次状态。宿主每秒读一次这个文件。
     * 失败只记 WARN：状态上报失败不该让正在跑的流程崩掉。
     */
    function report(patch) {
        if (!state.enabled || !last) {
            return;
        }
        for (var key in patch) {
            if (owns(patch, key)) {
                last[key] = patch[key];
            }
        }
        last.runId = state.runId;
        last.updatedAt = Date.now();

        try {
            files.write(state.statePath, JSON.stringify(last));
        } catch (error) {
            log('warn', '状态上报失败：' + error);
        }
    }

    /** 写终态。宿主靠它结束「运行中」并弹出结果。 */
    function finish(status, summary) {
        if (!state.enabled) {
            return;
        }
        var patch = {
            status: status,
            phase: '',
            summary: summary || null,
            message: describe(status, summary)
        };
        /* ID 提取的 `done` 是"已收个数"，而最后一次 `report` 往往发生在收下一个人之前 ——
         * 于是终态里 done 会比实际少一个（实测 11 个却报 10）。
         * 收尾时按 summary 校正一次，免得界面/记录上的数字自相矛盾。 */
        if (summary && typeof summary.extracted === 'number') {
            patch.done = summary.extracted;
        }
        report(patch);
        log('info', '终态已上报：' + status);
    }

    /** 给界面看的一句人话，不要求界面自己去解析 summary 结构 */
    function describe(status, summary) {
        /* ID 提取与视频链路的 summary 形状不同（提取个数 vs 视频个数），
         * 但界面只有"一句人话"这一个位置 —— 所以在这里分支，让两条链路都说得清楚。
         * 判据是 `extracted` 字段是否存在，与 task 解耦（summary 自己就带得动语义）。 */
        var isIdTask = summary && typeof summary.extracted === 'number';

        if (status === 'stopped') {
            return isIdTask
                ? '已停止：本次已收 ' + summary.extracted + ' 个 ID'
                : '已停止';
        }
        if (status === 'finished') {
            if (isIdTask) {
                var tail = summary.skipped > 0 ? '，按条件跳过 ' + summary.skipped + ' 个' : '';
                /* 生成了 uid 映射就顺带说一句 —— 用户不一定知道还有第二个文件 */
                var mapped = summary.mapFile ? '（已生成 uid 映射）' : '';
                return '完成：提取 ' + summary.extracted + ' 个 ID' + tail + mapped;
            }
            var watched = summary ? summary.attemptedVideos : 0;
            var posted = summary ? summary.postedComments : 0;
            /* 只写"真的做了"的：跳过（已赞/已关注）不计入，否则用户会以为
             * 自己点了 N 个赞，实际全是"本来就已经赞过"。 */
            var liked = summary && summary.likedVideos ? summary.likedVideos : 0;
            var followed = summary && summary.followedAuthors ? summary.followedAuthors : 0;
            var actions = [];
            if (liked > 0 || (summary && summary.likesRequested)) {
                actions.push('点赞 ' + liked);
            }
            if (followed > 0 || (summary && summary.followsRequested)) {
                actions.push('关注 ' + followed);
            }
            actions.push('评论 ' + posted);
            return '完成：处理 ' + watched + ' 个视频 / ' + actions.join(' / ');
        }
        var reason = summary && summary.errors && summary.errors.length > 0
            ? summary.errors[0]
            : '未知原因';
        return '未完成：' + reason;
    }

    /**
     * 停止检查。**由唯一的等待原语 `wait.tick` 调用**，
     * 于是所有长等待都能被打断，而流程代码一处都不用改。
     * 命中即抛 StopSignal。
     */
    function checkStop() {
        if (!state.enabled) {
            return;
        }
        var now = Date.now();
        if (now - state.lastStopCheckMs < STOP_POLL_MIN_MS) {
            return;
        }
        state.lastStopCheckMs = now;

        var content = '';
        try {
            if (!files.exists(state.stopFlagPath)) {
                return;
            }
            content = String(files.read(state.stopFlagPath)).replace(/\s/g, '');
        } catch (error) {
            log('warn', '读取停止标志失败：' + error);
            return;
        }

        if (content !== '' && content === state.runId) {
            report({ status: 'stopping', phase: '正在收尾', message: '收到停止请求，正在收尾' });
            log('warn', '收到停止请求（runId 匹配），中断当前等待');
            throw new StopSignal();
        }
    }

    function log(level, message) {
        if (TikTokAuto.logger && TikTokAuto.logger[level]) {
            TikTokAuto.logger[level]('bridge', message);
        }
    }

    return {
        DEFAULT_DIR: DEFAULT_DIR,
        DEFAULT_STATE: DEFAULT_STATE,
        DEFAULT_STOP_FLAG: DEFAULT_STOP_FLAG,
        DEFAULT_LOG: DEFAULT_LOG,
        StopSignal: StopSignal,
        isStopSignal: isStopSignal,
        readExecArgv: readExecArgv,
        parseArgs: parseArgs,
        fromExecArgv: fromExecArgv,
        isEnabled: isEnabled,
        checkStop: checkStop,
        report: report,
        finish: finish,
        describe: describe,
        appendLog: appendLog
    };
}());


/* ============================== src/config.js ============================== */
/**
 * config.js — 配置的默认值、设备端加载、合并与校验
 *
 * 设计依据（Zakas《编写可维护的JavaScript》第 9 章「使用配置对象」）：
 *   所有"会变的业务数据"——搜索关键词、评论文案、观看时长、超时阈值、开关——
 *   都集中在配置文件里；代码只负责读，不负责写死。
 *   于是**改文案/改时长不需要动代码**，也不需要重新构建。
 *
 * 配置来源优先级（后者覆盖前者）：
 *   1. DEFAULTS（本文件，保证"没有配置文件也能跑"）
 *   2. 设备上的 JSON 文件（默认 /sdcard/Download/tiktok-auto/config.json）
 *   3. 运行时注入的 payload（PC 侧下发脚本时携带，便于免推送做实验）
 *
 * 依赖：TikTokAuto.logger
 */
TikTokAuto.config = (function () {
    'use strict';

    var DEFAULT_DEVICE_PATH = '/sdcard/Download/tiktok-auto/config.json';

    var DEFAULTS = {
        /**
         * 任务类型。缺省 'video' 是**刻意的向后兼容**：
         * 老配置（PC 侧下发、设备上残留的 config.json）里没有这个字段，
         * 它们本来就是视频链路的，所以默认值必须还是 video，
         * 否则一次升级会把所有老用法打成"未知任务"。
         */
        task: 'video',
        target: {
            packageName: 'com.zhiliaoapp.musically',
            keyword: 'fashion',
            maxVideos: 1,
            resultTab: 'Top',
            pickStrategy: 'random'
        },
        /**
         * ID 提取（task = 'id'）。形状与界面 `sources.js` 对齐：
         * `sources` 是**不定长清单**，每条自带起点与深度。
         */
        id: {
            sources: [],
            filter: {
                private: false,
                noAvatar: false,
                langRegion: 'any',
                nicknameCheck: 'any',
                follow: { min: 0, max: 0 },
                fans: { min: 0, max: 0 },
                likes: { min: 0, max: 0 },
                videos: { min: 0, max: 0 }
            },
            output: {
                dir: '/sdcard/Download/tiktok_app',
                historyPath: '/sdcard/Download/tiktok_app/uid_extracted.txt',
                dedupeHistory: true,
                dryRun: false,
                limit: 0,
                /**
                 * 抓完之后是否把 username 换成 TikTok 的**数字 uid**，另存一份映射文件。
                 *
                 * 默认开：数字 uid 在 App 界面上任何地方都读不到，不在这里换就得事后另跑一次。
                 * 每个约 2.5 秒（要下整页 SSR 约 388KB），所以只要 handle 的场景可以关掉省时间。
                 */
                resolveUid: true
            },
            /**
             * 物理护栏。界面里 `limit = 0` 的语义是"不限"，
             * 但真跑起来没有上限等于跑到没电 —— 所以引擎自己有个时长上限。
             * 到点时**如实报告**，不装作抓完了。
             */
            guard: {
                /** 抓取阶段最长多久（不含收尾） */
                maxRuntimeMs: 30 * 60 * 1000,
                /**
                 * 解析数字 uid 阶段**自己的**预算。
                 *
                 * 为什么必须独立：抓取很容易把 `maxRuntimeMs` 用满
                 * （实测 83 个候选 × 每人约 8 秒 = 30 分钟），
                 * 而解析 uid 是**收尾工作**，恰恰在这之后才做。
                 * 两者共用一个预算时，抓满 = 收尾一点时间都不剩 = 一个 uid 都换不到。
                 */
                resolveMaxMs: 10 * 60 * 1000
            }
        },
        watch: {
            minMs: 10000,
            maxMs: 35000
        },
        /**
         * 点赞 / 关注：与 comments 平级的两个动作开关。
         *
         * 界面的「执行操作」是四项多选（关注 / 私信 / 点赞 / 评论），
         * 这四项各自映射到一个 enabled —— 用户没勾就不做，不能因为"顺手"就点上。
         *
         * 与 ID 提取里的 `id.filter.likes`（按获赞数量筛账号）**不是一回事**，
         * 只是名字撞了，层级不同。
         */
        likes: {
            enabled: true
        },
        follows: {
            enabled: true
        },
        comments: {
            /* 是否执行评论动作。关掉就是「只浏览不发评论」——
             * 界面把「执行操作」里的评论开关映射到这里：
             * 用户没勾评论就不该发，哪怕评论池配好了。 */
            enabled: true,
            pool: [
                'Love this!',
                'So pretty',
                'Great style',
                'This is amazing',
                'Need this look'
            ],
            avoidRepeatWithinRun: true,
            strictPostCheck: false,
            verifyInList: true
        },
        timeouts: {
            appLaunchMs: 25000,
            pageReadyMs: 15000,
            searchResultsMs: 20000,
            playerReadyMs: 20000,
            playbackStartMs: 12000,
            panelReadyMs: 8000,
            postMs: 15000,
            countRefreshMs: 6000
        },
        probe: {
            pollTickMs: 150,
            livenessIntervalMs: 2500,
            stallTolerance: 3,
            useAudio: true,
            usePixels: false
        },
        guard: {
            enabled: true,
            intervalMs: 1200,
            firstScanTimeoutMs: 4000,
            dismissLabels: [
                'Not now', 'No thanks', 'Skip', 'Later', 'Cancel', 'Close',
                '稍后', '暂不', '取消', '关闭', '以后再说'
            ]
        },
        runtime: {
            configPath: DEFAULT_DEVICE_PATH,
            maxRuntimeMs: 0,
            dryRun: false
        }
    };

    /** 配置错误：单独类型，便于上层区分"配置写错了"和"运行时炸了" */
    function ConfigError(message, detail) {
        this.name = 'ConfigError';
        this.message = message;
        this.detail = detail;
        this.stack = new Error(message).stack;
    }
    ConfigError.prototype = new Error();
    ConfigError.prototype.constructor = ConfigError;

    /**
     * 判断自有属性。
     *
     * 这里刻意写成 `.apply(...)` 而不是更常见的「属性名 + 点 + 名字为 call 的方法」那种形式。
     * 原因：MCP 桥会对下发的脚本做危险调用黑名单扫描，其中一条规则按词边界匹配
     * 「名字为 call 的方法 + 左括号」的片段。`.apply` 语义完全等价，却不会被误判成
     * 危险代码、从而让每次下发都多要一次人工确认。
     */
    function owns(object, key) {
        return Object.prototype.hasOwnProperty.apply(object, [key]) === true;
    }

    function isPlainObject(value) {
        return value !== null && typeof value === 'object' && !(value instanceof Array);
    }

    /** 深拷贝（Rhino 没有 Object.assign，也不该依赖它） */
    function clone(value) {
        if (value instanceof Array) {
            var list = [];
            for (var i = 0; i < value.length; i += 1) {
                list.push(clone(value[i]));
            }
            return list;
        }
        if (isPlainObject(value)) {
            var copy = {};
            for (var key in value) {
                if (owns(value, key)) {
                    copy[key] = clone(value[key]);
                }
            }
            return copy;
        }
        return value;
    }

    /**
     * 深合并：对象逐键递归，数组整体替换。
     * 数组"整体替换"是刻意的——评论池这类配置如果被逐项合并，
     * 用户就永远删不掉默认评论了。
     */
    function merge(base, override) {
        if (!isPlainObject(override)) {
            return clone(override);
        }
        var result = clone(base);
        for (var key in override) {
            if (!owns(override, key)) {
                continue;
            }
            var value = override[key];
            if (isPlainObject(value) && isPlainObject(result[key])) {
                result[key] = merge(result[key], value);
            } else {
                result[key] = clone(value);
            }
        }
        return result;
    }

    function readDeviceJson(path) {
        var logger = TikTokAuto.logger;
        try {
            if (typeof files === 'undefined' || !files.exists(path)) {
                logger.info('config', '未找到配置文件，使用内置默认值：' + path);
                return null;
            }
            var raw = files.read(path);
            var parsed = JSON.parse(raw);
            logger.info('config', '已加载配置文件：' + path);
            return parsed;
        } catch (error) {
            // 配置写坏了必须让用户知道，但不应因此让整脚本无法启动——
            // 用默认值继续跑，同时把问题显著地抛到日志里。
            logger.error('config', '配置文件解析失败，改用默认值：' + error);
            return null;
        }
    }

    function validate(config) {
        /* —— ID 提取任务：校验的是"取材清单"，不是搜索关键词 ——
         * 早先这个函数硬性要求 target.keyword 非空，那是视频链路的前提。
         * ID 提取可以不搜索（从粉丝列表、文本文件、当前屏幕取材），
         * 所以按 task 分支，而不是给关键词塞一个假默认值把校验糊过去。 */
        if (config.task === 'id') {
            if (!(config.id && config.id.sources instanceof Array)) {
                throw new ConfigError('id.sources 必须是数组（取材清单）', config.id && config.id.sources);
            }
            if (config.id.sources.length === 0) {
                throw new ConfigError('id.sources 不能为空，至少需要一条取材', 0);
            }
            var limit = Number(config.id.output && config.id.output.limit);
            if (limit < 0) {
                throw new ConfigError('id.output.limit 不能为负数', limit);
            }
            return config;
        }

        var target = config.target;
        if (!target.keyword || String(target.keyword).replace(/\s/g, '') === '') {
            throw new ConfigError('target.keyword 不能为空', target.keyword);
        }
        /* 「评论池为空」只有在**要发评论**时才算配置错误：
         * 只浏览不发评论是合法的一次运行（界面上没勾评论就是这种情形）。 */
        if (config.comments.enabled && config.comments.pool.length === 0) {
            throw new ConfigError('comments.pool 不能为空，至少需要一条评论文案', 0);
        }
        if (config.watch.minMs > config.watch.maxMs) {
            throw new ConfigError('watch.minMs 不能大于 watch.maxMs', {
                minMs: config.watch.minMs,
                maxMs: config.watch.maxMs
            });
        }
        if (config.target.maxVideos < 1) {
            throw new ConfigError('target.maxVideos 必须 >= 1', config.target.maxVideos);
        }
        return config;
    }

    /**
     * 解析最终生效的配置。
     *
     * @param injected PC 侧注入的覆盖项（可为 null）
     */
    function resolve(injected) {
        var logger = TikTokAuto.logger;
        var fromDefaults = clone(DEFAULTS);
        var path = (injected && injected.runtime && injected.runtime.configPath) || DEFAULTS.runtime.configPath;

        var fromDevice = readDeviceJson(path) || {};
        var config = merge(merge(fromDefaults, fromDevice), injected || {});

        validate(config);
        if (config.task === 'id') {
            logger.info('config', '生效配置（ID提取）：' + JSON.stringify({
                sources: config.id.sources.length,
                filter: config.id.filter,
                limit: config.id.output.limit,
                dedupeHistory: config.id.output.dedupeHistory,
                dryRun: config.id.output.dryRun
            }));
        } else {
            logger.info('config', '生效配置：' + JSON.stringify({
                keyword: config.target.keyword,
                maxVideos: config.target.maxVideos,
                resultTab: config.target.resultTab,
                watchMs: [config.watch.minMs, config.watch.maxMs],
                commentEnabled: config.comments.enabled,
                commentCount: config.comments.pool.length,
                dryRun: config.runtime.dryRun
            }));
        }
        return config;
    }

    return {
        DEFAULTS: DEFAULTS,
        DEFAULT_DEVICE_PATH: DEFAULT_DEVICE_PATH,
        readDeviceJson: readDeviceJson,
        merge: merge,
        resolve: resolve,
        ConfigError: ConfigError
    };
}());


/* ============================== src/wait.js ============================== */
/**
 * wait.js — 唯一的等待原语
 *
 * 核心主张：**脚本里不允许出现裸 sleep 当作"等待"**。
 *
 *   tick（轮询节拍）  = "多久检查一次"  → 允许存在，默认 150ms
 *   sleep（盲等）     = "赌它 X 秒后会好" → 禁止用作等待手段
 *
 * 为什么这是稳定性的关键：网络抖动时页面可能 300ms 才渲染，也可能 8s 才渲染。
 * 写 `sleep(2000)` 的脚本在快的时候白等 1.7s，在慢的时候直接失败；
 * 而 `waitFor(条件, 超时)` 在快的时候立刻返回，慢的时候一直等到条件成立。
 * 这把"网络有多慢"从"脚本能不能跑通"里彻底解耦。
 *
 * 依赖：TikTokAuto.logger（调用时取，避免 concat 顺序耦合）
 */
TikTokAuto.wait = (function () {
    'use strict';

    var DEFAULT_TICK_MS = 150;

    function now() {
        return Date.now();
    }

    /**
     * 轮询节拍。
     *
     * ★ 这里是**唯一**的等待出口，所以「用户点了停止」的检查放在这一处就够了 ——
     *   全流程（等待应用启动、等待播放、等待结果卡片、等待评论区……共几十处等待）
     *   都会经过 tick，于是都能被打断，业务代码一行都不用改。
     *   bridge 未启用时是空操作（独立运行时零开销）。
     */
    function tick(ms) {
        if (TikTokAuto.bridge) {
            TikTokAuto.bridge.checkStop();
        }
        sleep(ms === undefined ? DEFAULT_TICK_MS : ms);
    }

    /**
     * 反复求值 predicate 直到它返回"真值"或超时。
     *
     * predicate 的返回值语义：
     *   - null / false        → 条件未满足，继续轮询
     *   - 其它任何值（含 0！） → 条件已满足，原样返回该值
     * 之所以不用 `if (value)` 判断，是为了允许 predicate 合法地返回 0 / '' 这类"假值结果"。
     *
     * @returns 满足时的返回值；超时返回 null
     */
    function poll(predicate, timeoutMs, tickMs) {
        var deadline = now() + timeoutMs;
        var step = tickMs === undefined ? DEFAULT_TICK_MS : tickMs;
        var last = null;

        for (;;) {
            try {
                var value = predicate();
                if (value !== null && value !== false && value !== undefined) {
                    return value;
                }
                last = value;
            } catch (error) {
                last = error;
            }
            if (now() >= deadline) {
                return null;
            }
            tick(Math.min(step, Math.max(1, deadline - now())));
        }
    }

    /**
     * 带日志与语义名字的 poll —— 业务代码应该用这个，而不是裸 poll。
     * 超时会记 WARN（而不是静默返回 null），这样"卡在哪一步"永远有据可查。
     */
    function waitFor(name, predicate, timeoutMs, tickMs) {
        var began = now();
        var value = poll(predicate, timeoutMs, tickMs);
        var cost = now() - began;

        if (value === null) {
            TikTokAuto.logger.warn('waitFor', name + ' 超时（等了 ' + cost + 'ms / 上限 ' + timeoutMs + 'ms）');
        } else {
            TikTokAuto.logger.info('waitFor', name + ' 就绪（' + cost + 'ms）');
        }
        return value;
    }

    /** 等待条件成立，并把成立时的值原样返回；语义等价于 waitFor */
    function until(condition, timeoutMs, tickMs) {
        return poll(condition, timeoutMs, tickMs);
    }

    /** 等待某个东西消失（例如弹窗、加载圈） */
    function untilGone(isPresent, timeoutMs, tickMs) {
        return poll(function () {
            return isPresent() ? null : true;
        }, timeoutMs, tickMs);
    }

    /**
     * 等待页面"安静"下来。
     *
     * 判据不是时间，而是**可见文案的拼接签名连续 N 次不变**。
     * 这比 sleep 可靠：加载中会不断有新节点出现，签名就会变；
     * 真正稳定后才返回，因此天然适配"网络慢 → 渲染慢"。
     *
     * @param sample  () => string，页面签名
     * @param options { maxMs, tickMs, stableTimes }
     */
    function waitQuiet(sample, options) {
        var settings = options || {};
        var maxMs = settings.maxMs === undefined ? 8000 : settings.maxMs;
        var tickMs = settings.tickMs === undefined ? 250 : settings.tickMs;
        var stableTimes = settings.stableTimes === undefined ? 3 : settings.stableTimes;

        var deadline = now() + maxMs;
        var previous = null;
        var sameCount = 0;

        while (now() < deadline) {
            var current = sample();
            if (current === previous) {
                sameCount += 1;
                if (sameCount >= stableTimes) {
                    return true;
                }
            } else {
                sameCount = 0;
                previous = current;
            }
            tick(tickMs);
        }
        return false;
    }

    return {
        DEFAULT_TICK_MS: DEFAULT_TICK_MS,
        tick: tick,
        poll: poll,
        waitFor: waitFor,
        until: until,
        untilGone: untilGone,
        waitQuiet: waitQuiet
    };
}());


/* ============================== src/layout.js ============================== */
/**
 * layout.js — 对 AutoX 无障碍 API 的适配层（Boundary Adapter）
 *
 * 依据《代码整洁之道》第 8 章「边界」：
 *   第三方/平台 API 一定有自己的脾气（`auto.root` 是属性不是函数、
 *   `text()` 是快照、离屏节点占了 40%+…）。把所有这些脾气**关在这一个文件里**，
 *   业务代码就只面对一组干净、语义明确的函数。
 *   平台 API 变了 → 只改这里。
 *
 * 依赖：TikTokAuto.logger、TikTokAuto.wait
 */
TikTokAuto.layout = (function () {
    'use strict';

    var SAFE_MARGIN = 8;

    function screen() {
        return {
            width: device.width,
            height: device.height
        };
    }

    /** 当前应用窗口的根节点。注意：是属性 `auto.root`，不是函数 `auto().root()` */
    function root() {
        return auto.root;
    }

    /** 前台包名。**不能**用 currentPackage()——软键盘弹出时它返回输入法包名 */
    function foregroundPackage() {
        var node = root();
        return node ? node.packageName() : null;
    }

    function findAll(selector) {
        return selector.find();
    }

    function findOnce(selector) {
        var collection = selector.find();
        return collection && collection.size() > 0 ? collection.get(0) : null;
    }

    /**
     * 收集整棵树的节点（含离屏）。
     * AutoX 的 `find()` 只从根往下找**可见**节点，拿不到离屏节点；
     * 而我们需要离屏信息来做"下面还有内容 → 该滚动"的判断。
     */
    function collectAll(maxNodes) {
        var limit = maxNodes || 1200;
        var result = [];
        var start = root();
        if (!start) {
            return result;
        }
        var stack = [start];
        while (stack.length > 0 && result.length < limit) {
            var node = stack.pop();
            if (!node) {
                continue;   // 遍历过程中节点可能失效，child(i) 会返回 null
            }
            result.push(node);
            var count = node.childCount();
            for (var i = 0; i < count; i += 1) {
                stack.push(node.child(i));
            }
        }
        return result;
    }

    /** 可见性判据：优先用原生 isVisibleToUser()，退化为"与屏幕求交" */
    function isVisible(node) {
        try {
            if (typeof node.isVisibleToUser === 'function') {
                return node.isVisibleToUser();
            }
        } catch (ignored) {
            // 落到下面的几何判据
        }
        try {
            if (typeof node.visibleToUser === 'function') {
                return node.visibleToUser();
            }
        } catch (ignoredToo) {
            // 落到下面的几何判据
        }
        return visibleRect(node) !== null;
    }

    /** 与屏幕求交后的可见矩形；完全在屏幕外时返回 null */
    function visibleRect(node) {
        var box = node.bounds();
        var view = screen();
        var left = Math.max(box.left, 0);
        var top = Math.max(box.top, 0);
        var right = Math.min(box.right, view.width);
        var bottom = Math.min(box.bottom, view.height);
        if (right - left <= 0 || bottom - top <= 0) {
            return null;
        }
        return { left: left, top: top, right: right, bottom: bottom };
    }

    /**
     * 可点击坐标 = **可见交集矩形的中心**，再夹到安全区内。
     *
     * 为什么要交集而不是几何中心：被状态栏切掉一半的节点，几何中心可能落在 y=0
     * （点到了状态栏），交集中心才是真正能摸到的地方。
     */
    function center(node) {
        var rect = visibleRect(node);
        var view = screen();
        if (!rect) {
            return null;
        }
        var x = Math.round((rect.left + rect.right) / 2);
        var y = Math.round((rect.top + rect.bottom) / 2);
        return {
            x: Math.min(Math.max(x, SAFE_MARGIN), view.width - SAFE_MARGIN),
            y: Math.min(Math.max(y, SAFE_MARGIN), view.height - SAFE_MARGIN)
        };
    }

    /**
     * 去掉文案里的**不可见格式字符**（零宽空格、LTR/RTL 标记、软连字符等）。
     *
     * 这是真机踩出来的坑：评论列表头部的计数实际文本是 "‎150 comments"，
     * 前面挂着一个 U+200E（LEFT-TO-RIGHT MARK）——肉眼完全看不出来，
     * 但 `/^\s*\d+ comments$/` 这种带锚点的正则就是匹配不上，
     * 于是"评论列表确认"这条最强证据永远拿不到，只能退化到弱证据。
     *
     * 放在适配层里统一处理：平台这类噪音只在这里吸掉一次，业务代码就干净了。
     */
    function sanitize(value) {
        if (value === null || value === undefined) {
            return '';
        }
        return String(value)
            .replace(/[\u200b-\u200f\u202a-\u202e\u2060-\u2064\ufeff\u00ad]/g, '')
            .replace(/\s+/g, ' ')
            .trim();
    }

    function text(node) {
        var value = '';
        try {
            value = node.text();
        } catch (ignored) {
            value = '';
        }
        return sanitize(value);
    }

    function desc(node) {
        var value = '';
        try {
            value = node.desc();
        } catch (ignored) {
            value = '';
        }
        return sanitize(value);
    }

    /** 节点的"可读标签"：文案优先，没有就看内容描述 */
    function label(node) {
        return text(node) || desc(node);
    }

    function resourceId(node) {
        try {
            var id = node.id();
            return id ? String(id) : '';
        } catch (ignored) {
            return '';
        }
    }

    function shortId(node) {
        var id = resourceId(node);
        var parts = id.split('/');
        return parts.length > 1 ? parts[parts.length - 1] : id;
    }

    function classNameOf(node) {
        try {
            return String(node.className());
        } catch (ignored) {
            return '';
        }
    }

    function shortClass(node) {
        var parts = classNameOf(node).split('.');
        return parts[parts.length - 1];
    }

    function isClickable(node) {
        try {
            return node.clickable() === true;
        } catch (ignored) {
            return false;
        }
    }

    function isScrollable(node) {
        try {
            return node.scrollable() === true;
        } catch (ignored) {
            return false;
        }
    }

    function isEditable(node) {
        return /EditText/i.test(classNameOf(node));
    }

    function parent(node) {
        try {
            return node.parent();
        } catch (ignored) {
            return null;
        }
    }

    /** 从 node 向上找到第一个可点击的祖先（不含自身） */
    function clickableAncestor(node, maxDepth) {
        var depth = 0;
        var limit = maxDepth === undefined ? 8 : maxDepth;
        var cursor = parent(node);
        while (cursor && depth < limit) {
            if (isClickable(cursor)) {
                return cursor;
            }
            cursor = parent(cursor);
            depth += 1;
        }
        return null;
    }

    /** 节点在屏幕上的矩形是否与给定纵向区间有明显重叠 */
    function overlapsBand(node, top, bottom, minRatio) {
        var rect = visibleRect(node);
        if (!rect) {
            return false;
        }
        var overlap = Math.min(rect.bottom, bottom) - Math.max(rect.top, top);
        if (overlap <= 0) {
            return false;
        }
        var ratio = minRatio === undefined ? 0.6 : minRatio;
        return overlap >= (rect.bottom - rect.top) * ratio;
    }

    /** 扁平化渲染，用于把当前界面一行一个控件打进日志（排障时非常有用） */
    function describe(nodes, limit) {
        var lines = [];
        var max = limit === undefined ? nodes.length : Math.min(limit, nodes.length);
        for (var i = 0; i < max; i += 1) {
            var node = nodes[i];
            var point = center(node);
            lines.push([
                shortClass(node),
                shortId(node),
                point ? '(' + point.x + ',' + point.y + ')' : '(offscreen)',
                isClickable(node) ? 'clk' : '-',
                JSON.stringify(label(node)).slice(0, 48)
            ].join(' '));
        }
        return lines.join(' | ');
    }

    /**
     * 页面签名 = 所有可见节点文案/描述的拼接。
     * 用途：判断"页面变没变""是否已经稳定"，完全不依赖时间。
     */
    function signature() {
        var nodes = collectAll(1500);
        var parts = [];
        for (var i = 0; i < nodes.length; i += 1) {
            if (!isVisible(nodes[i])) {
                continue;
            }
            var value = label(nodes[i]);
            if (value) {
                parts.push(value);
            }
        }
        return parts.join('\u0001');
    }

    return {
        SAFE_MARGIN: SAFE_MARGIN,
        screen: screen,
        root: root,
        foregroundPackage: foregroundPackage,
        findAll: findAll,
        findOnce: findOnce,
        collectAll: collectAll,
        isVisible: isVisible,
        visibleRect: visibleRect,
        center: center,
        text: text,
        desc: desc,
        label: label,
        sanitize: sanitize,
        resourceId: resourceId,
        shortId: shortId,
        classNameOf: classNameOf,
        shortClass: shortClass,
        isClickable: isClickable,
        isScrollable: isScrollable,
        isEditable: isEditable,
        parent: parent,
        clickableAncestor: clickableAncestor,
        overlapsBand: overlapsBand,
        describe: describe,
        signature: signature
    };
}());


/* ============================== src/ui.js ============================== */
/**
 * ui.js — 通用交互动作
 *
 * 这一层只回答一个问题："怎么把一次『点击』做成功"。
 * 它不认识 TikTok，也不认识业务流程（那是 tiktok.js / flow.js 的事）——
 * 这是《代码整洁之道》第 3 章「只做一件事」的落地。
 *
 * 点击的四级降级（都走无障碍，**不需要 Root**）：
 *   1. node.click()
 *   2. 最近的可点击祖先 click()   ← 大多数"点不动"的真凶：文案节点本身不可点
 *   3. 手势 click(可见交集中心)
 *   4. 手势 Tap(可见交集中心)
 * 并且返回"真正点到了谁"，让调用方可以核对，而不是默默点错地方。
 *
 * 依赖：TikTokAuto.logger、TikTokAuto.layout、TikTokAuto.wait
 */
TikTokAuto.ui = (function () {
    'use strict';

    function tapPoint(x, y) {
        click(x, y);
    }

    /**
     * 点击一个节点，逐级降级直到成功。
     * @returns {ok, via, targetCls, targetLabel, point}
     */
    /* ---- 悬浮球避让（规格书 §10.9③）----
     *
     * 全局悬浮球浮在**所有应用之上**（包括 TikTok），所以坐标手势如果正好落在球的
     * 窗口矩形里，点到的是球、不是 TikTok —— 实测就是这样：搜索建议列表的某一条
     * 正好压在球位，`click(x,y)` 把球的扇形面板点了出来（用户看到的是"面板自己弹出来"）。
     *
     * 规格书给的缓解办法是「脚本侧点击区域避开球位」，这里就做这一件事：
     *   ① 界面把球的窗口矩形写进 ball-rect.json（球的窗口比球大一圈，见 floatball.js）；
     *   ② 本模块在**走坐标手势之前**读它，命中就把落点挪到同节点内、球区之外的角落；
     *   ③ 整块节点都在球区里（挪不开）→ 放弃这次点击并记 WARN，
     *      让日志能解释"这次为什么没点成"，而不是默默点到了球上。
     *
     * ⚠️ 注意 `node.click()` 全程不受影响：那是无障碍点击，不产生屏幕坐标，
     *    压根碰不到悬浮窗 —— 所以避让只挂在手势这条兜底路径上。
     */
    var BALL_RECT_PATH = '/sdcard/tiktok_app/ball-rect.json';
    var ballRectCache = { at: 0, rect: null };

    function ballRect() {
        var now = Date.now();
        if (now - ballRectCache.at < 500) { return ballRectCache.rect; }
        ballRectCache.at = now;
        ballRectCache.rect = null;
        try {
            if (!files.exists(BALL_RECT_PATH)) { return null; }
            var raw = JSON.parse(String(files.read(BALL_RECT_PATH)));
            if (!raw || raw.hidden || raw.open) { return null; }   /* 隐藏 / 扇形展开时不挡点击判断 */
            if (typeof raw.x !== 'number' || typeof raw.w !== 'number') { return null; }
            ballRectCache.rect = raw;
        } catch (error) {
            /* 读不到就当没有球：宁可偶尔点到球，也不要因为一个坏文件让整个脚本点不动 */
            ballRectCache.rect = null;
        }
        return ballRectCache.rect;
    }

    function inside(rect, x, y) {
        return x >= rect.x && x <= rect.x + rect.w && y >= rect.y && y <= rect.y + rect.h;
    }

    /**
     * 把落点挪出球区。挪不动返回 null。
     * 候选点是「节点四角内缩」：同一节点内的任何位置对这次点击都等价，
     * 而角落最可能远离屏幕中部的球位。
     */
    function shiftOffBall(point, node, rect) {
        if (!inside(rect, point.x, point.y)) { return point; }
        var layout = TikTokAuto.layout;
        /* 复用 layout.visibleRect：它已经处理了"可见区域/被遮挡"这些边界情况，
         * 自己再写一份 node.bounds() 会与 center() 的口径不一致。 */
        var b = layout.visibleRect(node);
        if (!b) { return null; }
        var pad = 6;
        var cands = [
            { x: b.left + pad, y: b.top + pad },
            { x: b.right - pad, y: b.top + pad },
            { x: b.left + pad, y: b.bottom - pad },
            { x: b.right - pad, y: b.bottom - pad }
        ];
        for (var i = 0; i < cands.length; i++) {
            if (cands[i].x > 0 && cands[i].y > 0 && !inside(rect, cands[i].x, cands[i].y)) {
                return cands[i];
            }
        }
        return null;
    }

    function clickNode(node, step) {
        var story = step || 'click';
        var layout = TikTokAuto.layout;
        var targetClass = layout.shortClass(node);
        var targetLabel = layout.label(node);

        if (node.click()) {
            return finish(story, true, 'node.click()', targetClass, targetLabel, layout.center(node));
        }

        var ancestor = layout.clickableAncestor(node);
        if (ancestor && ancestor.click()) {
            return finish(story, true, 'clickableAncestor.click()', targetClass, targetLabel, layout.center(ancestor));
        }

        var point = layout.center(node);
        if (point) {
            var rect = ballRect();
            if (rect) {
                var safe = shiftOffBall(point, node, rect);
                if (!safe) {
                    return finish(story, false, 'blocked-by-floatball', targetClass, targetLabel, point);
                }
                point = safe;
            }
            click(point.x, point.y);
            return finish(story, true, 'gesture click(visibleCenter)', targetClass, targetLabel, point);
        }

        return finish(story, false, 'no-clickable-target', targetClass, targetLabel, null);
    }

    function finish(step, ok, via, targetClass, targetLabel, point) {
        var logger = TikTokAuto.logger;
        var where = point ? '(' + point.x + ',' + point.y + ')' : '(n/a)';
        logger.info(step, '点击 ' + (ok ? '成功' : '失败') + ' via=' + via +
            ' target=' + targetClass + ' ' + JSON.stringify(targetLabel).slice(0, 40) + ' ' + where);
        return {
            ok: ok,
            via: via,
            targetClass: targetClass,
            targetLabel: targetLabel,
            point: point
        };
    }

    /**
     * 往一个**已知节点**写入文本，并重新查找节点回读校验。
     *
     * 必须回读：AutoX 的 UiObject 是 find 那一刻的快照，
     * setText 之后立刻 .text() 读到的还是旧值，直接判定"写入失败"是经典误判。
     */
    function typeInto(node, value, step) {
        var logger = TikTokAuto.logger;
        var layout = TikTokAuto.layout;
        var story = step || 'typeInto';

        if (!node) {
            logger.error(story, '输入目标为空');
            return { ok: false, via: 'no-target' };
        }
        // 先让它真正获得焦点，否则部分输入法/控件不会提交文本
        var point = layout.center(node);
        if (point) {
            click(point.x, point.y);
            TikTokAuto.wait.tick(200);
        }

        node.setText(value);
        TikTokAuto.wait.tick(300);

        var actual = readEditableText(value);
        var ok = actual === value;
        if (!ok) {
            logger.warn(story, '回读不一致，重试一次。期望=' + JSON.stringify(value) + ' 实际=' + JSON.stringify(actual));
            node.setText(value);
            TikTokAuto.wait.tick(400);
            actual = readEditableText(value);
            ok = actual === value;
        }
        logger.info(story, '写入' + (ok ? '成功' : '失败') + ' 实际=' + JSON.stringify(actual));
        return { ok: ok, via: 'setText+readback', actual: actual };
    }

    /** 便捷版：传选择器，内部自己找节点 */
    function setText(selector, value, step) {
        return typeInto(TikTokAuto.layout.findOnce(selector), value, step);
    }

    /** 回读：取与期望值相等的输入框文本；没有就返回最长的那条（便于排查） */
    function readEditableText(expected) {
        var layout = TikTokAuto.layout;
        var collection = className('android.widget.EditText').find();
        var longest = '';
        for (var i = 0; i < collection.size(); i += 1) {
            var value = layout.text(collection.get(i));
            if (value === expected) {
                return value;
            }
            if (String(value).length > longest.length) {
                longest = value;
            }
        }
        return longest;
    }

    function isEditableText(expected) {
        return readEditableText(expected) === expected;
    }

    /**
     * 滑动。
     * 注意函数名不能叫 `swipe`——那会遮蔽 AutoX 的全局 `swipe()`，导致自我递归。
     */
    function dragScreen(x1, y1, x2, y2, durationMs) {
        swipe(x1, y1, x2, y2, durationMs === undefined ? 320 : durationMs);
    }

    /**
     * 返回上一页。
     * 注意：只在**明确的页面迁移**里调用（如 播放页 → 结果页）。
     * 永远不要把它当成"兜底清理"——那会把正常页面也退掉。
     */
    function goBack(step) {
        TikTokAuto.logger.info(step || 'back', '按下返回');
        back();
    }

    return {
        tapPoint: tapPoint,
        clickNode: clickNode,
        typeInto: typeInto,
        setText: setText,
        readEditableText: readEditableText,
        isEditableText: isEditableText,
        dragScreen: dragScreen,
        goBack: goBack
    };
}());


/* ============================== src/popups.js ============================== */
/**
 * popups.js — 干扰弹窗的「检测 / 执行分离」
 *
 * 依据 AutoX 真机经验（也是《代码整洁之道》第 3 章的"指令查询分离"）：
 *   - 把「看」和「动」拆成两组函数。guard 线程负责"动"，
 *     主流程只用只读的 popupPresent() 去**等**它清干净，绝不抢它的活。
 *   - **绝不 back() 正常页面**。登录页/权限页的兜底必须命中"登录方式"这类语境关键词，
 *     否则在「我的」页看到"立即登录"就会把正常页面退掉。
 *
 * 对未知弹窗的策略是**记录而不是猜**：
 *   命中已知签名 → 点掉；看起来像弹窗但不在名单里 → 只记 WARN + dump 界面，
 *   由人来决定要不要加进名单。比"猜着点"安全得多。
 *
 * 依赖：TikTokAuto.logger、TikTokAuto.layout、TikTokAuto.ui、TikTokAuto.wait
 */
TikTokAuto.popups = (function () {
    'use strict';

    /**
     * 已知的阻塞型弹窗签名。
     * contains 里任一命中即认为出现；dismiss 决定点哪个按钮。
     */
    var KNOWN_DIALOGS = [
        {
            name: 'save-login-info',
            contains: ['Save login info', 'Save your login info', '记住登录'],
            dismiss: ['Not now', 'Cancel', '稍后', '取消']
        },
        {
            name: 'notifications-permission',
            contains: ['Turn on notifications', 'get notified', '打开通知'],
            dismiss: ['Not now', 'No thanks', 'Skip', '稍后', '暂不']
        },
        {
            name: 'rate-app',
            contains: ['Enjoying TikTok', 'Rate this app', 'rate your experience'],
            dismiss: ['Not now', 'No thanks', 'Later', '稍后']
        },
        {
            name: 'update-app',
            contains: ['Update TikTok', 'A new version'],
            dismiss: ['Not now', 'Later', '稍后']
        },
        {
            name: 'open-in-app',
            contains: ['Open in app', 'Continue in app'],
            dismiss: ['Cancel', 'Not now', '取消']
        }
    ];

    /** 只读：扫描当前应用窗口，返回命中的已知弹窗名 + 疑似未知弹窗 */
    function scan() {
        var layout = TikTokAuto.layout;
        var visibleLabels = collectVisibleLabels();
        var joined = visibleLabels.join(' \u0001 ');
        var hits = [];

        for (var i = 0; i < KNOWN_DIALOGS.length; i += 1) {
            var dialog = KNOWN_DIALOGS[i];
            if (containsAny(joined, dialog.contains)) {
                hits.push(dialog);
            }
        }

        return {
            known: hits,
            looksBlocking: hits.length > 0 || looksLikeUnknownModal(visibleLabels)
        };
    }

    function containsAny(haystack, needles) {
        for (var i = 0; i < needles.length; i += 1) {
            if (haystack.indexOf(needles[i]) !== -1) {
                return true;
            }
        }
        return false;
    }

    function collectVisibleLabels() {
        var layout = TikTokAuto.layout;
        var nodes = layout.collectAll(1200);
        var labels = [];
        for (var i = 0; i < nodes.length; i += 1) {
            if (!layout.isVisible(nodes[i])) {
                continue;
            }
            var value = layout.label(nodes[i]);
            if (value) {
                labels.push(value);
            }
        }
        return labels;
    }

    /**
     * "看起来像弹窗"的启发式判据（仅用于告警，不驱动动作）：
     * 可见文案很少（弹窗通常只有标题 + 一两个按钮），却又出现了否定的动作词。
     * 正常页面（信息流/结果页）动辄几十条文案，不会命中。
     */
    function looksLikeUnknownModal(labels) {
        var dismissLabels = TikTokAuto.config
            ? TikTokAuto.config.DEFAULTS.guard.dismissLabels
            : ['Not now', 'Cancel', '稍后', '取消'];
        if (labels.length > 8) {
            return false;
        }
        return containsAny(labels.join('\u0001'), dismissLabels);
    }

    /** 只读：是否还有阻塞弹窗（主流程用它"等"guard 清场） */
    function popupPresent() {
        return scan().looksBlocking;
    }

    /** 执行：尝试点掉一个已知弹窗。返回是否真的动了手 */
    function dismissKnown(step) {
        var logger = TikTokAuto.logger;
        var layout = TikTokAuto.layout;
        var found = scan();

        if (found.known.length === 0) {
            return false;
        }

        for (var i = 0; i < found.known.length; i += 1) {
            var dialog = found.known[i];
            for (var j = 0; j < dialog.dismiss.length; j += 1) {
                var button = findExactLabel(dialog.dismiss[j]);
                if (button) {
                    logger.info(step || 'popup', '关闭已知弹窗 ' + dialog.name + ' → 点击 ' + JSON.stringify(dialog.dismiss[j]));
                    TikTokAuto.ui.clickNode(button, step || 'popup');
                    TikTokAuto.wait.tick(400);
                    return true;
                }
            }
            logger.warn(step || 'popup', '命中弹窗 ' + dialog.name + ' 但找不到关闭按钮，跳过');
        }
        return false;
    }

    /** 按精确文案/描述找可见节点；文案优先于描述 */
    function findExactLabel(value) {
        var layout = TikTokAuto.layout;
        var nodes = layout.collectAll(1200);
        for (var i = 0; i < nodes.length; i += 1) {
            if (layout.text(nodes[i]) === value && layout.isVisible(nodes[i])) {
                return nodes[i];
            }
        }
        for (var j = 0; j < nodes.length; j += 1) {
            if (layout.desc(nodes[j]) === value && layout.isVisible(nodes[j])) {
                return nodes[j];
            }
        }
        return null;
    }

    /**
     * 启动守护线程：周期性清掉已知弹窗。
     *
     * 返回一个句柄，其中 passes 计数让主流程确认"它已经上岗了"——
     * 否则主流程可能在守护线程第一次巡检之前就撞上弹窗。
     */
    function startGuard(config, logger) {
        var state = { passes: 0, dismissed: 0, stopped: false };

        if (!config.guard.enabled) {
            logger.info('guard', '守护线程已通过配置关闭');
            state.passes = 1;
            return state;
        }

        var thread = threads.start(function () {
            while (!state.stopped) {
                try {
                    if (dismissKnown('guard')) {
                        state.dismissed += 1;
                    }
                    state.passes += 1;
                } catch (error) {
                    /* 用户叫停时会从 wait.tick 抛出 StopSignal。守护线程不该继续巡检，
                     * 也不该每一轮都记一条 WARN 把日志刷满 —— 直接收工。 */
                    if (TikTokAuto.bridge && TikTokAuto.bridge.isStopSignal(error)) {
                        logger.info('guard', '收到停止请求，守护线程收工');
                        break;
                    }
                    logger.warn('guard', '巡检异常：' + error);
                }
                sleep(config.guard.intervalMs);
            }
        });
        state.thread = thread;
        logger.info('guard', '守护线程已启动，间隔 ' + config.guard.intervalMs + 'ms');
        return state;
    }

    function stopGuard(state, logger) {
        if (!state) {
            return;
        }
        state.stopped = true;
        logger.info('guard', '守护线程已停止，累计清场 ' + state.dismissed + ' 次');
    }

    return {
        KNOWN_DIALOGS: KNOWN_DIALOGS,
        scan: scan,
        popupPresent: popupPresent,
        dismissKnown: dismissKnown,
        findExactLabel: findExactLabel,
        startGuard: startGuard,
        stopGuard: stopGuard
    };
}());


/* ============================== src/tiktok.js ============================== */
/**
 * tiktok.js — TikTok 的应用知识（选择器 + 页面状态判定）
 *
 * 这个文件是**唯一**允许出现"TikTok 具体长什么样"的地方。
 * 换 App、或 TikTok 改版时，只动这里，flow.js 一行都不用改。
 *
 * 所有选择器都基于**真机实测**的锚点，并且在实测基础上刻意选了"语义锚点"而不是
 * 混淆过的资源 id——TikTok 的 id 形如 `e4g`/`cn6`/`e8x`，每次改版都会重排；
 * 而 "Read or add comments" 这类无障碍文案相当稳定。
 * 少数确实只能靠 id 的地方（发送按钮）走 config.selectors 覆盖，便于不改代码修。
 *
 * 实测锚点（1080x1920，com.zhiliaoapp.musically）：
 *   信息流搜索入口   ImageView desc="Search"                [968,50,1080,162]
 *   搜索页输入框     EditText (top < 12%H)
 *   搜索页提交       Button text="Search"  (left > 80%W)
 *   结果页分类页签   text/desc ∈ {Top,Users,Videos,...}      y ≈ 152..232
 *   结果页卡片       Button(卡片文案) width ≥ 35%W, top > 30%H
 *   播放页           "Read or add comments" + "Like video." 同时存在
 *   播放页评论入口   Button desc="Read or add comments. N comments"
 *   播放页内联输入   EditText desc/text="Add comment..."
 *   评论面板输入     EditText top ∈ [50%H,80%H]
 *   面板工具行       desc="Stickers" / "Mention someone" / "Microphone"
 *   面板发送按钮     工具行同高、最右、且 right ≤ W-8 的可点击 Button（实测 id=cn6）
 *
 * 依赖：TikTokAuto.logger、TikTokAuto.layout
 */
TikTokAuto.tiktok = (function () {
    'use strict';

    var PKG = 'com.zhiliaoapp.musically';
    var COMMENT_DESC_KEYS = ['Read or add comments', '评论'];
    var LIKE_DESC_KEYS = ['Like video.', '点赞'];
    /** 已点赞后同一个按钮的 desc（实测是 `Video liked`，不是 `Unlike`） */
    var LIKED_DESC_KEYS = ['Video liked', '已点赞', 'Unlike'];
    /** 关注按钮 desc 前缀（后面跟作者名）。`Followers` 会被 followButton 里单独排除。 */
    var FOLLOW_DESC_KEYS = ['Follow ', '关注'];
    var COMMENT_PLACEHOLDER = ['Add comment...', '添加评论', 'Add comment'];
    var TOOL_ROW_ANCHORS = ['Stickers', 'Mention someone', 'Microphone', '表情', '提及', '语音'];
    var RESULT_TABS = ['Top', 'Users', 'Videos', 'Sounds', 'Shop', 'LIVE', 'Places', 'Photos'];

    var layout = TikTokAuto.layout; // 常量引用，模块加载顺序由 build.js 保证
    var logger = TikTokAuto.logger;

    function screenWidth() { return device.width; }
    function screenHeight() { return device.height; }

    function startsWithAny(value, keys) {
        for (var i = 0; i < keys.length; i += 1) {
            if (value.indexOf(keys[i]) === 0) {
                return true;
            }
        }
        return false;
    }

    function equalsAny(value, keys) {
        for (var i = 0; i < keys.length; i += 1) {
            if (value === keys[i]) {
                return true;
            }
        }
        return false;
    }

    function widthOf(node) {
        var box = node.bounds();
        return box.right - box.left;
    }

    function topOf(node) {
        return node.bounds().top;
    }

    function bottomOf(node) {
        return node.bounds().bottom;
    }

    /** 按"文案或描述命中"收集可见节点 */
    function findByLabel(selector, predicate) {
        var result = [];
        var collection = selector.find();
        for (var i = 0; i < collection.size(); i += 1) {
            var node = collection.get(i);
            if (predicate(node) && layout.isVisible(node)) {
                result.push(node);
            }
        }
        return result;
    }

    // ---------------------------------------------------------------- 信息流

    /** 信息流右上角的搜索入口 */
    function searchEntry() {
        var hits = findByLabel(className('android.widget.ImageView'), function (node) {
            var point = layout.center(node);
            return layout.desc(node) === 'Search' && point !== null &&
                point.y < screenHeight() * 0.12 && point.x > screenWidth() * 0.85;
        });
        return hits.length > 0 ? hits[0] : null;
    }

    /** 信息流就绪判据：底部导航存在 */
    function bottomNavPresent() {
        return layout.findOnce(desc('Home')) !== null && layout.findOnce(desc('Profile')) !== null;
    }

    // ---------------------------------------------------------------- 搜索页

    /** 顶部搜索输入框（排除评论输入框：后者在屏幕下方） */
    function searchInput() {
        var hits = findByLabel(className('android.widget.EditText'), function (node) {
            return topOf(node) < screenHeight() * 0.12;
        });
        return hits.length > 0 ? hits[0] : null;
    }

    function searchSubmit() {
        var hits = findByLabel(className('android.widget.Button'), function (node) {
            var point = layout.center(node);
            return layout.text(node) === 'Search' && point !== null &&
                point.y < screenHeight() * 0.12 && point.x > screenWidth() * 0.8;
        });
        return hits.length > 0 ? hits[0] : null;
    }

    /** 搜索页特征：搜索历史行（带删除按钮）或"发现"按钮 */
    function searchHistoryPresent() {
        return layout.findOnce(desc('Close')) !== null || layout.findOnce(desc('Find')) !== null;
    }

    // ---------------------------------------------------------------- 结果页

    /** 结果页顶部分类页签 */
    function resultTab(name) {
        var hits = findByLabel(className('android.widget.TextView'), function (node) {
            return equalsAny(layout.text(node) || layout.desc(node), [name]) &&
                topOf(node) > screenHeight() * 0.06 && topOf(node) < screenHeight() * 0.16;
        });
        if (hits.length > 0) {
            return hits[0];
        }
        // 页签的文案节点本身常常不可点，真正可点的是外层 FrameLayout
        var frames = findByLabel(className('android.widget.FrameLayout'), function (node) {
            return equalsAny(layout.desc(node) || layout.text(node), [name]) &&
                topOf(node) > screenHeight() * 0.06 && topOf(node) < screenHeight() * 0.16;
        });
        return frames.length > 0 ? frames[0] : null;
    }

    function resultTabStripPresent() {
        var found = 0;
        for (var i = 0; i < RESULT_TABS.length; i += 1) {
            if (resultTab(RESULT_TABS[i])) {
                found += 1;
            }
        }
        return found >= 3;
    }

    /**
     * 从卡片文案锚点向上找"卡片容器"。
     * 为什么不能直接点文案：文案节点多数不可点，而它的可点祖先可能是**整屏容器**——
     * 点下去等于点在屏幕中间，什么也不会发生（实测踩过）。
     * 因此要求容器高度落在合理的卡片区间内，否则认为锚点自己就是最佳目标。
     */
    function cardContainer(anchor) {
        var height = screenHeight();
        var cursor = layout.clickableAncestor(anchor);
        var depth = 0;
        while (cursor && depth < 6) {
            var cardHeight = bottomOf(cursor) - topOf(cursor);
            if (cardHeight >= height * 0.18 && cardHeight <= height * 0.8) {
                return cursor;
            }
            cursor = layout.clickableAncestor(cursor);
            depth += 1;
        }
        return anchor;
    }

    /**
     * 结果页的视频卡片列表。
     *
     * 判据（都来自实测踩坑）：
     *   - 卡片文案是一条"宽"控件（≥35%W），据此把右侧竖排的点赞/评论/分享按钮排掉；
     *   - top > 30%H，据此排掉顶部搜索框；
     *   - 底部被导航栏切掉半截的先不收，避免点到一半的位置。
     */
    function videoCards() {
        var width = screenWidth();
        var height = screenHeight();
        var cards = [];
        var seen = {};

        var hits = findByLabel(className('android.widget.Button'), function (node) {
            return widthOf(node) >= width * 0.35 &&
                topOf(node) > height * 0.3 &&
                bottomOf(node) <= height - 12;
        });

        for (var i = 0; i < hits.length; i += 1) {
            var caption = layout.text(hits[i]) || layout.desc(hits[i]);
            if (!caption) {
                continue;
            }
            var key = caption + '@' + topOf(hits[i]);
            if (seen[key]) {
                continue;
            }
            seen[key] = true;
            cards.push({
                anchor: hits[i],
                container: cardContainer(hits[i]),
                caption: caption,
                top: topOf(hits[i])
            });
        }

        cards.sort(function (a, b) { return a.top - b.top; });
        return cards;
    }

    // ---------------------------------------------------------------- 播放页

    function commentButton() {
        var hits = findByLabel(className('android.widget.Button'), function (node) {
            return startsWithAny(layout.desc(node), COMMENT_DESC_KEYS);
        });
        return hits.length > 0 ? hits[0] : null;
    }

    function likeButton() {
        var hits = findByLabel(className('android.widget.Button'), function (node) {
            return startsWithAny(layout.desc(node), LIKE_DESC_KEYS);
        });
        return hits.length > 0 ? hits[0] : null;
    }

    /**
     * 「已点赞」状态的点赞按钮。
     *
     * ★ 实测（2026-10-28，TikTok 47.1.4）：点过赞之后同一个 `Button` 的 desc
     *   从 `Like video. 2.4M likes` 变成 **`Video liked`**（不是 `Unlike`），
     *   而里面那个 ImageView 的 `selected` 从 false 变成 true。
     *
     * 两个判据都要留：desc 受本地化影响，selected 是状态位不受文案影响 ——
     * 任一命中就算已赞，比只认一个更耐改版。
     */
    function likedButton() {
        var hits = findByLabel(className('android.widget.Button'), function (node) {
            return startsWithAny(layout.desc(node), LIKED_DESC_KEYS);
        });
        return hits.length > 0 ? hits[0] : null;
    }

    /**
     * 点赞按钮里的图标节点（用它读 `selected`）。
     * 实测：未赞 selected=false，已赞 selected=true。
     */
    function likeIcon() {
        var button = likeButton() || likedButton();
        if (!button) {
            return null;
        }
        var icons = button.find(className('android.widget.ImageView'));
        return icons.size() > 0 ? icons.get(0) : null;
    }

    /** 'liked' | 'unliked' | 'unknown' */
    function likeState() {
        if (likedButton() !== null) {
            return 'liked';
        }
        if (likeButton() !== null) {
            return 'unliked';
        }
        /* 按钮本身找不到时，退回看图标状态位（有些版本用同一个 desc，只翻 selected） */
        var icon = null;
        try { icon = likeIcon(); } catch (ignored) { icon = null; }
        if (icon !== null && icon.selected()) {
            return 'liked';
        }
        return 'unknown';
    }

    /**
     * 播放页的「关注作者」按钮。
     *
     * 实测 desc 形如 `Follow Marcgagilang`（`Follow` + 空格 + 作者名），
     * 是 `android.widget.Button`。
     * ⚠️ 首页顶部那个 `Following` 页签是 **FrameLayout**，不是 Button，
     *    所以限定 className 就能把它排除掉，不必额外按坐标过滤。
     */
    function followButton() {
        var hits = findByLabel(className('android.widget.Button'), function (node) {
            var value = layout.desc(node);
            if (!startsWithAny(value, FOLLOW_DESC_KEYS)) {
                return false;
            }
            /* `Followers` 是粉丝列表的入口，不是关注按钮 —— 前缀匹配会误命中 */
            return value.indexOf('Followers') !== 0;
        });
        return hits.length > 0 ? hits[0] : null;
    }

    /**
     * 作者头像节点。用来区分「已关注（按钮消失）」和「页面还没渲染」。
     * 实测 desc 形如 `Marcgagilang profile`。
     */
    function authorAvatar() {
        var hits = findByLabel(className('android.widget.ImageView'), function (node) {
            var value = layout.desc(node);
            return value !== '' && / profile$/i.test(value);
        });
        return hits.length > 0 ? hits[0] : null;
    }

    /**
     * 'following' | 'not-following' | 'unknown'
     *
     * ★ 「已关注」的唯一表现是**按钮整个消失**（实测），所以不能只看"找不到按钮"
     *   —— 页面没渲染完也找不到。用作者头像是否存在来区分这两种情况：
     *   头像在、按钮不在 = 已关注；两个都不在 = 页面还没好。
     */
    function followState() {
        if (followButton() !== null) {
            return 'not-following';
        }
        if (authorAvatar() !== null) {
            return 'following';
        }
        return 'unknown';
    }

    /**
     * 播放页判据。
     *
     * 教训（实测踩到）：**信息流首页也有 "Like video." 和 "Read or add comments" 这一竖排**，
     * 所以只看这两个会一路把首页判成播放页，整个流程直接跑歪。
     * 真正能区分"从搜索结果点进来的播放页"的是：
     *   - 左上角有返回箭头（首页没有）
     *   - 没有底部导航栏（首页有 Home/Friends/Inbox/Profile）
     * 四条同时成立才算播放页。
     */
    function onPlayerPage() {
        return commentButton() !== null &&
            likeButton() !== null &&
            backButton() !== null &&
            !bottomNavPresent();
    }

    function backButton() {
        var hits = findByLabel(className('android.widget.ImageView'), function (node) {
            return layout.desc(node) === 'Back';
        });
        return hits.length > 0 ? hits[0] : null;
    }

    /** 从 "Read or add comments. 150 comments" 里把 150 抠出来 */
    function commentCount() {
        var button = commentButton();
        if (!button) {
            return null;
        }
        var matched = layout.desc(button).match(/([\d][\d,.\s]*)\s*(?:comments?|条评论|评论)/i);
        if (!matched) {
            return null;
        }
        return parseInt(String(matched[1]).replace(/[^\d]/g, ''), 10);
    }

    /** 视频页底部的内联评论输入框（面板未打开时就是它） */
    function inlineInput() {
        var hits = findByLabel(className('android.widget.EditText'), function (node) {
            return equalsAny(layout.text(node) || layout.desc(node), COMMENT_PLACEHOLDER) &&
                topOf(node) > screenHeight() * 0.8;
        });
        return hits.length > 0 ? hits[0] : null;
    }

    /** 评论面板里的输入框（打开面板后会出现在屏幕中部） */
    function panelInput() {
        var hits = findByLabel(className('android.widget.EditText'), function (node) {
            var top = topOf(node);
            return top > screenHeight() * 0.45 && top < screenHeight() * 0.85;
        });
        return hits.length > 0 ? hits[0] : null;
    }

    function toolRowAnchor() {
        for (var i = 0; i < TOOL_ROW_ANCHORS.length; i += 1) {
            var node = layout.findOnce(desc(TOOL_ROW_ANCHORS[i]));
            if (node && layout.isVisible(node)) {
                return node;
            }
        }
        return null;
    }

    /**
     * 评论发送按钮。
     *
     * 它没有可用的文案（实测其 content-desc 是一个无关的账号串），图标是粉色箭头，
     * 所以只能靠**结构**定位：
     *   面板里"工具行"（表情/提及/语音那一行）的同高区域里，
     *   最靠右、且不属于右侧竖排动作栏（动作栏 right == 屏宽）的那个可点击按钮。
     *
     * 优先用 config.selectors.sendButtonId（若配置里给了 id），
     * 这样 TikTok 改版时改配置即可，不用改代码。
     */
    function sendButton(config) {
        var override = config && config.selectors && config.selectors.sendButtonId;
        if (override) {
            var byId = layout.findOnce(id(override));
            if (byId && layout.isVisible(byId)) {
                logger.info('comment', '发送按钮：使用配置 id ' + override);
                return byId;
            }
        }

        var anchor = toolRowAnchor();
        if (!anchor) {
            logger.warn('comment', '找不到面板工具行，无法结构化定位发送按钮');
            return null;
        }
        var bandTop = topOf(anchor);
        var bandBottom = bottomOf(anchor);
        var width = screenWidth();

        var best = null;
        var hits = findByLabel(className('android.widget.Button'), function (node) {
            var point = layout.center(node);
            if (point === null) {
                return false;
            }
            var box = node.bounds();
            if (box.top < bandTop || box.top > bandBottom) {
                return false;                 // 不在工具行高度带里
            }
            if (box.right > width - layout.SAFE_MARGIN) {
                return false;                 // 属于右侧竖排动作栏
            }
            return box.left >= width * 0.5;   // 必须是右半边
        });

        for (var i = 0; i < hits.length; i += 1) {
            if (best === null || hits[i].bounds().left > best.bounds().left) {
                best = hits[i];
            }
        }
        if (best) {
            logger.info('comment', '发送按钮：结构化定位 id=' +
                layout.shortId(best) + ' b=' + JSON.stringify(best.bounds()));
        }
        return best;
    }

    // ---------------------------------------------------------------- 评论列表

    /**
     * 评论列表面板顶部的计数，形如 "150 comments"。
     *
     * 为什么需要它：实测发现**视频页那个评论角标不一定会立刻刷新**
     * （发完评论后仍读回旧值），而评论列表头部的计数是即时的。
     * 所以"计数自增"这条证据要用列表头部的那个，而不是角标的。
     */
    function listCommentCount() {
        var hits = findByLabel(className('android.widget.TextView'), function (node) {
            return /^[\d,\.]+\s*(comments?|条评论)$/i.test(layout.text(node));
        });
        if (hits.length === 0) {
            return null;
        }
        return parseInt(layout.text(hits[0]).replace(/[^\d]/g, ''), 10);
    }

    /**
     * 评论面板是否处于打开状态。
     * 注意：点内联输入框打开的是"快捷面板"（有中部输入框），
     * 点评论角标打开的是"列表面板"（没有中部输入框，但有 "N comments" 头部）。
     * 两种都要认，否则 back() 会漏按、面板关不掉。
     */
    function commentPanelOpen() {
        return panelInput() !== null || listCommentCount() !== null;
    }

    /**
     * 评论列表里是否出现了某条完全一致的文案。
     *
     * 这里刻意**不设数量上限**：早先为了省事写成"只看前 25 条可见文本"，
     * 结果遍历顺序是"先视频页、后评论面板"，25 条全被视频页的文案占满了，
     * 评论条目根本没轮到，于是最强的那条证据永远拿不到。
     * 可见 TextView 也就几百个，全扫一遍的开销远小于"判错"的代价。
     */
    function commentListContains(value) {
        var hits = findByLabel(className('android.widget.TextView'), function (node) {
            return layout.text(node) === value;
        });
        return hits.length > 0;
    }

    /** 当前屏幕上所有可见的文本文案（按屏幕顺序） */
    function visibleTexts(limit) {
        var hits = findByLabel(className('android.widget.TextView'), function () { return true; });
        var texts = [];
        for (var i = 0; i < hits.length; i += 1) {
            var value = layout.text(hits[i]);
            if (value && value.length >= 2) {
                texts.push(value);
            }
            if (limit && texts.length >= limit) {
                break;
            }
        }
        return texts;
    }

    // ============================================================ ID 提取
    /*
     * 下面这一整段是 2026-10-20 在真机上逐页 dump 出来的锚点
     * （Pixel 5a / 1080x1920 / TikTok 47.1.4 / 英文界面）。**每条都是实测值**，
     * 不是猜的 —— 猜出来的选择器在这个项目里从来没有一次是对的。
     *
     * ★ 一个重要发现：这一片的**资源 id 是语义化的**（`tv_username` / `txt_desc` /
     *   `user_avatar`），与信息流那批混淆 id（`e4g`/`cn6`）完全不同。
     *   原因是这些页面来自 TikTok 的搜索/社交业务模块，用的是另一套布局。
     *   所以这里优先按 id 定位，文案只作为兜底（改版时 id 比文案更稳）。
     *
     * 实测到的三处文本陷阱：
     *   ① 用户名被 **FID 隔离符** 包裹：显示 `⁨ajman_fashion_week⁩`（U+2068/U+2069），
     *      肉眼看不见，`layout.sanitize` 也不剥（那不是零宽字符）→ 统一走 `parse.username`；
     *   ② 搜索用户列表里 **`tv_aweme_id` 装的是昵称**（id 名违反直觉），`tv_username` 才是 uid；
     *   ③ 粉丝列表与搜索列表的同义控件**id 不同**：
     *      搜索列表 `tv_username`/`tv_desc`，粉丝列表 `txt_desc`(uid)/`txt_user_name`(昵称)。
     */

    /** 是否在用户主页：有一个文案形如 "@xxx" 的可点 Button，且下面跟着三组数字 */
    function profileUsernameNode() {
        var hits = findByLabel(className('android.widget.Button'), function (node) {
            var value = layout.text(node);
            return value.charAt(0) === '@' && value.length > 1 &&
                value.length < 40 && topOf(node) < screenHeight() * 0.3;
        });
        return hits.length > 0 ? hits[0] : null;
    }

    /** 用户主页的昵称（在 @xxx 上面那一行） */
    function profileNicknameNode() {
        var userNode = profileUsernameNode();
        if (!userNode) {
            return null;
        }
        var userTop = topOf(userNode);
        var hits = findByLabel(className('android.widget.Button'), function (node) {
            var box = node.bounds();
            return box.top < userTop && box.bottom > userTop - screenHeight() * 0.12 &&
                layout.text(node) !== '' && layout.text(node).charAt(0) !== '@';
        });
        return hits.length > 0 ? hits[0] : null;
    }

    /** 用户页顶部三组数字的标签文案。英文界面实测为这三个词。 */
    var STAT_LABELS = {
        'Following': 'follow',
        'Followers': 'fans',
        'Likes': 'likes',
        '关注': 'follow',
        '粉丝': 'fans',
        '获赞': 'likes',
        'Abonnements': 'follow',
        'Abonnés': 'fans',
        "J'aime": 'likes'
    };

    /**
     * 用户页顶部三组数字：`{ follow: 343, fans: 594, likes: 2491 }`。
     *
     * 结构（实测）：每个数字是一个 LinearLayout，里面两个 TextView ——
     * 数字在上、标签在下。所以按"标签找容器、再取容器里的数字"读。
     * 注意**没有视频数**：这个页面只显示 关注/粉丝/获赞 三组，这是平台行为。
     */
    function statNumbers() {
        var out = { follow: null, fans: null, likes: null };
        var parse = TikTokAuto.parse;
        var labels = findByLabel(className('android.widget.TextView'), function () { return true; });

        for (var i = 0; i < labels.length; i += 1) {
            var labelText = layout.text(labels[i]);
            var key = STAT_LABELS[labelText];
            if (!key) {
                continue;
            }
            /* 标签必须在页面上部（三组数字区），否则可能是别处长文本里恰好含这个词 */
            if (topOf(labels[i]) > screenHeight() * 0.25) {
                continue;
            }
            var container = parentOf(labels[i]);
            var value = container ? numberInside(container) : null;
            if (value === null) {
                value = parse.count(labelText);
            }
            if (out[key] === null) {
                out[key] = value;
            }
        }
        return out;
    }

    function parentOf(node) {
        try {
            return node.parent();
        } catch (ignored) {
            return null;
        }
    }

    /** 在一个容器里找那个"纯数字"的 TextView，解析成整数 */
    function numberInside(container) {
        var parse = TikTokAuto.parse;
        var found = null;
        var walk = [container];
        var guard = 0;
        while (walk.length > 0 && guard < 30) {
            guard += 1;
            var node = walk.shift();
            if (!node) {
                continue;
            }
            var value = layout.text(node);
            if (value !== '' && /^[\d,.\s]+[kKmMbBwW万萬亿億]?$/.test(value)) {
                var parsed = parse.count(value);
                if (parsed !== null && (found === null || parsed > found)) {
                    found = parsed;
                }
            }
            var count = 0;
            try { count = node.childCount(); } catch (ignored) { count = 0; }
            for (var i = 0; i < count; i += 1) {
                try { walk.push(node.child(i)); } catch (ignoredToo) { /* 遍历中失效就跳过 */ }
            }
        }
        return found;
    }

    /** 用户主页的个签：页面中上部一段较长的可点文本（实测是个 Button，不是 TextView） */
    function profileSignatureNode() {
        var hits = findByLabel(className('android.widget.Button'), function (node) {
            var value = layout.text(node);
            var box = node.bounds();
            return value.length >= 4 && value.charAt(0) !== '@' &&
                box.top > screenHeight() * 0.22 && box.top < screenHeight() * 0.34 &&
                (box.right - box.left) > screenWidth() * 0.4;
        });
        return hits.length > 0 ? hits[0] : null;
    }

    /**
     * 私密账号提示。
     * 实测：私密账号的主页会在视频区位置显示一行提示（"This account is private" 等）。
     * 这里只在**视频网格明显不存在**时才认这条，避免把正常账号的某条视频文案误判成提示。
     */
    function privateHint() {
        var keys = ['private', "isn't available", 'no videos', 'No videos'];
        var texts = visibleTexts(0);
        for (var i = 0; i < texts.length; i += 1) {
            for (var j = 0; j < keys.length; j += 1) {
                if (String(texts[i]).toLowerCase().indexOf(String(keys[j]).toLowerCase()) >= 0) {
                    return texts[i];
                }
            }
        }
        return '';
    }

    /** 用户主页的视频网格格子数（判断"有没有内容"用，不用于视频量门槛） */
    function videoGridCount() {
        var hits = findByLabel(className('android.widget.FrameLayout'), function (node) {
            var point = layout.center(node);
            return point !== null && point.y > screenHeight() * 0.33;
        });
        return hits.length;
    }

    /** 用户主页上的「关注/粉丝」入口（点它打开列表页） */
    function statEntry(which) {
        var wanted = which === 'following' ? 'follow' : 'fans';
        var labels = findByLabel(className('android.widget.TextView'), function () { return true; });
        for (var i = 0; i < labels.length; i += 1) {
            if (STAT_LABELS[layout.text(labels[i])] !== wanted) {
                continue;
            }
            if (topOf(labels[i]) > screenHeight() * 0.25) {
                continue;
            }
            /* 可点的是外层容器，标签自己不可点 */
            return layout.clickableAncestor(labels[i]) || parentOf(labels[i]);
        }
        return null;
    }

    /**
     * 粉丝/关注列表页的页签（"Following 343" / "Followers 594" / "Suggested"）。
     *
     * 实测这个列表是**从用户页点进来的一张覆盖页**，顶部有三个页签，
     * 可以直接在两个页签之间切换 —— 所以"先收粉丝再收关注"不必来回退。
     */
    function userListTabs() {
        var out = [];
        var hits = findByLabel(className('android.widget.TextView'), function (node) {
            var value = layout.text(node);
            return /^(Following|Followers|Suggested|关注|粉丝|推荐)\b/.test(value) &&
                topOf(node) < screenHeight() * 0.16;
        });
        for (var i = 0; i < hits.length; i += 1) {
            var value = layout.text(hits[i]);
            var key = value.indexOf('Follower') === 0 || value.indexOf('粉丝') === 0 ? 'fans'
                : (value.indexOf('Suggested') === 0 || value.indexOf('推荐') === 0 ? 'suggested' : 'following');
            out.push({
                key: key,
                label: value,
                node: layout.clickableAncestor(hits[i]) || hits[i]
            });
        }
        return out;
    }

    /** 当前列表页选中的是哪个页签（用 selected 属性判，实测可用） */
    function selectedListTab() {
        var tabs = userListTabs();
        for (var i = 0; i < tabs.length; i += 1) {
            var selected = false;
            try {
                selected = tabs[i].node.selected() === true || tabs[i].node.isSelected() === true;
            } catch (ignored) {
                selected = false;
            }
            if (selected) {
                return tabs[i].key;
            }
        }
        /* selected 读不到时退回文案判断：选中态的页签文案与未选中态无差异，
         * 所以这里只能返回 unknown，由调用方用"点完再看内容变没变"确认。 */
        return 'unknown';
    }

    /**
     * 粉丝/关注列表里的每一行。
     *
     * 实测结构：`LinearLayout`（整行可点）> `TextView txt_user_name`（昵称）
     * + `TextView txt_desc`（**uid**）+ `Button ubp`（Follow）。
     * 注意与搜索用户列表**id 不同**（那边是 tv_username/tv_desc）。
     *
     * 返回的 `node` 是行容器，点它进用户页；`x` 是"安全点击的横向位置"——
     * 靠左，避开右侧的 Follow 按钮（实测按钮左边界 x≈872）。
     */
    function userListRows() {
        var parse = TikTokAuto.parse;
        var rows = [];
        var uidNodes = findByLabel(className('android.widget.TextView'), function (node) {
            return resourceIdOf(node).indexOf('txt_desc') >= 0 && layout.text(node) !== '';
        });

        /* 有的版本 uid 放在 txt_user_name、昵称放在 txt_desc，所以按"哪个像 uid"再兜一层 */
        if (uidNodes.length === 0) {
            uidNodes = findByLabel(className('android.widget.TextView'), function (node) {
                return resourceIdOf(node).indexOf('txt_user_name') >= 0 &&
                    parse.looksLikeUsername(layout.text(node));
            });
        }

        for (var i = 0; i < uidNodes.length; i += 1) {
            var uidNode = uidNodes[i];
            var uid = parse.username(layout.text(uidNode));
            if (!parse.looksLikeUsername(uid)) {
                continue;
            }
            var row = findRowContainer(uidNode);
            var box = row ? row.bounds() : uidNode.bounds();
            rows.push({
                uid: uid,
                nickname: nicknameOf(uidNode, row),
                node: row || uidNode,
                top: box.top,
                x: Math.round(box.left + (box.right - box.left) * 0.3),
                y: Math.round((box.top + box.bottom) / 2)
            });
        }
        rows.sort(function (a, b) { return a.top - b.top; });
        return rows;
    }

    function resourceIdOf(node) {
        return layout.resourceId(node);
    }

    /** 从 uid 文本往上找"整行"容器（高度落在一行的高度区间内） */
    function findRowContainer(uidNode) {
        var cursor = uidNode;
        var depth = 0;
        while (cursor && depth < 5) {
            var box = cursor.bounds();
            var rowHeight = box.bottom - box.top;
            if (layout.isClickable(cursor) && rowHeight >= screenHeight() * 0.05 &&
                rowHeight <= screenHeight() * 0.12) {
                return cursor;
            }
            cursor = parentOf(cursor);
            depth += 1;
        }
        return layout.clickableAncestor(uidNode) || parentOf(uidNode);
    }

    /** 行里的昵称：找同一容器内的另一个 TextView（不是 uid 那个） */
    function nicknameOf(uidNode, row) {
        if (!row) {
            return '';
        }
        var found = '';
        var walk = [row];
        var guard = 0;
        while (walk.length > 0 && guard < 40) {
            guard += 1;
            var node = walk.shift();
            if (!node) {
                continue;
            }
            var id = resourceIdOf(node);
            var value = layout.text(node);
            if (value !== '' && (id.indexOf('txt_user_name') >= 0 || id.indexOf('tv_aweme_id') >= 0)) {
                found = value;
                break;
            }
            var count = 0;
            try { count = node.childCount(); } catch (ignored) { count = 0; }
            for (var i = 0; i < count; i += 1) {
                try { walk.push(node.child(i)); } catch (ignoredToo) { /* 跳过 */ }
            }
        }
        return found;
    }

    /**
     * 搜索结果的「用户」列表行。
     *
     * 实测结构：`Button`（整行可点）> `TextView tv_username`（uid）
     * + `TextView tv_aweme_id`（**昵称**，id 名违反直觉）+ `TextView tv_desc`（"594 followers · 2.5K likes"）。
     *
     * 额外好处：`tv_desc` 里就有粉丝数与获赞数 —— 所以按数量筛选时
     * **这一条来源不必逐个打开用户页**（其余来源没有这个信息）。
     */
    function usersResultRows() {
        var parse = TikTokAuto.parse;
        var rows = [];
        var uidNodes = findByLabel(className('android.widget.TextView'), function (node) {
            return resourceIdOf(node).indexOf('tv_username') >= 0 && layout.text(node) !== '';
        });

        for (var i = 0; i < uidNodes.length; i += 1) {
            var uid = parse.username(layout.text(uidNodes[i]));
            if (!parse.looksLikeUsername(uid)) {
                continue;
            }
            var box = uidNodes[i].bounds();
            var desc = '';
            var nickname = '';
            var rowNode = null;

            /* 向上两层找行容器，再在容器里读昵称与计数 */
            var cursor = uidNodes[i];
            for (var up = 0; up < 4 && cursor; up += 1) {
                cursor = parentOf(cursor);
                if (cursor && layout.isClickable(cursor)) {
                    rowNode = cursor;
                    break;
                }
            }
            if (rowNode) {
                var children = findByLabelInside(rowNode, className('android.widget.TextView'));
                for (var j = 0; j < children.length; j += 1) {
                    var id = resourceIdOf(children[j]);
                    var value = layout.text(children[j]);
                    if (id.indexOf('tv_aweme_id') >= 0) {
                        nickname = value;
                    } else if (id.indexOf('tv_desc') >= 0) {
                        desc = value;
                    }
                }
                var rowBox = rowNode.bounds();
                box = { left: rowBox.left, top: rowBox.top, right: rowBox.right, bottom: rowBox.bottom };
            }

            rows.push({
                uid: uid,
                nickname: nickname,
                node: rowNode || uidNodes[i],
                top: box.top,
                fans: parseFollowerLine(desc, 'followers'),
                likes: parseFollowerLine(desc, 'likes'),
                x: Math.round(box.left + (box.right - box.left) * 0.3),
                y: Math.round((box.top + box.bottom) / 2)
            });
        }
        rows.sort(function (a, b) { return a.top - b.top; });
        return rows;
    }

    /** 在一个节点内部找符合条件的子孙（不含自身之外的范围） */
    function findByLabelInside(rootNode, selector) {
        var out = [];
        var collection = selector.find();
        for (var i = 0; i < collection.size(); i += 1) {
            var node = collection.get(i);
            var cursor = node;
            var depth = 0;
            var inside = false;
            while (cursor && depth < 12) {
                if (cursor === rootNode) {
                    inside = true;
                    break;
                }
                cursor = parentOf(cursor);
                depth += 1;
            }
            if (inside) {
                out.push(node);
            }
        }
        return out;
    }

    /**
     * 从 "594 followers · 2.5K likes" 里分别抠出两个数。
     * 分隔符实测是 " · "（中点），但不同语言/版本可能不同，所以按**关键词**切而不是按分隔符。
     */
    function parseFollowerLine(text, which) {
        var parse = TikTokAuto.parse;
        if (!text) {
            return null;
        }
        var parts = String(text).split(/[·•|]/);
        for (var i = 0; i < parts.length; i += 1) {
            var part = parts[i];
            var lower = part.toLowerCase();
            if (which === 'followers' && (lower.indexOf('follower') >= 0 || lower.indexOf('粉丝') >= 0)) {
                return parse.count(part);
            }
            if (which === 'likes' && (lower.indexOf('like') >= 0 || lower.indexOf('获赞') >= 0)) {
                return parse.count(part);
            }
        }
        return null;
    }

    /** 播放页底部的作者 uid（实测：`Button l2m` 的 text = "@2131823375"） */
    function playerAuthorUid() {
        var parse = TikTokAuto.parse;
        var hits = findByLabel(className('android.widget.Button'), function (node) {
            var value = layout.text(node);
            return value.charAt(0) === '@' && parse.looksLikeUsername(value);
        });
        return hits.length > 0 ? parse.username(layout.text(hits[0])) : '';
    }

    /**
     * 评论区里的每一条：**只有昵称，没有 uid**（实测 2026-10-20）。
     *
     * 所以"从评论区取评论者"必须逐个点头像/昵称进用户页 —— 成本比列表高一个数量级。
     * 这里返回每个人可点的节点（头像 ImageView `blm`）与昵称，供上层决定怎么进。
     */
    function commentRowers() {
        var out = [];
        var avatars = findByLabel(className('android.widget.ImageView'), function (node) {
            return resourceIdOf(node).indexOf('blm') >= 0;
        });
        for (var i = 0; i < avatars.length; i += 1) {
            var box = avatars[i].bounds();
            /* 头像必须在评论列表区域内（屏幕中下部），不是视频右上角的作者头像 */
            if (box.top < screenHeight() * 0.38) {
                continue;
            }
            out.push({
                node: avatars[i],
                top: box.top,
                x: Math.round((box.left + box.right) / 2),
                y: Math.round((box.top + box.bottom) / 2)
            });
        }
        out.sort(function (a, b) { return a.top - b.top; });
        return out;
    }

    /** 结果页的某个页签当前是否选中（Users 页签用） */
    function resultTabSelected(name) {
        var node = resultTab(name);
        if (!node) {
            return false;
        }
        try {
            return node.selected() === true || node.isSelected() === true;
        } catch (ignored) {
            return false;
        }
    }

    /**
     * ID 提取这条链路自己在用的页面判定。
     *
     * **刻意与 pageState() 分开**：pageState 是视频链路的判据，
     * 往里加分支就有可能把"播放页 vs 结果页"的老判定带歪（方案 §12 明确要求回归）。
     * 新开一个函数，视频链路一行都不用动。
     *
     * @returns 'profile' | 'user-list' | 'users-results' | 'comment-panel' | 'search' | 'feed' | 'other'
     */
    function idPageState() {
        if (commentPanelOpen()) {
            return 'comment-panel';
        }
        if (profileUsernameNode() !== null) {
            return 'profile';
        }
        if (userListTabs().length >= 2 && userListRows().length > 0) {
            return 'user-list';
        }
        if (usersResultRows().length > 0) {
            return 'users-results';
        }
        if (searchInput() !== null) {
            return 'search';
        }
        if (bottomNavPresent()) {
            return 'feed';
        }
        return 'other';
    }

    // ---------------------------------------------------------------- 页面状态

    /**
     * 判定当前处于哪个页面。
     * 顺序即优先级：播放页最特征化先判，信息流最宽松最后判。
     */
    function pageState() {
        // 评论面板要最先判：面板一盖上来，播放页的返回箭头就被遮住了，
        // 于是 onPlayerPage() 会变 false，整个页面掉进 unknown 再也出不来
        // （实测踩到：脚本自己打开评论列表校验后没关掉，下一轮就彻底迷路）。
        if (commentPanelOpen()) {
            return 'comment-panel';
        }
        if (onPlayerPage()) {
            return 'player';
        }
        if (resultTabStripPresent()) {
            return 'results';
        }
        // 搜索页判据：顶部有输入框，且**没有**结果页的页签条。
        // 早先还要求存在搜索历史行，结果"历史为空 / 已被清空"时整页被判成 unknown，
        // 于是 ensureFeed 一路僵住。页签条的有无已经足够区分搜索页和结果页。
        if (searchInput() !== null && !resultTabStripPresent() && !bottomNavPresent()) {
            return 'search';
        }
        if (searchEntry() !== null && bottomNavPresent()) {
            return 'feed';
        }
        return 'unknown';
    }

    /** 排障用：把当前可见的关键节点打出来 */
    function describeScreen(tag) {
        var nodes = [];
        var classes = ['android.widget.Button', 'android.widget.EditText', 'android.widget.ImageView', 'android.widget.TextView'];
        for (var i = 0; i < classes.length; i += 1) {
            var collection = className(classes[i]).find();
            for (var j = 0; j < collection.size(); j += 1) {
                if (layout.isVisible(collection.get(j))) {
                    nodes.push(collection.get(j));
                }
            }
        }
        logger.info(tag || 'screen', layout.describe(nodes, 40));
    }

    return {
        PKG: PKG,
        pageState: pageState,
        searchEntry: searchEntry,
        searchInput: searchInput,
        searchSubmit: searchSubmit,
        searchHistoryPresent: searchHistoryPresent,
        bottomNavPresent: bottomNavPresent,
        resultTab: resultTab,
        resultTabStripPresent: resultTabStripPresent,
        videoCards: videoCards,
        commentButton: commentButton,
        likeButton: likeButton,
        likedButton: likedButton,
        likeIcon: likeIcon,
        likeState: likeState,
        followButton: followButton,
        authorAvatar: authorAvatar,
        followState: followState,
        onPlayerPage: onPlayerPage,
        backButton: backButton,
        commentCount: commentCount,
        inlineInput: inlineInput,
        panelInput: panelInput,
        toolRowAnchor: toolRowAnchor,
        sendButton: sendButton,
        listCommentCount: listCommentCount,
        commentPanelOpen: commentPanelOpen,
        commentListContains: commentListContains,
        visibleTexts: visibleTexts,
        describeScreen: describeScreen,

        /* —— ID 提取（2026-10-20 真机实测锚点，见上面的长注释） —— */
        profileUsernameNode: profileUsernameNode,
        profileNicknameNode: profileNicknameNode,
        profileSignatureNode: profileSignatureNode,
        statNumbers: statNumbers,
        statEntry: statEntry,
        privateHint: privateHint,
        videoGridCount: videoGridCount,
        userListTabs: userListTabs,
        selectedListTab: selectedListTab,
        userListRows: userListRows,
        usersResultRows: usersResultRows,
        playerAuthorUid: playerAuthorUid,
        commentRowers: commentRowers,
        resultTabSelected: resultTabSelected,
        idPageState: idPageState
    };
}());


/* ============================== src/player.js ============================== */
/**
 * player.js — 「看视频」这件事：播放存活探测 + 有界观看
 *
 * 需求原话是"随机观看 10-35 秒，且不单靠 sleep"。
 * 为什么裸 sleep 不行：sleep(20000) 只保证**墙上时钟**走了 20 秒，
 * 它不关心这 20 秒里视频是否卡在加载、是否弹了窗、是否被切走。
 * 网络一抖，sleep 出来的"观看"就是假的。
 *
 * 这里的做法：把"观看"实现成一个**带守卫的截止时间循环**——
 *   1. 先等"播放真的开始"（有界等待，而不是假定它已经开始）；
 *   2. 观看期间持续做两件事：
 *      a) 校验"还在播放页"（页面身份漂移就立刻记账，连续漂移就放弃并上报）；
 *      b) 按固定节拍采样**播放存活证据**，连续多次无证据即判定卡顿，尝试一次唤醒；
 *   3. 循环里那个 sleep 是**轮询节拍**（多久检查一次），不是"等待多少秒"。
 *
 * 播放存活证据（按可用性排序，可配置）：
 *   - useAudio : AudioManager.isMusicActive() —— 不依赖截图权限，实测可用
 *   - usePixels: captureScreen() 两点像素差 —— 最强，但 Android 14 需要 MediaProjection 授权
 * 两者都不可用时，脚本**不会假装成功**：会退化为"页面守卫"，并在结果里
 * 明确标记 probeMode='page-guard-only'，让上层知道这次的"观看"可信度较低。
 *
 * 依赖：TikTokAuto.logger、TikTokAuto.layout、TikTokAuto.tiktok、TikTokAuto.wait、TikTokAuto.ui
 */
TikTokAuto.player = (function () {
    'use strict';

    var PIXEL_SAMPLE_POINTS = [
        [0.5, 0.35], [0.5, 0.5], [0.5, 0.65], [0.25, 0.45], [0.75, 0.45]
    ];

    // ------------------------------------------------------------------ 证据源

    function createAudioProbe() {
        var manager = null;
        try {
            if (typeof context !== 'undefined' && context) {
                manager = context.getSystemService('audio');
            }
        } catch (error) {
            manager = null;
        }
        if (!manager) {
            return null;
        }
        return {
            name: 'audio',
            read: function () {
                try {
                    return manager.isMusicActive() === true;
                } catch (error) {
                    return false;
                }
            }
        };
    }

    function createPixelProbe() {
        var first = null;
        function grab() {
            var image = captureScreen();
            if (!image) {
                return null;
            }
            var width = image.getWidth();
            var height = image.getHeight();
            var samples = [];
            for (var i = 0; i < PIXEL_SAMPLE_POINTS.length; i += 1) {
                var x = Math.floor(width * PIXEL_SAMPLE_POINTS[i][0]);
                var y = Math.floor(height * PIXEL_SAMPLE_POINTS[i][1]);
                samples.push(image.pixel(x, y));
            }
            return samples.join(',');
        }
        try {
            first = grab();
        } catch (error) {
            return null; // 没有 MediaProjection 授权，直接放弃这条证据源
        }
        if (first === null) {
            return null;
        }
        return {
            name: 'pixels',
            read: function () {
                try {
                    var now = grab();
                    return now !== null && now !== first;
                } catch (error) {
                    return false;
                }
            }
        };
    }

    /**
     * 组装可用的探测源。
     * 返回的 probeMode 会一路带到最终结果里——**不要**把降级悄悄藏起来。
     */
    function createProbe(config) {
        var sources = [];
        if (config.probe.useAudio) {
            var audio = createAudioProbe();
            if (audio) {
                sources.push(audio);
            }
        }
        if (config.probe.usePixels) {
            var pixels = createPixelProbe();
            if (pixels) {
                sources.push(pixels);
            }
        }
        return {
            mode: sources.length === 0 ? 'page-guard-only' : sources.map(function (s) { return s.name; }).join('+'),
            degraded: sources.length === 0,
            /** 任一证据源报"在动"就算活着 */
            alive: function () {
                for (var i = 0; i < sources.length; i += 1) {
                    if (sources[i].read()) {
                        return true;
                    }
                }
                return false;
            }
        };
    }

    // ------------------------------------------------------------------ 等待播放

    /** 等播放真正开始（而不是假定点开就在播） */
    function waitPlaybackStart(config, step) {
        var logger = TikTokAuto.logger;
        var probe = createProbe(config);
        if (probe.degraded) {
            logger.warn(step, '没有可用的播放证据源（无音频/无截图权限），退化为页面守卫模式');
            return { started: false, probe: probe };
        }
        var started = TikTokAuto.wait.until(function () {
            return probe.alive() ? true : null;
        }, config.timeouts.playbackStartMs, config.probe.pollTickMs);

        if (started) {
            logger.info(step, '检测到播放已开始（证据源 ' + probe.mode + '）');
        } else {
            logger.warn(step, '等待 ' + config.timeouts.playbackStartMs + 'ms 未检测到播放证据，仍继续（可能是静音视频）');
        }
        return { started: started === true, probe: probe };
    }

    // ------------------------------------------------------------------ 观看

    function randomInt(min, max) {
        return Math.floor(Math.random() * (max - min + 1)) + min;
    }

    /**
     * 观看视频。
     *
     * @param config 生效配置
     * @param options { step, onInterrupt }
     * @returns 观看报告（对象，不是布尔——上层需要知道"为什么/可信度如何"）
     */
    function watch(config, options) {
        var settings = options || {};
        var step = settings.step || 'watch';
        var logger = TikTokAuto.logger;
        var tiktok = TikTokAuto.tiktok;

        var targetMs = randomInt(config.watch.minMs, config.watch.maxMs);
        var start = waitPlaybackStart(config, step);
        var probe = start.probe;

        var beganAt = Date.now();
        var deadline = beganAt + targetMs;
        var tickMs = config.probe.pollTickMs;
        var nextLivenessAt = beganAt + config.probe.livenessIntervalMs;

        var stalls = 0;
        var offPage = 0;
        var maxOffPage = 3;
        var nudges = 0;
        var aborted = null;

        logger.info(step, '开始观看，计划 ' + targetMs + 'ms（区间 ' +
            config.watch.minMs + '-' + config.watch.maxMs + 'ms），证据源=' + probe.mode);

        while (Date.now() < deadline) {
            // (a) 页面身份守卫：不在播放页就不是"在看视频"
            if (!tiktok.onPlayerPage()) {
                offPage += 1;
                logger.warn(step, '已离开播放页（第 ' + offPage + ' 次检测）');
                if (offPage >= maxOffPage) {
                    aborted = 'left-player-page';
                    break;
                }
            } else {
                offPage = 0;
            }

            // (b) 播放存活采样
            if (Date.now() >= nextLivenessAt) {
                nextLivenessAt = Date.now() + config.probe.livenessIntervalMs;
                if (!probe.degraded) {
                    if (probe.alive()) {
                        stalls = 0;
                    } else {
                        stalls += 1;
                        logger.warn(step, '未检测到播放证据（连续 ' + stalls + '/' + config.probe.stallTolerance + '）');
                        if (stalls >= config.probe.stallTolerance) {
                            // 只尝试一次唤醒，不无限戳屏幕——那会把页面点出别的东西
                            if (nudges < 1) {
                                nudge(step);
                                nudges += 1;
                                stalls = 0;
                            } else {
                                logger.warn(step, '判定卡顿且唤醒无效，提前结束观看');
                                aborted = 'stalled';
                                break;
                            }
                        }
                    }
                }
            }

            TikTokAuto.wait.tick(tickMs);
        }

        var actualMs = Date.now() - beganAt;
        var report = {
            requestedMs: targetMs,
            actualMs: actualMs,
            probeMode: probe.mode,
            degraded: probe.degraded,
            nudges: nudges,
            aborted: aborted,
            completed: aborted === null && actualMs >= targetMs - tickMs
        };

        if (report.completed) {
            logger.info(step, '观看完成 ' + actualMs + 'ms / 目标 ' + targetMs + 'ms');
        } else {
            logger.warn(step, '观看未按计划完成：' + JSON.stringify(report));
        }
        return report;
    }

    /** 轻点视频区域一次，尝试恢复播放（不会点到右侧动作栏） */
    function nudge(step) {
        var layout = TikTokAuto.layout;
        var point = { x: Math.floor(layout.screen().width * 0.5), y: Math.floor(layout.screen().height * 0.4) };
        TikTokAuto.logger.info(step, '尝试轻点画面恢复播放 @(' + point.x + ',' + point.y + ')');
        TikTokAuto.ui.tapPoint(point.x, point.y);
        TikTokAuto.wait.tick(300);
    }

    /** 等播放页就绪（点开卡片之后、开始计时之前） */
    function waitPlayerReady(config, step) {
        var logger = TikTokAuto.logger;
        var tiktok = TikTokAuto.tiktok;
        var ready = TikTokAuto.wait.waitFor(step, function () {
            return tiktok.onPlayerPage() ? true : null;
        }, config.timeouts.playerReadyMs, config.probe.pollTickMs);

        if (ready) {
            TikTokAuto.wait.waitQuiet(function () {
                return TikTokAuto.layout.signature();
            }, { maxMs: 3000, tickMs: 250, stableTimes: 3 });
        }
        return ready === true;
    }

    return {
        createProbe: createProbe,
        waitPlaybackStart: waitPlaybackStart,
        waitPlayerReady: waitPlayerReady,
        watch: watch,
        randomInt: randomInt
    };
}());


/* ============================== src/comment.js ============================== */
/**
 * comment.js — 评论：挑文案 → 打开面板 → 输入 → 发送 → **验证真的发出去了**
 *
 * 关键设计：发送后必须**验证**，而且要"多条证据同时成立"才敢说成功。
 * 只看着"面板关掉了"就宣布成功，是这类脚本最典型的假阳性来源
 * （面板也可能因为别的原因关掉，而评论被平台拒了）。
 *
 * 实测有效的两条证据：
 *   1. 评论计数自增： "Read or add comments. 149 comments" → "150 comments"
 *   2. 输入框被清空并恢复占位符 "Add comment..."，且面板收起
 * 默认以"计数自增"为强证据；计数有延迟时退回到第 2 条（可用
 * comments.strictPostCheck 强制只认第 1 条）。
 *
 * 依赖：TikTokAuto.logger、TikTokAuto.layout、TikTokAuto.ui、TikTokAuto.wait、TikTokAuto.tiktok
 */
TikTokAuto.comment = (function () {
    'use strict';

    var PLACEHOLDER = 'Add comment...';

    /** 从评论池里随机挑一条，尽量不重复（池子用完了就允许重复并告警） */
    function pickText(config, used, step) {
        var pool = config.comments.pool;
        var candidates = [];
        for (var i = 0; i < pool.length; i += 1) {
            if (!config.comments.avoidRepeatWithinRun || used.indexOf(pool[i]) === -1) {
                candidates.push(pool[i]);
            }
        }
        if (candidates.length === 0) {
            TikTokAuto.logger.warn(step || 'comment', '评论池已用尽，本轮允许重复');
            candidates = pool;
        }
        return candidates[Math.floor(Math.random() * candidates.length)];
    }

    /** 打开评论面板：点内联输入框 → 等面板输入框出现 */
    function openPanel(config, step) {
        var story = step || 'openCommentPanel';
        var logger = TikTokAuto.logger;
        var tiktok = TikTokAuto.tiktok;

        if (tiktok.panelInput() !== null) {
            logger.info(story, '评论面板已经是打开状态');
            return true;
        }

        var inline = tiktok.inlineInput();
        if (!inline) {
            logger.error(story, '找不到评论入口（内联输入框）');
            return false;
        }
        TikTokAuto.ui.clickNode(inline, story);

        var ready = TikTokAuto.wait.waitFor(story, function () {
            return tiktok.panelInput() !== null ? true : null;
        }, config.timeouts.panelReadyMs, config.probe.pollTickMs);

        return ready === true;
    }

    /** 收起面板（只在确认面板处于打开状态时调用，绝不无脑 back） */
    function closePanel(step) {
        var tiktok = TikTokAuto.tiktok;
        if (!tiktok.commentPanelOpen()) {
            return false;
        }
        TikTokAuto.logger.info(step || 'closeCommentPanel', '收起评论面板');
        back();
        TikTokAuto.wait.until(function () {
            return tiktok.commentPanelOpen() ? null : true;
        }, 4000, 200);
        return true;
    }

    /**
     * 发送一条评论。
     *
     * @returns {ok, via, text, countBefore, countAfter, reason}
     */
    function post(config, text, step) {
        var story = step || 'postComment';
        var logger = TikTokAuto.logger;
        var tiktok = TikTokAuto.tiktok;

        var countBefore = tiktok.commentCount();
        var before = { countBefore: countBefore };

        if (!openPanel(config, story)) {
            return { ok: false, via: 'panel-not-opened', text: text, reason: '评论面板未打开' };
        }

        var input = tiktok.panelInput();
        var typed = TikTokAuto.ui.typeInto(input, text, story);
        if (!typed.ok) {
            return { ok: false, via: 'type-failed', text: text, reason: '输入框回读不一致' };
        }

        if (config.runtime.dryRun) {
            logger.warn(story, 'dryRun 模式：已输入但**不发送**，清空并收起面板。待发文案=' + JSON.stringify(text));
            var restore = tiktok.panelInput();
            if (restore) {
                restore.setText('');
            }
            TikTokAuto.wait.tick(300);
            closePanel(story);
            return { ok: true, via: 'dry-run', text: text, countBefore: countBefore, countAfter: countBefore, skipped: true };
        }

        var button = tiktok.sendButton(config);
        if (!button) {
            return { ok: false, via: 'send-button-not-found', text: text, reason: '定位不到发送按钮' };
        }
        TikTokAuto.ui.clickNode(button, story);

        return awaitOutcome(config, text, before, story);
    }

    /**
     * 等待并判定"评论是否真的发出去了"，输出**带置信度**的结论。
     *
     * 证据分三级，从强到弱：
     *   高  comment-list      —— 评论列表里真的出现了这条文案（地面真相）
     *   中  comment-count     —— 列表头部计数自增
     *   低  panel-closed      —— 面板收起 + 输入框复位为占位符
     *
     * 为什么不能只用计数（实测踩到）：视频页那个评论角标不一定会立刻刷新，
     * 明明发成功却读回旧值。反过来，只看"面板关了"又可能被平台拒评骗过。
     * 所以用 waitFor 逐级升级证据，并把最终置信度**如实**报给上层。
     */
    function awaitOutcome(config, text, before, step) {
        var logger = TikTokAuto.logger;
        var tiktok = TikTokAuto.tiktok;

        // 必要条件：面板收起且输入框复位
        var closed = TikTokAuto.wait.waitFor(step, function () {
            if (tiktok.panelInput() !== null) {
                return null;
            }
            return tiktok.inlineInput() !== null ? true : null;
        }, config.timeouts.postMs, config.probe.pollTickMs);

        if (closed === null) {
            logger.error(step, '发送后面板未收起，疑似未发布成功');
            closePanel(step);
            return { ok: false, via: 'panel-still-open', text: text, reason: '发送后面板没有收起' };
        }

        // 中级证据：评论数自增。
        // **必须"等"而不是"看一眼"**——实测角标有延迟：发布返回后立刻读还是旧值，
        // 大约 1~2 秒后才 +1。看一眼就下结论的话，明明发成功了也会被判成弱证据。
        var counted = TikTokAuto.wait.waitFor(step, function () {
            var after = tiktok.commentCount();
            if (after === null || before.countBefore === null) {
                return null;
            }
            return after !== before.countBefore ? after : null;
        }, config.timeouts.countRefreshMs, 400);

        if (counted !== null) {
            logger.info(step, '评论已发布（计数自增）' + before.countBefore + '→' + counted + ' ' + JSON.stringify(text));
            return {
                ok: true, via: 'comment-count', confidence: 'medium', text: text,
                countBefore: before.countBefore, countAfter: counted
            };
        }

        // 高级证据：去评论列表里找这条文案（地面真相）
        if (config.comments.verifyInList) {
            var inList = verifyInCommentList(config, text, before, step);
            if (inList) {
                logger.info(step, '评论已发布（列表确认 via=' + inList.via + '）内容=' +
                    JSON.stringify(text) + ' 计数=' + inList.count);
                return {
                    ok: true, via: 'comment-list', confidence: 'high', text: text,
                    countBefore: before.countBefore, countAfter: inList.count
                };
            }
            if (config.comments.strictPostCheck) {
                logger.error(step, '严格校验开启但评论列表里找不到该文案，判定为失败');
                return {
                    ok: false, via: 'not-found-in-list', text: text,
                    countBefore: before.countBefore, countAfter: tiktok.commentCount(),
                    reason: '评论列表里找不到刚发布的文案'
                };
            }
        }

        logger.warn(step, '评论已发布，但只有弱证据（面板收起）。计数=' +
            before.countBefore + '→' + tiktok.commentCount() + ' 内容=' + JSON.stringify(text));
        return {
            ok: true, via: 'panel-closed-and-input-reset', confidence: 'low', text: text,
            countBefore: before.countBefore, countAfter: tiktok.commentCount()
        };
    }

    /**
     * 打开评论列表，找这条评论是否在列表里。
     * 返回 {count} 或 null。无论成败都会把面板收回去，不污染后续步骤。
     *
     * 为什么要"重试 + 等页面安静"：紧跟着发布之后点评论角标，面板还在收起动画里，
     * 这一下点击会被吞掉（实测：列表死活不出来，等到超时）。
     * 所以每次点击前先等签名稳定，并且允许最多点三次。
     */
    function verifyInCommentList(config, text, before, step) {
        var tiktok = TikTokAuto.tiktok;
        var logger = TikTokAuto.logger;
        var clickAttempts = 0;
        var maxClicks = 3;
        var deadline = Date.now() + config.timeouts.panelReadyMs;

        while (Date.now() < deadline) {
            var headerCount = tiktok.listCommentCount();
            if (headerCount !== null) {
                // 最强：列表里真的出现了这条文案
                if (tiktok.commentListContains(text)) {
                    closePanel(step);
                    return { via: 'text-in-list', count: headerCount };
                }
                // 次强：列表头部计数变了（说明确实多了一条）
                if (before.countBefore !== null && headerCount !== before.countBefore) {
                    closePanel(step);
                    return { via: 'list-count', count: headerCount };
                }
            } else if (clickAttempts < maxClicks) {
                settle();
                var button = tiktok.commentButton();
                if (!button) {
                    logger.warn(step, '找不到评论角标，跳过列表校验');
                    return null;
                }
                clickAttempts += 1;
                logger.info(step, '第 ' + clickAttempts + ' 次打开评论列表');
                TikTokAuto.ui.clickNode(button, step);
            }
            TikTokAuto.wait.tick(400);
        }

        logger.warn(step, '评论列表校验未通过（点了 ' + clickAttempts + ' 次，列表计数=' +
            tiktok.listCommentCount() + '，发布前计数=' + before.countBefore + '）');
        closePanel(step);
        return null;
    }

    /** 等页面签名稳定下来（收起动画结束），再去做下一次点击 */
    function settle() {
        TikTokAuto.wait.waitQuiet(function () {
            return TikTokAuto.layout.signature();
        }, { maxMs: 1500, tickMs: 200, stableTimes: 2 });
    }

    return {
        PLACEHOLDER: PLACEHOLDER,
        pickText: pickText,
        openPanel: openPanel,
        closePanel: closePanel,
        post: post,
        awaitOutcome: awaitOutcome,
        verifyInCommentList: verifyInCommentList
    };
}());


/* ============================== src/interact.js ============================== */
/**
 * interact.js — 播放页的两个轻量互动动作：**点赞** 与 **关注作者**
 *
 * ## 为什么单独一个模块
 * 它们和评论一样是"在播放页上点一下、然后验证真的生效"，但比评论简单得多：
 * 不用开面板、不用输入、不用回读。所以不塞进 comment.js（那是评论发布的地盘）。
 *
 * ## 实测锚点（2026-10-28 / TikTok 47.1.4 / 1080×1920）
 *
 * | 元素 | 类 | content-desc | 备注 |
 * |---|---|---|---|
 * | 点赞（未赞） | Button | `Like video. 2.4M likes` | 里面的 ImageView selected=false |
 * | 点赞（已赞） | Button | **`Video liked`** | ImageView selected=**true** |
 * | 关注 | Button | `Follow <作者名>` | 已关注时**整个按钮消失** |
 * | 作者头像 | ImageView | `<作者名> profile` | 用来区分"已关注"和"页面没渲染" |
 *
 * 点赞按钮和分享按钮**共用同一个 resource-id**（`g8g`），所以只能靠 desc 区分，
 * 不要试图用 id 定位。
 *
 * ## 两条安全原则
 *
 * ① **状态不明就不点。** 读不到"当前是否已赞"时，点一下可能把已赞的取消掉 ——
 *    和用户意图正好相反。宁可跳过并如实记录。
 * ② **点了必须验。** 点击成功不代表生效（可能被弹窗挡、可能点偏）。
 *    只有状态真的变了才算数，否则记失败，不虚报。
 *
 * 依赖：TikTokAuto.tiktok / ui / wait / logger
 */
TikTokAuto.interact = (function () {
    'use strict';

    function logger() { return TikTokAuto.logger; }

    /**
     * 给当前视频点赞。
     *
     * @returns { ok, skipped?, via, reason? }
     */
    function like(step) {
        var tiktok = TikTokAuto.tiktok;
        var tag = step || 'like';

        var state = tiktok.likeState();
        if (state === 'liked') {
            return { ok: true, skipped: true, via: 'already-liked', reason: '这个视频已经点过赞' };
        }
        if (state !== 'unliked') {
            return {
                ok: false, via: 'state-unknown',
                reason: '读不到点赞状态，跳过（不盲点：可能是已赞，点一下会变成取消）'
            };
        }

        var button = tiktok.likeButton();
        if (!button) {
            return { ok: false, via: 'button-missing', reason: '找不到点赞按钮' };
        }
        TikTokAuto.ui.clickNode(button, tag);

        /* 验证：desc 从 `Like video.` 变成 `Video liked`（或图标 selected 翻转） */
        var done = TikTokAuto.wait.waitFor(tag + ':verify', function () {
            return tiktok.likeState() === 'liked' ? true : null;
        }, 6000, 300);
        if (done === true) {
            logger().info(tag, '点赞成功（状态已变为已赞）');
            return { ok: true, via: 'state-changed' };
        }
        logger().warn(tag, '点赞后状态没有变化（可能被弹窗挡住或点偏了）');
        return { ok: false, via: 'not-verified', reason: '点击后没有变成已赞' };
    }

    /**
     * 关注当前视频的作者。
     *
     * @returns { ok, skipped?, via, reason? }
     */
    function follow(step) {
        var tiktok = TikTokAuto.tiktok;
        var tag = step || 'follow';

        var state = tiktok.followState();
        if (state === 'following') {
            return { ok: true, skipped: true, via: 'already-following', reason: '已经关注过这个作者' };
        }
        if (state !== 'not-following') {
            /* 头像和按钮都读不到 = 页面还没渲染好。
             * 这时不点：点到空白处可能触发别的动作（播放/暂停），没有意义。 */
            return {
                ok: false, via: 'page-not-ready',
                reason: '作者头像与关注按钮都读不到，页面可能还没渲染完'
            };
        }

        var button = tiktok.followButton();
        if (!button) {
            return { ok: false, via: 'button-missing', reason: '找不到关注按钮' };
        }
        TikTokAuto.ui.clickNode(button, tag);

        /* 验证：关注按钮**整个消失**（实测就是这种表现，不是改成 Following） */
        var done = TikTokAuto.wait.waitFor(tag + ':verify', function () {
            return tiktok.followState() === 'following' ? true : null;
        }, 6000, 300);
        if (done === true) {
            logger().info(tag, '关注成功（关注按钮已消失）');
            return { ok: true, via: 'button-gone' };
        }
        logger().warn(tag, '关注后按钮仍在，可能没生效');
        return { ok: false, via: 'not-verified', reason: '点击后关注按钮仍然存在' };
    }

    return {
        like: like,
        follow: follow
    };
}());


/* ============================== src/flow.js ============================== */
/**
 * flow.js — 业务流程编排
 *
 * 这里只写"先做什么、再做什么、失败了怎么办"，不写"怎么点"（ui.js）
 * 也不写"TikTok 长什么样"（tiktok.js）。
 * 每一段都是一次"进入某页面 → 等它真的就绪 → 做事 → 校验"的小闭环，
 * 因此任何一步卡住都能从日志里立刻看出卡在哪。
 *
 * 收敛原则（《代码整洁之道》第 3 章）：每个函数只做一件事，且**只在一个抽象层级上**。
 * 所以下面几乎没有嵌套循环和条件，读起来就是需求本身。
 *
 * 依赖：TikTokAuto.logger / tiktok / player / comment / ui / wait / popups
 */
TikTokAuto.flow = (function () {
    'use strict';

    function logger() { return TikTokAuto.logger; }

    // ------------------------------------------------------------ 启动与就位

    function launchApp(config) {
        var step = 'launch';
        var pkg = config.target.packageName;

        /* ★ 已经在前台就**绝对别动它**。
         *
         * `app.launchPackage()` 不是"切到前台"，而是"重新打开这个 app" ——
         * 即使 app 已经在前台，它也会再发一次 startActivity，把叠在主界面上的
         * 页面（视频播放页、评论面板、用户列表）清掉，退回首页。
         *
         * 对「当前屏幕」类取材这是致命的：用户手动把 TikTok 停在评论区，
         * 那正是这个取材源的全部前提，而引擎一启动就把它退成了 feed，
         * 然后再报"取材设置为当前屏幕，但当前不在播放页"。
         * 实测（2026-10-22）：日志里 `launch 就绪（56ms）` 看着毫秒级完成、
         * 什么都没干，实际上页面已经被重置了 —— 时间是 56ms，副作用却不可逆。
         */
        if (TikTokAuto.layout.foregroundPackage() === pkg) {
            logger().info(step, '已在前台，保持当前页面不动');
            return true;
        }

        logger().step(step, '启动 ' + pkg);
        app.launchPackage(pkg);

        var ready = TikTokAuto.wait.waitFor(step, function () {
            return TikTokAuto.layout.foregroundPackage() === pkg ? true : null;
        }, config.timeouts.appLaunchMs, config.probe.pollTickMs);

        return ready === true;
    }

    /**
     * 保证停在信息流首页。
     *
     * 早先的写法有两个坑（实测踩到）：
     *   1. 一上来就 `waitFor(feed, 15s)` —— 明明已经在播放页，却先白等 15 秒；
     *   2. 循环里最后按完 back 不回头复查，4 次退完刚好差一步，然后误判"退不回去"去重启。
     * 现在改成：**先看再动**，每退一步都等页面真的换了（按签名变化判断，不是固定 sleep），
     * 并且只在确认当前不是首页时才按返回——避免把正常页面退掉或退出 App。
     */
    function ensureFeed(config) {
        var step = 'ensureFeed';
        var log = logger();
        var tiktok = TikTokAuto.tiktok;
        var tiktokLayout = TikTokAuto.layout;
        var deadline = Date.now() + 25000;
        var unknownRounds = 0;

        while (Date.now() < deadline) {
            var state = tiktok.pageState();
            if (state === 'feed') {
                log.info(step, '已处于信息流首页');
                return true;
            }
            if (state === 'unknown') {
                // 页面可能还在渲染。但连续多轮都认不出来，说明有东西盖在上面
                // （弹窗、半透明遮罩、异常页），这时**必须**试着按返回脱离，
                // 否则就是原地等到超时、然后"重启大法"。
                unknownRounds += 1;
                if (unknownRounds >= 4) {
                    log.warn(step, '页面状态连续 ' + unknownRounds + ' 轮未知，按返回尝试脱离');
                    back();
                    TikTokAuto.wait.waitQuiet(function () {
                        return tiktokLayout.signature();
                    }, { maxMs: 2000, tickMs: 200, stableTimes: 2 });
                    unknownRounds = 0;
                } else {
                    TikTokAuto.wait.tick(700);
                }
                continue;
            }
            unknownRounds = 0;
            log.info(step, '当前在 ' + state + '，返回上一页');
            back();
            TikTokAuto.wait.waitQuiet(function () {
                return tiktokLayout.signature();
            }, { maxMs: 2500, tickMs: 200, stableTimes: 2 });
        }

        log.warn(step, '多次返回仍未到首页，重新启动应用');
        launchApp(config);
        return TikTokAuto.wait.waitFor(step, function () {
            return tiktok.pageState() === 'feed' ? true : null;
        }, config.timeouts.pageReadyMs, config.probe.pollTickMs) === true;
    }

    // ------------------------------------------------------------ 搜索

    function openSearchPage(config) {
        var step = 'openSearch';
        var entry = TikTokAuto.tiktok.searchEntry();
        if (!entry) {
            logger().error(step, '首页找不到搜索入口');
            return false;
        }
        TikTokAuto.ui.clickNode(entry, step);

        return TikTokAuto.wait.waitFor(step, function () {
            if (TikTokAuto.tiktok.pageState() === 'search') {
                return true;
            }
            // 结果页也算"搜索这条链走通了"，直接复用
            return TikTokAuto.tiktok.pageState() === 'results' ? true : null;
        }, config.timeouts.pageReadyMs, config.probe.pollTickMs) === true;
    }

    function submitKeyword(config) {
        var step = 'submitKeyword';
        var tiktok = TikTokAuto.tiktok;

        if (tiktok.pageState() === 'results') {
            logger().info(step, '已经在结果页，跳过输入');
            return true;
        }

        var input = tiktok.searchInput();
        if (!input) {
            logger().error(step, '找不到搜索输入框');
            return false;
        }
        TikTokAuto.ui.clickNode(input, step);
        TikTokAuto.wait.tick(250);

        var typed = TikTokAuto.ui.typeInto(tiktok.searchInput() || input, config.target.keyword, step);
        if (!typed.ok) {
            return false;
        }

        var submit = tiktok.searchSubmit();
        if (!submit) {
            logger().error(step, '找不到搜索提交按钮');
            return false;
        }
        TikTokAuto.ui.clickNode(submit, step);

        return TikTokAuto.wait.waitFor(step, function () {
            return tiktok.pageState() === 'results' ? true : null;
        }, config.timeouts.searchResultsMs, config.probe.pollTickMs) === true;
    }

    /** 等结果网格真的渲染出卡片（而不是页面框架出来了就算完） */
    function waitForCards(config) {
        var step = 'waitForCards';
        return TikTokAuto.wait.waitFor(step, function () {
            var cards = TikTokAuto.tiktok.videoCards();
            return cards.length > 0 ? cards : null;
        }, config.timeouts.searchResultsMs, config.probe.pollTickMs);
    }

    function selectResultTab(config) {
        var step = 'selectResultTab';
        var name = config.target.resultTab;
        if (!name) {
            return false;
        }
        var tab = TikTokAuto.tiktok.resultTab(name);
        if (!tab) {
            logger().warn(step, '找不到页签 ' + name + '，沿用当前页签');
            return false;
        }
        logger().info(step, '切换到页签 ' + name);
        TikTokAuto.ui.clickNode(tab, step);
        TikTokAuto.wait.waitQuiet(function () {
            return TikTokAuto.layout.signature();
        }, { maxMs: 4000, tickMs: 250, stableTimes: 3 });
        return true;
    }

    /** 结果页滚动加载更多卡片 */
    function scrollResults(config) {
        var layout = TikTokAuto.layout;
        var screen = layout.screen();
        logger().info('scrollResults', '结果页下拉加载更多');
        TikTokAuto.ui.dragScreen(
            Math.floor(screen.width * 0.25), Math.floor(screen.height * 0.8),
            Math.floor(screen.width * 0.25), Math.floor(screen.height * 0.35),
            400
        );
        TikTokAuto.wait.waitQuiet(function () {
            return TikTokAuto.layout.signature();
        }, { maxMs: 4000, tickMs: 250, stableTimes: 3 });
    }

    // ------------------------------------------------------------ 选片与观看

    function chooseCard(config, cards, visited) {
        var fresh = [];
        for (var i = 0; i < cards.length; i += 1) {
            if (visited.indexOf(cards[i].caption) === -1) {
                fresh.push(cards[i]);
            }
        }
        var pool = fresh.length > 0 ? fresh : cards;
        if (config.target.pickStrategy === 'first') {
            return pool[0];
        }
        return pool[Math.floor(Math.random() * pool.length)];
    }

    function openCard(config, card) {
        var step = 'openCard';
        logger().step(step, '打开视频：' + JSON.stringify(String(card.caption).slice(0, 40)));
        TikTokAuto.ui.clickNode(card.container, step);
        return TikTokAuto.player.waitPlayerReady(config, step);
    }

    /**
     * 从播放页回到结果页。
     *
     * 必须允许连按多次：校验评论时会把评论列表打开，此时状态是 comment-panel，
     * 一次 back 只够收起面板，得再退一次才真正回到结果页。
     */
    function returnToResults(config) {
        var step = 'returnToResults';
        var log = logger();
        var tiktok = TikTokAuto.tiktok;
        var tiktokLayout = TikTokAuto.layout;
        var deadline = Date.now() + config.timeouts.pageReadyMs;
        var backs = 0;

        while (Date.now() < deadline && backs < 5) {
            var state = tiktok.pageState();
            if (state === 'results') {
                return true;
            }
            if (state === 'unknown') {
                TikTokAuto.wait.tick(500);
                continue;
            }
            backs += 1;
            log.info(step, '当前在 ' + state + '，返回上一页');
            back();
            TikTokAuto.wait.waitQuiet(function () {
                return tiktokLayout.signature();
            }, { maxMs: 2500, tickMs: 200, stableTimes: 2 });
        }

        log.warn(step, '未能回到结果页，跳过后续取片');
        return false;
    }

    // ------------------------------------------------------------ 主流程

    /**
     * 上报进度给界面宿主（未接宿主时是空操作，见 bridge.js）。
     * 只在这里包一层是为了让下面的流程读起来仍是"业务语言"，
     * 不必到处重复 status:'running' 这种传输细节。
     */
    function progress(phase, done, total) {
        TikTokAuto.bridge.report({
            status: 'running',
            phase: phase,
            done: done,
            total: total
        });
    }

    /**
     * 跑一轮完整会话：启动 → 搜索 → 逐个视频「看 → 评」。
     * @returns 结构化结果，会被 main.js 打印成一行 RESULT 供 PC 侧断言
     */
    function runSession(config) {
        var summary = {
            ok: false,
            keyword: config.target.keyword,
            requestedVideos: config.target.maxVideos,
            attemptedVideos: 0,
            postedComments: 0,
            /* 四个动作各自的成功计数：只有"真的做了"才加，跳过不算 */
            likedVideos: 0,
            followedAuthors: 0,
            /* 用户是否勾了这两个动作 —— 用来决定结果文案里要不要提它们
             * （勾了但全是"已赞"时显示 0 是有意义的信息；没勾就干脆不提） */
            likesRequested: config.likes && config.likes.enabled === true,
            followsRequested: config.follows && config.follows.enabled === true,
            details: [],
            errors: []
        };
        var total = config.target.maxVideos;

        progress('\u542f\u52a8\u5e94\u7528', 0, total);
        if (!launchApp(config)) {
            summary.errors.push('启动应用失败');
            return summary;
        }

        progress('\u8fdb\u5165\u4fe1\u606f\u6d41', 0, total);
        if (!ensureFeed(config)) {
            summary.errors.push('未能进入信息流首页');
            return summary;
        }

        progress('\u641c\u7d22 ' + config.target.keyword, 0, total);
        if (!openSearchPage(config) || !submitKeyword(config)) {
            summary.errors.push('搜索流程失败');
            return summary;
        }
        if (!waitForCards(config)) {
            summary.errors.push('搜索结果里没有可用卡片');
            return summary;
        }
        selectResultTab(config);

        var visited = [];
        var usedComments = [];
        var guard = 0;

        while (summary.attemptedVideos < config.target.maxVideos && guard < config.target.maxVideos * 3) {
            guard += 1;

            progress('\u6b63\u5728\u5904\u7406\u7b2c ' + (summary.attemptedVideos + 1) + '/' + total + ' \u4e2a\u89c6\u9891',
                     summary.attemptedVideos, total);

            var cards = TikTokAuto.tiktok.videoCards();
            if (cards.length === 0) {
                scrollResults(config);
                cards = TikTokAuto.tiktok.videoCards();
                if (cards.length === 0) {
                    summary.errors.push('结果页已无更多卡片');
                    break;
                }
            }

            var card = chooseCard(config, cards, visited);
            visited.push(card.caption);

            if (!openCard(config, card)) {
                summary.errors.push('打开视频失败：' + String(card.caption).slice(0, 30));
                returnToResults(config);
                continue;
            }

            var detail = { caption: String(card.caption).slice(0, 60) };

            detail.watch = TikTokAuto.player.watch(config, { step: 'watch' });

            /* 点赞 / 关注：都在播放页上点一下就好，不必跳转。
             * 顺序放在评论**之前** —— 评论会打开面板盖住动作栏，
             * 之后再点赞就得先把面板收掉，多一步且更容易出错。 */
            if (config.likes && config.likes.enabled) {
                detail.like = TikTokAuto.interact.like('like');
                if (detail.like.ok && !detail.like.skipped) {
                    summary.likedVideos += 1;
                }
            } else {
                detail.like = { ok: true, skipped: true, reason: '本次未启用点赞动作' };
            }

            if (config.follows && config.follows.enabled) {
                detail.follow = TikTokAuto.interact.follow('follow');
                if (detail.follow.ok && !detail.follow.skipped) {
                    summary.followedAuthors += 1;
                }
            } else {
                detail.follow = { ok: true, skipped: true, reason: '本次未启用关注动作' };
            }

            /* 没勾「评论」时只浏览：这不是失败，是一种合法的运行模式
             * （界面上的「执行操作」没勾评论就是这个意思）。 */
            if (config.comments.enabled) {
                var text = TikTokAuto.comment.pickText(config, usedComments, 'comment');
                detail.comment = TikTokAuto.comment.post(config, text, 'comment');
                if (detail.comment.ok && !detail.comment.skipped) {
                    usedComments.push(text);
                    summary.postedComments += 1;
                }
            } else {
                detail.comment = { ok: true, skipped: true, reason: '本次未启用评论动作' };
            }

            summary.attemptedVideos += 1;
            summary.details.push(detail);

            progress('\u5df2\u5b8c\u6210 ' + summary.attemptedVideos + '/' + total,
                     summary.attemptedVideos, total);

            returnToResults(config);
        }

        summary.ok = summary.attemptedVideos > 0;
        return summary;
    }

    return {
        launchApp: launchApp,
        ensureFeed: ensureFeed,
        openSearchPage: openSearchPage,
        submitKeyword: submitKeyword,
        waitForCards: waitForCards,
        selectResultTab: selectResultTab,
        scrollResults: scrollResults,
        chooseCard: chooseCard,
        openCard: openCard,
        returnToResults: returnToResults,
        runSession: runSession
    };
}());


/* ============================== src/parse.js ============================== */
/**
 * parse.js — 文本 → 数值 / 语言 / 区间的**纯函数**解析
 *
 * ## 为什么单独一个模块
 * 这三件事都是「界面上的设置真的会拦人」这一主张的证据链：
 *   · 数量门槛要先把 "1.6M" 变成 1600000 才谈得上比较；
 *   · 语言区域要靠昵称/个签里的字符构成来判；
 *   · 区间判定要能表达"不限"和"读不到"这两种不同的"没有值"。
 * 它们全部与界面无关，所以能 100% 离线自检 —— 这是整个 ID 提取里
 * **唯一一处可以用断言证明"逻辑对了"** 的部分。
 *
 * ## 关于数字缩写（真机实测）
 * TikTok 的计数一律是缩写形态，实测到的写法：
 *   "594"、"2,491"、"1.6M"、"253.9M"、"245K"、"371.7K"
 * 中文界面下会是 "1.2万" / "1.5亿"。所以后缀要同时认 K/M/B 与 万/亿。
 *
 * 依赖：无（纯函数，不取任何模块引用）
 */
TikTokAuto.parse = (function () {
    'use strict';

    /* ---------------------------------------------------------- 数字 */

    /** 后缀倍数。键统一小写；`二`的两种写法（万/萬）都认。 */
    var SUFFIX = {
        '': 1,
        'k': 1000,
        'm': 1000000,
        'b': 1000000000,
        'w': 10000,          /* 万：中文界面 "1.2万" */
        '万': 10000,
        '萬': 10000,
        '亿': 100000000,
        '億': 100000000
    };

    /**
     * 把一个计数字符串解析成整数。
     *
     * 返回 **null** 表示"读不到"，与 **0** 严格区分：
     * "0 followers" 是真实的值（一个粉丝都没有），"读不到"是另一回事 ——
     * 数量门槛的判定要靠这个区别决定是"拦下"还是"放行"。
     *
     * @param raw 原始文本，如 "1.6M followers" / "2,491" / "1.2万"
     * @returns {number|null}
     */
    function count(raw) {
        if (raw === null || raw === undefined) {
            return null;
        }
        /* 统一全角数字与全角逗号：某些语言/输入法会给出全角 */
        var text = String(raw)
            .replace(/[０-９]/g, function (ch) {
                return String.fromCharCode(ch.charCodeAt(0) - 0xFEE0);
            })
            .replace(/[，]/g, ',');

        /* 抓「数字 + 可选小数 + 可选后缀」。前面的自由文本（"1.6M followers"）不影响。
         * 后缀只认白名单里的字符，避免把 "594 followers" 的 f 当成后缀。 */
        var matched = text.match(/(\d[\d,]*(?:\.\d+)?)\s*([kKmMbBwW万萬亿億]?)/);
        if (!matched) {
            return null;
        }

        var number = Number(String(matched[1]).replace(/,/g, ''));
        if (isNaN(number)) {
            return null;
        }
        var suffix = String(matched[2] || '').toLowerCase();
        var factor = SUFFIX[suffix];
        if (factor === undefined) {
            /* 后缀不在白名单（例如 "594 followers" 的 f 已不会被捕获）→ 按无后缀处理 */
            factor = 1;
        }
        return Math.round(number * factor);
    }

    /* ---------------------------------------------------------- 语言 */

    /** CJK 汉字（含扩展 A 与兼容区）与假名 —— 判定"中文内容"用 */
    var CJK = /[\u3400-\u4dbf\u4e00-\u9fff\uf900-\ufaff\u3040-\u30ff]/;
    var LATIN = /[A-Za-z\u00c0-\u024f]/;   /* 含带音标的拉丁字母（西/法/德用户昵称很常见） */

    /**
     * 估算一段文本的语种。只返回三类，够用且不猜。
     *
     * 判定规则（不是拍脑袋，理由在下面）：
     *   · **只统计字母类字符**，忽略数字/标点/emoji —— 昵称里 emoji 占比极高，
     *     算进分母会把"中文昵称 + 三个 emoji"判成"非中文"。
     *   · 中文门槛 **30%**：中文用户常混英文单词（"小美的Fashion"），
     *     门槛设成 50% 会把这类人漏掉。
     *   · 英文门槛 **70%**：反过来，英文用户极少混中文，
     *     所以"仅英文"要更严格 —— 否则一个 "Fashion 小美" 会同时进两个桶。
     *
     * @returns {string} "zh" | "en" | "mixed" | "none"
     */
    function language(raw) {
        var text = String(raw === null || raw === undefined ? '' : raw);
        if (text === '') {
            return 'none';
        }

        var cjk = 0;
        var latin = 0;
        for (var i = 0; i < text.length; i += 1) {
            var ch = text.charAt(i);
            if (CJK.test(ch)) {
                cjk += 1;
            } else if (LATIN.test(ch)) {
                latin += 1;
            }
        }

        var total = cjk + latin;
        if (total === 0) {
            return 'none';       /* 纯 emoji / 纯数字 / 阿拉伯文等 */
        }
        var zhRatio = cjk / total;
        var enRatio = latin / total;

        if (zhRatio >= 0.3) {
            return 'zh';
        }
        if (enRatio >= 0.7) {
            return 'en';
        }
        return 'mixed';
    }

    /**
     * 语言是否匹配"仅中文 / 仅英文 / 通杀"。
     *
     * `mixed` 在两边都不算匹配 —— 说不清是哪一边的，就不该被任何一边选中。
     * 但 `none`（纯 emoji 昵称）在"通杀"下通过：通杀本来就不筛。
     */
    function languageMatches(want, actual) {
        if (!want || want === 'any') {
            return true;
        }
        if (want === 'zh') {
            return actual === 'zh';
        }
        if (want === 'en') {
            return actual === 'en';
        }
        return true;
    }

    /* ---------------------------------------------------------- 区间 */

    /**
     * 区间判定。
     *
     * 三种状态必须分开表达，这是这个函数存在的理由：
     *   · **不限**（min/max 都是 0）→ 永远通过，连值都不用读；
     *   · **有值** → 落在 [min, max] 内（0 表示该侧不设限）；
     *   · **读不到**（value === null）→ **不通过**。
     *
     * 为什么读不到要拦：用户明确设了门槛，说明他在意这个条件；
     * 读不到就无法证明符合，宁可少收并在日志里说清楚 ——
     * 若这里放行，"过滤"就是形同虚设，而用户以为它生效了。
     *
     * @returns {boolean}
     */
    function inRange(value, min, max) {
        var low = Number(min) || 0;
        var high = Number(max) || 0;
        if (low <= 0 && high <= 0) {
            return true;
        }
        if (value === null || value === undefined) {
            return false;
        }
        var number = Number(value);
        if (isNaN(number)) {
            return false;
        }
        if (low > 0 && number < low) {
            return false;
        }
        if (high > 0 && number > high) {
            return false;
        }
        return true;
    }

    /** 该区间是否"什么都没设"（用来判断要不要为此打开用户页） */
    function isRangeOpen(min, max) {
        return (Number(min) || 0) <= 0 && (Number(max) || 0) <= 0;
    }

    /* ---------------------------------------------------------- 用户名 */

    /**
     * 把 "@username" 归一成 "username"。
     *
     * 实测发现用户名文本被 **FID 隔离符** 包裹（U+2068 / U+2069）：
     * 显示为 `⁨ajman_fashion_week⁩`，肉眼完全看不出，但直接当文件名/比对键就会出错。
     * `layout.sanitize` 处理了 U+200b-200f 等，**没有**处理 2068/2069（它们不是零宽字符，
     * 是双向文本隔离符），所以这里单独剥一次。
     *
     * 同时剥掉全角 @ 与首尾空白。
     */
    function username(raw) {
        if (raw === null || raw === undefined) {
            return '';
        }
        return String(raw)
            .replace(/[\u2066-\u2069\u202a-\u202e]/g, '')
            .replace(/\s+/g, '')
            .replace(/^[@＠]+/, '');
    }

    /**
     * 一个字符串是否像 TikTok 用户名（字母数字下划线点，长度 2~30）。
     *
     * 注意**不能**先走 username() —— 那个函数会去掉所有空白（清洗用途），
     * 于是 "This is a caption" 会被压成 "Thisisacaption" 而"看起来像用户名"。
     * 判定必须**保留原始空白**：真正的用户名里不会有空格。
     */
    function looksLikeUsername(raw) {
        if (raw === null || raw === undefined) {
            return false;
        }
        var name = String(raw)
            .replace(/[\u2066-\u2069\u202a-\u202e]/g, '')
            .replace(/^[\s@＠]+|[\s]+$/g, '');
        if (name.length < 2 || name.length > 30) {
            return false;
        }
        if (/\s/.test(name)) {
            return false;      /* 中间有空白 → 是文案，不是用户名 */
        }
        return /^[A-Za-z0-9_.]+$/.test(name);
    }

    /* ---------------------------------------------------------- 文件名 */

    /** 两位补零 */
    function pad2(value) {
        return value < 10 ? '0' + value : String(value);
    }

    /**
     * 结果文件名：`前缀_YYYYMMDD_HHmm.txt`
     *
     * 方案 §6.1 是对规格书的有意识偏离：规格书只有日期（`uid_20261013.txt`），
     * 同一天跑两次会互相覆盖 —— 而"同一天调两次参数"恰恰是最常见的用法。
     */
    function timestampName(prefix, date) {
        var d = date || new Date();
        return prefix + '_' + d.getFullYear() + pad2(d.getMonth() + 1) + pad2(d.getDate()) +
            '_' + pad2(d.getHours()) + pad2(d.getMinutes()) + '.txt';
    }

    return {
        count: count,
        language: language,
        languageMatches: languageMatches,
        inRange: inRange,
        isRangeOpen: isRangeOpen,
        username: username,
        looksLikeUsername: looksLikeUsername,
        timestampName: timestampName
    };
}());


/* ============================== src/uidset.js ============================== */
/**
 * uidset.js — 去重集合与结果文件
 *
 * ## 三种"已经见过"
 * 1. **本轮已收**：这次运行里已经写进产物文件的；
 * 2. **历史已收**：之前各轮跑过的（`uid_extracted.txt`，只追加不删除）；
 * 3. **输入里已有**：文本取材那份文件本身就列着的（"裂变"时，"输入里的人"不该再算新收获）。
 * 三者合成一个集合，`add` 之后就不再重复。区别只在**装载来源**，判定逻辑是同一个。
 *
 * ## 为什么落盘是"追加"而不是"最后一次性写"
 * 用户点了停止、或脚本被系统杀掉时，已经抓到的部分不能全丢。
 * 所以每收 N 个就 append 一次 —— 代价是几条多余的系统调用，收益是"停在哪都留着"。
 *
 * ## 为什么不用 files 的删除接口
 * 引擎产物要过 MCP 的危险调用黑名单（`build.js` 的 `DANGEROUS_RULES` 里有一条按
 * 词边界匹配 `remove` 加左括号），命中后每次下发都要求人工确认。
 * 所以这里**只追加不删除** —— 需要"重来"时由用户自己在文件管理器里删。
 *
 * 依赖：TikTokAuto.logger（调用时取）
 */
TikTokAuto.uidset = (function () {
    'use strict';

    /** 每收这么多个就 append 一次。20 是"丢掉的最多几个"与"写盘频率"的折中。 */
    var FLUSH_EVERY = 20;

    /**
     * 去重集合。
     *
     * 内部用普通对象而不是 Set：Rhino 对 ES6 Set 的支持在各版本不一致，
     * 而对象字面量的键查找在所有版本上都是稳的。uid 只会是字母数字下划线点，不会撞 `__proto__`。
     */
    function create() {
        var seen = {};
        var count = 0;

        return {
            /** 见过没有 */
            has: function (uid) {
                return seen[uid] === true;
            },
            /** 记一笔；返回 true 表示这是新加的（之前没见过） */
            add: function (uid) {
                if (seen[uid] === true) {
                    return false;
                }
                seen[uid] = true;
                count += 1;
                return true;
            },
            /** 已记多少（含历史装载的） */
            size: function () {
                return count;
            }
        };
    }

    /**
     * 读一批文本行，返回去重后的 uid 数组。
     * 跳过空行、`#` 注释行、以及带 @ 的行（有些用户会直接粘贴 "@name"，我们容忍这种输入）。
     */
    function readUidFile(path) {
        var out = [];
        try {
            if (!path || !files.exists(path)) {
                return out;
            }
            var lines = String(files.read(path)).split(/\r?\n/);
            for (var i = 0; i < lines.length; i += 1) {
                var uid = TikTokAuto.parse.username(lines[i]);
                if (uid !== '' && uid.charAt(0) !== '#') {
                    out.push(uid);
                }
            }
        } catch (error) {
            TikTokAuto.logger.warn('uidset', '读取 ' + path + ' 失败：' + error);
        }
        return out;
    }

    /**
     * 从历史文件装载去重集合。
     * 文件不存在 = 第一次跑，不是错误。
     */
    function loadHistory(set, path) {
        var list = readUidFile(path);
        for (var i = 0; i < list.length; i += 1) {
            set.add(list[i]);
        }
        TikTokAuto.logger.info('uidset', '历史去重装载 ' + list.length + ' 条（' + path + '）');
        return list.length;
    }

    /**
     * 结果写入器。
     *
     * 两个文件同时写：
     *   · `本次`：这一轮新收的（新建，给人看/给下游吃）；
     *   · `累计`：所有轮次的（追加，跨轮去重的基准）。
     *
     * @param options { runPath, historyPath, dryRun, historyEnabled }
     */
    function createWriter(options) {
        var pending = [];
        var collected = [];
        var written = 0;
        var flushFailed = false;

        function flush() {
            if (pending.length === 0) {
                return;
            }
            var block = pending.join('\n') + '\n';
            pending = [];
            if (options.dryRun) {
                return;         /* 演练模式：不碰任何文件 */
            }
            try {
                files.append(options.runPath, block);
                if (options.historyEnabled) {
                    files.append(options.historyPath, block);
                }
            } catch (error) {
                /* 写盘失败要留痕但不能中断 —— 用户更需要"继续抓"而不是"因为一个文件写不进去全停"。
                 * 只报一次，避免几百条一模一样的警告把日志刷满。 */
                if (!flushFailed) {
                    flushFailed = true;
                    TikTokAuto.logger.error('uidset', '写结果文件失败：' + error);
                }
            }
        }

        return {
            /** 收一个 uid。调用方保证已经过去重。 */
            write: function (uid) {
                pending.push(uid);
                /* 同时留一份在内存里：收尾阶段要拿它去换数字 uid（见 resolve.js）。
                 * 从文件读一遍也行，但那样得处理"文件还没 flush 完"的时序问题，
                 * 而这里的量级（几十到几千）远没到需要省内存的地步。 */
                collected.push(uid);
                written += 1;
                if (pending.length >= FLUSH_EVERY) {
                    flush();
                }
            },
            /** 本轮收到的全部 uid（按收取顺序） */
            list: function () {
                return collected.slice(0);
            },
            /** 已写多少个 */
            count: function () {
                return written;
            },
            /** 收尾：把剩下的刷出去。**收到停止信号时也必须调它**，否则"停了但文件是空的"。 */
            close: function () {
                flush();
                return written;
            },
            /** 是否发生过写盘失败（给 summary 用） */
            hadFailure: function () {
                return flushFailed;
            }
        };
    }

    /** 确保目录存在（结果文件与累计文件同目录） */
    function ensureDir(dir) {
        try {
            files.ensureDir(dir + '/');
            return true;
        } catch (error) {
            TikTokAuto.logger.error('uidset', '创建目录失败 ' + dir + '：' + error);
            return false;
        }
    }

    return {
        FLUSH_EVERY: FLUSH_EVERY,
        create: create,
        readUidFile: readUidFile,
        loadHistory: loadHistory,
        createWriter: createWriter,
        ensureDir: ensureDir
    };
}());


/* ============================== src/filters.js ============================== */
/**
 * filters.js — 「只要这样的账号」的判定
 *
 * 这一层是**纯函数**：给它一份采集到的资料 + 一份过滤设置，它只回答"要 / 不要 / 为什么"。
 * 不点屏幕、不读写文件、不知道 TikTok 长什么样。所以它能被 100% 离线自检，
 * 而"界面上的 21 项设置真的会拦人"这件事也就有了证据。
 *
 * ## 一条重要的区分：**数据缺失**不等于**不符合**
 * 三种"没有值"必须分开处理，否则过滤要么形同虚设，要么乱杀：
 *
 *   ① 用户没设这个门槛        → 放行（设置里是 0，语义就是"不限"）
 *   ② 设了，但平台根本不提供  → **放行 + 记一条 warn**（例如"视频量"：真机实测用户页
 *                              顶部只有 关注/粉丝/获赞 三组数字，没有视频数）
 *   ③ 设了，本应能读到却读不到 → **拦下**（读不到就无法证明符合，宁可少收）
 *
 * ②和③看起来像，但责任不同：②是我们做不到，不该惩罚用户抓到的人；③是数据异常，
 * 放行会让过滤失去意义而用户以为它生效了。
 *
 * 依赖：TikTokAuto.parse、TikTokAuto.logger（调用时取）
 */
TikTokAuto.filters = (function () {
    'use strict';

    /**
     * 这份过滤设置是否需要打开用户页才能判。
     *
     * 用途是**快路径**：所有过滤都关着时（最常见的第一种用法），
     * 直接从列表页把 uid 抄下来就行 —— 不必为每个人开一次用户页。
     * 实测一次用户页打开约 3~5 秒，100 个人就是 5~8 分钟，差一个数量级。
     *
     * 注意 `videos` 不参与这个判断：它读不到（见文件头 ②），
     * 为此打开用户页也只是白花时间。
     */
    function needsProfile(filter) {
        var f = filter || {};
        if (f.private === true || f.noAvatar === true) {
            return true;
        }
        if (f.langRegion && f.langRegion !== 'any') {
            return true;
        }
        var groups = ['follow', 'fans', 'likes'];
        for (var i = 0; i < groups.length; i += 1) {
            var range = f[groups[i]] || {};
            if (!TikTokAuto.parse.isRangeOpen(range.min, range.max)) {
                return true;
            }
        }
        return false;
    }

    /** 取该判定的取样文本：昵称、个签，或两者（昵称检测下拉的三个取值）。 */
    function sampleText(profile, mode) {
        var nick = profile.nickname || '';
        var sign = profile.signature || '';
        if (mode === 'nick') {
            return nick;
        }
        if (mode === 'sign') {
            return sign;
        }
        /* "通杀"：两段合起来判 —— 分开判会让"昵称中文、个签全英文"的人两边都不算 */
        return nick + ' ' + sign;
    }

    /**
     * 单条判定的结果。
     * `soft` 表示"我们做不到，放行但要告知"（对应文件头的 ②）。
     */
    function pass() {
        return { ok: true, reason: '', soft: '' };
    }

    function reject(reason) {
        return { ok: false, reason: reason, soft: '' };
    }

    function softPass(reason) {
        return { ok: true, reason: '', soft: reason };
    }

    /**
     * 判定一个账号要不要。
     *
     * @param profile 采集到的资料；`null` 表示"这次没有打开用户页"（快路径）
     *                —— 此时只有不看资料就能判的项目生效，其余全部放行
     * @param filter  过滤设置
     * @returns { ok, reason, soft }
     *   reason 是"为什么不要"（人话，会进日志）
     *   soft 是"放行了但你应该知道"（进 summary 的 warnings，只报一次）
     */
    function judge(profile, filter) {
        var f = filter || {};
        var parse = TikTokAuto.parse;

        if (!profile) {
            /* 没有资料，两种情况必须分开：
             *   · 这份设置**本来就不需要**资料（快路径）→ 放行；
             *   · 需要资料却拿不到（用户页打不开、读不出）→ **拦下**。
             * 第二种如果放行，等于"打不开的人全都通过" —— 过滤看着在跑，
             * 实际放进来一批根本没检查过的账号，比不过滤更糟（用户以为筛过了）。 */
            if (needsProfile(f)) {
                return reject('打不开用户页，读不到任何资料');
            }
            return pass();
        }

        /* ① 私密账户。列表页读不到，只能打开用户页看提示文案。 */
        if (f.private === true && profile.isPrivate === true) {
            return reject('私密账号');
        }

        /* ② 无头像。真机实测头像节点不可读（无文案、不可点），
         *    只能靠像素法 —— 见 profile.js 里的说明。读不到时放行并告知。 */
        if (f.noAvatar === true) {
            if (profile.hasAvatar === false) {
                return reject('无头像');
            }
            if (profile.hasAvatar === null) {
                return {
                    ok: true,
                    reason: '',
                    soft: '无头像检测：头像读取不可用，本次未生效'
                };
            }
        }

        /* ③ 语言区域：按昵称/个签的字符构成判（见 parse.language 的规则说明） */
        if (f.langRegion && f.langRegion !== 'any') {
            var text = sampleText(profile, f.nicknameCheck || 'any');
            var lang = parse.language(text);
            if (lang === 'none') {
                /* 纯 emoji / 纯数字昵称：没有语言线索。用户明确要筛语言，就不该混进来。 */
                return reject('看不出语言（昵称与个签都没有文字）');
            }
            if (!parse.languageMatches(f.langRegion, lang)) {
                return reject('语言不符：' + lang + ' ≠ ' + f.langRegion);
            }
        }

        /* ④ 三组数量门槛。真机实测用户页顶部是 关注 / 粉丝 / 获赞，
         *    数字形态是缩写（"1.6M"），parse.count 负责解析。 */
        var checks = [
            { key: 'follow', label: '关注量' },
            { key: 'fans', label: '粉丝量' },
            { key: 'likes', label: '获赞量' }
        ];
        for (var i = 0; i < checks.length; i += 1) {
            var one = checks[i];
            var range = f[one.key] || {};
            if (parse.isRangeOpen(range.min, range.max)) {
                continue;
            }
            if (!parse.inRange(profile[one.key], range.min, range.max)) {
                var actual = profile[one.key];
                return reject(one.label + '不在区间内（' +
                    (actual === null || actual === undefined ? '读不到' : actual) + '）');
            }
        }

        /* ⑤ 视频量：平台不提供（实测），放行 + 告知。见文件头 ②。 */
        var videoRange = f.videos || {};
        if (!parse.isRangeOpen(videoRange.min, videoRange.max)) {
            return softPass('视频量：用户页不显示该数字，本次未参与过滤');
        }

        return pass();
    }

    /** 给人看的一句话：这次到底在筛什么（进日志与界面状态条） */
    function describe(filter) {
        var f = filter || {};
        var parts = [];
        if (f.private === true) { parts.push('排除私密'); }
        if (f.noAvatar === true) { parts.push('排除无头像'); }
        if (f.langRegion && f.langRegion !== 'any') {
            parts.push(f.langRegion === 'zh' ? '仅中文' : '仅英文');
        }
        var labels = { follow: '关注', fans: '粉丝', likes: '获赞' };
        var keys = ['follow', 'fans', 'likes'];
        for (var i = 0; i < keys.length; i += 1) {
            var range = f[keys[i]] || {};
            if (TikTokAuto.parse.isRangeOpen(range.min, range.max)) {
                continue;
            }
            parts.push(labels[keys[i]] + ' ' + (range.min || 0) + '~' + (range.max || '∞'));
        }
        return parts.length === 0 ? '不过滤（拿到就收）' : parts.join('，');
    }

    return {
        needsProfile: needsProfile,
        judge: judge,
        describe: describe
    };
}());


/* ============================== src/profile.js ============================== */
/**
 * profile.js — 在 TikTok 里"走到某个账号的主页并读出来"
 *
 * ## 这一层管什么
 * 只管**导航**与**读取**：打开搜索、进用户主页、点开粉丝列表、翻一屏、退回去。
 * 它不判断"要不要这个人"（那是 filters.js），也不管"从哪来"（idsource.js）。
 *
 * ## 真机实测出来的三条导航事实（2026-10-20 / TikTok 47.1.4）
 * 1. **用户主页 → 粉丝列表是一张覆盖页**，顶部有三个页签（Following / Followers / Suggested），
 *    可以直接在页签间切换 —— 所以"先收粉丝再收关注"不必退回主页再进。
 * 2. **从列表进用户页再返回，列表位置会保持**（实测首行与坐标都不变）。
 *    这条决定了翻页策略：可以"读一屏 → 逐个进 → 退回来接着读下一屏"，
 *    不必先把整屏 uid 存起来再统一处理。
 * 3. **列表行里就有 uid**（`txt_desc`），不必为了拿 uid 去开用户页。
 *    用户页只在**需要更多资料**（数量、语言、私密、头像）时才开 —— 差一个数量级的时间。
 *
 * ## 头像为什么要截屏
 * 头像是 ImageView，**没有 text、没有 desc、不可点**，无障碍树里读不到任何线索。
 * 实测对比：默认头像（灰色人形剪影）高饱和像素占比 0.035，真头像 0.472 ——
 * 分离度足够，所以用像素法。**已知局限：纯黑白照片的头像会被误判成"无头像"**，
 * 这一点会如实写进 README 与界面说明，不假装没有。
 *
 * 依赖：TikTokAuto.layout / tiktok / ui / wait / logger / parse
 */
TikTokAuto.profile = (function () {
    'use strict';

    /** 头像采样网格：5x5。25 个点足够区分剪影与照片，又不会让截图开销变成瓶颈。 */
    var AVATAR_GRID = 5;

    /** 高饱和像素占比超过它就认为"有头像"。实测默认头像 0.035 / 真头像 0.472。 */
    var AVATAR_SATURATED_RATIO = 0.12;

    function logger() { return TikTokAuto.logger; }

    /** 等页面安静下来（签名连续几次不变），比固定 sleep 可靠 */
    function settle(maxMs) {
        TikTokAuto.wait.waitQuiet(function () {
            return TikTokAuto.layout.signature();
        }, { maxMs: maxMs || 2500, tickMs: 200, stableTimes: 2 });
    }

    // ------------------------------------------------------------ 读取主页

    /**
     * 把当前用户主页读成一份资料。
     *
     * 读不到的字段一律给 **null**（而不是 0 或空串）：
     * "读不到"与"就是 0"在过滤判定里含义完全不同（见 filters.js 文件头）。
     *
     * @returns { uid, nickname, signature, follow, fans, likes, isPrivate, hasAvatar, gridCount }
     */
    function readProfile() {
        var tiktok = TikTokAuto.tiktok;
        var parse = TikTokAuto.parse;

        var userNode = tiktok.profileUsernameNode();
        var uid = userNode ? parse.username(TikTokAuto.layout.text(userNode)) : '';

        var nicknameNode = tiktok.profileNicknameNode();
        var signatureNode = tiktok.profileSignatureNode();
        var stats = readStatsStable();
        var hint = tiktok.privateHint();
        var grid = tiktok.videoGridCount();

        return {
            uid: uid,
            nickname: nicknameNode ? TikTokAuto.layout.text(nicknameNode) : '',
            signature: signatureNode ? TikTokAuto.layout.text(signatureNode) : '',
            follow: stats.follow,
            fans: stats.fans,
            likes: stats.likes,
            /* 私密：读到了提示文案才算私密；读不到就是"看起来是公开的"。
             * 反过来判（"没读到就是私密"）会把所有正常账号都排除掉。 */
            isPrivate: hint !== '' && grid < 3,
            privateHint: hint,
            /* 头像：null = 判定不可用（截屏没授权 / 找不到头像节点） */
            hasAvatar: readAvatarState(),
            gridCount: grid
        };
    }

    /**
     * 读三组数字，直到**连续两次一致**才采信。
     *
     * ★ 这是实测踩出来的：点开用户主页后，页面会先渲染骨架、再把数字填进去，
     *   中间那一小段时间读到的数字是**占位的 0**。
     *   同一个账号（@user3670597276145）两次运行分别读到 78 与 0，
     *   而 78 才是真的 —— 如果拿 0 去比"粉丝量 ≥ 1000"，它就被冤枉地跳过了。
     *   页面"安静"不代表数字已经就位，只有"两次读到一样"才是可靠的信号。
     */
    function readStatsStable() {
        var tiktok = TikTokAuto.tiktok;
        TikTokAuto.wait.tick(350);
        var previous = tiktok.statNumbers();

        for (var i = 0; i < 3; i += 1) {
            TikTokAuto.wait.tick(350);
            var current = tiktok.statNumbers();
            if (current.follow === previous.follow && current.fans === previous.fans &&
                current.likes === previous.likes) {
                /* 三组全是 0 是**可疑值**：既可能是真新号，也可能是占位还没换掉。
                 * 多等 1.5 秒复核一次 —— 真新号复核后还是 0，不影响结果；
                 * 占位的话这一刻通常已经填上真值了（实测把 2019 粉丝读成 0 过）。 */
                if (current.follow === 0 && current.fans === 0 && current.likes === 0) {
                    TikTokAuto.wait.tick(1500);
                    var recheck = tiktok.statNumbers();
                    if (recheck.follow !== 0 || recheck.fans !== 0 || recheck.likes !== 0) {
                        logger().info('profile', '三组全 0 复核后拿到真值：' +
                            recheck.follow + '/' + recheck.fans + '/' + recheck.likes);
                        return recheck;
                    }
                }
                return current;
            }
            previous = current;
        }
        logger().warn('profile', '三组数字连续三次都没稳定，采用最后一次的值（可能是中间态）');
        return previous;
    }

    /**
     * 截屏授权状态：null = 还没试过，true = 已就绪，false = 不可用。
     *
     * ★ 真机实测（2026-10-20）：**`requestScreenCapture(false)` 是静默的** ——
     *   AutoX 的无障碍服务带 `CAPABILITY_CAN_TAKE_SCREENSHOT`，申请当场返回 true，
     *   不弹 MediaProjection 确认框，1 秒内完成，随后 `captureScreen()` 直接可用。
     *   而**不主动申请**时 `captureScreen()` 会抛 `No screen capture permission` ——
     *   这就是早先"排除无头像一直不生效、每个账号还刷一条错误"的全部原因。
     *
     * 代价与风险：某些设备/ROM 上申请会弹一次系统授权框并阻塞。
     * 所以申请失败就锁定"不可用"并**只告知一次**，不让它把整轮拖住或刷屏。
     */
    var screenCaptureReady = null;

    function ensureScreenCapture() {
        if (screenCaptureReady !== null) {
            return screenCaptureReady;
        }
        if (typeof requestScreenCapture !== "function") {
            screenCaptureReady = false;
            logger().warn('profile', '这个运行时不支持截屏申请，本次运行的头像判定会跳过');
            return false;
        }
        try {
            screenCaptureReady = requestScreenCapture(false) === true;
        } catch (error) {
            screenCaptureReady = false;
            logger().warn('profile', '申请截屏授权失败，本次运行的头像判定会跳过：' + error);
            return false;
        }
        if (screenCaptureReady) {
            logger().info('profile', '截屏授权已就绪，头像判定可用');
        } else {
            logger().warn('profile', '截屏授权未获批准，本次运行的头像判定会跳过');
        }
        return screenCaptureReady;
    }

    /**
     * 头像是默认剪影吗？
     *
     * ★ "判为无头像"必须**再采一次**才采信。
     *   实测发现：刚进用户页时（`waitProfile` 只等到 `@username` 出现，约 585ms），
     *   头像图片往往还在下载，截到的是**灰色占位块** → 高饱和 0.000 → 误判"无头像"
     *   → 一个明明有头像的账号被错误跳过。
     *   有色的情况不必二次确认（灰底不会自己变彩色），所以这个额外开销只落在
     *   "疑似无头像"的那部分账号上，约多花 400ms。
     *
     * @returns true（有头像）/ false（默认剪影）/ null（判不了）
     */
    function readAvatarState() {
        if (!ensureScreenCapture()) {
            return null;
        }
        var node = avatarNode();
        if (!node) {
            return null;
        }

        var first = sampleAvatar(node);
        if (first === null || first === true) {
            return first;
        }

        /* 第一次判为"无色"：等图片加载完再确认一次 */
        TikTokAuto.wait.tick(400);
        var second = sampleAvatar(node);
        if (second === null) {
            return first;
        }
        if (second !== first) {
            logger().info('profile', '头像两次采样不一致（' + first + ' → ' + second +
                '），采用第二次 —— 第一次多半是图片还没加载');
        }
        return second;
    }

    /**
     * 对头像区域采样一次，返回"是否有头像"。
     * @returns true / false / null（拿不到节点或截屏失败）
     */
    function sampleAvatar(node) {
        var box = node.bounds();
        var saturated = 0;
        var total = 0;

        var image = null;
        try {
            image = captureScreen();
        } catch (error) {
            /* 申请过了却还是拿不到（被系统撤销 / ROM 限制）：不是"没头像"，
             * 是"这次判不了" —— 必须返回 null，由上层如实告知。 */
            screenCaptureReady = false;
            logger().warn('profile', '截屏不可用，后续账号不再尝试头像判定：' + error);
            return null;
        }
        if (!image) {
            screenCaptureReady = false;
            return null;
        }

        var stepX = (box.right - box.left) / (AVATAR_GRID + 1);
        var stepY = (box.bottom - box.top) / (AVATAR_GRID + 1);
        for (var row = 1; row <= AVATAR_GRID; row += 1) {
            for (var col = 1; col <= AVATAR_GRID; col += 1) {
                var x = Math.round(box.left + stepX * col);
                var y = Math.round(box.top + stepY * row);
                var pixel = 0;
                try {
                    pixel = image.pixel(x, y);
                } catch (error2) {
                    continue;
                }
                total += 1;
                if (isSaturated(pixel)) {
                    saturated += 1;
                }
            }
        }

        if (total === 0) {
            return null;
        }
        var ratio = saturated / total;
        logger().info('profile', '头像像素判定：高饱和 ' + saturated + '/' + total +
            ' = ' + ratio.toFixed(3) + '（阈值 ' + AVATAR_SATURATED_RATIO + '）');
        return ratio >= AVATAR_SATURATED_RATIO;
    }

    /** ARGB int → 饱和度是否够高。s = (max-min)/max，避开明亮的白色背景。 */
    function isSaturated(pixel) {
        var r = (pixel >> 16) & 0xff;
        var g = (pixel >> 8) & 0xff;
        var b = pixel & 0xff;
        var max = Math.max(r, Math.max(g, b));
        var min = Math.min(r, Math.min(g, b));
        if (max < 40) {
            return false;        /* 太暗：黑边/阴影，不算色彩 */
        }
        return (max - min) / max >= 0.25;
    }

    /**
     * 用户主页的头像节点。
     * 判据：可见 ImageView、尺寸 140~280px、位于页面上部 1/3。
     * 实测新版布局在右上角（[856,168][1048,360]），老布局可能在左上，所以两侧都认。
     */
    function avatarNode() {
        var layout = TikTokAuto.layout;
        var best = null;
        var bestArea = 0;
        var collection = className('android.widget.ImageView').find();
        for (var i = 0; i < collection.size(); i += 1) {
            var node = collection.get(i);
            if (!layout.isVisible(node)) {
                continue;
            }
            var box = node.bounds();
            var width = box.right - box.left;
            var height = box.bottom - box.top;
            if (width < 140 || width > 280 || height < 140 || height > 280) {
                continue;
            }
            if (box.top > device.height * 0.33) {
                continue;
            }
            /* 取面积最大的那个：页面上部可能还有别的图标，头像一定是最大的 */
            if (width * height > bestArea) {
                bestArea = width * height;
                best = node;
            }
        }
        return best;
    }

    // ------------------------------------------------------------ 导航

    /** 当前在哪个页面（ID 提取这条链路自己的判据） */
    function where() {
        return TikTokAuto.tiktok.idPageState();
    }

    /**
     * 打开一个账号的主页（走搜索）。
     *
     * 为什么不直接拼 URL 打开：TikTok 的 deeplink 需要签名参数，
     * 而且"用户在用的这个 TikTok 版本"才是唯一可靠的入口。
     * 走搜索虽然慢（约 8 秒），但实测稳定。
     *
     * @returns 资料对象；失败返回 null
     */
    function openBySearch(uid, config) {
        var step = 'openProfile';
        var tiktok = TikTokAuto.tiktok;
        var log = logger();
        var parse = TikTokAuto.parse;
        var wanted = parse.username(uid);

        if (wanted === '') {
            return null;
        }

        log.step(step, '搜索并打开 @' + wanted);
        if (!ensureFeed(config)) {
            return null;
        }
        if (!openSearch(config)) {
            return null;
        }
        if (!submit(wanted, config)) {
            return null;
        }

        /* 切到 Users 页签：不切的话看到的是视频，找不到人 */
        var usersTab = tiktok.resultTab('Users');
        if (usersTab) {
            TikTokAuto.ui.clickNode(usersTab, step + ':usersTab');
            /* ★ 等**结果行真的出现**，不能只等"页面安静"：
             * 页签条一渲染出来签名就稳定了，而结果列表还要联网加载 1~2 秒。
             * 这里如果不等，就会稳定地误报"搜索结果里找不到该账号"（实测踩到）。 */
            TikTokAuto.wait.waitFor(step + ':rows', function () {
                return tiktok.usersResultRows().length > 0 ? true : null;
            }, config.timeouts.searchResultsMs, config.probe.pollTickMs);
        }

        var row = findRowByUid(wanted);
        if (!row) {
            log.warn(step, '搜索结果里找不到 @' + wanted +
                '（当前可见 ' + tiktok.usersResultRows().length + ' 行）');
            return null;
        }
        tapRow(row, step + ':row');
        var arrived = waitProfile(step);

        if (!arrived) {
            /* 实测：`node.click()` 打在整行容器上会落在**中心**，
             * 而搜索用户行的中心那块是空白（有时还是 Follow 按钮的邻域）——
             * 点了返回 true 却没进主页。左侧 30% 处（用户名文字上）才稳定。
             * 所以这里再补一次"按坐标点"，只重试一次，不做无限重试。 */
            log.info(step, '第一次点击没进主页，改用行内坐标重试');
            tapRow(row, step + ':row-retry');
            arrived = waitProfile(step + ':retry');
        }
        if (!arrived) {
            log.warn(step, '点了搜索结果但没有进入用户主页（当前 ' + where() + '）');
            return null;
        }
        /* 主页渲染完成后，数字区可能还差一帧。读之前再确认一次"三组数字里至少有一个读到了"，
         * 否则会把"还没渲染"当成"这个账号没有数据"。最多再等 3 秒。 */
        TikTokAuto.wait.waitFor(step + ':stats', function () {
            var stats = tiktok.statNumbers();
            return (stats.follow !== null || stats.fans !== null || stats.likes !== null) ? true : null;
        }, 3000, 200);
        return readProfile();
    }

    /** 搜索页 → 输入 → 提交。复用 flow 里已经验证过的锚点，但关键词由这里给。 */
    function openSearch(config) {
        var step = 'openSearch';
        var entry = TikTokAuto.tiktok.searchEntry();
        if (!entry) {
            logger().error(step, '首页找不到搜索入口');
            return false;
        }
        TikTokAuto.ui.clickNode(entry, step);
        return TikTokAuto.wait.waitFor(step, function () {
            var state = TikTokAuto.tiktok.idPageState();
            return (state === 'search' || state === 'users-results') ? true : null;
        }, config.timeouts.pageReadyMs, config.probe.pollTickMs) === true;
    }

    function submit(keyword, config) {
        var step = 'submitKeyword';
        var tiktok = TikTokAuto.tiktok;

        var input = tiktok.searchInput();
        if (!input) {
            logger().error(step, '找不到搜索输入框');
            return false;
        }
        TikTokAuto.ui.clickNode(input, step);
        TikTokAuto.wait.tick(250);

        var typed = TikTokAuto.ui.typeInto(tiktok.searchInput() || input, keyword, step);
        if (!typed.ok) {
            return false;
        }
        var button = tiktok.searchSubmit();
        if (!button) {
            logger().error(step, '找不到搜索提交按钮');
            return false;
        }
        TikTokAuto.ui.clickNode(button, step);

        return TikTokAuto.wait.waitFor(step, function () {
            var state = tiktok.idPageState();
            return (state === 'users-results' || TikTokAuto.tiktok.resultTabStripPresent()) ? true : null;
        }, config.timeouts.searchResultsMs, config.probe.pollTickMs) === true;
    }

    /** 在当前搜索结果里按 uid 找行（找不到返回 null，不猜第一行） */
    function findRowByUid(uid) {
        var rows = TikTokAuto.tiktok.usersResultRows();
        for (var i = 0; i < rows.length; i += 1) {
            if (rows[i].uid === uid) {
                return rows[i];
            }
        }
        return null;
    }

    /** 保证停在信息流首页（复用 flow 的成熟实现，避免两套退出逻辑） */
    function ensureFeed(config) {
        return TikTokAuto.flow.ensureFeed(config) === true;
    }

    /**
     * 在用户主页上打开「粉丝/关注」列表。
     *
     * ★ 这里**不能**用 `settle()` 判就绪：点完之后列表要联网加载，
     * 而 `waitQuiet` 的判据是"可见文案连续两次不变" —— 加载中的列表和
     * 打开前的页面**签名是一样的**，于是它会立刻就返回（实测 872ms 就回来了），
     * 然后被判成"打不开列表"。正确做法是等**列表真的有行**。
     *
     * @param which 'fans' | 'following'
     */
    function openList(which, config) {
        var step = 'openList';
        var tiktok = TikTokAuto.tiktok;
        var wanted = which === 'following' ? 'following' : 'fans';

        var entry = tiktok.statEntry(wanted);
        if (!entry) {
            /* ★ 找不到入口时**再等一次**，不要立刻报失败。
             * 实测（用户 2026-10-21 反馈）：从搜索结果进主页后，标题已经出来了，
             * 但数字区还在渲染，这时 `statEntry()` 返回 null，直接判"找不到 fans 入口"，
             * 用户看到的现象就是"还没加载出来就已经返回了"。重跑往往就正常 —— 典型的时序问题。
             * 这里最多等 3 秒，够渲染完；真没有（比如私密号不显示列表）就如实失败。 */
            logger().info(step, '暂时找不到 ' + wanted + ' 入口，等页面渲染完再试');
            TikTokAuto.wait.waitFor(step + ':entry', function () {
                entry = tiktok.statEntry(wanted);
                return entry !== null ? true : null;
            }, 3000, 300);
        }
        if (!entry) {
            logger().warn(step, '用户主页上找不到 ' + wanted + ' 入口（等了 3 秒仍没有）');
            return false;
        }
        logger().step(step, '打开列表：' + wanted);
        TikTokAuto.ui.clickNode(entry, step);

        var ready = TikTokAuto.wait.waitFor(step, function () {
            return where() === 'user-list' ? true : null;
        }, config.timeouts.pageReadyMs, config.probe.pollTickMs);

        if (ready === true) {
            return true;
        }

        /* 与粉丝列表相关的一个真机实况：首次打开会弹「给 TikTok 访问你的 Facebook 好友列表」
         * 的授权窗，盖住整个列表。它不是错误页，但会让"列表就绪"永远等不到。
         * 这里点掉它再等一次 —— 只做一轮，不无限重试。 */
        if (dismissFriendPrompt()) {
            logger().info(step, '点掉了好友列表授权窗，再等一次');
            ready = TikTokAuto.wait.waitFor(step + ':retry', function () {
                return where() === 'user-list' ? true : null;
            }, config.timeouts.pageReadyMs, config.probe.pollTickMs);
        }
        return ready === true;
    }

    /**
     * 点掉「Facebook 好友列表」授权窗的"不允许"。
     *
     * 实测这个弹窗的文案是英文 `Don’t allow`（撇号是 U+2019，不是 ASCII 单引号，
     * 直接比对 'Don\'t allow' 是匹配不上的 —— 这里按**包含**比对并同时认几种写法）。
     * 找不到就当没有弹窗，返回 false，由上层决定下一步。
     */
    function dismissFriendPrompt() {
        var layout = TikTokAuto.layout;
        var keywords = ['Facebook', '好友列表', 'friends list'];
        var buttons = className('android.widget.Button').find();
        var hint = false;

        for (var i = 0; i < buttons.size(); i += 1) {
            var text = layout.text(buttons.get(i));
            if (text === '') {
                continue;
            }
            if (text.indexOf('allow') >= 0 || text.indexOf('允许') >= 0 || text.indexOf('允許') >= 0) {
                hint = true;
                continue;
            }
            for (var k = 0; k < keywords.length; k += 1) {
                if (text.indexOf(keywords[k]) >= 0) {
                    hint = true;
                    break;
                }
            }
        }
        if (!hint) {
            return false;
        }

        /* 有授权窗：找那个"不允许 / Don't allow"，它一定比"OK"靠左（实测 [260,1114][539,1209] vs [540,1114][819,1209]） */
        var target = null;
        for (var j = 0; j < buttons.size(); j += 1) {
            var label = layout.text(buttons.get(j));
            if (/don.t allow|不允许|不允許|稍后|稍後|not now|no thanks/i.test(label)) {
                if (target === null || buttons.get(j).bounds().left < target.bounds().left) {
                    target = buttons.get(j);
                }
            }
        }
        if (!target) {
            return false;
        }
        logger().info('profile', '点掉授权窗：' + JSON.stringify(TikTokAuto.layout.text(target)));
        TikTokAuto.ui.clickNode(target, 'dismissFriendPrompt');
        settle(2000);
        return true;
    }

    /**
     * 在列表页切页签。已在目标页签上时直接返回 true（不重复点）。
     * @param which 'fans' | 'following'
     */
    function switchListTab(which) {
        var step = 'switchTab';
        var tabs = TikTokAuto.tiktok.userListTabs();
        var wanted = which === 'following' ? 'following' : 'fans';

        for (var i = 0; i < tabs.length; i += 1) {
            if (tabs[i].key !== wanted) {
                continue;
            }
            if (TikTokAuto.tiktok.selectedListTab() === wanted) {
                logger().info(step, '已在 ' + wanted + ' 页签上');
                return true;
            }
            logger().info(step, '切到 ' + wanted + ' 页签（' + tabs[i].label + '）');
            TikTokAuto.ui.clickNode(tabs[i].node, step);
            settle(3000);
            return true;
        }
        logger().warn(step, '找不到 ' + wanted + ' 页签');
        return false;
    }

    /**
     * 当前在不在"一个可以逐行取 uid 的列表页"上。
     *
     * 有两种，长得不一样、资源 id 也不同，但对上层来说都是"一屏一屏的用户行"：
     *   · `user-list`    粉丝/关注列表（`txt_desc` 装 uid）
     *   · `users-results` 搜索结果的用户页签（`tv_username` 装 uid）
     * 上层不该关心是哪种 —— 这正是这个判据存在的意义。
     */
    function isListPage(state) {
        var now = state || where();
        return now === 'user-list' || now === 'users-results';
    }

    /**
     * 列表当前可见的每一行（已按屏幕从上到下排序）。
     *
     * ★ **按当前页面选解析器**，这是实测踩出来的一个"看起来能跑但永远 0 行"的 bug：
     *   当初这里写死成 `userListRows()`（粉丝列表的解析器，找 `txt_desc`），
     *   而搜索结果页的用户行是 `tv_username` —— 于是"取材=搜索结果"时，
     *   上一步 `usersResultRows()` 明明读到了行（日志里 `userRows` 就绪），
     *   下一步 `listRows()` 却返回空，最后表现为"处理 0 行、一个都没抓到"。
     *   两种页面的行结构不同，但**对调用方是同一件事**，所以分派必须留在这里。
     */
    function listRows() {
        if (where() === 'users-results') {
            return TikTokAuto.tiktok.usersResultRows();
        }
        return TikTokAuto.tiktok.userListRows();
    }

    /**
     * 列表向下翻一屏。
     *
     * 起点刻意选在屏幕中部偏下、终点在中部偏上：太靠下会落到 Follow 按钮上
     * （按钮吃掉手势，页面纹丝不动 —— 这个坑在界面上踩过一次，这里避开）。
     *
     * @returns 翻之前那一屏的 uid 签名，供调用方判断"翻完有没有新东西"
     */
    function scrollList() {
        var layout = TikTokAuto.layout;
        var screen = layout.screen();
        TikTokAuto.ui.dragScreen(
            Math.floor(screen.width * 0.3), Math.floor(screen.height * 0.78),
            Math.floor(screen.width * 0.3), Math.floor(screen.height * 0.3),
            420
        );
        settle(2500);
    }

    /** 点列表里的一行，进入该用户主页 */
    function openRow(row) {
        var step = 'openRow';
        if (!row) {
            return false;
        }
        logger().info(step, '点开 @' + row.uid);
        tapRow(row, step);
        return waitProfile(step);
    }

    /**
     * 等用户主页**真的渲染出来**。
     *
     * ★ 不能只等 `settle()`（页面安静）：点开主页后骨架先出现、`@username`
     *   那几个字后出现，中间页面是"安静的" —— 于是 settle 会提前返回，
     *   紧接着 readProfile() 读到一份**空资料**。
     *   实测后果：一个粉丝数为 0 的账号被当成"读不到资料"，或被误判过滤。
     *   判据必须是"@username 节点已经存在"。
     */
    /**
     * 等用户主页**真的渲染完**，而不是"标题出来了就算到"。
     *
     * ★ 两段等待，缺一不可（实测踩出来的）：
     *
     *   ① 等 `@username` 出现 —— 这一步很快（约 585ms），因为标题先渲染；
     *   ② 再等顶部三组数字（关注/粉丝/获赞）**至少读到两个**。
     *
     * 只做 ① 会出两类问题，而且都很难查：
     *   · 数字区还是占位的 0 → 把"粉丝 78"读成"粉丝 0"→ 按数量门槛被错误跳过；
     *   · 数字区根本没渲染 → `statEntry()` 找不到"粉丝/关注"那个可点入口
     *     → 报"用户主页上找不到 fans 入口"（用户看到的就是"还没加载出来就返回了"）。
     *
     * 第 ② 段是**尽力等**：有些账号（私密号、无数据的新号）可能只有一组数字，
     * 所以超时也照常返回 true —— 不能因为等不到三组就把正常账号判成失败。
     */
    function waitProfile(step) {
        var tiktok = TikTokAuto.tiktok;
        var arrived = TikTokAuto.wait.waitFor(step + ':profile', function () {
            return tiktok.profileUsernameNode() !== null ? true : null;
        }, 10000, 300);
        if (arrived !== true) {
            return false;
        }
        /* 第二段：数字区。**三组都要读到**，10 秒上限。
         *
         * 为什么要求三组而不是两组：TikTok 会先把数字渲染成占位的 0，
         * 再逐组换成真值。要求"两组"时，`粉丝 0 / 关注 0 / 获赞 null` 这种
         * 半渲染状态就算通过了 —— 实测把 @.1523615 的 2019 粉丝读成了 0，
         * 而这类错误会直接影响数量门槛的判定（读成 0 就会被"粉丝≥1000"筛掉）。 */
        var statsReady = TikTokAuto.wait.waitFor(step + ':stats', function () {
            var stats = tiktok.statNumbers();
            return (stats.follow !== null && stats.fans !== null && stats.likes !== null)
                ? true : null;
        }, 10000, 300);
        if (statsReady !== true) {
            /* 不是错误：确实有账号不显示某一组（新号可能没有获赞）。
             * 但要在日志里留痕，因为后面的"读不到数量"多半是这里没等到。 */
            var last = tiktok.statNumbers();
            logger().info('profile', '三组数字 10 秒内没读全（关注 ' + last.follow +
                ' / 粉丝 ' + last.fans + ' / 获赞 ' + last.likes + '），继续');
        }
        return true;
    }

    /**
     * 点一行用户条目。
     *
     * 用**坐标**而不是 `node.click()`：整行容器的 click() 在真机上常常落到
     * "行内第一个可点元素"（也就是右侧那个 Follow 按钮），会把用户关注掉 ——
     * 这是不能接受的副作用。所以点在行左侧 30% 处（用户名文字上），远离按钮。
     * 实测这一处既能进主页，也不会误触关注。
     */
    function tapRow(row, step) {
        if (row.x === undefined || row.y === undefined) {
            TikTokAuto.ui.clickNode(row.node, step || 'tapRow');
            return;
        }
        TikTokAuto.ui.tapPoint(row.x, row.y);
    }

    /** 从用户主页退回列表（列表位置会保持，实测）；两种列表页都认 */
    function backToList() {
        var step = 'backToList';
        var deadline = Date.now() + 10000;
        while (Date.now() < deadline) {
            var state = where();
            if (isListPage(state)) {
                return true;
            }
            if (state === 'profile' || state === 'comment-panel') {
                TikTokAuto.ui.goBack(step);
                settle(2000);
                continue;
            }
            /* 已经退到搜索页/结果页/信息流：说明退过头了（列表已经不在栈上）。
             * 这种情况不该再往回退 —— 再退就退到首页去了。 */
            return false;
        }
        return isListPage();
    }

    /** 从列表退回用户主页 */
    function backToProfile() {
        var step = 'backToProfile';
        var deadline = Date.now() + 8000;
        while (Date.now() < deadline) {
            var state = where();
            if (state === 'profile') {
                return true;
            }
            TikTokAuto.ui.goBack(step);
            settle(2000);
        }
        return where() === 'profile';
    }

    /**
     * 从用户主页退回评论区。
     *
     * 与 backToProfile/backToList 是一组：评论区取材时每个评论者都要
     * "点头像 → 读 → 退回来"，退错一层（退到播放页而不是评论区）就会
     * 让下一轮找不到评论者。所以这里按状态确认，不靠数次数。
     */
    function backToCommentPanel() {
        var step = 'backToComment';
        var deadline = Date.now() + 10000;
        while (Date.now() < deadline) {
            var state = where();
            if (state === 'comment-panel') {
                return true;
            }
            if (state === 'player') {
                /* 退到了播放页：把评论面板重新点开，而不是继续退 */
                var button = TikTokAuto.tiktok.commentButton();
                if (button) {
                    TikTokAuto.ui.clickNode(button, step + ':reopen');
                    settle(2500);
                    if (where() === 'comment-panel') {
                        return true;
                    }
                }
                return false;
            }
            TikTokAuto.ui.goBack(step);
            settle(2000);
        }
        return where() === 'comment-panel';
    }

    return {
        readProfile: readProfile,
        readAvatarState: readAvatarState,
        avatarNode: avatarNode,
        where: where,
        ensureFeed: ensureFeed,
        openBySearch: openBySearch,
        findRowByUid: findRowByUid,
        openList: openList,
        switchListTab: switchListTab,
        listRows: listRows,
        isListPage: isListPage,
        /** 给外部用的"等主页就绪"：等 @username + 三组数字，见 waitProfile 的注释 */
        waitProfilePublic: function () { return waitProfile('waitProfile'); },
        scrollList: scrollList,
        openRow: openRow,
        backToList: backToList,
        backToProfile: backToProfile,
        backToCommentPanel: backToCommentPanel,
        settle: settle,
        dismissFriendPrompt: dismissFriendPrompt,
        AVATAR_SATURATED_RATIO: AVATAR_SATURATED_RATIO
    };
}());


/* ============================== src/idsource.js ============================== */
/**
 * idsource.js — 五种「从哪儿找人」，以及深度展开
 *
 * ## 为什么是五种而不是四张脚本卡
 * 旧的四个脚本卡是「起点 × 深度」的 4 个**不完整组合**。把它们拆开后发现，
 * 真正不同的只有一件事：**候选 ID 从哪儿来**。于是收敛成五种起点
 * （指定账号 / 搜索结果 / 某个视频的评论区 / 文本文件 / 当前屏幕），
 * 深度（再取这些人的粉丝）是所有起点共用的一个选项。
 *
 * ## 三种遍历模式
 * 五种起点在"怎么走"上只有三种形态，实现都归到这三条路径上：
 *   · **列表型**（指定账号 / 搜索用户 / 当前屏幕）—— 逐屏读行，可翻页；
 *   · **文本型**（文本文件）—— 一次性读出每一行；
 *   · **逐个点开型**（搜索视频作者 / 评论区）—— 屏幕上的条目没有 uid，
 *     只能点进去看（视频页底部有 `@uid`，评论者要靠头像进用户页）。
 *
 * ## 深度展开为什么分两阶段
 * "取这批人的粉丝"如果边遍历边展开，会嵌套两层列表上下文 ——
 * 打开 B 列表时 A 的滚动位置就丢了。所以做成：
 *   ① 先把基础层收完，边收边记下"这些人要展开"；
 *   ② 再对这批人逐个打开其粉丝/关注列表。
 * 两层都线性，没有嵌套，也就没有"回到上一层时不知道走到哪"的问题。
 * **上限固定两层**：100 粉丝 × 每人 100 粉丝 = 1 万次开页，真机上不现实。
 *
 * 依赖：TikTokAuto.tiktok / profile / filters / parse / logger / wait
 */
TikTokAuto.idsource = (function () {
    'use strict';

    /** 翻一个列表最多翻多少屏。防止"永远有新内容"（推荐流）把一轮拖成无限长。 */
    var MAX_SCREENS = 60;

    /** 连续这么多屏都没有新 uid 就认为到底了（有的列表末尾会重复推荐位） */
    var IDLE_SCREENS_TO_STOP = 2;

    function logger() { return TikTokAuto.logger; }

    /** 一行 uid 的临时载体（列表行带昵称与计数，用户页带更多资料，统一成这个形状） */
    function rowOf(uid, nickname, extra) {
        var one = { uid: uid, nickname: nickname || '' };
        if (extra) {
            for (var key in extra) {
                if (extra.hasOwnProperty(key)) {
                    one[key] = extra[key];
                }
            }
        }
        return one;
    }

    /* ============================================================ 列表型 */

    /**
     * 在"一个可滚动的用户列表"上逐行推进。
     *
     * 关键设计：**用 uid 集合判断进度，不用行下标**。
     * 因为每次点进用户页再退回来，列表的节点树都重建过一遍（引用失效），
     * 只有 uid 是稳的。
     *
     * @param ctx { seen, onRow(row), shouldStop() }
     * @returns 处理了多少行
     */
    function walkList(ctx) {
        var log = logger();
        var handled = 0;
        var idle = 0;
        var screens = 0;

        while (screens < MAX_SCREENS) {
            if (ctx.shouldStop()) {
                log.info('idsource', '达到停止条件，结束当前列表');
                break;
            }
            screens += 1;

            var rows = TikTokAuto.profile.listRows();
            if (rows.length === 0 && screens === 1) {
                /* 首屏还在加载。**等一次**再判定，否则会把"慢"当成"空"：
                 * 从用户页点开粉丝列表、或从结果页切到用户页签后，
                 * 容器先出来、行后出来（实测差 1~2 秒），这时 listRows() 返回空数组 ——
                 * 直接 break 就等于"一条都没抓到"。 */
                TikTokAuto.wait.waitFor('listRows', function () {
                    return TikTokAuto.profile.listRows().length > 0 ? true : null;
                }, ctx.config ? ctx.config.timeouts.pageReadyMs : 8000, 300);
                rows = TikTokAuto.profile.listRows();
            }
            if (rows.length === 0) {
                log.info('idsource', '当前屏没有读到用户行，结束列表');
                break;
            }

            var fresh = [];
            for (var i = 0; i < rows.length; i += 1) {
                if (!ctx.seen.has(rows[i].uid)) {
                    fresh.push(rows[i]);
                }
            }

            if (fresh.length === 0) {
                idle += 1;
                if (idle >= IDLE_SCREENS_TO_STOP) {
                    log.info('idsource', '连续 ' + idle + ' 屏没有新 uid，认为列表到底');
                    break;
                }
            } else {
                idle = 0;
            }

            /* 一行一行处理：需要资料时会点进用户页再退回（实测位置保持） */
            for (var j = 0; j < fresh.length; j += 1) {
                if (ctx.shouldStop()) {
                    return handled;
                }
                ctx.onRow(fresh[j]);
                ctx.seen.add(fresh[j].uid);     /* 处理过就算见过，避免同一行被反复点开 */
                handled += 1;
            }

            /* 翻一屏再看有没有新的 */
            var before = signatureOfRows(rows);
            TikTokAuto.profile.scrollList();
            var after = signatureOfRows(TikTokAuto.profile.listRows());
            if (after === before) {
                idle += 1;
                if (idle >= IDLE_SCREENS_TO_STOP) {
                    log.info('idsource', '翻屏后内容不变，认为列表到底');
                    break;
                }
            }
        }
        return handled;
    }

    /** 一屏 uid 的签名，用来判断"翻完到底有没有变" */
    function signatureOfRows(rows) {
        var parts = [];
        for (var i = 0; i < rows.length; i += 1) {
            parts.push(rows[i].uid);
        }
        return parts.join('|');
    }

    /* ============================================================ 文本型 */

    /**
     * 从本地文本文件读 uid。
     *
     * 两条容忍（都是为了让用户不用改自己的文件）：
     *   · 行首的 `@` 会被剥掉（有人习惯直接粘贴 "@name"）；
     *   · `#` 开头的行当注释跳过。
     */
    function readTextSource(source) {
        var list = TikTokAuto.uidset.readUidFile(source.path);
        logger().info('idsource', '文本取材：' + source.path + ' 读到 ' + list.length + ' 行');
        var rows = [];
        for (var i = 0; i < list.length; i += 1) {
            rows.push(rowOf(list[i], ''));
        }
        return rows;
    }

    /* ============================================================ 逐个点开型 */

    /**
     * 搜索结果里的视频 → 逐个点开，读播放页底部的作者 uid。
     *
     * 实测：搜索结果的视频卡片上只有**作者昵称**，没有 uid；
     * 播放页底部有一个 `Button` 文案是 `@uid` —— 这是唯一能拿到 uid 的地方。
     * 所以每个视频要"点开 → 读 → 退回"，约 6 秒一个。
     */
    function walkSearchVideos(source, ctx) {
        var log = logger();
        var handled = 0;
        var idle = 0;

        for (var screen = 0; screen < MAX_SCREENS; screen += 1) {
            if (ctx.shouldStop()) {
                break;
            }
            var cards = TikTokAuto.tiktok.videoCards();
            if (cards.length === 0) {
                log.info('idsource', '结果页没有卡片了');
                break;
            }

            var opened = 0;
            for (var i = 0; i < cards.length; i += 1) {
                if (ctx.shouldStop()) {
                    return handled;
                }
                var card = cards[i];
                var marker = 'card:' + String(card.caption).slice(0, 40);
                if (ctx.seen.has(marker)) {
                    continue;
                }
                ctx.seen.add(marker);

                if (!TikTokAuto.flow.openCard(ctx.config, card)) {
                    log.warn('idsource', '打开视频失败：' + marker);
                    TikTokAuto.flow.returnToResults(ctx.config);
                    continue;
                }
                var uid = TikTokAuto.tiktok.playerAuthorUid();
                if (uid) {
                    ctx.onRow(rowOf(uid, String(card.caption).slice(0, 30)));
                    handled += 1;
                    opened += 1;
                } else {
                    log.warn('idsource', '播放页读不到作者 uid');
                }
                TikTokAuto.flow.returnToResults(ctx.config);
            }

            if (opened === 0) {
                idle += 1;
                if (idle >= IDLE_SCREENS_TO_STOP) {
                    log.info('idsource', '连续几屏都读不到作者，结束');
                    break;
                }
            } else {
                idle = 0;
            }
            TikTokAuto.flow.scrollResults(ctx.config);
        }
        return handled;
    }

    /**
     * 评论区 → 逐个点评论者的头像进用户页读 uid。
     *
     * 实测这条最贵：评论区只显示昵称，没有 uid（`Button title` 是昵称，
     * 旁边那个 `@uid` 是固定节点、不是评论者的）。所以每个评论者都要
     * "点头像 → 读 → 退回"，约 8 秒一个。这也是为什么方案里
     * 把"评论者"和"评论者的粉丝"分开成两条取材，而不是默认都开。
     */
    function walkCommenters(source, ctx) {
        var log = logger();
        var handled = 0;

        for (var screen = 0; screen < MAX_SCREENS; screen += 1) {
            if (ctx.shouldStop()) {
                break;
            }
            var rows = TikTokAuto.tiktok.commentRowers();
            if (rows.length === 0) {
                log.info('idsource', '评论区没有更多可见条目');
                break;
            }

            var opened = 0;
            var before = signatureOfNodes(rows);
            for (var i = 0; i < rows.length; i += 1) {
                if (ctx.shouldStop()) {
                    return handled;
                }
                /* 头像节点每次都会重建，用"位置 + 序号"当标记 —— 换一屏位置就会变 */
                var marker = 'cmt:' + rows[i].top + ':' + (screen * 100 + i);
                if (ctx.seen.has(marker)) {
                    continue;
                }
                ctx.seen.add(marker);

                TikTokAuto.ui.tapPoint(rows[i].x, rows[i].y);
                /* ★ 用 waitProfile（等 @username + 三组数字），而不是 settle + where()。
                 *
                 * 早先这里是"等页面安静 3 秒，再看 where() 是不是 profile"：
                 *   · settle 会提前返回（骨架先出、内容后加载，签名看起来没变）；
                 *   · 而 where() 要求 `@username` 已经渲染出来。
                 * 两头一凑，就成了"人明明已经进主页了，却被判成没进去"——
                 * 实测日志里连续两条"点评论者头像没有进入用户主页"，然后一条都没取到。
                 */
                if (!TikTokAuto.profile.waitProfilePublic()) {
                    log.warn('idsource', '点评论者头像没有进入用户主页（等了 10 秒）');
                    continue;
                }
                var profile = TikTokAuto.profile.readProfile();
                if (profile.uid) {
                    /* 资料已经在手上了，带上 `_profile` 让编排层不必再开一次用户页 */
                    ctx.onRow(rowOf(profile.uid, profile.nickname, { _profile: profile }));
                    handled += 1;
                    opened += 1;
                }
                TikTokAuto.profile.backToCommentPanel();
            }

            if (opened === 0) {
                break;
            }
            /* 评论区滚动 */
            var layout = TikTokAuto.layout;
            var screenSize = layout.screen();
            TikTokAuto.ui.dragScreen(
                Math.floor(screenSize.width * 0.5), Math.floor(screenSize.height * 0.8),
                Math.floor(screenSize.width * 0.5), Math.floor(screenSize.height * 0.4),
                420
            );
            TikTokAuto.profile.settle(2000);

            if (signatureOfNodes(TikTokAuto.tiktok.commentRowers()) === before) {
                log.info('idsource', '评论区滚动后内容不变，结束');
                break;
            }
        }
        return handled;
    }

    function signatureOfNodes(rows) {
        var parts = [];
        for (var i = 0; i < rows.length; i += 1) {
            parts.push(rows[i].top);
        }
        return parts.join(',');
    }

    /* ============================================================ 入口 */

    /**
     * 把一个取材源跑完，逐行交给 `onRow`。
     *
     * @param source 取材项（与界面 sources.js 的形状一致）
     * @param ctx    { config, seen, onRow(row), shouldStop() }
     * @returns 处理的行数
     */
    function run(source, ctx) {
        var log = logger();
        log.step('idsource', '取材开始：' + describe(source));

        if (source.kind === 'text') {
            /* 文本源也走 `onRow`，**不在这一层自己判去重** ——
             * 去重与过滤是编排层（idflow）的职责，在这里再做一遍会让
             * `duplicates` 统计漏掉（实测：跨轮去重跳了 3 个，summary 里却是 0）。 */
            var rows = readTextSource(source);
            var handled = 0;
            for (var i = 0; i < rows.length; i += 1) {
                if (ctx.shouldStop()) {
                    break;
                }
                ctx.onRow(rows[i]);
                handled += 1;
            }
            return handled;
        }

        if (source.kind === 'screen') {
            /* 当前屏幕：不做任何导航，直接把眼前这一屏当列表读。
             *
             * 但要先确认眼前确实是"一个用户列表" —— 否则 walkList 会一屏一屏地读，
             * 最后报"处理 0 行"，用户完全不知道是页面不对。 */
            var state = TikTokAuto.profile.where();
            if (!TikTokAuto.profile.isListPage(state)) {
                log.warn('idsource', '当前屏幕取材：需要先把页面停在「用户列表」（粉丝/关注/搜索用户）上，' +
                    '引擎不会替你跳转。现在停在「' + state + '」');
                return 0;
            }
            return walkList(ctx);
        }

        if (source.kind === 'anchor') {
            return runAnchor(source, ctx);
        }

        if (source.kind === 'search') {
            if (source.searchType === 'videos') {
                if (!prepareSearch(source.keyword, ctx.config)) {
                    return 0;
                }
                TikTokAuto.flow.selectResultTab({
                    target: { resultTab: 'Top' },
                    timeouts: ctx.config.timeouts,
                    probe: ctx.config.probe
                });
                return walkSearchVideos(source, ctx);
            }
            if (!prepareSearch(source.keyword, ctx.config)) {
                return 0;
            }
            return walkList(ctx);
        }

        if (source.kind === 'video') {
            if (!prepareVideo(source, ctx.config)) {
                return 0;
            }
            return walkCommenters(source, ctx);
        }

        log.warn('idsource', '未知的取材起点：' + source.kind);
        return 0;
    }

    /**
     * 指定账号：打开它的主页 → 按 `lists` 逐个开列表 → 每处走一遍 walkList。
     *
     * `anchors` 为空表示"不限定账号，从当前屏幕取" —— 这是界面允许的状态，
     * 对应 v6 时代「主播 ID 留空」的语义。
     */
    function runAnchor(source, ctx) {
        var log = logger();
        var parse = TikTokAuto.parse;
        var anchors = String(source.anchors || '').split('#');
        var handled = 0;

        var accounts = [];
        for (var i = 0; i < anchors.length; i += 1) {
            var name = parse.username(anchors[i]);
            if (name !== '') {
                accounts.push(name);
            }
        }

        if (accounts.length === 0) {
            log.info('idsource', '没有指定账号 → 直接把当前屏幕当列表');
            return walkList(ctx);
        }

        for (var a = 0; a < accounts.length; a += 1) {
            if (ctx.shouldStop()) {
                break;
            }
            var profile = TikTokAuto.profile.openBySearch(accounts[a], ctx.config);
            if (!profile) {
                log.warn('idsource', '打不开账号 @' + accounts[a] + '，跳过');
                continue;
            }
            ctx.onSeenProfile(profile);

            var lists = source.lists && source.lists.length > 0 ? source.lists : ['fans'];
            for (var l = 0; l < lists.length; l += 1) {
                if (ctx.shouldStop()) {
                    return handled;
                }
                var which = lists[l] === 'home' ? 'fans' : lists[l];
                if (!TikTokAuto.profile.openList(which, ctx.config)) {
                    log.warn('idsource', '打不开 ' + lists[l] + ' 列表');
                    continue;
                }
                TikTokAuto.profile.switchListTab(which);
                handled += walkList(ctx);
                TikTokAuto.profile.backToProfile();
            }
        }
        return handled;
    }

    /** 搜索关键词并停在结果页（供列表型与逐个点开型共用） */
    function prepareSearch(keyword, config) {
        var log = logger();
        if (!TikTokAuto.profile.ensureFeed(config)) {
            return false;
        }
        var tiktok = TikTokAuto.tiktok;
        var entry = tiktok.searchEntry();
        if (!entry) {
            log.error('idsource', '首页找不到搜索入口');
            return false;
        }
        TikTokAuto.ui.clickNode(entry, 'idsource:search');
        if (TikTokAuto.wait.waitFor('idsource:search', function () {
            var state = tiktok.idPageState();
            return (state === 'search' || state === 'users-results') ? true : null;
        }, config.timeouts.pageReadyMs, config.probe.pollTickMs) !== true) {
            return false;
        }

        var input = tiktok.searchInput();
        if (!input) {
            return false;
        }
        TikTokAuto.ui.clickNode(input, 'idsource:input');
        TikTokAuto.wait.tick(250);
        if (!TikTokAuto.ui.typeInto(tiktok.searchInput() || input, keyword, 'idsource:type').ok) {
            return false;
        }
        var submit = tiktok.searchSubmit();
        if (!submit) {
            return false;
        }
        TikTokAuto.ui.clickNode(submit, 'idsource:submit');

        if (TikTokAuto.wait.waitFor('idsource:results', function () {
            return tiktok.resultTabStripPresent() ? true : null;
        }, config.timeouts.searchResultsMs, config.probe.pollTickMs) !== true) {
            return false;
        }

        /* 用户搜索要切到 Users 页签；视频搜索留在 Top */
        var usersTab = tiktok.resultTab('Users');
        if (usersTab && !tiktok.resultTabSelected('Users')) {
            TikTokAuto.ui.clickNode(usersTab, 'idsource:usersTab');
            /* 等结果行真的出现（页签条先渲染、行后加载，只等"安静"会误判为空） */
            TikTokAuto.wait.waitFor('idsource:userRows', function () {
                return tiktok.usersResultRows().length > 0 ? true : null;
            }, config.timeouts.searchResultsMs, config.probe.pollTickMs);
        }
        return true;
    }

    /**
     * 打开一个视频（播放页），供评论区取材用。
     * `videoSource = "screen"` 表示用户自己已经把视频停在屏幕上，不动它。
     */
    function prepareVideo(source, config) {
        var log = logger();
        if (source.videoSource !== 'keyword') {
            var state = TikTokAuto.tiktok.pageState();
            if (state === 'player' || state === 'comment-panel') {
                log.info('idsource', '已在播放页，直接用当前屏幕的视频');
                return true;
            }
            /* 这里的提示必须是**可操作**的：用户能做的只有三件事 —— 自己先把页面停好、
             * 改用关键词模式、或者换一个取材源。不能只说"不在播放页"。 */
            log.warn('idsource', '「当前屏幕」需要用你手上已经打开的那个视频，引擎不会替你跳转。\n' +
                '  请先在 TikTok 里打开视频（或直接打开它的评论区），再点「开始运行」。\n' +
                '  当前页面是「' + state + '」。');
            return false;
        }

        if (!prepareSearch(source.videoKeyword, config)) {
            return false;
        }
        /* Top 页签是视频；取第一张卡点开 */
        var cards = TikTokAuto.tiktok.videoCards();
        if (cards.length === 0 && !TikTokAuto.flow.waitForCards(config)) {
            return false;
        }
        cards = TikTokAuto.tiktok.videoCards();
        if (cards.length === 0) {
            return false;
        }
        if (!TikTokAuto.flow.openCard(config, cards[0])) {
            return false;
        }
        /* 打开评论面板 */
        var button = TikTokAuto.tiktok.commentButton();
        if (!button) {
            log.warn('idsource', '播放页找不到评论按钮');
            return false;
        }
        TikTokAuto.ui.clickNode(button, 'idsource:comments');
        return TikTokAuto.wait.waitFor('idsource:panel', function () {
            return TikTokAuto.tiktok.commentPanelOpen() ? true : null;
        }, config.timeouts.panelReadyMs, config.probe.pollTickMs) === true;
    }

    /** 一句人话摘要（日志与状态条用） */
    function describe(source) {
        var parse = TikTokAuto.parse;
        if (source.kind === 'anchor') {
            var list = source.anchors ? source.anchors.split('#')[0] : '当前屏幕';
            return '账号 ' + list + ' 的 ' + (source.lists || []).join('+');
        }
        if (source.kind === 'search') {
            return (source.searchType === 'videos' ? '视频作者' : '用户') + '「' + source.keyword + '」';
        }
        if (source.kind === 'video') {
            return source.videoSource === 'keyword'
                ? '评论区「' + source.videoKeyword + '」'
                : '当前屏幕的评论区';
        }
        if (source.kind === 'text') {
            return '文本 ' + String(source.path).split('/').pop();
        }
        return '当前屏幕';
    }

    return {
        MAX_SCREENS: MAX_SCREENS,
        run: run,
        walkList: walkList,
        readTextSource: readTextSource,
        describe: describe
    };
}());


/* ============================== src/resolve.js ============================== */
/**
 * resolve.js — 把 username（@handle）换成 TikTok 的数字 uid
 *
 * ## 为什么需要它
 * 抓取产物里存的是 **username**（`beautifulsoul78869`）—— 那是能搜到人、能 @ 的标识。
 * 但有些下游（对接接口、入库、跟外部系统对账）要的是 **数字 uid**（`254801657882882048`）。
 * 两者完全不同：
 *
 *   uniqueId / handle   beautifulsoul78869      能搜到人、能 @，界面上可见
 *   nickname             🌹Beautiful Soul💀     显示名，可重名、可随时改
 *   id（本文的 uid）      254801657882882048     平台内部主键，界面上**读不到**
 *
 * 数字 uid 在 App 界面上任何地方都不显示，所以只能靠 HTTP 拿。
 *
 * ## 三条取数路径（照 `tiktok-uid和视频短链解析.js` 的分级思路）
 *
 *   ① `www.tiktok.com/api/user/detail/?uniqueId=`  官方详情接口，最轻（本应几百字节）
 *   ② `www.tiktok.com/node/share/user/@<handle>`   老的分享接口
 *   ③ `www.tiktok.com/@<handle>` 的整页 SSR        最重（约 388KB），但**最可靠**
 *
 * 2026-10-20 真机实测：**①② 都已经不可用** ——
 *   ① 返回 `HTTP 200` 但**响应体为空**（风控静默拒绝，最容易让人误以为"接口还在"）
 *   ② 返回 `403`
 *   ③ 200 / 388KB / 约 2 秒 / `JSON.parse` 仅 7ms
 *
 * 所以路径按"轻 → 重"逐个降级，且**每条只探一次**：某个账号证明 ① 不可用之后，
 * 本次运行内不再尝试 ① —— 否则每个账号都要白付两次失败请求。
 * 这样将来接口恢复了，第一次就会自动走轻的那条；恢复不了也不会拖慢。
 *
 * ## 试过但走不通的（别再试）
 *   · `tikwm.com/api/user/info` —— Cloudflare 挑战页（"Just a moment..."）
 *   · `m.tiktok.com/@user` —— 404（那条短链只认 `/v/<videoId>.html`）
 *   · `www.tiktok.com/oembed?url=...` —— 只有昵称与 handle，**没有数字 id**
 *   · AutoX 的 `http.get` —— 本机这个版本是坏的：
 *     `TypeError: Cannot find function newCall`（OkHttp 绑定冲突）→ 走 Java `HttpURLConnection`
 *
 * 依赖：TikTokAuto.logger、TikTokAuto.wait（节流与停止响应）、TikTokAuto.parse
 */
TikTokAuto.resolve = (function () {
    'use strict';

    var UA = 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 ' +
             '(KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36';

    /** 整页近 400KB，慢网下 20 秒是合理的上限；接口那两条给 8 秒就够。 */
    var API_TIMEOUT_MS = 8000;
    var PAGE_TIMEOUT_MS = 20000;

    /**
     * 两次请求之间的间隔区间。
     *
     * 为什么不并发：这是网页版接口，短时间高频请求很容易被要求过验证码；
     * 而我们是"一次几十个"的量级，串行 + 随机间隔的代价可以接受（每个约 2.5 秒）。
     */
    var GAP_MIN_MS = 400;
    var GAP_MAX_MS = 900;

    /**
     * 本次运行里各条路径是否已被证明不可用。
     *
     * 这是**性能关键**：接口①② 实测必失败，若不记住，每个账号要多付两次失败请求；
     * 记住之后只有第一个账号付这个代价。
     */
    var deadPaths = { api: false, share: false };

    /** ttwid 只取一次（接口风控用；主页 HTML 不需要它） */
    var ttwidCache = null;
    var ttwidTried = false;

    function logger() { return TikTokAuto.logger; }

    /**
     * 读一个连接的响应体。
     *
     * ★ 必须区分**正常流与错误流**：`getInputStream()` 在 4xx/5xx 时会直接抛异常，
     *   于是「404 账号不存在」会被误判成「网络错误」。
     *   从 `getErrorStream()` 读出来的 body 才是真正的原因（有时还带 JSON 错误码）。
     */
    function readBody(conn) {
        var stream = null;
        try {
            var code = conn.getResponseCode();
            stream = code >= 400 ? conn.getErrorStream() : conn.getInputStream();
            if (!stream) {
                return { code: code, body: '' };
            }
            var reader = new java.io.BufferedReader(new java.io.InputStreamReader(stream, 'UTF-8'));
            var buffer = new java.lang.StringBuilder();
            var line;
            while ((line = reader.readLine()) !== null) {
                buffer.append(line).append('\n');
            }
            reader.close();
            return { code: code, body: String(buffer.toString()) };
        } finally {
            try { if (stream) { stream.close(); } } catch (ignored) { }
        }
    }

    /**
     * 发一个 GET。
     * @returns { ok, status, body, error }
     */
    function get(url, headers, timeoutMs) {
        var conn = null;
        try {
            conn = new java.net.URL(url).openConnection();
            conn.setConnectTimeout(timeoutMs);
            conn.setReadTimeout(timeoutMs);
            conn.setInstanceFollowRedirects(true);
            conn.setRequestProperty('User-Agent', UA);
            conn.setRequestProperty('Accept-Language', 'en-US,en;q=0.9');
            if (headers) {
                for (var key in headers) {
                    if (headers.hasOwnProperty(key)) {
                        conn.setRequestProperty(key, headers[key]);
                    }
                }
            }
            var result = readBody(conn);
            return { ok: true, status: result.code, body: result.body };
        } catch (error) {
            return { ok: false, status: 0, body: '', error: String(error) };
        } finally {
            /* 一定要断开：不关的话连接会一直占着，几十个账号之后就容易出问题 */
            try { if (conn) { conn.disconnect(); } } catch (ignoredToo) { }
        }
    }

    /**
     * 取 ttwid（TikTok 首页下发，接口风控用）。
     * 取不到不算错 —— 只是那两条接口大概也走不通，直接降级到主页 HTML。
     */
    function ttwid() {
        if (ttwidTried) {
            return ttwidCache;
        }
        ttwidTried = true;
        var conn = null;
        try {
            conn = new java.net.URL('https://www.tiktok.com/').openConnection();
            conn.setConnectTimeout(API_TIMEOUT_MS);
            conn.setReadTimeout(API_TIMEOUT_MS);
            conn.setRequestProperty('User-Agent', UA);
            conn.getResponseCode();
            var fields = conn.getHeaderFields();
            var cookies = fields ? fields.get('Set-Cookie') : null;
            if (cookies) {
                for (var i = 0; i < cookies.size(); i += 1) {
                    var one = String(cookies.get(i));
                    var idx = one.indexOf('ttwid=');
                    if (idx !== -1) {
                        ttwidCache = one.substring(idx).split(';')[0];  /* 形如 ttwid=xxx */
                        break;
                    }
                }
            }
        } catch (error) {
            logger().warn('resolve', '取 ttwid 失败（不影响后续降级）：' + error);
        } finally {
            try { if (conn) { conn.disconnect(); } } catch (ignored) { }
        }
        return ttwidCache;
    }

    /** 从 JSON 对象里找 `userInfo.user`（别写死键路径，层级改过） */
    function findUser(node, depth) {
        if (depth > 8 || node === null || typeof node !== 'object') {
            return null;
        }
        if (node.userInfo && node.userInfo.user && node.userInfo.user.id) {
            return node.userInfo.user;
        }
        for (var key in node) {
            if (node.hasOwnProperty(key)) {
                var hit = findUser(node[key], depth + 1);
                if (hit) {
                    return hit;
                }
            }
        }
        return null;
    }

    /** JSON 解析失败时用正则兜一层（整页 SSR 结构改版时不至于全废） */
    function findUserByRegex(html, handle) {
        var escaped = String(handle).replace(/[.*+?^${}()|[\]\\]/g, '\\$&');
        var matched = html.match(
            new RegExp('"uniqueId":"' + escaped + '"[^}]*?"id":"(\\d+)"')
        ) || html.match(
            new RegExp('"id":"(\\d+)","shortId":"[^"]*","uniqueId":"' + escaped + '"')
        );
        if (!matched) {
            return null;
        }
        return { id: matched[1], uniqueId: handle };
    }

    /** 统一校验：拿到的确实是这个 handle 的用户（网页版可能重定向到别名） */
    function accept(user, wanted) {
        if (!user || !user.id) {
            return null;
        }
        var got = TikTokAuto.parse.username(user.uniqueId || '');
        if (got !== '' && got.toLowerCase() !== String(wanted).toLowerCase()) {
            logger().warn('resolve', '返回的是另一个账号（' + got + ' ≠ ' + wanted + '），丢弃');
            return null;
        }
        return {
            ok: true,
            uid: String(user.id),
            nickname: user.nickname || '',
            secUid: user.secUid || ''
        };
    }

    /* ---------------------------------------------------------- 三条路径 */

    /** ① 官方用户详情接口 */
    function viaApi(handle) {
        var headers = {
            'Accept': 'application/json, text/plain, */*',
            'Referer': 'https://www.tiktok.com/@' + encodeURIComponent(handle)
        };
        var cookie = ttwid();
        if (cookie) {
            headers['Cookie'] = cookie;
        }
        var res = get('https://www.tiktok.com/api/user/detail/?uniqueId=' +
            encodeURIComponent(handle), headers, API_TIMEOUT_MS);
        if (!res.ok || res.status !== 200 || res.body === '') {
            return null;
        }
        var data = null;
        try { data = JSON.parse(res.body); } catch (error) { return null; }
        return findUser(data, 0);
    }

    /** ② 老的分享接口 */
    function viaShare(handle) {
        var res = get('https://www.tiktok.com/node/share/user/@' + encodeURIComponent(handle) +
            '?uniqueId=' + encodeURIComponent(handle),
            { 'Accept': 'application/json, text/plain, */*' }, API_TIMEOUT_MS);
        if (!res.ok || res.status !== 200 || res.body === '') {
            return null;
        }
        var data = null;
        try { data = JSON.parse(res.body); } catch (error) { return null; }
        return findUser(data, 0);
    }

    /** ③ 主页整页 SSR（实测唯一可用的一条） */
    function viaProfileHtml(handle) {
        var res = get('https://www.tiktok.com/@' + encodeURIComponent(handle),
            { 'Accept': 'text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8' },
            PAGE_TIMEOUT_MS);
        if (!res.ok || res.status !== 200 || res.body === '') {
            return null;
        }
        var matched = res.body.match(
            /<script id="__UNIVERSAL_DATA_FOR_REHYDRATION__" type="application\/json">([\s\S]*?)<\/script>/
        );
        if (matched) {
            var data = null;
            try { data = JSON.parse(matched[1]); } catch (error) { data = null; }
            if (data) {
                var user = findUser(data, 0);
                if (user) {
                    return user;
                }
            }
        }
        /* 结构改版 / 解析失败时的兜底 */
        return findUserByRegex(res.body, handle);
    }

    /**
     * 一个 username → uid。
     *
     * @returns { ok, uid, nickname, secUid, via, error }
     *   `via` 记录这次用的是哪条路径（api / share / html），看日志就知道接口有没有恢复。
     */
    function fetchUserId(username) {
        var name = TikTokAuto.parse.username(username);
        if (name === '') {
            return { ok: false, error: '空用户名' };
        }

        var paths = [
            { key: 'api', dead: deadPaths.api, run: viaApi,
              label: '官方 user/detail' },
            { key: 'share', dead: deadPaths.share, run: viaShare,
              label: 'node/share' },
            { key: 'html', dead: false, run: viaProfileHtml,
              label: '主页 SSR' }
        ];

        for (var i = 0; i < paths.length; i += 1) {
            var path = paths[i];
            if (path.dead) {
                continue;
            }
            var user = path.run(name);
            if (user) {
                var accepted = accept(user, name);
                if (accepted) {
                    accepted.via = path.key;
                    return accepted;
                }
            }
            /* 前两条失败就标记"本次运行不再试"；主页是最后一条，没有可退的地方 */
            if (path.key !== 'html') {
                deadPaths[path.key] = true;
                logger().info('resolve', path.label + ' 不可用，本次运行后续直接走主页 SSR');
            }
        }

        return { ok: false, error: '三条路径都拿不到（账号可能不存在或已注销）' };
    }

    /** 随机间隔，让请求节奏不像机器 */
    function pause() {
        var span = GAP_MAX_MS - GAP_MIN_MS;
        TikTokAuto.wait.tick(GAP_MIN_MS + Math.floor(Math.random() * (span + 1)));
    }

    /**
     * 批量把 username 换成 uid。
     *
     * 三条原则：
     *   ① **一个失败不影响其余**（注销的号、网络抖动都只记一行）；
     *   ② 每处理一个就回报进度（这个阶段比抓取慢，没有进度会让人以为卡死）；
     *   ③ 可以被停止打断（`wait.tick` 里会检查停止标志）；
     *   ④ 换不到的**不写进映射文件** —— 文件里全是可用的对应关系，比写一堆空值有用。
     *
     * @param usernames 用户名数组
     * @param options { onProgress(done, total, name), shouldStop() }
     * @returns { ok, map: [{username, uid, nickname}], failed: [{username, error}], stopped }
     */
    function resolveAll(usernames, options) {
        var settings = options || {};
        var log = logger();
        var map = [];
        var failed = [];
        var total = usernames.length;

        for (var i = 0; i < total; i += 1) {
            if (settings.shouldStop && settings.shouldStop()) {
                /* 注意措辞：这里的 shouldStop 只反映**时长护栏**，
                 * 不含"提取上限已到"（那个属于抓取阶段，不该阻止收尾）。
                 * 早先写成"收到停止"，把"跑太久"和"用户点了停止"混为一谈，排查时很误导。 */
                log.warn('resolve', '到达时长上限，已换 ' + map.length + '/' + total + ' 个');
                return { ok: true, map: map, failed: failed, stopped: true };
            }
            var name = usernames[i];
            if (settings.onProgress) {
                settings.onProgress(i + 1, total, name);
            }

            var result = fetchUserId(name);
            if (result.ok) {
                map.push({ username: name, uid: result.uid, nickname: result.nickname });
                /* 带上 via：这样一看日志就知道现在走的是哪条路径，
                 * 接口哪天恢复了也能立刻发现（不用等别人报告）。 */
                log.info('resolve', name + ' → ' + result.uid + '（via ' + result.via + '）');
            } else {
                failed.push({ username: name, error: result.error });
                log.warn('resolve', '换不到 ' + name + '：' + result.error);
            }

            if (i < total - 1) {
                pause();
            }
        }
        return { ok: true, map: map, failed: failed, stopped: false };
    }

    /** 把映射写成两列文本（TAB 分隔）。写入失败返回 false，不抛。 */
    function writeMap(path, map) {
        var lines = [];
        for (var i = 0; i < map.length; i += 1) {
            lines.push(map[i].username + '\t' + map[i].uid);
        }
        try {
            files.write(path, lines.join('\n') + (lines.length > 0 ? '\n' : ''));
            return true;
        } catch (error) {
            logger().error('resolve', '写映射文件失败 ' + path + '：' + error);
            return false;
        }
    }

    return {
        fetchUserId: fetchUserId,
        viaApi: viaApi,
        viaShare: viaShare,
        viaProfileHtml: viaProfileHtml,
        resolveAll: resolveAll,
        writeMap: writeMap,
        GAP_MIN_MS: GAP_MIN_MS,
        GAP_MAX_MS: GAP_MAX_MS
    };
}());


/* ============================== src/idflow.js ============================== */
/**
 * idflow.js — ID 提取的编排
 *
 * 与 `flow.js`（视频链路）并列，共用同一套基础设施：应用启动、弹窗守护、
 * 坐标点击、`wait.tick()` 的停止、`bridge.report()` 的状态上报。
 *
 * ## 一轮跑完是什么样
 *
 *   启动应用 → 进信息流 → 对每条取材：
 *        取材（列表型 / 文本型 / 逐个点开型）
 *        → 每个候选：去重判定 → 需要时打开用户页 → 过滤判定 → 写盘
 *    → 深度展开（第二层，最多一层）
 *    → 收尾：关文件、把 summary 上报给界面
 *
 * ## 三个必须处理好的"与视频链路不同"
 *
 * ① **总量未知**。粉丝列表可能几十万人，没有 `total` 可报。
 *    所以状态条上的进度是「已收 N 个」而不是"N/M" —— 界面只读 `phase`，零改动。
 *
 * ② **"不限"是危险的**。界面里 `extractLimit = 0` 的语义是"不限制"。
 *    但真跑起来没有上限就等于跑到没电。所以引擎**另加三道物理护栏**：
 *    最大时长、单列表最大翻屏数（在 idsource 里）、连续无新内容即止。
 *    到护栏时**如实报告**"因达到护栏而结束"，绝不装作抓完了。
 *
 * ③ **停止时必须写文件**。用户在任意时刻点停，已经抓到的部分不能丢 ——
 *    所以 `writer.close()` 放在 finally 里，无论怎么结束都会刷盘。
 *
 * 依赖：全部 ID 相关模块 + bridge / wait / ui / popups
 */
TikTokAuto.idflow = (function () {
    'use strict';

    /**
     * 最近一次运行的 summary。
     *
     * 为什么挂模块级而不是只靠返回值：用户点停止时 StopSignal 会从
     * `wait.tick()` 里抛出来，穿过整个流程到 main.js 的 catch ——
     * 那时 `runSession` 的返回值根本用不上。main 从这里取已经统计好的数字，
     * 否则界面会显示"提取 0 个"（实际抓到的都在文件里，只是没报上去）。
     */
    var lastSummary = null;

    function logger() { return TikTokAuto.logger; }

    /** 上报进度。只动 phase（界面状态条只读它），total 恒为 0 —— 这里没有总量。 */
    function progress(phase, done) {
        TikTokAuto.bridge.report({
            status: 'running',
            phase: phase + '（已收 ' + done + ' 个）',
            done: done,
            total: 0
        });
    }

    /**
     * 估算"够用的抓取预算"。
     *
     * ## 为什么要自动算
     * 预算是**按时间**给的，而用户的目标是**按个数**（"提取满 100 个"）。
     * 两者之间要经过"每个的平均耗时"，而这个耗时取决于过滤设置（差 6 倍）：
     *   · 不过滤 → 直接从列表抄 uid，约 1.5 秒/个；
     *   · 开了私密/无头像/数量门槛 → 每个都要打开用户页读资料，约 8 秒/个；
     *   · 再加上被过滤跳过的（实测收录率约 37%）→ 折算到"每个**收录**"约 20 秒。
     *
     * 所以固定给 30 分钟是错的：设 100 个要 38 分钟、设 1000 个要 5 个多小时。
     * 用户设的数只当**下限**（"至少跑这么久"），实际按提取上限放宽。
     *
     * ## 为什么还要封顶
     * 4 小时是设备安全的边界（长时间亮屏运行会发热）。真要更多，分几轮跑更好 ——
     * 每轮都刷盘，中断不丢，还能跨轮去重。
     */
    var PER_RESULT_MS = 20000;                 /* 折算到每个"收录"的耗时 */
    var FIXED_OVERHEAD_MS = 5 * 60 * 1000;     /* 启动 app / 搜索 / 开列表的固定开销 */
    var HARD_CAP_MS = 4 * 60 * 60 * 1000;      /* 4 小时硬顶 */

    /** 解析 uid 的预算：按实际待解析个数算（每个约 3 秒 + 1 分钟缓冲），1~60 分钟 */
    var PER_RESOLVE_MS = 3000;
    var RESOLVE_CAP_MS = 60 * 60 * 1000;

    function budgetFor(limit, userMinMs) {
        var userMs = Math.max(1, userMinMs);
        if (limit <= 0) {
            /* 不限个数 → 没有依据可算，按用户设的走 */
            return Math.min(userMs, HARD_CAP_MS);
        }
        var autoMs = limit * PER_RESULT_MS + FIXED_OVERHEAD_MS;
        return Math.min(Math.max(userMs, autoMs), HARD_CAP_MS);
    }

    function resolveBudgetFor(count) {
        var need = count * PER_RESOLVE_MS + 60000;
        return Math.min(Math.max(10 * 60 * 1000, need), RESOLVE_CAP_MS);
    }

    /**
     * 把界面配置里的 `id` 段收拢成引擎侧要用的形状。
     *
     * 界面已经做过一遍归一化（Sources.normalize），但**引擎不能假设界面一定对**：
     * 手写的 engine-config.json、旧版本残留、被改坏的文件都会进来。
     * 这里只做"缺了就补默认"，不做语义校验 —— 语义校验在 filters 与 idsource 里。
     */
    function readSettings(config) {
        var id = config.id || {};
        var filter = id.filter || {};
        var output = id.output || {};
        var guard = id.guard || {};
        var limit = Number(output.limit) || 0;
        var userMaxMs = Number(guard.maxRuntimeMs) || 30 * 60 * 1000;

        return {
            sources: (id.sources instanceof Array ? id.sources : []),
            filter: {
                private: filter.private === true,
                noAvatar: filter.noAvatar === true,
                langRegion: filter.langRegion || 'any',
                nicknameCheck: filter.nicknameCheck || 'any',
                follow: filter.follow || {},
                fans: filter.fans || {},
                likes: filter.likes || {},
                videos: filter.videos || {}
            },
            output: {
                dir: output.dir || '/sdcard/Download/tiktok_app',
                historyPath: output.historyPath || (output.dir || '/sdcard/Download/tiktok_app') + '/uid_extracted.txt',
                dedupeHistory: output.dedupeHistory !== false,
                dryRun: output.dryRun === true,
                /* 缺省开：数字 uid 在界面上读不到，不在这里换就得事后另跑一次 */
                resolveUid: output.resolveUid !== false
            },
            limit: limit,
            /** 用户设的（下限，界面「单次最长运行」） */
            userMaxRuntimeMs: userMaxMs,
            /** 实际生效的抓取预算（按 limit 自动放宽） */
            maxRuntimeMs: budgetFor(limit, userMaxMs),
            resolveMaxMs: Number(guard.resolveMaxMs) || 10 * 60 * 1000
        };
    }

    /**
     * 跑一轮 ID 提取。
     *
     * @returns 结构化 summary（与视频链路同族，供 bridge/main 复用）
     */
    function runSession(config) {
        var log = logger();
        var profileApi = TikTokAuto.profile;
        var settings = readSettings(config);
        var began = Date.now();

        var summary = {
            ok: false,
            task: 'id',
            extracted: 0,          /* 本次写进产物文件的个数 */
            skipped: 0,            /* 因过滤被排除 */
            duplicates: 0,         /* 因去重被排除 */
            openedProfiles: 0,     /* 打开过多少次用户页（成本指标） */
            sources: [],
            warnings: [],
            resultFile: '',
            errors: []
        };
        lastSummary = summary;

        var seen = TikTokAuto.uidset.create();
        var expandQueue = [];
        var softReported = {};
        var writer = null;

        /* —— 停止条件：上限 / 时长 / 用户叫停，三处统一问它 —— */
        function limitReached() {
            return settings.limit > 0 && summary.extracted >= settings.limit;
        }
        function timeUp() {
            return Date.now() - began >= settings.maxRuntimeMs;
        }
        function shouldStop() {
            if (limitReached()) {
                return true;
            }
            if (timeUp()) {
                if (!summary.warnings.length || summary.warnings[summary.warnings.length - 1] !== 'TIME_LIMIT') {
                    log.warn('idflow', '已达单次运行时长上限（' +
                        Math.round(settings.maxRuntimeMs / 60000) + ' 分钟），准备收尾');
                    summary.warnings.push('TIME_LIMIT');
                }
                return true;
            }
            return false;
        }

        /**
         * 给一个候选拿到资料。三条路径按代价从低到高：
         *   ① 调用方已经读过（评论者那只，`_profile`）；
         *   ② 列表行自带计数（搜索用户列表有"粉丝 · 获赞"）；
         *   ③ 打开用户页（最贵，约 3~5 秒）。
         */
        function obtainProfile(row) {
            if (row._profile) {
                return row._profile;
            }
            if (!TikTokAuto.filters.needsProfile(settings.filter)) {
                /* 不需要任何用户页才能判的条件 → 绝不为此付一次开页代价 */
                if (row.fans !== undefined || row.likes !== undefined) {
                    return {
                        uid: row.uid,
                        nickname: row.nickname,
                        signature: '',
                        follow: null,
                        fans: row.fans === undefined ? null : row.fans,
                        likes: row.likes === undefined ? null : row.likes,
                        isPrivate: false,
                        hasAvatar: null
                    };
                }
                return null;
            }

            /* 从列表行点进去最快（且实测返回后列表位置保持）。
             * ★ 判据是"当前在**任一**种列表页上"，不是只有粉丝列表：
             *   搜索结果的用户列表也一样能直接点行进去。
             *   早先写死成 `where() === 'user-list'`，于是搜索取材时
             *   每个候选都要**重新搜一次**（约 15 秒/个）—— 慢十倍且没有必要。
             * ★ 点开失败时不再退回搜索：在列表遍历中途跳去搜索，
             *   会把"当前在哪个列表的第几行"整个丢掉，之后再也接不回原来的列表。 */
            if (row.node && row.x !== undefined && profileApi.isListPage()) {
                if (profileApi.openRow(row)) {
                    summary.openedProfiles += 1;
                    var data = profileApi.readProfile();
                    profileApi.backToList();
                    return data;
                }
                log.warn('idflow', '点不开 @' + row.uid + ' 的主页，跳过（不回搜索，避免丢失列表位置）');
                return null;
            }
            var profile = profileApi.openBySearch(row.uid, config);
            if (profile) {
                summary.openedProfiles += 1;
            }
            return profile;
        }

        /**
         * 收尾阶段：把本轮抓到的 username 换成数字 uid，另存一份映射文件。
         *
         * 产物分工：
         *   `uid_*.txt`      一行一个 username —— 给"搜人/私信"这类下游用
         *   `uid_map_*.txt`  `username<TAB>uid` 两列 —— 给"要平台主键"的下游用
         * 两份都留着，因为它们的用途真的不同，而且映射只有这一轮的数据。
         */
        function resolvePhase(target, settings) {
            var names = writer.list();
            if (names.length === 0) {
                return;
            }
            var mapFile = settings.output.dir + '/' +
                TikTokAuto.parse.timestampName('uid_map', new Date());

            log.step('idflow', '开始解析数字 uid：' + names.length + ' 个（每个约 2~3 秒）');
            var resolveStarted = Date.now();
            /* 解析预算也按实际个数算：10 分钟只够 240 个，抓了 1000 个就不够用了 */
            var resolveBudgetMs = resolveBudgetFor(names.length);
            log.info('idflow', '解析预算 ' + Math.round(resolveBudgetMs / 60000) + ' 分钟');
            var result = TikTokAuto.resolve.resolveAll(names, {
                /**
                 * ★ 这里**只用自己的预算**，不继承抓取阶段的任何停止条件。
                 *
                 * 两次踩同一个坑，两次都是"收尾继承了抓取的条件"：
                 *   ① 先是 `shouldStop()` 里的 `limitReached()` —— 抓满 N 个后解析 0 个；
                 *   ② 再是 `shouldStop()` 里的 `timeUp()` —— 抓取把 30 分钟用满后解析 0 个
                 *      （实测：83 个候选 × 每人约 8 秒 = 30 分钟，收尾一点时间都不剩）。
                 *
                 * 抓取阶段的"够了 / 到点了"和收尾阶段的"必须做完"是相反的要求。
                 * 所以这里从**进入解析的那一刻**重新计时，用一个独立预算（默认 10 分钟）。
                 * 用户主动停止仍然有效 —— 那是 StopSignal 从 `wait.tick` 抛出来的。
                 */
                shouldStop: function () {
                    return Date.now() - resolveStarted >= resolveBudgetMs;
                },
                onProgress: function (done, total) {
                    progress('解析 uid ' + done + '/' + total, target.extracted);
                }
            });

            if (result.stopped) {
                target.warnings.push('解析 uid 到达自身时长上限（' +
                    Math.round(resolveBudgetMs / 60000) + ' 分钟），只换到 ' +
                    result.map.length + '/' + names.length + ' 个');
            }

            target.resolved = result.map.length;
            target.unresolved = result.failed.length;
            if (result.map.length > 0 && TikTokAuto.resolve.writeMap(mapFile, result.map)) {
                target.mapFile = mapFile;
            }
            if (result.failed.length > 0) {
                target.warnings.push(result.failed.length +
                    ' 个账号换不到数字 uid（账号可能已注销，详见日志）');
            }
            log.step('idflow', 'uid 解析完成：成功 ' + result.map.length +
                ' / 失败 ' + result.failed.length);
        }

        /** 处理一个候选：去重 → 过滤 → 写盘 → 记下要不要展开 */
        function handleRow(row) {
            var parse = TikTokAuto.parse;
            var uid = parse.username(row.uid);
            if (uid === '' || !parse.looksLikeUsername(uid)) {
                return;
            }
            if (seen.has(uid)) {
                summary.duplicates += 1;
                return;
            }
            if (shouldStop()) {
                return;
            }

            progress('正在读取 @' + uid, summary.extracted);

            var profile = obtainProfile(row);
            var verdict = TikTokAuto.filters.judge(profile, settings.filter);
            if (!verdict.ok) {
                summary.skipped += 1;
                log.info('idflow', '跳过 @' + uid + '：' + verdict.reason);
                seen.add(uid);
                return;
            }
            if (verdict.soft && !softReported[verdict.soft]) {
                softReported[verdict.soft] = true;
                summary.warnings.push(verdict.soft);
                log.warn('idflow', verdict.soft);
            }

            seen.add(uid);
            writer.write(uid);
            summary.extracted += 1;

            /* 收录时记下依据。这不只是"好看"：用户事后想核对"这个人为啥被收进来"时，
             * 日志是唯一的答案；没有它就只能重新跑一遍。 */
            log.info('idflow', '收录 @' + uid + (profile
                ? '（粉丝 ' + profile.fans + ' / 关注 ' + profile.follow +
                  ' / 获赞 ' + profile.likes + '）'
                : '（未打开用户页，按列表现有资料通过）'));

            if (row.expandTo) {
                expandQueue.push({ uid: uid, which: row.expandTo });
            }
        }

        try {
            log.step('idflow', '=== TikTok ID 提取开始 ===');
            log.info('idflow', '取材 ' + settings.sources.length + ' 条，过滤：' +
                TikTokAuto.filters.describe(settings.filter));
            /* 把预算说清楚：用户设的是下限，实际按提取上限放宽过。
             * 不说的话，"怎么跑了 38 分钟"会变成第二个疑问。 */
            log.info('idflow', '抓取预算 ' + Math.round(settings.maxRuntimeMs / 60000) + ' 分钟' +
                (settings.limit > 0
                    ? '（按提取上限 ' + settings.limit + ' 个估算；你设的下限是 ' +
                      Math.round(settings.userMaxRuntimeMs / 60000) + ' 分钟）'
                    : '（未设提取上限，按你设的时长）'));

            TikTokAuto.bridge.report({ status: 'running', phase: '准备', done: 0, total: 0 });

            if (!TikTokAuto.uidset.ensureDir(settings.output.dir)) {
                summary.errors.push('无法创建结果目录：' + settings.output.dir);
                return summary;
            }
            /* 文件名只生成一次：分两次调 timestampName 有可能跨过整分钟，
             * 于是"写进去的文件"和"报给界面的文件名"不是同一个 —— 这种错几乎无法复现。 */
            var runFile = settings.output.dir + '/' +
                TikTokAuto.parse.timestampName('uid', new Date());
            writer = TikTokAuto.uidset.createWriter({
                runPath: runFile,
                historyPath: settings.output.historyPath,
                dryRun: settings.output.dryRun,
                historyEnabled: settings.output.dedupeHistory
            });
            summary.resultFile = settings.output.dryRun ? '' : runFile;

            if (settings.output.dedupeHistory) {
                TikTokAuto.uidset.loadHistory(seen, settings.output.historyPath);
            }

            /* —— 启动与就位（复用视频链路的成熟实现） —— */
            progress('启动应用', 0);
            if (!TikTokAuto.flow.launchApp(config)) {
                summary.errors.push('启动应用失败');
                return summary;
            }
            /* ★ 这里**刻意不做 ensureFeed**。
             *
             * 早先这里无条件把页面退回信息流首页，于是「当前屏幕」类的取材必然失败：
             * 用户手动把 TikTok 停在视频评论区（那正是这个取材源的全部前提），
             * 引擎一上来就连按几次返回退到首页，然后再报"取材设置为当前屏幕，
             * 但当前不在播放页（feed）"。用户看到的是"我明明停在评论区，它说我不在"。
             *
             * 各个取材源自己知道自己需要什么前置状态，让它们自己保证：
             *   · 指定账号 / 搜索 → 走 prepareSearch，内部会 ensureFeed；
             *   · 视频/当前屏幕     → **不动页面**，就用用户准备好的那一屏；
             *   · 文本文件          → 根本不需要 UI。
             */
            progress('准备取材', 0);

            if (settings.sources.length === 0) {
                summary.errors.push('没有配置任何取材（界面里至少需要一条）');
                return summary;
            }

            /* —— 第一层：逐条取材 —— */
            for (var i = 0; i < settings.sources.length; i += 1) {
                if (shouldStop()) {
                    break;
                }
                var source = settings.sources[i];
                var before = summary.extracted;

                progress('取材 ' + (i + 1) + '/' + settings.sources.length, summary.extracted);
                var ctx = {
                    config: config,
                    seen: seen,
                    shouldStop: shouldStop,
                    onSeenProfile: function (prof) {
                        log.info('idflow', '取材账号 @' + prof.uid + '：粉丝 ' + prof.fans +
                            ' / 关注 ' + prof.follow + ' / 获赞 ' + prof.likes);
                    },
                    onRow: function (row) {
                        /* 深度只在第一层记：第二层不再展开（上限两层） */
                        if (source.expand && !row.expandTo) {
                            row.expandTo = source.expand;
                        }
                        handleRow(row);
                    }
                };

                var handled = 0;
                try {
                    handled = TikTokAuto.idsource.run(source, ctx);
                } catch (error) {
                    if (TikTokAuto.bridge.isStopSignal(error)) {
                        throw error;
                    }
                    log.error('idflow', '取材失败（' + TikTokAuto.idsource.describe(source) + '）：' + error);
                    summary.errors.push('取材失败：' + TikTokAuto.idsource.describe(source));
                }
                summary.sources.push({
                    label: TikTokAuto.idsource.describe(source),
                    handled: handled,
                    added: summary.extracted - before
                });
                log.info('idflow', '取材完成：' + TikTokAuto.idsource.describe(source) +
                    '，处理 ' + handled + ' 行，新增 ' + (summary.extracted - before) + ' 个');
            }

            /* —— 第二层：深度展开 ——
             * 与第一层分开跑，是为了避免嵌套列表上下文（见 idsource.js 文件头）。
             * 展开进来的人**同样要过一遍过滤** —— 否则"粉丝的粉丝"会绕过所有条件。 */
            if (expandQueue.length > 0 && shouldStop() && limitReached()) {
                /* 上限在主层就满了 → 展开根本没跑。这必须说出来：
                 * 用户明明勾了「再取粉丝列表」，看到"提取满 3 个"很容易以为展开做了。 */
                summary.warnings.push('提取上限已到，深度展开（再取粉丝列表）本次没有执行');
                log.warn('idflow', '提取上限已到，' + expandQueue.length + ' 个待展开的账号本次没有展开');
            }
            if (expandQueue.length > 0 && !shouldStop()) {
                log.step('idflow', '开始深度展开：' + expandQueue.length + ' 个账号');
                for (var e = 0; e < expandQueue.length; e += 1) {
                    if (shouldStop()) {
                        break;
                    }
                    var target = expandQueue[e];
                    progress('展开 @' + target.uid + ' 的' +
                        (target.which === 'following' ? '关注' : '粉丝'), summary.extracted);

                    var opened = profileApi.openBySearch(target.uid, config);
                    if (!opened) {
                        log.warn('idflow', '展开时打不开 @' + target.uid);
                        continue;
                    }
                    summary.openedProfiles += 1;
                    if (!profileApi.openList(target.which, config)) {
                        continue;
                    }
                    profileApi.switchListTab(target.which);

                    var subCtx = {
                        config: config,
                        seen: seen,
                        shouldStop: shouldStop,
                        onSeenProfile: function () { },
                        onRow: handleRow          /* 注意：这里**不再**设置 expandTo，所以不会递归 */
                    };
                    try {
                        TikTokAuto.idsource.walkList(subCtx);
                    } catch (error2) {
                        if (TikTokAuto.bridge.isStopSignal(error2)) {
                            throw error2;
                        }
                        log.warn('idflow', '展开 @' + target.uid + ' 失败：' + error2);
                    }
                }
            }

            summary.ok = summary.extracted > 0;
            if (!summary.ok && summary.errors.length === 0) {
                summary.errors.push('没有提取到任何 ID（取材范围内都被过滤或去重掉了）');
            }

            /* —— 收尾：username → 数字 uid ——
             * 数字 uid 在 App 界面上任何地方都读不到，只能取网页版 SSR（见 resolve.js）。
             * 它比抓取慢（每个约 2.5 秒）且依赖网络，所以三条边界：
             *   ① 只在**主产物已经落盘之后**做（先 close 一次，保证文件完整）；
             *   ② 失败**只记 warning**，绝不把已经抓到的 username 算成失败；
             *   ③ 换不到的**不写进映射文件** —— 文件里全是可用的对应关系。
             */
            if (settings.output.resolveUid && summary.extracted > 0 && !settings.output.dryRun) {
                try {
                    writer.close();
                    resolvePhase(summary, settings);
                } catch (error) {
                    if (TikTokAuto.bridge.isStopSignal(error)) {
                        summary.warnings.push('解析 uid 阶段被停止，映射文件只含已换到的部分');
                        throw error;
                    }
                    log.warn('idflow', '解析 uid 失败（不影响已抓到的 username）：' + error);
                    summary.warnings.push('解析 uid 失败：' + error);
                }
            }
        } finally {
            /* 无论是正常结束、出错、还是用户叫停，都必须把已经抓到的刷进文件 ——
             * "点了停止但文件是空的"是最不能接受的一种失败。 */
            if (writer) {
                var written = writer.close();
                if (written !== summary.extracted) {
                    log.warn('idflow', '写盘数量与统计不符：文件 ' + written + ' / 统计 ' + summary.extracted);
                }
                if (writer.hadFailure()) {
                    summary.warnings.push('结果文件写入失败（部分结果可能没有落盘）');
                }
            }
            /* 一个都没收时**不报文件名**：那个文件根本没被创建（writer 只在有内容时 append），
             * 报一个不存在的路径，用户去文件管理器找会以为"抓到了但丢了"。 */
            if (summary.extracted === 0) {
                summary.resultFile = '';
            }
            if (limitReached()) {
                summary.warnings.push('已提取满 ' + settings.limit + ' 个，按设置停止');
            } else if (settings.limit > 0 && timeUp()) {
                /* ★ 时间先到、上限没满 —— 这是最容易被误解的一种结束：
                 * 用户设了"提取满 100 个"，看到只收了 83 个，会以为是过滤太严或程序漏了，
                 * 而真正的原因是**两个上限谁先到听谁**：30 分钟到了就停，不管够不够数。
                 *
                 * 这里直接给出换算结论，省得用户自己猜：
                 * 按本轮速度，收满 limit 个大约需要多久。
                 *
                 * 估算方法（简单但够用）：本轮 T 秒收到 E 个 → 平均每个 E/T 个，
                 * 那么收满 L 个需要 L × T / E 秒。实测 1800 秒 / 83 个 → 100 个约 36 分钟。
                 */
                var elapsedMs = Date.now() - began;
                if (summary.extracted > 0) {
                    var needMin = Math.ceil(
                        settings.limit * elapsedMs / summary.extracted / 60000
                    );
                    summary.warnings.push(
                        '时间到，只收了 ' + summary.extracted + '/' + settings.limit + ' 个。' +
                        '按本轮速度，收满 ' + settings.limit + ' 个约需 ' + needMin +
                        ' 分钟 —— 建议把「单次最长运行」调到 ' + (needMin + 5) + ' 分钟以上'
                    );
                    log.warn('idflow', '时间到，只收 ' + summary.extracted + ' 个；' +
                        '按本轮速度收满 ' + settings.limit + ' 个约需 ' + needMin + ' 分钟');
                } else {
                    /* 一个都没收到就超时：多半不是时间不够，而是过滤太严或取材取不到人。
                     * 这时给"调大时间"的建议是害人 —— 要说清该查哪里。 */
                    summary.warnings.push(
                        '时间到，一个都没收到 —— 不是时间太短，请检查取材是否取到人、' +
                        '过滤条件是否过严（见日志里的跳过原因）'
                    );
                }
            } else if (settings.limit > 0 && summary.extracted < settings.limit) {
                /* 第三种"没到上限"：取材本身跑完了（列表到底/文件读完），不是时间问题。
                 * 这时调时间没用，得加取材量。 */
                summary.warnings.push(
                    '取材范围已取尽，共收 ' + summary.extracted + '/' + settings.limit +
                    ' 个 —— 想收更多请增加取材（换关键词、加账号，或打开「再取粉丝列表」）'
                );
            }
            log.step('idflow', '=== 提取结束：新增 ' + summary.extracted +
                ' 个，跳过 ' + summary.skipped + ' 个，重复 ' + summary.duplicates +
                ' 个，耗时 ' + Math.round((Date.now() - began) / 1000) + ' 秒 ===');
        }

        return summary;
    }

    return {
        runSession: runSession,
        readSettings: readSettings,
        lastSummary: function () {
            return lastSummary;
        }
    };
}());


/* ============================== src/main.js ============================== */
/**
 * main.js — 入口与收尾
 *
 * 入口只负责三件事：读配置、开守护线程、跑流程。
 * 收尾负责四件**必须保证**的事：
 *   1. 无论成功失败都打印 `__END__`（否则 PC 侧执行器会一直等到超时）；
 *   2. 关掉守护线程（`threads.shutDownAll()`，否则进程不退出）；
 *   3. 打印一行机器可读的 RESULT，让 PC 侧能直接断言而不是解析自然语言日志；
 *   4. 向界面宿主上报终态（被界面唤起时才有这一步，见 bridge.js）。
 *
 * 依赖：全部模块
 */
TikTokAuto.main = (function () {
    'use strict';

    var RESULT_MARKER = '__END__';

    function emptySummary(reason) {
        return {
            ok: false,
            attemptedVideos: 0,
            postedComments: 0,
            details: [],
            errors: [reason]
        };
    }

    /**
     * 去掉占位原因。
     * `emptySummary('未开始')` 的那条只在"一次都没跑起来"时才有意义；
     * 流程已经跑过一段后再追加真实原因，留着它会让界面把"未开始"显示成第一条错误。
     */
    function dropPlaceholder(errors) {
        var kept = [];
        for (var i = 0; i < errors.length; i += 1) {
            if (errors[i] !== '未开始') {
                kept.push(errors[i]);
            }
        }
        return kept;
    }

    /**
     * 按 `config.task` 分派。
     *
     * 入口只有这一个分岔点：两条链路都走同一套"配置 → 守护线程 → 流程 → 终态上报"，
     * 差别只在中间调哪个 runSession。所以 `__END__`、RESULT、终态上报这些收尾逻辑
     * **一份就够** —— 各写一份的话，两边的收尾行为迟早会不一致。
     */
    function runByTask(config) {
        if (config.task === 'id') {
            return TikTokAuto.idflow.runSession(config);
        }
        return TikTokAuto.flow.runSession(config);
    }

    /**
     * @param injected PC 侧注入的配置覆盖项
     * @returns 结构化结果
     */
    function run(injected) {
        var log = TikTokAuto.logger;
        var bridge = TikTokAuto.bridge;
        var summary = emptySummary('未开始');
        var guardState = null;
        var config = null;
        /* 是"用户叫停"还是"出错了"，收尾时的上报状态不同 */
        var stoppedByUser = false;

        try {
            log.step('main', '=== TikTok 自动互动开始 ===');
            bridge.report({ status: 'running', phase: '准备', done: 0, total: 0 });

            try {
                config = TikTokAuto.config.resolve(injected);
            } catch (configError) {
                log.error('main', '配置无效：' + configError.message + ' / detail=' + JSON.stringify(configError.detail));
                summary = emptySummary('配置无效：' + configError.message);
                return summary;
            }

            bridge.report({ phase: '启动应用', total: config.task === 'id' ? 0 : config.target.maxVideos });

            guardState = TikTokAuto.popups.startGuard(config, log);
            var guardUp = TikTokAuto.wait.waitFor('guard', function () {
                return guardState.passes >= 1 ? true : null;
            }, config.guard.firstScanTimeoutMs, 200);
            if (!guardUp) {
                log.warn('guard', '守护线程首次巡检未确认，继续执行（不阻塞主流程）');
            }

            summary = runByTask(config);
            log.step('main', '=== 流程结束，耗时 ' + log.elapsedMs() + 'ms ===');
        } catch (error) {
            if (bridge.isStopSignal(error)) {
                /* 停止是**正常收尾**，不是崩溃：不记 ERROR、不把堆栈当异常信息 */
                stoppedByUser = true;
                log.warn('main', '收到停止请求，提前结束本次运行');
                /* ID 提取的统计在 idflow 里已经算好了（含刚刷盘的那个数），
                 * 这里取它 —— 否则界面会显示"提取 0 个"，而文件里明明有内容。 */
                var partial = TikTokAuto.idflow ? TikTokAuto.idflow.lastSummary() : null;
                if (partial) {
                    summary = partial;
                }
                summary.ok = false;
                summary.errors = dropPlaceholder(summary.errors || []);
                summary.errors.push('用户停止');
            } else {
                var detail = error && error.stack ? String(error.stack) : String(error);
                log.error('main', '未捕获异常：' + detail);
                summary.ok = false;
                summary.errors.push(String(error));
            }
        } finally {
            TikTokAuto.popups.stopGuard(guardState, log);
            log.result(summary);

            /* 先把终态交给宿主，再收线程：顺序反了的话，界面可能永远等不到"结束"，
             * 状态条会一直显示"运行中"。 */
            bridge.finish(
                stoppedByUser ? 'stopped' : (summary.ok ? 'finished' : 'failed'),
                summary
            );

            // 顺序很重要：先让日志刷出去，再收线程，最后打结束标记
            try {
                threads.shutDownAll();
            } catch (ignored) {
                // 没有线程在跑时该调用可能抛错，忽略即可
            }
            console.log(RESULT_MARKER);
        }
        return summary;
    }

    
    return {
        RESULT_MARKER: RESULT_MARKER,
        run: run
    };
}());


/* PC 侧下发时可替换下面这一行的 null 来注入配置覆盖项 */
var INJECTED_CONFIG = /*TTA_INJECTED_CONFIG*/null;
/* 被界面宿主唤起时（engines.execScriptFile 带 --config/--run-id 参数），
 * fromExecArgv 会把参数翻译成「配置路径 + 桥的开关」；独立运行时是空操作。 */
TikTokAuto.main.run(TikTokAuto.bridge.fromExecArgv(INJECTED_CONFIG));
}());