3. Settle the order

type SettlementInput = {
  transactionId: string;
  parentOperationId: string;
};

const { transactionId, parentOperationId } = api.input()
  ?.message as SettlementInput;
const operationId = api.getOperationId();
const transactions = await api.getDatabaseData('transactions', {
  filter: { field: 'transactionId', op: 'eq', value: transactionId },
  take: 1,
});

if (transactions.results !== 1) {
  api.throw(404, { message: 'Transaction not found', operationId });
}

const transaction = transactions.data[0];

const provider = await api.httpCall(
  {
    url: 'https://payments.example.com/v1/settlements',
    method: 'POST',
    headers: {
      Authorization: `Bearer ${
        (await vault.get('PAYMENTS_API_KEY')).revision.value
      }`,
      'Idempotency-Key': transaction.transactionId,
      'X-Correlation-ID': operationId,
    },
    data: {
      transactionId: transaction.transactionId,
      amountMinor: transaction.amountMinor,
      currency: transaction.currency,
    },
  },
  {
    requestType: 'json',
    responseType: 'json',
    timeout: 15_000,
  },
);

if (provider.status < 200 || provider.status >= 300) {
  api.log(
    {
      message: 'Payment provider rejected settlement',
      args: {
        operationId,
        transactionId,
        providerStatus: provider.status,
        durationMs: provider.time,
      },
    },
    'WARN',
  );

  api.throw(424, {
    message: 'Settlement provider did not accept the operation',
    operationId,
    transactionId,
  });
}

if (typeof provider.data?.reference !== 'string') {
  api.throw(424, {
    message: 'Settlement provider returned an invalid response',
    operationId,
    transactionId,
  });
}

const providerReference = provider.data.reference;
const settledAt = new Date().toISOString();

await api.updateDatabaseData(
  'transactions',
  { transactionId, status: 'PENDING_SETTLEMENT' },
  {
    status: 'SETTLED',
    providerReference,
    settledAt,
    settlementOperationId: operationId,
  },
);

const receiptFolder = await storage.ensureFolderPath(
  'payments/settlement-receipts',
  {
    restricted: true,
  },
);

if (!receiptFolder.effectiveRestricted) {
  api.throw(500, {
    message: 'Settlement receipt folder is not restricted',
    operationId,
    parentOperationId,
    transactionId,
  });
}

const receiptName = `settlement-${transactionId}.json`;
const priorReceipts = await storage.explore({
  parentStorageEntryId: receiptFolder.storageEntryId,
  term: receiptName,
  take: 10,
});
const priorReceipt = priorReceipts.data.find(
  (entry) => entry.name === receiptName,
);

const receipt =
  priorReceipt ??
  (await storage.putObject({
    parentStorageEntryId: receiptFolder.storageEntryId,
    name: receiptName,
    data: JSON.stringify(
      {
        operationId,
        parentOperationId,
        transactionId,
        orderId: transaction.orderId,
        amountMinor: transaction.amountMinor,
        currency: transaction.currency,
        providerReference,
        settledAt,
      },
      null,
      2,
    ),
    mimeType: 'application/json',
    computeStats: 'sync',
    metadata: {
      operationId,
      parentOperationId,
      transactionId,
      documentType: 'settlement-receipt',
    },
  }));

await api.updateDatabaseData(
  'transactions',
  { transactionId },
  { receiptStorageEntryId: receipt.storageEntryId },
);

api.log(
  {
    message: 'Order settlement completed',
    args: {
      operationId,
      parentOperationId,
      transactionId,
      providerReference,
      receiptStorageEntryId: receipt.storageEntryId,
      providerDurationMs: provider.time,
    },
  },
  'INFO',
);

return {
  operationId,
  parentOperationId,
  transactionId,
  providerReference,
  receiptStorageEntryId: receipt.storageEntryId,
  status: 'SETTLED',
};