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 { BankTransactionRecord } from '../models';
9import { OPENBANKING_TELEMETRY_EVENTS } from '../telemetry';
10
11export const OpenBankingSyncTransactions = defineCommand({
12	meta: {
13		key: 'openbanking.transactions.sync',
14		version: '1.0.0',
15		description:
16			'Synchronise transactions for a bank account by calling the configured open banking provider.',
17		goal: 'Ensure the canonical transaction ledger stays aligned with the external provider.',
18		context:
19			'Triggered by scheduled workflows or on-demand actions when activity is expected on an account.',
20		owners: ['@platform.finance'],
21		tags: ['open-banking', 'powens', 'transactions'],
22		stability: 'experimental',
23	},
24	io: {
25		input: OpenBankingSyncTransactionsInput,
26		output: OpenBankingSyncTransactionsOutput,
27	},
28	policy: {
29		auth: 'admin',
30	},
31	telemetry: {
32		success: {
33			event: { key: OPENBANKING_TELEMETRY_EVENTS.transactionsSynced },
34			properties: ({ input, output }) => {
35				const payload = input as {
36					tenantId?: string;
37					accountId?: string;
38				};
39				const result = output as {
40					synced?: number;
41					failed?: number;
42					earliestSyncedAt?: string;
43					latestSyncedAt?: string;
44				} | null;
45				return {
46					tenantId: payload?.tenantId,
47					accountId: payload?.accountId,
48					synced: result?.synced,
49					failed: result?.failed,
50					earliestSyncedAt: result?.earliestSyncedAt,
51					latestSyncedAt: result?.latestSyncedAt,
52				};
53			},
54		},
55		failure: {
56			event: { key: OPENBANKING_TELEMETRY_EVENTS.transactionsSyncFailed },
57			properties: ({ input, error }) => {
58				const payload = input as {
59					tenantId?: string;
60					accountId?: string;
61				};
62				return {
63					tenantId: payload?.tenantId,
64					accountId: payload?.accountId,
65					error:
66						error instanceof Error ? error.message : String(error ?? 'unknown'),
67				};
68			},
69		},
70	},
71});