Catalog

$
pip install zstandard lmdb

$
# Your catalog URL from voodoo.center/dashboard/api
$
CATALOG_URL="https://downloads.voodoo.center/{client_id}.lmdb.zst"
$
$
# Stream the download straight through the decompressor — nothing is buffered
$
# and the compressed archive is never written to disk.
$
curl -sS "$CATALOG_URL" | zstd -d -o catalog.lmdb

1
import json
2
import struct
3
4
import lmdb
5
import requests
6
import zstandard
7
8
# Your catalog URL from the dashboard (voodoo.center/dashboard/api)
9
CATALOG_URL = "https://downloads.voodoo.center/{client_id}.lmdb.zst"
10
11
12
def item_key(item_id: int) -> bytes:
13
    # Records are keyed by the 8-byte big-endian item id (so they sort by id).
14
    return struct.pack(">Q", item_id)
15
16
17
# 1. Stream the download straight through the zstd decompressor to disk. The
18
#    archive is never held in memory (compressed or decompressed) as a whole.
19
dctx = zstandard.ZstdDecompressor()
20
with requests.get(CATALOG_URL, stream=True) as response:
21
    response.raise_for_status()
22
    response.raw.decode_content = True   # undo any HTTP Content-Encoding
23
    with open("catalog.lmdb", "wb") as db:
24
        dctx.copy_stream(response.raw, db)
25
26
# 2. Open the env read-only and memory-mapped. It is a single FILE, not a
27
#    directory (subdir=False), and read-only readers must pass lock=False. LMDB
28
#    pages in only the records you touch, so opening costs almost nothing.
29
env = lmdb.open("catalog.lmdb", subdir=False, readonly=True, lock=False)
30
31
# Look up one item by id — a single page read, not a scan.
32
with env.begin() as txn:
33
    raw = txn.get(item_key(689556))
34
    item = json.loads(raw) if raw else None
35
    print(item)
36
37
# Iterate the whole catalog one record at a time — constant memory, ordered by id.
38
with env.begin() as txn:
39
    for key, value in txn.cursor():
40
        item = json.loads(value)
41
        if item["in_stock"]:
42
            price = item["price"] / 100  # cents -> major units
43
            print(item["id"], item["product_type"], f"{price:.2f}", item["name"])

1
{
2
  "id": 689556,
3
  "name": "Steam Top-up (USD)",
4
  "product_type": "topup",
5
  "min_quantity": 1,
6
  "max_quantity": 1000,
7
  "price": 500,
8
  "base_price": 500,
9
  "subscriber_price": 450,
10
  "amount_per_price": 1,
11
  "in_stock": true,
12
  "updated_at": "2026-07-05T12:00:00+00:00",
13
  "fields": [
14
    { "id": 88, "name": "steam_login", "type": "string", "required": true, "options": [] }
15
  ]
16
}

1
# `item` is a record read from the catalog above; `access_token` is your
2
# Bearer token (see Authentication).
3
import requests
4
5
body = {
6
    "item_id": item["id"],
7
    "quantity": 1,                  # within min_quantity..max_quantity
8
    "merchant_order_id": "order-2024",
9
    "fields": {
10
        "steam_login": "test",      # a text field -> its string value
11
    },
12
}
13
response = requests.post(
14
    "https://api.voodoo.center/v1/orders",
15
    headers={"Authorization": f"Bearer {access_token}"},
16
    json=body,
17
)
18
response.raise_for_status()
19
order = response.json()
20
print(order["id"], order["status"])

1
import os
2
3
import lmdb
4
import requests
5
import zstandard
6
7
# Your catalog URL from the dashboard (voodoo.center/dashboard/api)
8
CATALOG_URL = "https://downloads.voodoo.center/{client_id}.lmdb.zst"
9
10
DATABASE = "catalog.lmdb"
11
ETAG_FILE = "catalog.etag"
12
13
14
def refresh_catalog() -> bool:
15
    """Download the snapshot only if it changed; return True if a new copy was fetched."""
16
    headers = {}
17
    # Send the ETag from the last download so the server can reply 304 Not Modified.
18
    if os.path.exists(ETAG_FILE):
19
        with open(ETAG_FILE) as f:
20
            headers["If-None-Match"] = f.read().strip()
21
22
    dctx = zstandard.ZstdDecompressor()
23
    with requests.get(CATALOG_URL, headers=headers, stream=True) as response:
24
        if response.status_code == 304:          # nothing changed
25
            return False
26
        response.raise_for_status()              # surface any real error
27
28
        # A 200 reaches here — stream-decompress straight to the LMDB file, so the
29
        # snapshot is never buffered in memory or written to disk compressed.
30
        response.raw.decode_content = True
31
        with open(DATABASE, "wb") as db:
32
            dctx.copy_stream(response.raw, db)
33
        etag = response.headers.get("ETag")
34
35
    if etag:
36
        with open(ETAG_FILE, "w") as f:
37
            f.write(etag)
38
    return True
39
40
41
def open_catalog() -> lmdb.Environment:
42
    return lmdb.open(DATABASE, subdir=False, readonly=True, lock=False)
43
44
45
# Run refresh_catalog() on a schedule (e.g. every few minutes). It returns True
46
# only when a new snapshot was fetched — reopen the LMDB env when it does, and
47
# keep using the previous env until then.
48
if refresh_catalog():
49
    env = open_catalog()