決済・サービス連携

npm install --save-exact @hazbase/kit@0.9.0 ethers@6.16.0

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

import { summarizeX402Request, isX402RequestExpired, type HazbaseX402Request } from '@hazbase/kit/x402';
import { createHazbaseWalletClient, type PayX402WithHazbaseWalletInput } from '@hazbase/kit/wallet';
import { getAddress } from 'ethers';

export function inspectReportPayment(
  payload: Record<string, unknown>,
  resourceUrl: string,
  policy: { network: string; asset: string; payTo: string; maxAmountAtomic: bigint },
) {
  const request = summarizeX402Request(payload, { sourceUrl: resourceUrl }, {
    networks: [policy.network],
    assets: [{ address: policy.asset }],
    requirePayTo: true,
  });
  if (!request) throw new Error('Unsupported payment request.');
  const terms = request.requirement;
  if (terms.resource !== resourceUrl || getAddress(terms.payTo) !== getAddress(policy.payTo)) {
    throw new Error('Payment does not match the requested service.');
  }
  const amount = BigInt(terms.amountAtomic);
  if (amount <= 0n || amount > policy.maxAmountAtomic) throw new Error('Amount is outside policy.');
  if (isX402RequestExpired(request, Date.now())) throw new Error('Payment request expired.');
  return request;
}

export async function payApprovedReport(
  request: HazbaseX402Request,
  auth: Pick<PayX402WithHazbaseWalletInput,
    'emailSession' | 'smartAccountAddress' | 'deviceBindingId' | 'highTrustToken'>,
) {
  // Call only after the user confirms the displayed resource and payment terms.
  if (isX402RequestExpired(request, Date.now())) throw new Error('Payment request expired.');
  const wallet = createHazbaseWalletClient();
  return wallet.payX402WithHazbaseWallet({
    ...auth,
    paymentRequestId: request.paymentRequestId,
    expectedAmountAtomic: request.requirement.amountAtomic,
    expectedPayTo: request.requirement.payTo,
    waitForReceipt: false,
  });
}