1import {
2	type AnyOperationSpec,
3	defineCommand,
4	defineQuery,
5} from '@lssm-tech/lib.contracts-spec/operations';
6import type { OperationSpecRegistry } from '@lssm-tech/lib.contracts-spec/operations/registry';
7import { ScalarTypeEnum, SchemaModel } from '@lssm-tech/lib.schema';
8import { MeetingTranscriptRecord } from '../models';
9import { MEETING_RECORDER_TELEMETRY_EVENTS } from '../telemetry';
10
11export const MeetingRecorderSyncTranscript = defineCommand({
12	meta: {
13		key: 'meeting-recorder.transcripts.sync',
14		version: '1.0.0',
15		description:
16			'Trigger a transcript sync from the meeting recorder provider.',
17		goal: 'Keep canonical transcripts aligned with external meeting providers.',
18		context:
19			'Invoked by scheduled jobs or webhooks when new transcripts are ready.',
20		owners: ['@platform.integrations'],
21		tags: ['meeting-recorder', 'transcripts', 'sync'],
22		stability: 'experimental',
23	},
24	io: {
25		input: MeetingRecorderSyncTranscriptInput,
26		output: MeetingRecorderSyncTranscriptOutput,
27	},
28	policy: {
29		auth: 'admin',
30	},
31	telemetry: {
32		success: {
33			event: { key: MEETING_RECORDER_TELEMETRY_EVENTS.transcriptsSynced },
34			properties: ({ input, output }) => {
35				const payload = input as {
36					tenantId?: string;
37					meetingId?: string;
38				};
39				const result = output as {
40					synced?: number;
41					failed?: number;
42				} | null;
43				return {
44					tenantId: payload?.tenantId,
45					meetingId: payload?.meetingId,
46					synced: result?.synced,
47					failed: result?.failed,
48				};
49			},
50		},
51		failure: {
52			event: { key: MEETING_RECORDER_TELEMETRY_EVENTS.transcriptsSyncFailed },
53			properties: ({ input, error }) => {
54				const payload = input as {
55					tenantId?: string;
56					meetingId?: string;
57				};
58				return {
59					tenantId: payload?.tenantId,
60					meetingId: payload?.meetingId,
61					error:
62						error instanceof Error ? error.message : String(error ?? 'unknown'),
63				};
64			},
65		},
66	},
67});