Synchronization flows

ProductSync.run()
  ├─ license.isValidNow()? ──── NO ──► abort with errors=["LICENSE INVALID"]
  │                              YES
  ▼
  loop over pages, pageSize from config (200):
    SyncClient.get('/v1/products?page=N&pageSize=200&tier=1')
        │
        ▼
    HMAC sign + retry 3x → microservice → SQL:
        SELECT Twr_Kod, Twr_Nazwa, Twr_Jm, Twr_Ean,
               CASE WHEN TwC_Typ=1 THEN TwC_Wartosc END AS PriceNet,
               CASE WHEN TwC_Typ=2 THEN TwC_Wartosc END AS PriceGross
        FROM CDN.Towary t LEFT JOIN CDN.TwrCeny c
            ON c.TwC_TwrID = t.Twr_GIDNumer AND c.TwC_TwCNumer = @tier
        WHERE t.Twr_GIDTyp = 16
        OFFSET @offset ROWS FETCH NEXT @pageSize ROWS ONLY
        │
        ▼
    for each SKU:
      ├─ SKU prefix filter (optional)
      ├─ skip if it's a service (jm=GODZ, twr_typ != 0)
      ├─ skip if attribute sisl_optima_sync_disabled = 1
      ▼
      upsert into catalog_product_entity:
        - new → SKU + name + status (config) + visibility (config) + ean + jm + price (if sync_prices ON, otherwise 0)
        - existing → only name + ean + jm (price only if sync_prices ON)
        - description: never overwrites existing

StockSync.run()
  └─ license gate ── as above
  ▼
  SyncClient.get('/v1/stocks?warehouse=MAGAZYN&page=N&pageSize=500')
      │
      ▼
  microservice → SQL (real stock from PZ documents):
      SELECT t.Twr_Kod AS Sku, m.Mag_Symbol AS Warehouse,
             SUM(z.TwZ_Ilosc - z.TwZ_Quan) AS Available,
             MAX(i.TwI_Rezerwacje) AS Reserved,
             MAX(i.TwI_Zamowienia) AS OnOrder
      FROM CDN.Towary t
      JOIN CDN.Magazyny m ON m.Mag_Symbol = @warehouse
      LEFT JOIN CDN.TwrZasoby z
          ON z.TwZ_TwrId = t.Twr_GIDNumer AND z.TwZ_MagId = m.Mag_MagId
          AND z.TwZ_TrSIdDost > 0    -- ONLY real documents, ignores synthetic entries
      LEFT JOIN CDN.TwrIlosci i ON i.TwI_TwrId = t.Twr_GIDNumer
      GROUP BY t.Twr_Kod, m.Mag_Symbol
      ▼
  for each SKU:
    rawQty   = Available from Optima
    effective = max(0, rawQty - stock_buffer)
    inStock  = effective > oos_threshold
    StockRegistry.updateStockItemBySku(sku, {qty: effective, isInStock: inStock})

OrderPlaceAfter.execute(observer)
  └─ license gate
  └─ orders_enabled config gate
  ▼
  OrderForward.send(order):
      builds payload:
        {
          magentoOrderId, incrementId, createdAt, currency,
          grandTotal, subtotal, tax, shippingTotal, shippingMethod, paymentMethod,
          customer: {email, firstname, lastname, taxId, isCompany, magentoId},
          billingAddress: {...},
          shippingAddress: {...},
          items: [{sku, name, qty, priceNet, priceGross, taxAmount, taxPercent}, ...]
        }
      ▼
      SyncClient.post('/v1/orders', payload)
          ▼
      microservice:
          - validates payload
          - checks license + HMAC
          - generates XML matching Optima Import (TraNag + TraElem + KntKarty)
          - drops it into the folder watched by Optima (XML import in)
          - returns {optimaInvoiceId} after async processing

LicenseChecker.checkNow()
  builds request:
    {
      key: <license key from config>,
      product: "sisl_optima",
      host: <BASE_URL host>,
      version: "0.1.0",
      nonce: <16 bytes random hex>,
      manifest_hash: <SHA256 of 8 critical files>
    }
    ▼
  POST https://license.sisl.pl/check
    ▼
  SISL server:
    - looks up license
    - checks status (active / revoked / expired)
    - checks valid_until
    - checks host binding (first time: bind; later: must match)
    - records manifest hash + compares to previous (logs drift)
    - signs Ed25519 response with echoed nonce
    ▼
  plugin:
    - VERIFIES Ed25519 SIGNATURE (WITHOUT THIS, STATE IS NOT SAVED)
    - checks nonce match (anti-replay)
    - saves state to core_config_data (sisl_optima/license/state):
        {valid, message, valid_until, checked_at, verified: true, was_valid}