const { test } = require('node:test');
const assert = require('node:assert');
const { formatUploadLogLine, parseUploadLogLine } = require('../lib/upload-log');
const { partitionRestoredJobsByLog } = require('../lib/queue-dedup');

function previewJob(fileName, hoster) {
  return { status: 'preview', fileName, hoster, file: `C:/dl/${fileName}` };
}

test('writer -> reader round trip: parsed ts is the same epoch frame as the source Date getTime', () => {
  const d = new Date(2026, 5, 19, 12, 0, 30);
  const line = formatUploadLogLine(d, 'voe.sx', 'https://voe.sx/x', 'a.mkv');
  const parsed = parseUploadLogLine(line);
  assert.equal(parsed.hoster, 'voe.sx');
  assert.equal(parsed.fileName, 'a.mkv');
  assert.equal(parsed.ts, d.getTime(), 'parser ts must equal the writer Date epoch (no tz shift)');
});

test('SEAM: a real appendUploadLog-format line drops a preview ghost vs a savedAt taken BEFORE completion', () => {
  const completion = new Date(2026, 5, 19, 12, 0, 30);
  const line = formatUploadLogLine(completion, 'voe.sx', 'link', 'a.mkv');
  const parsed = parseUploadLogLine(line);
  const savedAt = completion.getTime() - 5000;
  const { removed, kept } = partitionRestoredJobsByLog([previewJob('a.mkv', 'voe.sx')], [parsed], savedAt);
  assert.equal(removed.length, 1, 'a file logged after the snapshot is a ghost and must drop');
  assert.equal(kept.length, 0);
});

test('SEAM: the same real line is KEPT vs a savedAt taken AFTER completion (intentional re-upload)', () => {
  const completion = new Date(2026, 5, 19, 12, 0, 30);
  const parsed = parseUploadLogLine(formatUploadLogLine(completion, 'voe.sx', 'link', 'a.mkv'));
  const savedAt = completion.getTime() + 5000;
  const { removed, kept } = partitionRestoredJobsByLog([previewJob('a.mkv', 'voe.sx')], [parsed], savedAt);
  assert.equal(removed.length, 0, 'an older upload than the snapshot is a deliberate re-queue and must survive');
  assert.equal(kept.length, 1);
});

test('parseUploadLogLine skips comments, blanks and malformed lines', () => {
  assert.equal(parseUploadLogLine('# fileuploader log'), null);
  assert.equal(parseUploadLogLine(''), null);
  assert.equal(parseUploadLogLine('   '), null);
  assert.equal(parseUploadLogLine('only|three|parts|here'), null);
  assert.equal(parseUploadLogLine(null), null);
  assert.equal(parseUploadLogLine(42), null);
});

test('parseUploadLogLine: missing/garbage timestamp yields ts=undefined (legacy lines still match by name)', () => {
  const parsed = parseUploadLogLine('|voe.sx|link||a.mkv|');
  assert.equal(parsed.hoster, 'voe.sx');
  assert.equal(parsed.fileName, 'a.mkv');
  assert.equal(parsed.ts, undefined);
});