feat: add TIP-1034 tempo session

.changeset/tempo-tip-1034-session.md

@@ -0,0 +1,5 @@
+---
+'mppx': minor
+---
+
+Added TIP-1034-backed Tempo sessions as the default `tempo.session` interface and moved the previous session flow to `tempo.sessionLegacy`.

.github/workflows/verify.yml

@@ -129,6 +129,45 @@ jobs:
           docker pull ghcr.io/tempoxyz/tempo:${VITE_TEMPO_TAG}
           docker save ghcr.io/tempoxyz/tempo:${VITE_TEMPO_TAG} -o /tmp/tempo-image.tar
 
+      - name: Start Tempo localnet
+        run: |
+          docker rm -f mppx-tempo-localnet 2>/dev/null || true
+          docker run -d \
+            --name mppx-tempo-localnet \
+            -p 18545:54515 \
+            ghcr.io/tempoxyz/tempo:${VITE_TEMPO_TAG} \
+            node \
+            --authrpc.port 54545 \
+            --datadir /tmp/mppx-tempo-localnet \
+            --dev \
+            --dev.block-time 200ms \
+            --dev.mnemonic 'test test test test test test test test test test test junk' \
+            --engine.disable-precompile-cache \
+            --engine.legacy-state-root \
+            --faucet.address 0x20c0000000000000000000000000000000000000 0x20c0000000000000000000000000000000000001 0x20c0000000000000000000000000000000000002 0x20c0000000000000000000000000000000000003 \
+            --faucet.amount 1000000000000 \
+            --faucet.enabled \
+            --faucet.private-key 0xac0974bec39a17e36ba4a6b4d238ff944bacb478cbed5efcae784d7bf4f2ff80 \
+            --http.addr 0.0.0.0 \
+            --http.api all \
+            --http.corsdomain '*' \
+            --http.port 54515 \
+            --port 54525 \
+            --ws.port 54535
+
+          for attempt in {1..30}; do
+            if curl -fsS \
+              -H 'content-type: application/json' \
+              --data '{"jsonrpc":"2.0","id":1,"method":"eth_chainId","params":[]}' \
+              http://localhost:18545 >/dev/null; then
+              exit 0
+            fi
+            sleep 1
+          done
+
+          docker logs mppx-tempo-localnet
+          exit 1
+
       - name: Bundle HTML files
         run: pnpm build
 
@@ -214,7 +253,7 @@ jobs:
           CI: true
           # These browser-only unit tests do not touch localnet, so skip the
           # global Tempo server startup/teardown path that can leave the step hanging.
-          VITE_NODE_ENV: testnet
+          VITE_TEMPO_NETWORK: none
 
       - name: Run tests
         run: pnpm run test:html

examples/session/multi-fetch/src/server.ts

@@ -74,7 +74,6 @@ const client = createClient({
 // Configuration:
 //   - `currency`: The TIP-20 token address to accept payment in
 //   - `recipient`: The server's address that receives funds on settlement
-//   - `testnet: true`: Uses Tempo Moderato testnet defaults (chain ID, escrow contract)
 //   - `getClient: () => client`: Returns an account-bearing viem client.
 //     The server needs this to:
 //       (a) Read on-chain channel state (deposit, settled amounts)
@@ -89,7 +88,6 @@ const mppx = Mppx.create({
       account,
       currency,
       feePayer: true,
-      testnet: true,
       getClient: () => client,
     }),
   ],

examples/session/sse/src/server.ts

@@ -134,9 +134,7 @@ const mppx = Mppx.create({
       // SSE transport for streaming. The session method detects the SSE
       // transport and wires up Tempo metering (per-token charging, voucher
       // handling) automatically using the shared storage.
-      sse: true,
-      // Enable testnet mode (relaxes certain validation constraints).
-      testnet: true,
+      sse: { poll: true },
     }),
   ],
 })
