wehub-resource-sync
d18ada4ee7
Docker Publish / docker (web, apps/web/Dockerfile, web) (push) Failing after 0s
Docker Publish / docker (api, apps/api/Dockerfile, api) (push) Failing after 1s
Publish Extension / detect-version (push) Has been skipped
Publish Extension / submit (push) Has been cancelled
94 lines
2.2 KiB
TypeScript
94 lines
2.2 KiB
TypeScript
import { describe, expect, it } from 'vitest'
|
|
|
|
import { taskQueueContract } from '../src/contract'
|
|
import {
|
|
AddInputSchema,
|
|
TaskInputSchema,
|
|
TaskSchema,
|
|
TaskStatusSchema
|
|
} from '../src/schemas'
|
|
|
|
describe('taskQueueContract', () => {
|
|
it('exposes the routes that adapters must implement', () => {
|
|
const expected = [
|
|
'add',
|
|
'get',
|
|
'list',
|
|
'cancel',
|
|
'pause',
|
|
'resume',
|
|
'retry',
|
|
'setMaxConcurrency',
|
|
'setMaxPerGroup',
|
|
'removeFromHistory',
|
|
'stats'
|
|
]
|
|
expect(Object.keys(taskQueueContract).sort()).toEqual(expected.sort())
|
|
})
|
|
})
|
|
|
|
describe('schemas', () => {
|
|
it('TaskInput accepts a minimal payload', () => {
|
|
const parsed = TaskInputSchema.parse({
|
|
url: 'https://e.com/v',
|
|
kind: 'video'
|
|
})
|
|
expect(parsed.kind).toBe('video')
|
|
})
|
|
|
|
it('TaskStatus enumerates exactly the 8 design statuses', () => {
|
|
const expected = [
|
|
'queued',
|
|
'running',
|
|
'processing',
|
|
'paused',
|
|
'retry-scheduled',
|
|
'completed',
|
|
'failed',
|
|
'cancelled'
|
|
]
|
|
for (const s of expected) {
|
|
expect(() => TaskStatusSchema.parse(s)).not.toThrow()
|
|
}
|
|
expect(() => TaskStatusSchema.parse('downloading')).toThrow()
|
|
})
|
|
|
|
it('AddInput requires a kind on the inner input', () => {
|
|
const r = AddInputSchema.safeParse({ input: { url: 'https://e.com' } })
|
|
expect(r.success).toBe(false)
|
|
})
|
|
|
|
it('Task allows null parentId/output/lastError', () => {
|
|
const t = {
|
|
id: 'x',
|
|
kind: 'video' as const,
|
|
parentId: null,
|
|
input: { url: 'https://e.com', kind: 'video' as const },
|
|
priority: 0 as const,
|
|
groupKey: 'e.com',
|
|
status: 'queued' as const,
|
|
prevStatus: null,
|
|
statusReason: null,
|
|
enteredStatusAt: 1,
|
|
attempt: 0,
|
|
maxAttempts: 5,
|
|
nextRetryAt: null,
|
|
progress: {
|
|
percent: null,
|
|
bytesDownloaded: null,
|
|
bytesTotal: null,
|
|
speedBps: null,
|
|
etaMs: null,
|
|
ticks: 0
|
|
},
|
|
output: null,
|
|
lastError: null,
|
|
pid: null,
|
|
pidStartedAt: null,
|
|
createdAt: 1,
|
|
updatedAt: 1
|
|
}
|
|
expect(() => TaskSchema.parse(t)).not.toThrow()
|
|
})
|
|
})
|