SAP + NeutronEDI

import os
import requests

NEUTRON_API_KEY = os.environ["NEUTRON_API_KEY"]
SAP_ODATA_URL = os.environ["SAP_ODATA_URL"]  # /sap/opu/odata/sap/SALES_ORDER_SRV
SAP_AUTH = (os.environ["SAP_USER"], os.environ["SAP_PASS"])


def translate_edi(raw_edi: str) -> dict:
    response = requests.post(
        "https://api.neutronedi.com/api/v1/read/x12",
        headers={
            "X-API-Key": NEUTRON_API_KEY,
            "Content-Type": "application/edi-x12",
        },
        data=raw_edi,
        timeout=15,
    )
    response.raise_for_status()
    return response.json()


def post_to_sap(po: dict) -> None:
    requests.post(
        f"{SAP_ODATA_URL}/SalesOrderSet",
        json={
            "PurchaseOrderByCustomer": po["poNumber"],
            "CustomerPurchaseOrderDate": po["date"],
            "Items": [
                {"Material": item["sku"], "RequestedQuantity": item["qty"]}
                for item in po["items"]
            ],
        },
        auth=SAP_AUTH,
        timeout=20,
    ).raise_for_status()


def handle_inbound_850(raw_edi: str) -> None:
    parsed = translate_edi(raw_edi)
    for txn in parsed["transactions"]:
        if txn["type"] == "850":
            post_to_sap(txn)

{
  "interchange": { "sender": "WALMART", "receiver": "ACMECORP", "control": "000000123" },
  "transactions": [
    {
      "type": "850",
      "name": "Purchase Order",
      "poNumber": "4500291837",
      "date": "2026-04-12",
      "buyerDuns": "0078903456",
      "items": [
        { "sku": "WIDGET-BLUE", "qty": 240, "unitPrice": "12.50" },
        { "sku": "WIDGET-RED",  "qty": 120, "unitPrice": "12.50" }
      ],
      "total": "4500.00"
    }
  ]
}