Copy trading

import requests
from flask import Flask, request

API = "https://api-id.cabalspy.xyz"
H = {"Authorization": "Bearer YOUR_KEY"}
app = Flask(__name__)
seen = set()

@app.post("/webhooks/csid")
def webhook():
    # verify the Standard Webhooks signature first, see Webhooks
    event = request.get_json()
    if event["type"] != "copy_trade.instruction" or event["data"]["id"] in seen:
        return "", 204
    i = event["data"]
    seen.add(i["id"])
    queue_copy(i)          # do the work outside the request
    return "", 204

def execute(i):
    a = i["action"]
    try:
        if a["side"] == "buy":
            # your swap: spend a["amount_usd"] (or a["amount_native"] of a["currency"])
            # on a["mint"], at most a["max_price_usd"] per token
            sig, usd = my_buy(i["external_id"] or i["csid_id"], a)
        else:
            # sell a["sell_percent"] % of the user's copied position, at least a["min_price_usd"]
            sig, usd = my_sell(i["external_id"] or i["csid_id"], a)
        body = {"id": i["id"], "status": "executed", "tx_signature": sig, "executed_amount_usd": usd}
    except PriceMoved:
        body = {"id": i["id"], "status": "skipped", "note": "price above the limit"}
    except Exception as e:
        body = {"id": i["id"], "status": "failed", "note": str(e)[:300]}
    requests.post(f"{API}/v1/copy-trading/instructions/status", json=body, headers=H)

import express from "express";

const API = "https://api-id.cabalspy.xyz";
const H = { Authorization: "Bearer YOUR_KEY", "Content-Type": "application/json" };
const app = express();
const seen = new Set();

app.post("/webhooks/csid", express.json(), (req, res) => {
  // verify the Standard Webhooks signature first, see Webhooks
  const event = req.body;
  res.sendStatus(204);
  if (event.type !== "copy_trade.instruction" || seen.has(event.data.id)) return;
  seen.add(event.data.id);
  execute(event.data);
});

async function execute(i) {
  const a = i.action;
  let body;
  try {
    const { sig, usd } = a.side === "buy"
      ? await myBuy(i.external_id ?? i.csid_id, a)   // a.amount_usd on a.mint, at most a.max_price_usd
      : await mySell(i.external_id ?? i.csid_id, a); // a.sell_percent % of the copied position, at least a.min_price_usd
    body = { id: i.id, status: "executed", tx_signature: sig, executed_amount_usd: usd };
  } catch (e) {
    body = { id: i.id, status: e.priceMoved ? "skipped" : "failed", note: String(e.message).slice(0, 300) };
  }
  await fetch(`${API}/v1/copy-trading/instructions/status`, { method: "POST", headers: H, body: JSON.stringify(body) });
}