@@ -210,6 +208,7 @@ export async function handler(request: Request): Promise<Response | null> {
     // `result.challenge` is a Response object with the WWW-Authenticate header
     // containing the base64url-encoded challenge parameters.
     if (result.status === 402) return result.challenge
+    if (request.method !== 'GET') return result.withReceipt(new Response(null, { status: 204 }))
 
     // Phases 2–4: `withReceipt` handles everything.
     //
@@ -239,29 +238,7 @@ export async function handler(request: Request): Promise<Response | null> {
     // After all tokens are yielded, the transport automatically appends a
     // final `event: payment-receipt` SSE event with the settlement details.
     //
-    return result.withReceipt(async function* (stream) {
-      for await (const token of generateTokens(prompt)) {
-        try {
-          // `stream.charge()` — Charge the client for one token.
-          //
-          // This is the core of the pay-per-token model. Each call:
-          //   - Deducts `pricePerToken` from the channel's available balance
-          //   - If the client's voucher doesn't cover this charge, a
-          //     `payment-need-voucher` SSE event is emitted and the call blocks
-          //     until a new voucher arrives via POST
-          //   - Only returns once payment is confirmed, ensuring the server
-          //     never gives away content for free
-          await stream.charge()
-        } catch {
-          // Client disconnected or abort signal fired — stop streaming.
-          break
-        }
-        // Yield the token — this becomes an `event: message\ndata: <token>`
-        // in the SSE stream. The client's async iterator surfaces this as
-        // the next value in `for await (const token of tokens)`.
-        yield token
-      }
-    })
+    return result.withReceipt(generateTokens(prompt))
   }
 
   // Return null for unrecognized paths (framework can handle 404).

examples/session/sse/vite.config.ts

@@ -12,8 +12,11 @@ export default defineConfig({
         server.middlewares.use(async (req, res, next) => {
           const request = createRequest(req, res)
           const response = await handler(request)
-          if (response) await sendResponse(res, response)
-          else next()
+          if (response) {
+            await sendResponse(res, response)
+            return
+          }
+          next()
         })
         server.httpServer?.once('listening', () => {
           const addr = server.httpServer!.address()

examples/session/ws/src/server.ts

@@ -86,7 +86,6 @@ const mppx = Mppx.create({
       currency,
       getClient: () => client,
       store,
-      testnet: true,
     }),
   ],
   secretKey,

package.json

@@ -72,113 +72,113 @@
   ],
   "exports": {
     ".": {
-      "types": "./dist/index.d.ts",
       "src": "./src/index.ts",
+      "types": "./dist/index.d.ts",
       "default": "./dist/index.js"
     },
     "./cli": {
-      "types": "./dist/cli/config.d.ts",
       "src": "./src/cli/config.ts",
+      "types": "./dist/cli/config.d.ts",
       "default": "./dist/cli/config.js"
     },
     "./cli/plugins": {
-      "types": "./dist/cli/plugins/index.d.ts",
       "src": "./src/cli/plugins/index.ts",
+      "types": "./dist/cli/plugins/index.d.ts",
       "default": "./dist/cli/plugins/index.js"
     },
     "./client": {
-      "types": "./dist/client/index.d.ts",
       "src": "./src/client/index.ts",
+      "types": "./dist/client/index.d.ts",
       "default": "./dist/client/index.js"
     },
     "./discovery": {
-      "types": "./dist/discovery/index.d.ts",
       "src": "./src/discovery/index.ts",
+      "types": "./dist/discovery/index.d.ts",
       "default": "./dist/discovery/index.js"
     },
     "./evm": {
-      "types": "./dist/evm/index.d.ts",
       "src": "./src/evm/index.ts",
+      "types": "./dist/evm/index.d.ts",
       "default": "./dist/evm/index.js"
     },
     "./evm/client": {
-      "types": "./dist/evm/client/index.d.ts",
       "src": "./src/evm/client/index.ts",
+      "types": "./dist/evm/client/index.d.ts",
       "default": "./dist/evm/client/index.js"
     },
     "./evm/server": {
-      "types": "./dist/evm/server/index.d.ts",
       "src": "./src/evm/server/index.ts",
+      "types": "./dist/evm/server/index.d.ts",
       "default": "./dist/evm/server/index.js"
     },
     "./mcp-sdk/client": {
-      "types": "./dist/mcp-sdk/client/index.d.ts",
       "src": "./src/mcp-sdk/client/index.ts",
+      "types": "./dist/mcp-sdk/client/index.d.ts",
       "default": "./dist/mcp-sdk/client/index.js"
     },
     "./mcp-sdk/server": {
-      "types": "./dist/mcp-sdk/server/index.d.ts",
       "src": "./src/mcp-sdk/server/index.ts",
+      "types": "./dist/mcp-sdk/server/index.d.ts",
       "default": "./dist/mcp-sdk/server/index.js"
     },
     "./proxy": {
-      "types": "./dist/proxy/index.d.ts",
       "src": "./src/proxy/index.ts",
+      "types": "./dist/proxy/index.d.ts",
       "default": "./dist/proxy/index.js"
     },
     "./server": {
-      "types": "./dist/server/index.d.ts",
       "src": "./src/server/index.ts",
+      "types": "./dist/server/index.d.ts",
       "default": "./dist/server/index.js"
     },
     "./stripe": {
-      "types": "./dist/stripe/index.d.ts",
       "src": "./src/stripe/index.ts",
+      "types": "./dist/stripe/index.d.ts",
       "default": "./dist/stripe/index.js"
     },
     "./stripe/client": {
-      "types": "./dist/stripe/client/index.d.ts",
       "src": "./src/stripe/client/index.ts",
+      "types": "./dist/stripe/client/index.d.ts",
       "default": "./dist/stripe/client/index.js"
     },
     "./stripe/server": {
-      "types": "./dist/stripe/server/index.d.ts",
       "src": "./src/stripe/server/index.ts",
+      "types": "./dist/stripe/server/index.d.ts",
       "default": "./dist/stripe/server/index.js"
     },
     "./x402": {
-      "types": "./dist/x402/index.d.ts",
       "src": "./src/x402/index.ts",
+      "types": "./dist/x402/index.d.ts",
       "default": "./dist/x402/index.js"
     },
     "./tempo": {
-      "types": "./dist/tempo/index.d.ts",
       "src": "./src/tempo/index.ts",
+      "types": "./dist/tempo/index.d.ts",
       "default": "./dist/tempo/index.js"
     },
     "./html": {
-      "types": "./dist/Html.d.ts",
       "src": "./src/Html.ts",
+      "types": "./dist/Html.d.ts",
       "default": "./dist/Html.js"
     },
     "./hono": {
-      "types": "./dist/middlewares/hono.d.ts",
       "src": "./src/middlewares/hono.ts",
+      "types": "./dist/middlewares/hono.d.ts",
       "default": "./dist/middlewares/hono.js"
     },
     "./express": {
-      "types": "./dist/middlewares/express.d.ts",
       "src": "./src/middlewares/express.ts",
+      "types": "./dist/middlewares/express.d.ts",
       "default": "./dist/middlewares/express.js"
     },
     "./nextjs": {
-      "types": "./dist/middlewares/nextjs.d.ts",
       "src": "./src/middlewares/nextjs.ts",
+      "types": "./dist/middlewares/nextjs.d.ts",
       "default": "./dist/middlewares/nextjs.js"
     },
     "./elysia": {
-      "types": "./dist/middlewares/elysia.d.ts",
       "src": "./src/middlewares/elysia.ts",
+      "types": "./dist/middlewares/elysia.d.ts",
       "default": "./dist/middlewares/elysia.js"
     }
   },