Build on IntaOps network.

import os, requests

BASE  = "https://infra.intaops.io"
TOKEN = os.environ["INTAOPS_TOKEN"]        # from POST /oauth/token
CHUNK = 1000                               # push 1,000 per call

# ISO 4217 exponents. Most currencies have 2 decimals; these are the
# exceptions. NGN is 2, so kobo -> naira divides by 100.
ZERO_DECIMAL  = {"JPY", "KRW", "VND", "XAF", "XOF", "XPF", "CLP", "ISK", "UGX", "RWF"}
THREE_DECIMAL = {"BHD", "IQD", "JOD", "KWD", "LYD", "OMR", "TND"}

def to_major(amount, currency):             # minor units -> major (kobo -> naira)
    exp = 0 if currency in ZERO_DECIMAL else 3 if currency in THREE_DECIMAL else 2
    return amount / (10 ** exp)

def to_product(row):                       # map YOUR columns -> IntaOps fields
    return {
        "name":       row["title"],
        # Your own stable id, carried so you can reconcile the two
        # catalogues. IntaOps does NOT match on it, re-running this import
        # creates a second copy of every product.
        "sku":        row["id"],
        "base_price": to_major(row["price"], row["currency"]),
        "currency":   row["currency"],
        "category":   row["kind"],
    }

def push(products):
    r = requests.post(
        f"{BASE}/api/interop/products/bulk-import/",
        headers={"Authorization": f"Bearer {TOKEN}"},
        json={"products": products}, timeout=60,
    )
    r.raise_for_status()
    return r.json()["data"]["results"]

# page through your catalog and push each batch
batch = []
for row in db.execute("SELECT id, title, price, currency, kind FROM products WHERE active"):
    batch.append(to_product(row))
    if len(batch) >= CHUNK:
        push(batch); batch = []
if batch:
    push(batch)

# schedule (continuous): every 15 min via cron →  */15 * * * *  python sync.py

curl -X POST https://infra.intaops.io/api/interop/products/bulk-import/ \
  -H "Authorization: Bearer Your_access_token" \
  -H "Content-Type: application/json" \
  --data @products.json          # file holds { "products": [ … ] }

curl -X POST https://infra.intaops.io/api/interop/products/csv-upload/ \
  -H "Authorization: Bearer Your_access_token" \
  -F "file=@products.csv"

curl -X POST https://infra.intaops.io/api/interop/products/bulk-import/ \
  -H "Authorization: Bearer Your_access_token" \
  -H "Content-Type: application/json" \
  -d '{ "products": [{ "name": "Basic Life Support — Victoria Island", "sku": "bls-lagos-vi", "base_price": 45000, "currency": "NGN", "category": "ride_hailing", "subcategory": "ambulance" }] }'

{ "success": true, "data": { "results": { "successful": 1, "failed": 0 } } }

curl -X GET 'https://infra.intaops.io/api/interop/products/mine/?page_size=100' \
  -H "Authorization: Bearer Your_access_token"

{ "success": true, "data": { "products": [{ "product_id": "9f3a…", "name": "Basic Life Support — Victoria Island", "base_price": 45000, "currency": "NGN", "status": "active" }] } }

curl -X PUT https://infra.intaops.io/api/interop/products/PRODUCT_ID/update/ \
  -H "Authorization: Bearer Your_access_token" \
  -H "Content-Type: application/json" \
  -d '{ "base_price": 4000, "status": "active" }'

{ "success": true, "data": { "product_id": "9f3a…", "updated": true } }

curl -X GET 'https://infra.intaops.io/api/interop/products/search/?q=ambulance&category=ambulance&max_price=60000&page_size=20' \
  -H "Authorization: Bearer Your_access_token"

{ "success": true, "data": { "products": [{ "product_id": "9f3a…", "name": "Basic Life Support — Victoria Island", "base_price": 45000, "entity_name": "Naija Medics" }], "page": 1, "total": 12 } }

curl -X POST https://infra.intaops.io/api/interop/transform/schema-mapping/ \
  -H "Authorization: Bearer Your_access_token" \
  -H "Content-Type: application/json" \
  -d '{ "entity_schema_name": "my_products", "intaops_schema_name": "product", "field_mappings": [{ "source_field": "title", "target_field": "name" }] }'

{ "success": true, "data": { "mapping_id": "map_…" } }

curl -X POST https://infra.intaops.io/api/interop/sync/config/ \
  -H "Authorization: Bearer Your_access_token" \
  -H "Content-Type: application/json" \
  -d '{ "resource_type": "product", "sync_mode": "real_time", "sync_direction": "push", "conflict_resolution": "latest_wins",
        "target_connection": { "base_url": "https://app.domain.com", "auth_type": "bearer", "secret": "YOUR_API_TOKEN", "paths": { "product": "/v1/products" } } }'

{ "success": true, "data": { "config_id": "cfg_…", "target_connection": { "base_url": "https://app.domain.com", "auth_type": "bearer", "has_secret": true, "paths": { "product": "/v1/products" } } } }

curl -X POST https://infra.intaops.io/api/interop/webhooks/subscribe/ \
  -H "Authorization: Bearer Your_access_token" \
  -H "Content-Type: application/json" \
  -d '{ "url": "https://app.domain.com/intaops/webhooks", "events": ["order.placed","payment.completed"], "max_retries": 5 }'

{ "success": true, "data": { "subscription_id": "sub_…", "signing_secret": "whsec_…" } }