mirror of
https://github.com/deepseek-ai/deepseek-harness.git
synced 2026-08-29 04:26:38 +00:00
99 lines
4.0 KiB
TypeScript
99 lines
4.0 KiB
TypeScript
/**
|
|
* TestRemote's own contract: subscription and disposal, dispatch driven by the
|
|
* internal plumbing event, the silent drop for an unsubscribed name, and the
|
|
* `$mount` refusal that sends a spec to the real Client Remote service.
|
|
*/
|
|
import { Context } from '@deepseek-ai/cordis'
|
|
import { describe, expect, it } from 'vitest'
|
|
import { TestRemote } from '../src/remote.ts'
|
|
import { scriptedSettingsRemote } from '../src/settings-remote.ts'
|
|
|
|
describe('TestRemote', () => {
|
|
it('delivers a forwarded event to its subscribers and stops after disposal', async () => {
|
|
const ctx = new Context()
|
|
const remote = new TestRemote(ctx)
|
|
const seen: string[] = []
|
|
const off = remote.$on('settings/document-updated', (ns: string) => {
|
|
seen.push(ns)
|
|
})
|
|
|
|
remote.emit('settings/document-updated', ['ui-theme', 1])
|
|
expect(seen).toEqual(['ui-theme'])
|
|
|
|
off()
|
|
remote.emit('settings/document-updated', ['ui-theme', 2])
|
|
expect(seen).toEqual(['ui-theme'])
|
|
await ctx.fiber.dispose()
|
|
})
|
|
|
|
it('drops a forwarded event nobody subscribed to', async () => {
|
|
const ctx = new Context()
|
|
const remote = new TestRemote(ctx)
|
|
// No subscriber for this name: the emit must be inert rather than throwing,
|
|
// because the wire carries whatever the Host allowlist selected.
|
|
expect(() => { remote.emit('credentials/reference-updated', ['DEEPSEEK_API_KEY']) }).not.toThrow()
|
|
await ctx.fiber.dispose()
|
|
})
|
|
|
|
it('refuses $mount, which needs the real Client Remote service', async () => {
|
|
const ctx = new Context()
|
|
const remote = new TestRemote(ctx)
|
|
await expect(remote.$mount()).rejects.toThrow('needs the real Client Remote service')
|
|
await ctx.fiber.dispose()
|
|
})
|
|
|
|
it('reaches a scripted namespace as ctx.remote.<name> and as its own service', async () => {
|
|
const ctx = new Context()
|
|
const credentials = { describe: () => Promise.resolve({ ok: true as const, value: {} }) }
|
|
const remote = new TestRemote(ctx, { credentials })
|
|
|
|
expect((remote as unknown as { credentials: unknown }).credentials).toBe(credentials)
|
|
expect(ctx.get('remote.credentials')).toBe(credentials)
|
|
await ctx.fiber.dispose()
|
|
})
|
|
|
|
it('refuses a scripted namespace that would shadow one of its own members', async () => {
|
|
const ctx = new Context()
|
|
// Accepting this would replace the very refusal the case above pins.
|
|
expect(() => new TestRemote(ctx, { $mount: {} })).toThrow('would shadow')
|
|
expect(() => new TestRemote(ctx, { subscriptions: {} })).toThrow('would shadow')
|
|
await ctx.fiber.dispose()
|
|
})
|
|
})
|
|
|
|
describe('scriptedSettingsRemote', () => {
|
|
it('serves, writes, and replaces its scripted namespace list', async () => {
|
|
const first = { ns: 'first', revision: 1 }
|
|
const second = { ns: 'second', revision: 2 }
|
|
const remote = scriptedSettingsRemote([first])
|
|
|
|
await expect(remote.settings.describe()).resolves.toEqual({
|
|
ok: true,
|
|
value: { writable: true, hasDocument: false, namespaces: [first] },
|
|
})
|
|
await expect(remote.settings.update('first', {}, undefined)).resolves.toEqual({ ok: true, value: first })
|
|
await expect(remote.settings.replace('missing', {}, undefined)).resolves.toMatchObject({
|
|
ok: false,
|
|
error: { code: 'settings-rejected', details: { ns: 'missing' } },
|
|
})
|
|
await expect(remote.settings.mutate('first', [], undefined)).resolves.toEqual({ ok: true, value: first })
|
|
expect(remote.update).toHaveBeenCalledWith('first', {}, undefined)
|
|
expect(remote.replace).toHaveBeenCalledWith('missing', {}, undefined)
|
|
expect(remote.mutate).toHaveBeenCalledWith('first', [], undefined)
|
|
|
|
remote.publish([second])
|
|
await expect(remote.settings.describe()).resolves.toEqual({
|
|
ok: true,
|
|
value: { writable: true, hasDocument: false, namespaces: [second] },
|
|
})
|
|
})
|
|
|
|
it('reports explicit deployment facts', async () => {
|
|
const remote = scriptedSettingsRemote([], { writable: false, hasDocument: true })
|
|
await expect(remote.settings.describe()).resolves.toEqual({
|
|
ok: true,
|
|
value: { writable: false, hasDocument: true, namespaces: [] },
|
|
})
|
|
})
|
|
})
|