Eniverse Bridge

class BridgeSync:
    def on_order(self, payload):
        mapped = map_fields(
            payload, erp_schema
        )
        queue.push(mapped)

@bridge.on("order.paid")
def handle_order(payload):
    sync.retry(
        max_attempts=3,
        backoff="exponential"
    )

def map_field(src, target):
    return schema.get(target, src)

class BridgeSync:
    def on_order(self, payload):
        mapped = map_fields(
            payload, erp_schema
        )
        queue.push(mapped)

if stock < 3:
    hide(product, channel="allegro")

@app.route("/webhook", methods=["POST"])
def webhook():
    verify(signature, secret)
    log.write(
        ts=now(), op="sync", ok=True
    )
    return {"status": "ok"}

class Product:
    sku: str
    stock: int
    channels: list[str]

if stock < 3:
    hide(product, channel="allegro")