SDK Quickstart

# Required -- signing key
MAKER_PRIVATE_KEY=0x59c6995e998f97a5a0044966f0945389dc9e86dae88c7a8412f4603b6b78690d
 
# Chain configuration
CHAIN_ID=31337
ENGINE_ADDRESS=0x5FbDB2315678afecb367f032d93F642f64180aa3
 
# Relay
RELAY_WS_URL=ws://127.0.0.1:8080
 
# Token addresses (V1)
WHYPE_ADDRESS=0x0000000000000000000000000000000000000001
USDC_ADDRESS=0x0000000000000000000000000000000000000002
USDH_ADDRESS=0x0000000000000000000000000000000000000003
 
# Market data
HYPE_SPOT_USD=25
HYPE_IV_BPS=8000
RISK_FREE_RATE_BPS=500

import { Wallet } from "ethers";
import WebSocket from "ws";
import {
  rfqFromJson,
  quoteToJson,
  signQuote,
  StubPricingEngine,
  RiskState,
  checkRisk,
  computeNotional,
} from "@hyperquote/sdk-maker";
import type {
  Quote,
  MakerConfig,
  MarketData,
  RFQBroadcastMessage,
  QuoteSubmitMessage,
  RelayMessage,
} from "@hyperquote/sdk-maker";
 
// 1. Initialize wallet from private key
const wallet = new Wallet(process.env.MAKER_PRIVATE_KEY!);
 
// 2. Chain configuration
const chainId = parseInt(process.env.CHAIN_ID ?? "31337");
const engineAddress =
  process.env.ENGINE_ADDRESS ?? "0x5FbDB2315678afecb367f032d93F642f64180aa3";
 
// 3. Pricing engine (uses Black-Scholes with configurable vol surface)
const pricingEngine = new StubPricingEngine();
 
// 4. Risk state tracker (per-expiry delta buckets + per-collateral notional)
const riskState = new RiskState();
 
// 5. Market data snapshot
const spotPriceUsd = parseFloat(process.env.HYPE_SPOT_USD ?? "25");
const market: MarketData = {
  spotPrice: BigInt(Math.round(spotPriceUsd * 1e18)),
  ivBps: parseInt(process.env.HYPE_IV_BPS ?? "8000"),
  riskFreeRateBps: parseInt(process.env.RISK_FREE_RATE_BPS ?? "500"),
};
 
// 6. Nonce counter (increments with each submitted quote)
let nonce = 0n;

const relayUrl = process.env.RELAY_WS_URL ?? "ws://127.0.0.1:8080";
const ws = new WebSocket(relayUrl);
 
ws.on("open", () => {
  console.log("[CONNECTED] Relay WebSocket open");
});
 
ws.on("error", (err) => {
  console.error("[WS ERROR]", err.message);
});
 
ws.on("close", () => {
  console.log("[DISCONNECTED] Reconnecting in 3s...");
  setTimeout(() => { /* reconnect logic */ }, 3000);
});

ws.on("message", async (raw) => {
  const msg: RelayMessage = JSON.parse(raw.toString());
 
  // Respond to relay keepalive
  if (msg.type === "PING") {
    ws.send(JSON.stringify({ type: "PONG", data: {} }));
    return;
  }
 
  // Log relay errors
  if (msg.type === "ERROR") {
    console.error("[RELAY ERROR]", (msg.data as { message: string }).message);
    return;
  }
 
  // Process RFQ broadcasts
  if (msg.type === "RFQ_BROADCAST") {
    const broadcast = msg as unknown as RFQBroadcastMessage;
    const rfq = rfqFromJson(broadcast.data.rfq);
    const rfqId = broadcast.data.rfqId;
 
    console.log(`[RFQ] ${rfqId.slice(0, 14)}... ${rfq.isCall ? "CC" : "CSP"}`);
 
    // ... filter, price, risk check, build quote, sign, submit
  }
});

// Build the quote (most fields mirror the RFQ)
const now = BigInt(Math.floor(Date.now() / 1000));
const quote: Quote = {
  maker: wallet.address,
  taker: "0x0000000000000000000000000000000000000000", // open quote
  underlying: rfq.underlying,
  collateral: rfq.collateral,
  isCall: rfq.isCall,
  isMakerSeller: false,  // V1 requirement: maker is always the buyer
  strike: rfq.strike,
  quantity: rfq.quantity,
  premium: pricingResult.premium,  // from your pricing engine
  expiry: rfq.expiry,
  deadline: now + 120n,  // quote valid for 2 minutes
  nonce: nonce,
};
 
// Sign with EIP-712
const signature = await signQuote(wallet, quote, chainId, engineAddress);
 
// Submit to relay
const submitMsg: QuoteSubmitMessage = {
  type: "QUOTE_SUBMIT",
  data: {
    rfqId,
    quote: quoteToJson(quote),
    makerSig: signature,
  },
};
ws.send(JSON.stringify(submitMsg));
 
// Advance nonce for next quote
nonce += 1n;
 
console.log(`[QUOTE] Submitted for ${rfqId.slice(0, 14)}...`);