1export const ingestEmailThreadsWorkflow = defineWorkflow({
2	meta: {
3		key: 'pfo.workflow.ingest-email-threads',
4		version: '1.0.0',
5		title: 'Ingest Email Threads',
6		description:
7			'Synchronises Gmail threads tagged with finance labels and indexes them into operational knowledge spaces.',
8		domain: 'communications',
9		owners: [OwnersEnum.PlatformMessaging],
10		tags: ['gmail', 'knowledge', TagsEnum.Automation],
11		stability: StabilityEnum.Experimental,
12	},
13	definition: {
14		entryStepId: 'sync',
15		steps: [
16			{
17				id: 'sync',
18				type: 'automation',
19				label: 'Sync Gmail Threads',
20				description:
21					'Fetches Gmail threads and transforms them into knowledge fragments before vector indexing.',
22				action: {
23					operation: { key: 'pfo.email.sync-threads', version: '1.0.0' },
24				},
25				requiredIntegrations: ['emailInbound', 'primaryVectorDb'],
26				retry: {
27					maxAttempts: 3,
28					backoff: 'exponential',
29					delayMs: 1000,
30				},
31			},
32			{
33				id: 'triage',
34				type: 'human',
35				label: 'Triage Exceptions',
36				description:
37					'Operators can resolve sync failures or tag important threads for follow-up.',
38			},
39		],
40		transitions: [
41			{
42				from: 'sync',
43				to: 'triage',
44				condition: 'output?.syncedThreads === 0',
45				label: 'No new threads',
46			},
47		],
48	},
49});