Каталог dropX у вашому сайті, боті та CRM

import os
import time

import requests

API = "https://api.dropx.site/v1"
HEADERS = {"X-API-Key": os.environ["DROPX_API_KEY"]}
MARKUP = 30  # price = cost_price + 30%; send the same value on every call


def sync(cursor=None):
    """Apply every change since `cursor`; returns the cursor to store for the next run."""
    while True:
        params = {"limit": 200, "markup_percent": MARKUP}
        if cursor:
            params["cursor"] = cursor
        response = requests.get(f"{API}/products/changes", headers=HEADERS, params=params, timeout=30)
        if response.status_code == 429:
            time.sleep(int(response.headers.get("Retry-After", "5")))
            continue
        response.raise_for_status()
        body = response.json()

        for change in body["data"]:
            if change["status"] == "removed":
                remove_product(change["id"])        # take it off your shop
            else:
                upsert_product(change["product"])   # create or update it

        cursor = body["meta"]["next_cursor"]
        save_cursor(cursor)                        # store it even when nothing changed
        if not body["meta"]["has_more"]:
            return cursor


# Run every 5-15 minutes (cron, Celery, systemd timer):
# sync(load_cursor())