通过 SDK 接入#

npm install express @okxweb3/x402-express @okxweb3/x402-core @okxweb3/x402-evm
npm install -D typescript tsx @types/express @types/node

go get github.com/okx/payments/go

# Cargo.toml 中配置
[dependencies]
x402-axum = { git = "https://github.com/okx/payments", subdirectory = "rust/x402-axum" }
x402-core = { git = "https://github.com/okx/payments", subdirectory = "rust/x402-core" }
x402-evm  = { git = "https://github.com/okx/payments", subdirectory = "rust/x402-evm" }

import express from "express";
import {
  paymentMiddleware,
  x402ResourceServer,
} from "@okxweb3/x402-express";
import { ExactEvmScheme } from "@okxweb3/x402-evm/exact/server";
import { OKXFacilitatorClient } from "@okxweb3/x402-core";

const app = express();

const NETWORK = "eip155:196"; // X Layer Mainnet
const PAY_TO = process.env.PAY_TO_ADDRESS || "0xYourWalletAddress";

// OKX Facilitator Client（需要 OKX API 凭证）
const facilitatorClient = new OKXFacilitatorClient({
  apiKey: "OKX_API_KEY",
  secretKey: "OKX_SECRET_KEY",
  passphrase: "OKX_PASSPHRASE",
});

// 创建资源服务器并注册 EVM exact scheme
const resourceServer = new x402ResourceServer(facilitatorClient);
resourceServer.register(NETWORK, new ExactEvmScheme());

// 挂载 x402 支付中间件
app.use(
  paymentMiddleware(
    {
      "GET /generateImg": {
        accepts: [{
          scheme: "exact",
          network: NETWORK,
          payTo: PAY_TO,
          price: "$0.01", // USDT 0.01
        }],
        description: "AI Image Generation Service",
        mimeType: "application/json",
      },
    },
    resourceServer,
  ),
);

// 受保护的图片生成路由（支付通过后才会执行）
app.get("/generateImg", (_req, res) => {
  console.log("[Seller] Payment verified, generating image...");
  res.json({
    success: true,
    imageUrl: "https://placehold.co/512x512/png?text=AI+Generated",
    prompt: "a sunset over mountains",
    timestamp: new Date().toISOString(),
  });
});

app.listen(4000, () => {
  console.log("[Seller] Image generation service listening at http://localhost:4000");
  console.log("[Seller] Protected route: GET http://localhost:4000/generateImg");
  console.log(`[Seller] Network: ${NETWORK}, PayTo: ${PAY_TO}`);
});

package main

import (
    "net/http"
    "os"
    "time"

    ginfw "github.com/gin-gonic/gin"
    x402http "github.com/okx/payments/go/http"
    ginmw "github.com/okx/payments/go/http/gin"
    evm "github.com/okx/payments/go/mechanisms/evm/exact/server"
)

func main() {
    // 1. Create OKX Facilitator client
    facilitator, _ := x402http.NewOKXFacilitatorClient(&x402http.OKXFacilitatorConfig{
        Auth: x402http.OKXAuthConfig{
            APIKey:     os.Getenv("OKX_API_KEY"),
            SecretKey:  os.Getenv("OKX_SECRET_KEY"),
            Passphrase: os.Getenv("OKX_PASSPHRASE"),
        },
    })

    // 2. Define payment-protected routes
    routes := x402http.RoutesConfig{
        "GET /generateImg": {
            Accepts: x402http.PaymentOptions{
                {
                    Scheme:  "exact",
                    Price:   "$0.01",
                    Network: "eip155:196",
                    PayTo:   "0xYourWalletAddress",
                },
            },
            Description: "AI-generated image",
            MimeType:    "image/png",
        },
    }

    // 3. Create Gin router with payment middleware
    r := ginfw.Default()
    r.Use(ginmw.X402Payment(ginmw.Config{
        Routes:      routes,
        Facilitator: facilitator,
        Schemes: []ginmw.SchemeConfig{
            {Network: "eip155:196", Server: evm.NewExactEvmScheme()},
        },
        Timeout: 30 * time.Second,
    }))

    r.GET("/genarateImg", func(c *ginfw.Context) {
        c.JSON(http.StatusOK, ginfw.H{"image": "https://placehold.co/512x512/png?text=AI+Generated"})
    })

    r.Run(":4000")
}

use std::collections::HashMap;

use axum::{routing::get, Json, Router};
use serde_json::{json, Value};

use x402_axum::{payment_middleware, AcceptConfig, RoutePaymentConfig};
use x402_core::http::OkxHttpFacilitatorClient;
use x402_core::server::X402ResourceServer;
use x402_evm::{DeferredEvmScheme, ExactEvmScheme};

#[tokio::main]
async fn main() {
    // 初始化日志（可以在终端看到 Facilitator 请求/响应）
    tracing_subscriber::fmt::init();

    // 从环境变量读取配置
    let api_key = std::env::var("OKX_API_KEY").expect("xxx");
    let secret_key = std::env::var("OKX_SECRET_KEY").expect("xxx");
    let passphrase = std::env::var("OKX_PASSPHRASE").expect("xxx");
    let pay_to = std::env::var("PAY_TO_ADDRESS")
        .expect("0xb483abdb92f8061e9a3a082a4aaaa6b88c381308");
    let facilitator_url = std::env::var("FACILITATOR_URL")
        .unwrap_or_else(|_| "https://web3.okx.com".to_string());

    // 1. 配置 OKX Facilitator
    let facilitator = OkxHttpFacilitatorClient::new(
        &facilitator_url,
        &api_key,
        &secret_key,
        &passphrase,
    );

    // 2. 创建 Server，注册支付 scheme
    let server = X402ResourceServer::new(facilitator)
        .register("eip155:196", ExactEvmScheme::new())
        .register("eip155:196", AggrDeferredEvmScheme::new());

    // 3. 配置哪些路由需要付费
    let routes = HashMap::from([
        ("GET /api/joke".to_string(), RoutePaymentConfig {
            accepts: vec![
                AcceptConfig {
                    scheme: "exact".into(),
                    price: "$0.001".into(),           // 每次请求 0.001 美元
                    network: "eip155:196".into(),      // X Layer
                    pay_to: pay_to.clone(),
                },
            ],
            description: "获取一个随机笑话".into(),
            mime_type: "application/json".into(),
            sync_settle: None,
        }),
    ]);

    // 4. 构建 Axum 路由
    let app = Router::new()
        .route("/health", get(health))              // 免费
        .route("/api/joke", get(joke))              // 付费 $0.001
        .layer(payment_middleware(routes, server));

    // 5. 启动服务
    let listener = tokio::net::TcpListener::bind("0.0.0.0:3000")
        .await
        .unwrap();
    println!("========================================");
    println!("  你的付费 API 已启动！");
    println!("  免费端点: http://localhost:3000/health");
    println!("  付费端点: http://localhost:3000/api/joke ($0.001)");
    println!("========================================");
    axum::serve(listener, app).await.unwrap();
}

// 免费端点
async fn health() -> Json<Value> {
    Json(json!({ "status": "ok" }))
}

// 付费端点 — 需要支付 $0.001 才能访问
async fn joke() -> Json<Value> {
    Json(json!({
        "joke": "为什么程序员总是分不清万圣节和圣诞节？因为 Oct 31 = Dec 25",
        "price": "$0.001"
    }))
}

请使用onchainOS访问http://localhost:4000/genarateImg