mirror of
https://github.com/windmill-labs/windmill.git
synced 2026-09-21 00:02:30 +00:00
120 lines
5.1 KiB
TypeScript
120 lines
5.1 KiB
TypeScript
import { describe, expect, it } from 'vitest'
|
|
import { AI_AGENT_SCHEMA, memoryPropertyFor } from './flowInfers'
|
|
import {
|
|
AGENT_FIELD_BY_KEY,
|
|
AGENT_FIELDS,
|
|
historyInputApplies,
|
|
keepsManagedMemory,
|
|
agentFieldIsSet,
|
|
initialVisibleAgentFields
|
|
} from './agentFormFields'
|
|
|
|
const schemaProperties = AI_AGENT_SCHEMA.properties ?? {}
|
|
|
|
function set(key: string, transform: unknown): boolean {
|
|
return agentFieldIsSet(AGENT_FIELD_BY_KEY[key], transform)
|
|
}
|
|
|
|
describe('agentFieldIsSet', () => {
|
|
it('reads the seeded placeholder as unset', () => {
|
|
expect(set('temperature', { type: 'static', value: undefined })).toBe(false)
|
|
expect(set('temperature', undefined)).toBe(false)
|
|
// The same placeholder after a round trip through the API.
|
|
expect(set('temperature', { type: 'static', value: null })).toBe(false)
|
|
})
|
|
|
|
it('treats a value the runtime cannot tell from absence as unset', () => {
|
|
expect(set('output_type', { type: 'static', value: 'text' })).toBe(false)
|
|
expect(set('max_iterations', { type: 'static', value: 10 })).toBe(false)
|
|
expect(set('memory', { type: 'static', value: { kind: 'off' } })).toBe(false)
|
|
expect(set('user_attachments', { type: 'static', value: [] })).toBe(false)
|
|
})
|
|
|
|
it('reads streaming as unset while it is on, which is what an absent key does', () => {
|
|
expect(schemaProperties.streaming?.default).toBe(true)
|
|
expect(set('streaming', { type: 'static', value: true })).toBe(false)
|
|
expect(set('streaming', { type: 'static', value: false })).toBe(true)
|
|
})
|
|
|
|
it('reads anything the user authored as set', () => {
|
|
expect(set('temperature', { type: 'static', value: 0 })).toBe(true)
|
|
// An empty `enabled_tools` advertises no tools, so it is a choice rather than an unset field:
|
|
// giving the spec an `implicit` of `[]` would hide the row while the run still carries none.
|
|
expect(set('enabled_tools', { type: 'static', value: [] })).toBe(true)
|
|
expect(set('output_type', { type: 'static', value: 'image' })).toBe(true)
|
|
expect(set('memory', { type: 'static', value: { kind: 'auto', context_length: 5 } })).toBe(true)
|
|
expect(set('max_iterations', { type: 'javascript', expr: 'flow_input.loops' })).toBe(true)
|
|
expect(set('max_iterations', { type: 'javascript', expr: '' })).toBe(false)
|
|
})
|
|
})
|
|
|
|
describe('initialVisibleAgentFields', () => {
|
|
it('shows only the core fields for a step that materialized every default', () => {
|
|
// What the pre-redesign form wrote on first render of a blank agent step.
|
|
const legacy = {
|
|
provider: { type: 'static', value: { kind: 'openai', resource: '$res:u/admin/openai' } },
|
|
output_type: { type: 'static', value: 'text' },
|
|
user_message: { type: 'static', value: undefined },
|
|
system_prompt: { type: 'static', value: undefined },
|
|
streaming: { type: 'static', value: true },
|
|
memory: { type: 'static', value: { kind: 'off' } },
|
|
output_schema: { type: 'static', value: null },
|
|
user_attachments: { type: 'static', value: [] },
|
|
max_completion_tokens: { type: 'static', value: null },
|
|
temperature: { type: 'static', value: null },
|
|
max_iterations: { type: 'static', value: 10 }
|
|
}
|
|
expect([...initialVisibleAgentFields(legacy, schemaProperties)].sort()).toEqual([
|
|
'provider',
|
|
'system_prompt',
|
|
'tools',
|
|
'user_message'
|
|
])
|
|
})
|
|
|
|
it('collapses a linked step to its flow-local inputs', () => {
|
|
const linkedSchema = {
|
|
user_message: schemaProperties.user_message,
|
|
user_attachments: schemaProperties.user_attachments
|
|
}
|
|
expect([...initialVisibleAgentFields({}, linkedSchema)]).toEqual(['user_message'])
|
|
})
|
|
|
|
it('covers every schema key, so no field can only be reached through the raw doc', () => {
|
|
const registered = new Set<string>(AGENT_FIELDS.map((f) => f.key))
|
|
expect(Object.keys(schemaProperties).filter((k) => !registered.has(k))).toEqual([])
|
|
})
|
|
})
|
|
|
|
describe('historyInputApplies', () => {
|
|
// Mirrors the worker: offering a step input a run would ignore misleads the author.
|
|
it('offers a memory id only with managed memory, and messages only without', () => {
|
|
expect(keepsManagedMemory(undefined)).toBe(false)
|
|
expect(keepsManagedMemory({ kind: 'window', context_length: 0 })).toBe(false)
|
|
expect(keepsManagedMemory({ kind: 'manual', messages: [] })).toBe(false)
|
|
expect(keepsManagedMemory({ kind: 'auto', context_length: 4, memory_id: 'x' })).toBe(true)
|
|
expect(historyInputApplies('memory_id', true)).toBe(true)
|
|
expect(historyInputApplies('messages', true)).toBe(false)
|
|
expect(historyInputApplies('memory_id', false)).toBe(false)
|
|
expect(historyInputApplies('messages', false)).toBe(true)
|
|
expect(historyInputApplies('messages', undefined)).toBe(true)
|
|
})
|
|
})
|
|
|
|
describe('memoryPropertyFor', () => {
|
|
const property = schemaProperties.memory
|
|
const kinds = (value: unknown) =>
|
|
memoryPropertyFor(property, value).oneOf.map((variant: { title: string }) => variant.title)
|
|
|
|
it('adds a legacy kind as an option only while the value holds it', () => {
|
|
expect(memoryPropertyFor(property, { kind: 'window', context_length: 10 })).toBe(property)
|
|
expect(memoryPropertyFor(property, undefined)).toBe(property)
|
|
expect(kinds({ kind: 'auto', context_length: 4, memory_id: 'x' })).toEqual([
|
|
'off',
|
|
'window',
|
|
'auto'
|
|
])
|
|
expect(kinds({ kind: 'manual', messages: [] })).toEqual(['off', 'window', 'manual'])
|
|
})
|
|
})
|