const socket = new SocketServer(server, {
	cors: { origin: '*' },
	pingTimeout: 5000,
});

const serverAddress = `${serverURLPrefix ? serverURL : 'http://' + serverURL}:${serverPort}/worker`;

const workerID = socket.handshake.query['workerID'] as string;

io.of('/worker').on('connection', async (socket) => {
	const workerID = socket.handshake.query['workerID'] as string;
	AddWorker(socket);

	const properties = await socket.emitWithAck('get-properties');
	AddWorkerProperties(workerID, properties);

	const existingJobID = await socket.emitWithAck('check-for-existing-job');
	if (existingJobID) { /* 恢复中断的任务状态 */ }
	else { WorkerForAvailableJobs(workerID); }
	// ……之后才注册 disconnect / get-job-data / transcode-* 等监听
});

[connect] id=zxHm93WzQ5XVnr_qAAAD transport=polling

[on] connections-update <- 2 keys
[on] config-update <- 4 keys
[on] queue-update <- 0 items
[on] presets-update <- 1 keys
[on] default-presets-update <- 6 keys
[on] queue-status-update <- number:0
[on] properties-update <- 1 keys
[on] watchers-update <- 0 items

--- get-directory ---
[ack get-directory] {"parent":{"path":".../d5/video","name":".../d5","isDirectory":true},"current":{"path":".../d5/video/input"...

--- check-name-collision ---
[ack check-name-collision] ["sample.mkv"]

--- add-job 缺失输入 ---
[on] queue-update <- 1 items
[queue] [{"id":1,"stage":0,"pct":0,"worker":null}]
[ack add-job 缺失输入] ok（服务端未做存在性校验）

[server] [version] The file 'version-info.json' does not exist. Fetching the information about 'v0.8.1' from github...
[server] [version] Fetched information about the current release.
[server] [version] Wrote information about the current release to '.../version-info.json'.

{"tag_name":"v0.8.1","html_url":"https://github.com/TheNickOfTime/handbrake-web/releases/tag/v0.8.1","published_at":"2025-12-10T20:08:10Z","prerelease":false}

--- 未定义事件 no-such-event ---
[ack no-such-event] timeout/error: operation has timed out

{
  "version": { "handbrake": "1.11.0", "application": "0.8.1" },
  "capabilities": { "cpu": true, "qsv": false, "nvenc": false, "vcn": false }
}

{"transcode_stage":1,"time_started":1761575300000}
{"transcode_stage":1,"transcode_percentage":0.42}
{"transcode_stage":2,"transcode_percentage":0.42,"transcode_eta":11,"transcode_fps_current":240.1,"transcode_fps_average":238.7}
{"transcode_stage":2,"transcode_percentage":0.99}
{"worker_id":null,"transcode_stage":3,"transcode_percentage":1,"transcode_eta":0,"transcode_fps_current":0,"time_finished":1761575315000}

[worker-01] [socket] Connected to the server 'http://127.0.0.1:9999/worker' with id 'HJtUqsuQN5dkSvAPAAAB'.
[worker-01] [socket] The server is requesting this worker's properties...
[worker-01] [properties] HandBrake Version = 1.11.0
[worker-01] [properties] Capability 'cpu' support = true
[worker-01] [properties] Capability 'qsv' support = false
[worker-01] [properties] Capability 'nvenc' support = false
[worker-01] [properties] Capability 'vcn' support = false
[worker-01] [socket] The server is requesting the status of this worker...
[worker-01] [socket] This worker is currently not busy with a job - reporting to the server.

[server] [socket] Worker 'worker-01' has connected with ID 'HJtUqsuQN5dkSvAPAAAB'.
[server] [socket] Getting worker 'worker-01' properties...
[server] [socket] Worker properties = {
  "version": { "handbrake": "1.11.0", "application": "0.8.1" },
  "capabilities": { "cpu": true, "qsv": false, "nvenc": false, "vcn": false }
}
[server] [socket] Checking worker 'worker-01' for an existing job in progress...
[server] [socket] Worker 'worker-01' is not busy with an existing job.

const { io } = require('socket.io-client');
const s = io('http://127.0.0.1:9999/client');
s.on('presets-update', (p) => console.log('presets:', JSON.stringify(Object.keys(p))));
s.on('default-presets-update', (p) => console.log('default categories:', Object.keys(p)));
s.on('queue-update', (q) => console.log('queue:', JSON.stringify(q)));
s.on('config-update', (c) => console.log('config:', JSON.stringify(c)));

config: {"config":{"version":2},"paths":{"media-path":"/video","input-path":"/video","output-path":""},"presets":{"show-default-presets":true,"allow-preset-creator":false},"application":{"queue-startup-behavior":0,"update-check-interval":12}}
presets: ["uncategorized"]
default categories: [ 'General', 'Web', 'Devices', 'Matroska', 'Hardware', 'Professional' ]

const s = io('http://127.0.0.1:9999/client');
s.on('connect', () => {
  s.timeout(4000).emit('add-job', {
    input_path: '/srv/video/input/sample.mp4',
    output_path: '/srv/video/output/sample-out.mkv',
    preset_category: 'Default: General',
    preset_id: 'Very Fast 720p30',
  }, (err) => console.log('add-job ack', err));
  setTimeout(() => s.emit('start-queue'), 300);
});
s.on('queue-update', (q) => console.log(JSON.stringify(q.map((j) => ({ id: j.job_id, stage: j.transcode_stage, pct: j.transcode_percentage, worker: j.worker_id })))));

[queue] [{"id":1,"stage":0,"pct":0,"worker":null}]                     // Waiting，刚入队
[on] queue-status-update <- number:2                                    // Active
[queue] [{"id":1,"stage":1,"pct":0,"worker":null}]                     // Scanning，worker 已接单
[queue] [{"id":1,"stage":1,"pct":0,"worker":"worker-01"}]              // worker_id 回填
[queue] [{"id":1,"stage":2,"pct":0.09305555373430252,"worker":"worker-01"}]
[queue] [{"id":1,"stage":2,"pct":0.6041666865348816,"worker":"worker-01"}]
[queue] [{"id":1,"stage":2,"pct":0.9993055462837219,"worker":"worker-01"}]
[queue] [{"id":1,"stage":3,"pct":1,"worker":null}]                     // Finished

const { io } = require('socket.io-client');
const w = io('http://127.0.0.1:9999/worker', { query: { workerID: 'fake-01' } });
w.onAny((event, ...args) => {
  if (event === 'get-properties') {
    args[0]({ version: { handbrake: '9.9.9', application: '0.0.0' },
              capabilities: { cpu: false, qsv: false, nvenc: false, vcn: false } });
  }
  if (event === 'check-for-existing-job') args[0](null);
});

[fake-01 connect] id=6p__WTTgTWj714mwAAAB transport=polling
[fake-01 on] get-properties <- [null]
[fake-01 ack] get-properties -> cpu:false, handbrake:9.9.9
[fake-01 on] check-for-existing-job <- [null]
[fake-01 ack] check-for-existing-job -> null

[server] [socket] Worker 'fake-01' has connected with ID '6p__WTTgTWj714mwAAAB'.
[server] [socket] Worker properties = {
  "version": { "handbrake": "9.9.9", "application": "0.0.0" },
  "capabilities": { "cpu": false, "qsv": false, "nvenc": false, "vcn": false }
}
[server] [queue] There are 1 available jobs and 0 eligible for 'fake-01'.
[server] [queue] There are available jobs, but none that require the capabilities of worker with ID 'fake-01'.
[server] [queue] There are no active workers, setting queue to 'Idle'.

[no-workerID connect] id=_J17pwQuLEPBx3E1AAAE
[no-workerID on] get-properties（故意不应答）

[server] [socket] Worker 'undefined' has connected with ID '_J17pwQuLEPBx3E1AAAE'.
[server] [socket] Getting worker 'undefined' properties...
（此后 9 秒无任何日志，直到服务端关闭）

s.emit('reorder-job', 999, 0);

[server] [database] [error] Could not get the order_index for '999' from the jobs_order table.
NoResultError: no result
    at _SelectQueryBuilderImpl.executeTakeFirstOrThrow (...)
    at async DatabaseGetJobOrderIndexByID (...)
    at async Socket3.<anonymous> (...)
Node.js v24.22.1

[after] 新连接失败: xhr poll error

[server] [socket] Client 'zxHm93WzQ5XVnr_qAAAD' has requested to add a job for '.../video/input/nope.mp4' to the queue.
[server] [database] Inserted a new job with id '1' into the database at order index '1'.

hb_stream_open: open .../video/input/nope.mp4 failed
scan: unrecognized file type
libhb: scan thread found 0 valid title(s)
No title found.
HandBrake has exited.

[queue] [{"id":1,"stage":1,"pct":0,"worker":null},{"id":2,"stage":0,"pct":0,"worker":null}]
（随后 12 秒直到脚本结束，第 1 条停在 stage=1，第 2 条停在 stage=0，再没有新的 queue-update）

handbrake.on('exit', () => {
	const transport = (jobLogger.transports as CustomTransportType[]).find((t) => t._dest != undefined);
	if (transport && transport.dirname && transport.filename) {
		const logPath = path.join(transport.dirname, transport.filename);
		SendLogToServer(logPath, socket);
	}
	jobLogger.destroy();
});

[server] [socket] Disconnected worker 'worker-01' was working on job '1' when disconnected - setting job to 'unknown'.
[server] [database] Status for job with id '1' has changed from 'Scanning' to 'Unknown'.

handbrake.kill();
while (!handbrake.killed) {
	logger.info(`[transcode] Still waiting for the HandBrake child process to exit.`);
	await new Promise((res) => setTimeout(res, 100));
}

22:39:13 [worker-01] [transcode] Waiting for the HandBrake child process to exit.
22:39:13 [worker-01] [transcode] Still waiting for the HandBrake child process to exit.
（……每 100ms 一行……）
22:39:54 [worker-01] [transcode] Still waiting for the HandBrake child process to exit.