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 { BankAccountRecord } from '../models';
9import { OPENBANKING_TELEMETRY_EVENTS } from '../telemetry';
10
11export const OpenBankingSyncAccounts = defineCommand({
12	meta: {
13		key: 'openbanking.accounts.sync',
14		version: '1.0.0',
15		description:
16			'Initiate a synchronisation run to refresh bank account metadata from Powens.',
17		goal: 'Keep canonical bank account records aligned with the external open banking provider.',
18		context:
19			'Triggered by scheduled workflows or manual operator actions to reconcile account metadata prior to transaction/balance syncs.',
20		owners: ['@platform.finance'],
21		tags: ['open-banking', 'powens', 'accounts'],
22		stability: 'experimental',
23	},
24	io: {
25		input: OpenBankingSyncAccountsInput,
26		output: OpenBankingSyncAccountsOutput,
27	},
28	policy: {
29		auth: 'admin',
30	},
31	telemetry: {
32		success: {
33			event: { key: OPENBANKING_TELEMETRY_EVENTS.accountsSynced },
34			properties: ({ input, output }) => {
35				const payload = input as {
36					tenantId?: string;
37					connectionId?: string;
38				};
39				const result = output as {
40					synced?: number;
41					failed?: number;
42				} | null;
43				return {
44					tenantId: payload?.tenantId,
45					connectionId: payload?.connectionId,
46					synced: result?.synced,
47					failed: result?.failed,
48				};
49			},
50		},
51		failure: {
52			event: { key: OPENBANKING_TELEMETRY_EVENTS.accountsSyncFailed },
53			properties: ({ input, error }) => {
54				const payload = input as {
55					tenantId?: string;
56					connectionId?: string;
57				};
58				return {
59					tenantId: payload?.tenantId,
60					connectionId: payload?.connectionId,
61					error:
62						error instanceof Error ? error.message : String(error ?? 'unknown'),
63				};
64			},
65		},
66	},
67});