1import {
2	defineCommand,
3	defineQuery,
4} from '@lssm-tech/lib.contracts-spec/operations';
5import { defineSchemaModel, ScalarTypeEnum } from '@lssm-tech/lib.schema';
6import { GranularityEnum, LogLevelEnum, RunStatusEnum } from './run.enum';
7import {
8	RunInputModel,
9	RunLogModel,
10	RunModel,
11	RunStepModel,
12	RunSummaryModel,
13	TimelineDataPointModel,
14} from './run.schema';
15
16export const ExecuteAgentCommand = defineCommand({
17	meta: {
18		key: 'agent.run.execute',
19		version: '1.0.0',
20		stability: 'stable',
21		owners: ['@agent-console-team'],
22		tags: ['run', 'execute'],
23		description: 'Starts a new agent run with the given input.',
24		goal: 'Execute an AI agent with user input.',
25		context: 'Called from chat interface or API.',
26	},
27	io: {
28		input: defineSchemaModel({
29			name: 'ExecuteAgentInput',
30			fields: {
31				agentId: { type: ScalarTypeEnum.String_unsecure(), isOptional: false },
32				input: { type: RunInputModel, isOptional: false },
33				sessionId: { type: ScalarTypeEnum.String_unsecure(), isOptional: true },
34				metadata: { type: ScalarTypeEnum.JSONObject(), isOptional: true },
35				stream: { type: ScalarTypeEnum.Boolean(), isOptional: true },
36				maxIterations: {
37					type: ScalarTypeEnum.Int_unsecure(),
38					isOptional: true,
39				},
40				timeoutMs: { type: ScalarTypeEnum.Int_unsecure(), isOptional: true },
41			},
42		}),
43		output: defineSchemaModel({
44			name: 'ExecuteAgentOutput',
45			fields: {
46				runId: { type: ScalarTypeEnum.String_unsecure(), isOptional: false },
47				status: { type: RunStatusEnum, isOptional: false },
48				estimatedWaitMs: {
49					type: ScalarTypeEnum.Int_unsecure(),
50					isOptional: true,
51				},
52			},
53		}),
54		errors: {
55			AGENT_NOT_FOUND: {
56				description: 'The specified agent does not exist',
57				http: 404,
58				gqlCode: 'AGENT_NOT_FOUND',
59				when: 'Agent ID is invalid',
60			},
61			AGENT_NOT_ACTIVE: {
62				description: 'The specified agent is not active',
63				http: 400,
64				gqlCode: 'AGENT_NOT_ACTIVE',
65				when: 'Agent is in draft/paused/archived state',
66			},
67		},
68	},
69	policy: { auth: 'user' },
70	sideEffects: {
71		emits: [
72			{
73				key: 'run.started',
74				version: '1.0.0',
75				stability: 'stable',
76				owners: ['@agent-console-team'],
77				tags: ['run', 'started'],
78				when: 'Run is queued',
79				payload: RunSummaryModel,
80			},
81		],
82		audit: ['run.started'],
83	},
84	acceptance: {
85		scenarios: [
86			{
87				key: 'execute-agent-happy-path',
88				given: ['Agent exists', 'Agent is active'],
89				when: ['User submits execution request'],
90				then: ['Run is created', 'RunStarted event is emitted'],
91			},
92			{
93				key: 'execute-agent-not-active',
94				given: ['Agent exists but is not active'],
95				when: ['User attempts to execute'],
96				then: ['AGENT_NOT_ACTIVE error is returned'],
97			},
98		],
99		examples: [
100			{
101				key: 'basic-execute',
102				input: { agentId: 'agent-123', input: { message: 'Hello' } },
103				output: { runId: 'run-456', status: 'pending', estimatedWaitMs: 5000 },
104			},
105		],
106	},
107});