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
87 lines
2.7 KiB
TypeScript
87 lines
2.7 KiB
TypeScript
import { describe, expect, it } from 'vitest'
|
|
|
|
import { connect } from '../src/transport/connect'
|
|
|
|
describe('connect (transport selection)', () => {
|
|
const baseFlags = {
|
|
local: false,
|
|
json: true,
|
|
pretty: false,
|
|
wait: false,
|
|
detach: false,
|
|
noRetry: false,
|
|
noAutostart: false
|
|
}
|
|
|
|
it('returns local client when --vidbee-local', async () => {
|
|
const fakeClient = {
|
|
list: async () => ({ items: [], nextCursor: null }),
|
|
get: async () => {
|
|
throw new Error('not used')
|
|
},
|
|
stats: async () => ({}),
|
|
removeFromHistory: async () => {},
|
|
shutdown: async () => {}
|
|
}
|
|
const r = await connect({
|
|
flags: { ...baseFlags, local: true },
|
|
createLocalClientImpl: async () => fakeClient as never
|
|
})
|
|
if (r.kind !== 'connected') throw new Error('expected connected')
|
|
expect(r.client.stats).toBeDefined()
|
|
expect(r.teardown).toBeDefined()
|
|
})
|
|
|
|
it('reports DESKTOP_NOT_READY when descriptor missing and autostart disabled', async () => {
|
|
const r = await connect({
|
|
flags: { ...baseFlags, noAutostart: true },
|
|
readDescriptorImpl: () => ({ ok: false, path: '/x', envelope: { ok: false, code: 'DESKTOP_NOT_READY', message: 'missing' } }),
|
|
ensureDesktopReadyImpl: async () => ({ kind: 'autostart-disabled' })
|
|
})
|
|
if (r.kind !== 'error') throw new Error('expected error')
|
|
expect(r.envelope.code).toBe('DESKTOP_NOT_READY')
|
|
})
|
|
|
|
it('uses descriptor + automation client when ready', async () => {
|
|
const r = await connect({
|
|
flags: { ...baseFlags },
|
|
readDescriptorImpl: () => ({
|
|
ok: true,
|
|
path: '/x',
|
|
descriptor: {
|
|
version: 1,
|
|
schemaVersion: '1.0.0',
|
|
kind: 'desktop',
|
|
host: '127.0.0.1',
|
|
port: 27_100,
|
|
tokenHash: null,
|
|
tokenIssuedAt: null,
|
|
tokenExpiresAt: null,
|
|
pid: process.pid,
|
|
pidStartedAt: 0,
|
|
updatedAt: 0,
|
|
appVersion: '1.0.0'
|
|
}
|
|
}),
|
|
buildAutomationClient: (baseUrl) => {
|
|
return {
|
|
list: async () => ({ items: [], nextCursor: null }),
|
|
get: async () => {
|
|
throw new Error('not used')
|
|
},
|
|
stats: async () => ({ baseUrl }),
|
|
removeFromHistory: async () => {}
|
|
}
|
|
}
|
|
})
|
|
if (r.kind !== 'connected') throw new Error('expected connected')
|
|
expect(await r.client.stats()).toEqual({ baseUrl: 'http://127.0.0.1:27100' })
|
|
})
|
|
|
|
it('reports API_UNREACHABLE when --vidbee-target api with no url', async () => {
|
|
const r = await connect({ flags: { ...baseFlags, target: 'api' } })
|
|
if (r.kind !== 'error') throw new Error('expected error')
|
|
expect(r.envelope.code).toBe('API_UNREACHABLE')
|
|
})
|
|
})
|