Market making with heartbeat protection

create heartbeat (timeout T)
loop:
  refresh heartbeat every T/3          on its own timer
  read the book                        from the stream
  decide quotes
  place new orders                     each with a fresh request_uuid
  close orders that no longer fit
  close betslips you stop quoting      DELETE /v2/betslips/{betslip_id}/
on exit:
  close open orders
  delete heartbeat

import os, json, time, uuid, threading, requests

API = "https://magicmarkets.com/v2"
H = {"X-Api-Key": os.environ["MAGICMARKETS_API_KEY"]}
T = 60
SPORT = "fb"  # the sport this strategy quotes

def post(path, body=None):
    r = requests.post(f"{API}{path}", headers=H, json=body, timeout=10).json()
    if r["status"] != "ok" and r.get("code") != "order_already_created":
        raise RuntimeError(r)
    return r["data"]

hb = post("/heartbeats/", {"timeout": T})["heartbeat_id"]
stop = threading.Event()

def keep_alive():
    while not stop.wait(T / 3):
        try:
            post(f"/heartbeats/{hb}/refresh/")
        except Exception as e:
            print("refresh failed:", e)

threading.Thread(target=keep_alive, daemon=True).start()

try:
    while True:
        # 1. read your book from the stream (see the price book guide)
        # 2. decide the quotes you want resting
        # 3. quote: betslip -> pmm -> order, always with a request_uuid
        req = str(uuid.uuid4())
        # order = post("/orders/", {"betslip_id": ..., "price": ..., "stake": ["USDT", 10.0],
        #                           "duration": 30.0, "request_uuid": req})
        # 4. close orders that no longer fit
        # 5. close betslips you stop quoting:
        #    requests.delete(f"{API}/betslips/{betslip_id}/", headers=H)
        time.sleep(1)
finally:
    stop.set()
    post("/orders/close_all/", {"sport": SPORT})
    requests.delete(f"{API}/heartbeats/{hb}/", headers=H)