import { expect, test } from 'bun:test'
import { mkdtemp, rm, writeFile } from 'node:fs/promises'
import { tmpdir } from 'node:os'
import { join } from 'node:path'
import {
  listNamedWorkflows,
  resolveNamedWorkflow,
} from '../engine/namedWorkflows.js'

test('按扩展名优先级解析命名 workflow', async () => {
  const dir = await mkdtemp(join(tmpdir(), 'wf-named-'))
  try {
    await writeFile(
      join(dir, 'a.ts'),
      'export const meta = { name: "a", description: "d" }\nreturn 1',
    )
    await writeFile(join(dir, 'b.js'), 'return 2')
    await writeFile(join(dir, 'c.mjs'), 'return 3')
    await writeFile(join(dir, 'ignore.md'), '# not a workflow')

    const a = await resolveNamedWorkflow(dir, 'a')
    expect(a?.path.endsWith('a.ts')).toBe(true)
    expect(a?.content).toContain('meta')

    expect(await resolveNamedWorkflow(dir, 'missing')).toBeNull()

    const names = await listNamedWorkflows(dir)
    expect(names).toEqual(['a', 'b', 'c']) // 不含 .md
  } finally {
    await rm(dir, { recursive: true, force: true })
  }
})

test('listNamedWorkflows 不存在目录返回空数组', async () => {
  expect(
    await listNamedWorkflows(join(tmpdir(), 'wf-nope-' + Date.now())),
  ).toEqual([])
})

test('resolveNamedWorkflow 在 .ts 缺失时降级到 .js/.mjs', async () => {
  const dir = await mkdtemp(join(tmpdir(), 'wf-named-'))
  try {
    await writeFile(join(dir, 'onlyjs.js'), 'return 1')
    await writeFile(join(dir, 'onlymjs.mjs'), 'return 2')
    expect(
      (await resolveNamedWorkflow(dir, 'onlyjs'))?.path.endsWith('onlyjs.js'),
    ).toBe(true)
    expect(
      (await resolveNamedWorkflow(dir, 'onlymjs'))?.path.endsWith(
        'onlymjs.mjs',
      ),
    ).toBe(true)
  } finally {
    await rm(dir, { recursive: true, force: true })
  }
})

test('listNamedWorkflows 返回排序后的名字', async () => {
  const dir = await mkdtemp(join(tmpdir(), 'wf-named-'))
  try {
    await writeFile(join(dir, 'zeta.ts'), 'return 1')
    await writeFile(join(dir, 'alpha.js'), 'return 2')
    await writeFile(join(dir, 'mid.mjs'), 'return 3')
    expect(await listNamedWorkflows(dir)).toEqual(['alpha', 'mid', 'zeta'])
  } finally {
    await rm(dir, { recursive: true, force: true })
  }
})