Nhận thanh toán từ agent

paymentMiddlewareFromConfig({/* routes */}, [
  inflow, // claims (balance, inflow), (exact, eip155:8453), …
  otherFacilitator, // claims what inflow does not claim
  partnerFacilitator,
]);

import { Mppx, inflow, paymentHttpTransport } from '@inflowpayai/mpp-seller';

const mppx = Mppx.create({
  transport: paymentHttpTransport(),
  methods: [
    inflow({
      apiKey: process.env.INFLOW_API_KEY!,
      environment: 'sandbox',
    }),
  ],
  secretKey: process.env.MPP_SECRET_KEY,
});

export async function handler(req: Request) {
  const r = await mppx.charge({ amount: '0.01', currency: 'USDC' })(req);
  if (r.status === 402) return r.challenge;
  return r.withReceipt(Response.json({ data: '…' }));
}

openssl rand -base64 32

import { Mppx, inflow, inflowChargesNodeListener, paymentHttpTransport } from '@inflowpayai/mpp-seller';

// Core instance from mppx/server. It keeps compose().
const mppx = Mppx.create({
  transport: paymentHttpTransport(),
  methods: [inflow({ apiKey: process.env.INFLOW_API_KEY!, environment: 'sandbox' })],
  secretKey: process.env.MPP_SECRET_KEY,
});

// USD → instrument rail, USDC → balance rail.
const checkout = inflowChargesNodeListener(mppx, [
  { amount: '1.0', currency: 'USD' },
  { amount: '0.0095', currency: 'USDC' },
]);

const mppx = Mppx.create({
  transport: paymentHttpTransport(),
  methods: [
    inflow({
      apiKey: process.env.INFLOW_API_KEY!,
      environment: 'sandbox',
      canOffer: ({ input }) => input.headers.get('x-market') !== 'blocked',
    }),
  ],
  selectOffers: (offers, { request }) =>
    request.headers.get('x-usdc-only') === 'true'
      ? offers.filter((offer) => offer.request.currency === 'USDC')
      : offers,
  secretKey: process.env.MPP_SECRET_KEY,
});

import express from 'express';
import { Mppx } from 'mppx/server';
import { inflow, inflowSubscriptionsNodeListener, paymentHttpTransport } from '@inflowpayai/mpp-seller';

const subscriptions = Mppx.create({
  transport: paymentHttpTransport(),
  methods: [
    inflow.subscription({
      apiKey: process.env.INFLOW_API_KEY!,
      environment: 'sandbox',
    }),
  ],
  secretKey: process.env.MPP_SECRET_KEY,
});

const subscribe = inflowSubscriptionsNodeListener(subscriptions, [
  {
    amount: '9.99',
    currency: 'USDC',
    periodUnit: 'month',
    periodCount: 1,
    subscriptionExpires: '2027-12-31T23:59:59Z',
    externalId: 'pro-monthly',
  },
]);

const app = express();
app.get('/api/subscribe', async (request, response) => {
  const result = await subscribe(request, response);
  if (result.status === 402) return;
  response.json({ access: 'granted' });
});

import { Mppx } from 'mppx/express';
import { Mppx as MppxServer } from 'mppx/server';
import { inflow, paymentHttpTransport } from '@inflowpayai/mpp-seller';
import { paymentMiddlewareFromConfig } from '@x402/express';
import type { RequestHandler } from 'express';

const method = inflow(options);
const realm = 'report-service';
const payments = Mppx.create({
  methods: [method], realm, secretKey, transport: paymentHttpTransport(),
});
const challenges = MppxServer.create({
  methods: [method], realm, secretKey, transport: paymentHttpTransport(),
});
const terms = {amount: '0.01', currency: 'USDC'};
const mppPayment = payments.charge(terms);
const mppChallenge = challenges.charge(terms);
const x402Payment = paymentMiddlewareFromConfig(
  {'GET /api/report': route}, [facilitator], registrations,
);
const report: RequestHandler = (_request, response) => {
  response.set('Cache-Control', 'no-store');
  response.json({report: 'Your sample report is ready.'});
};

app.get('/api/report', async (request, response, next) => {
  response.set('Cache-Control', 'no-store');
  const authorization = request.get('Authorization') ?? '';
  const hasMpp = /^Payment(?:\s|$)/i.test(authorization);
  const hasX402 = request.get('Payment-Signature') !== undefined
    || request.get('X-Payment') !== undefined;
  const duplicate = ['authorization', 'payment-signature', 'x-payment']
    .some(name => (request.headersDistinct[name]?.length ?? 0) > 1);
  if (duplicate || (hasMpp && hasX402)
    || (request.get('Payment-Signature') !== undefined
      && request.get('X-Payment') !== undefined)) {
    response.status(400).json({error: 'Send one payment credential.'});
    return;
  }
  if (hasMpp) return mppPayment(request, response, next);
  if (hasX402) return x402Payment(request, response, next);

  const unpaid = await mppChallenge(new Request(resourceUrl));
  if (unpaid.status !== 402) throw new Error('Expected an MPP challenge.');
  const challenge = unpaid.challenge;
  if (challenge.status !== 402) {
    challenge.headers.forEach((value, name) => response.set(name, value));
    response.status(challenge.status).send(await challenge.text());
    return;
  }
  const header = challenge.headers.get('WWW-Authenticate');
  if (header === null) throw new Error('Missing MPP challenge header.');
  response.append('WWW-Authenticate', header);
  return x402Payment(request, response, next);
}, report);