HyperVapor Documentation

// Take a position. isLong = true → long, false → short.
function deposit(bool isLong, uint256 amount) external;        // Market
function deposit(bool isLong) external payable;                // Native

// Exit both sides at once. Always available, even if paused.
function withdraw() external;

// Move your entire balance from one side to the other.
function switchPosition(bool fromLongToShort) external;

// Permissionless settlement. Anyone can call when a rebalance is due.
function rebalance() external;

// Read your position.
function getUserPosition(address user) external view returns (
    uint256 longShares, uint256 shortShares,
    uint256 longPrincipal, uint256 shortPrincipal
);
function previewWithdraw(address user) external view returns (
    uint256 grossLong, uint256 grossShort,
    uint256 netLong,   uint256 netShort,
    uint256 totalFee,  uint256 totalProfitTax
);

import { createPublicClient, http } from "viem";

const client = createPublicClient({
  chain: { id: 143, name: "Monad", nativeCurrency: { name: "MON", symbol: "MON", decimals: 18 }, rpcUrls: { default: { http: ["https://rpc.monad.xyz"] } } },
  transport: http(),
});

const FACTORY_ABI = [
  { type: "function", name: "getAllMarketIds", inputs: [], outputs: [{ type: "bytes32[]" }], stateMutability: "view" },
  { type: "function", name: "getMarketInfo", inputs: [{ name: "id", type: "bytes32" }],
    outputs: [{ components: [
      { name: "market",            type: "address" },
      { name: "marketType",        type: "uint8"   },   // 0 = ERC20, 1 = NATIVE
      { name: "priceSymbol",       type: "string"  },
      { name: "collateralToken",   type: "address" },
      { name: "priceProvider",     type: "address" },
      { name: "marketOwner",       type: "address" },
      { name: "rebalanceInterval", type: "uint256" },   // 600 (10m) or 3600 (1h)
      { name: "createdAt",         type: "uint256" },
      { name: "listed",            type: "bool"    },
      { name: "exists",            type: "bool"    },
    ], type: "tuple" }],
    stateMutability: "view" },
] as const;

const ids = await client.readContract({
  address: "0x63072Cdc78874DaDA5A6053f07E636eF3aec8c57",
  abi: FACTORY_ABI,
  functionName: "getAllMarketIds",
});

const pools = await Promise.all(ids.map((id) =>
  client.readContract({ address: "0x63072Cdc78874DaDA5A6053f07E636eF3aec8c57", abi: FACTORY_ABI, functionName: "getMarketInfo", args: [id] })
));

// QuickNode Stream Filter — HyperVapor
// Forward every log whose topic0 matches a known v2.1 event.
const TOPICS = new Set([
  // Pool
  "0xc2cf288cd8c138e724d1e17ce848afd04e0d32e56883d38635d5a81523dbce02", // Deposited
  "0x06c514d6b519b3f249f6f8b7fc10573de80de5388bfc514bfb432616ee930be7", // Withdrawn
  "0x0945716462655c1f308382e972112dec530f9595b0ee214386dbb14adf618dea", // Switched
  "0x5ef5c3de2451b8e81ef437df0ed11d9c3e7fd1485531ad5dd1874f64df4d7d70", // Rebalanced
  // Factory
  "0xd782b4fbb126b84aa938ca9ef083461d682456398f5d1b1f4112c40a6376ee00", // MarketCreated
  "0x1fb3747e10a9f9d9b8368bbf1e725aa452f6c4eb3527168288f16899f453bef4", // MarketStatusUpdated
]);

function main(streamData) {
  const blocks = [];
  for (const item of streamData.data ?? []) {
    const block = item.block ?? item;
    const logs = (item.receipts ?? block.receipts ?? [])
      .flatMap((r) => r.logs ?? [])
      .filter((l) => l.topics?.[0] && TOPICS.has(l.topics[0].toLowerCase()));
    if (logs.length) blocks.push({ number: block.number, hash: block.hash, timestamp: block.timestamp, logs });
  }
  return blocks.length ? { data: blocks, metadata: streamData.metadata } : null;
}

{
  "data": [
    {
      "number":    "0x...",
      "hash":      "0x...",
      "timestamp": "0x...",      // hex unix seconds
      "logs": [
        {
          "address":          "0x5fa1585458ca8fc1bb2b9b1528d488cdcbb8643c",
          "topics":           ["0xc2cf288c...", "0x000...abc"],
          "data":             "0x...",
          "blockNumber":      "0x...",
          "transactionHash":  "0x...",
          "transactionIndex": "0x...",
          "blockHash":        "0x...",
          "logIndex":         "0x...",
          "removed":          false
        }
      ]
    }
  ],
  "metadata": { "...": "..." }
}

import { createHmac, timingSafeEqual } from "crypto";
import express from "express";

const app = express();

// IMPORTANT: capture the raw body BEFORE JSON.parse runs.
app.use(express.json({
  limit: "10mb",
  verify: (req, _res, buf) => { (req as any).rawBody = buf.toString(); },
}));

app.post("/webhook", (req, res) => {
  const sig = (req.header("x-qn-signature") ?? "").replace(/^sha256=/, "");
  const expected = createHmac("sha256", process.env.QUICKNODE_WEBHOOK_SECRET!)
    .update((req as any).rawBody)
    .digest("hex");

  const a = Buffer.from(sig);
  const b = Buffer.from(expected);
  if (a.length !== b.length || !timingSafeEqual(a, b)) {
    return res.status(401).json({ error: "Invalid signature" });
  }

  // req.body is safe to use now
  res.json({ ok: true });
});