1export const OpenBankingRefreshBalances = defineCommand({
2  meta: {
3    key: 'openbanking.balances.refresh',
4    version: '1.0.0',
5    description:
6      'Refresh balances for a bank account via the configured open banking provider.',
7    goal: 'Ensure canonical balance records reflect the latest values from Powens.',
8    context:
9      'Triggered by scheduled workflows before generating summaries or forecasting cashflow.',
10    owners: ['@platform.finance'],
11    tags: ['open-banking', 'powens', 'balances'],
12    stability: 'experimental',
13  },
14  io: {
15    input: OpenBankingRefreshBalancesInput,
16    output: OpenBankingRefreshBalancesOutput,
17  },
18  policy: {
19    auth: 'admin',
20  },
21  telemetry: {
22    success: {
23      event: { key: OPENBANKING_TELEMETRY_EVENTS.balancesRefreshed },
24      properties: ({ input, output }) => {
25        const payload = input as {
26          tenantId?: string;
27          accountId?: string;
28        };
29        const result = output as {
30          balances?: unknown[];
31          refreshedAt?: string;
32        } | null;
33        return {
34          tenantId: payload?.tenantId,
35          accountId: payload?.accountId,
36          refreshedAt: result?.refreshedAt,
37          balanceCount: Array.isArray(result?.balances)
38            ? result?.balances.length
39            : undefined,
40        };
41      },
42    },
43    failure: {
44      event: { key: OPENBANKING_TELEMETRY_EVENTS.balancesRefreshFailed },
45      properties: ({ input, error }) => {
46        const payload = input as {
47          tenantId?: string;
48          accountId?: string;
49        };
50        return {
51          tenantId: payload?.tenantId,
52          accountId: payload?.accountId,
53          error:
54            error instanceof Error ? error.message : String(error ?? 'unknown'),
55        };
56      },
57    },
58  },
59});