import { z } from 'zod';

export const SessionStartEventSchema = z
	.object({
		id: z.string().describe('the session id'),
		threadId: z.string().optional().describe('the thread id (optional, can be set in complete)'),
		orgId: z.string().describe('the organization id'),
		projectId: z.string().describe('the project id'),
		deploymentId: z.string().optional().describe('the deployment id'),
		routeId: z.string().describe('the route id'),
		environment: z.string().describe('the environment (AGENTUITY_ENVIRONMENT)'),
		devmode: z.boolean().describe('true if running in devmode'),
		url: z.string().describe('the url for the session event'),
		method: z.string().describe('the method for the session event'),
		trigger: z
			.enum(['agent', 'api', 'email', 'sms', 'cron', 'manual', 'discord', 'websocket'])
			.describe('how the session was triggered'),
		metadata: z
			.record(z.string(), z.unknown())
			.optional()
			.describe('optional unencrypted key-value metadata'),
	})
	.describe('The event to record a session started');

export type SessionStartEvent = z.infer<typeof SessionStartEventSchema>;

export const SessionCompleteEventSchema = z
	.object({
		id: z.string().describe('the session id'),
		threadId: z.string().nullable().describe('the thread id (null if thread has no data)'),
		error: z.string().optional().describe('the optional error message if the session failed'),
		agentIds: z
			.array(z.string())
			.optional()
			.describe('optional array of ids for the agents that executed for the session'),
		statusCode: z.number().describe('the HTTP status code'),
		userData: z.string().optional().describe('optional JSON string of session state data'),
		metadata: z
			.record(z.string(), z.unknown())
			.optional()
			.describe('optional unencrypted key-value metadata'),
	})
	.describe('The event to record a session completed successfully');

export type SessionCompleteEvent = z.infer<typeof SessionCompleteEventSchema>;

export const SessionStartEventDelayedSchema = z.intersection(
	SessionStartEventSchema,
	z.object({ timestamp: z.number().int().describe('the event timestamp in epoch') })
);

export const SessionCompleteEventDelayedSchema = z.intersection(
	SessionCompleteEventSchema,
	z.object({ timestamp: z.number().int().describe('the event timestamp in epoch') })
);

/**
 * SessionEventProvider is a provider for logging and tracking agent session lifecycle events.
 * Sessions represent individual agent executions triggered by API calls, cron jobs, or other sources.
 */
export interface SessionEventProvider {
	/**
	 * Called when an agent session starts. Records the initial context and metadata
	 * for the session including trigger source, environment, and routing information.
	 *
	 * @param event - SessionStartEvent containing session initialization data
	 *
	 * @example
	 * ```typescript
	 * await sessionProvider.start({
	 *   id: 'session-123',
	 *   threadId: 'thread-abc',
	 *   orgId: 'org-456',
	 *   projectId: 'proj-789',
	 *   deploymentId: 'deploy-xyz',
	 *   routeId: 'route-001',
	 *   environment: 'production',
	 *   devmode: false,
	 *   url: '/api/agent/chat',
	 *   method: 'POST',
	 *   trigger: 'api'
	 * });
	 * ```
	 */
	start(event: SessionStartEvent): Promise<void>;

	/**
	 * Called when an agent session completes (successfully or with error).
	 * Records final status, any errors, and which agents participated.
	 *
	 * @param event - SessionCompleteEvent containing completion status and results
	 *
	 * @example
	 * ```typescript
	 * // Successful completion
	 * await sessionProvider.complete({
	 *   id: 'session-123',
	 *   statusCode: 200,
	 *   agentIds: ['agent-1', 'agent-2']
	 * });
	 *
	 * // Completion with error
	 * await sessionProvider.complete({
	 *   id: 'session-123',
	 *   statusCode: 500,
	 *   error: 'Database connection timeout',
	 *   agentIds: ['agent-1']
	 * });
	 * ```
	 */
	complete(event: SessionCompleteEvent): Promise<void>;
}