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