Solana Payment Channels

import { channelAuthMiddleware } from '@solana-payment-channel/server';

// Fixed price endpoint
app.get('/api/markets',
  channelAuthMiddleware(paymentService, {
    amount: 1_000_000n  // 1 USDC
  }),
  (req, res) => res.json({ markets, payment: req.payment })
);

// Dynamic pricing
app.post('/api/process',
  channelAuthMiddleware(paymentService, {
    amount: async (req) => BigInt(req.body.items.length * 100_000)
  }),
  handler
);

import { RequirePayment, Payment } from '@solana-payment-channel/server';

@Controller('markets')
export class MarketsController {
  @Get('stream')
  @RequirePayment(100n) // 0.0001 USDC per request
  getStream(@Payment() payment: PaymentResult) {
    return {
      markets: this.getMarkets(),
      paymentMethod: payment.method, // 'channel' or 'x402'
      remainingBalance: payment.channelBalance
    };
  }

  // Dynamic pricing
  @Post('process')
  @RequirePayment((context) => {
    const items = context.switchToHttp().getRequest().body.items;
    return BigInt(items.length * 100_000);
  })
  processData() { /* ... */ }
}

import { channelPaymentPlugin } from '@solana-payment-channel/server';

// Register plugin
await fastify.register(channelPaymentPlugin, {
  rpcUrl: process.env.SOLANA_RPC_URL,
  network: 'devnet',
  programId: new PublicKey(PROGRAM_ID)
});

// Protected route
fastify.get('/api/premium', {
  preHandler: fastify.requirePayment({ amount: 1_000_000n })
}, async (request, reply) => {
  return { data: 'premium', payment: request.payment };
});