run-demo

name	run-demo
description	Start the Surf prediction market demo. Use when the user wants to run, restart, or show the demo (benchmark dashboard, MV app, re-query app).
user_invocable	true

Run Surf Demo

Start the prediction market demo with live Polymarket data: two app instances (MV vs re-query mode) for side-by-side comparison.

Prerequisites

• Docker installed
• Demo app built (npm run demo:build)

Steps

1. Start RisingWave

Always ensure RisingWave is running. Start it and wait for it to accept connections:

docker start surf-risingwave 2>/dev/null || docker run -d --name surf-risingwave -p 4566:4566 risingwavelabs/risingwave:latest

Wait for it to be ready (retry up to 30 seconds):

for i in $(seq 1 30); do pg_isready -h localhost -p 4566 && break; sleep 1; done

If it doesn't become ready after 30 seconds, stop and report the error.

2. Build the demo app (if needed)

npm run demo:build

3. Kill any existing instances and reset schema

pkill -f "tsx demo/server.ts" 2>/dev/null
pkill -f "tsx benchmark/index.ts" 2>/dev/null
lsof -ti:8081 -ti:8082 -ti:3002 -ti:3003 | xargs kill -9 2>/dev/null
sleep 2

Reset stale schema (required for clean MV creation):

psql -h localhost -p 4566 -U root -d dev -c 'DROP SUBSCRIPTION IF EXISTS "_surf_sub_marketPrices";' 2>/dev/null
psql -h localhost -p 4566 -U root -d dev -c 'DROP SUBSCRIPTION IF EXISTS "_surf_sub_marketTrades";' 2>/dev/null
psql -h localhost -p 4566 -U root -d dev -c 'DROP MATERIALIZED VIEW IF EXISTS "_surf_marketPrices" CASCADE;' 2>/dev/null
psql -h localhost -p 4566 -U root -d dev -c 'DROP MATERIALIZED VIEW IF EXISTS "_surf_marketTrades" CASCADE;' 2>/dev/null
psql -h localhost -p 4566 -U root -d dev -c 'DROP TABLE IF EXISTS "trades" CASCADE;' 2>/dev/null

4. Start the MV server first (it inserts trades)

The MV server connects to Polymarket's WebSocket for real-time trades and inserts them into RisingWave. It must start first.

nohup npx tsx demo/server.ts --mode mv --live > /tmp/surf-live-mv.log 2>&1 &

Wait ~15 seconds for it to fetch markets, backfill trades, and connect WebSocket. Verify:

tail -3 /tmp/surf-live-mv.log
curl -s -o /dev/null -w "MV (3002): %{http_code}\n" http://localhost:3002

5. Start the re-query server (read-only)

The re-query server reads from the same shared table but polls every 5s instead of 200ms. It does NOT insert trades.

nohup npx tsx demo/server.ts --mode requery --live > /tmp/surf-live-rq.log 2>&1 &

Wait ~10 seconds, then verify:

tail -3 /tmp/surf-live-rq.log
curl -s -o /dev/null -w "RQ (3003): %{http_code}\n" http://localhost:3003

6. Report to the user

Tell the user to open these side by side:

• http://localhost:3002 -- Prediction market app (MV mode, ~200ms updates, purple "Polymarket Live" badge)
• http://localhost:3003 -- Prediction market app (re-query mode, ~5s updates, yellow "Delayed" badge)

Both show the same 20 live Polymarket markets with real-time trade data streaming via WebSocket.

Ports

Port	Service
4566	RisingWave
3002	Demo app (MV mode, HTTP)
3003	Demo app (re-query mode, HTTP)
8081	Surf WebSocket server (MV mode)
8082	Surf WebSocket server (re-query mode)

Stopping

pkill -f "tsx demo/server.ts"
lsof -ti:8081 -ti:8082 -ti:3002 -ti:3003 | xargs kill -9 2>/dev/null

Troubleshooting

• Port in use: Kill existing processes with the stop commands above
• RisingWave not ready: Wait a few seconds after docker start, then retry pg_isready
• Stale data / MV errors: Reset schema (step 3) and restart
• Demo app not built: Run npm run demo:build first
• No trade updates: Check tail /tmp/surf-live-mv.log for "WS: inserted" messages. If none, Polymarket WebSocket may be down.