Pricing Pipeline

graph LR
    subgraph "Upstream scrapers (separate services)"
        SPS["steam-pricing-scraper"]
        BUFF["tradeit-buff-scrapper"]
        CSGOS["csgoskins-pricing"]
    end

    subgraph "External API (called at run time)"
        CSAPI["csgoskins.gg\n/prices"]
    end

    subgraph "MySQL steamtrade (reads)"
        BPS[("buff_prices_scraper")]
        SNAP[("item_prices_snapshot")]
        TIS[("trade_item_stats")]
        SIS[("store_item_stats")]
        EOD[("item_eod")]
        PG[("pricing_groups")]
        CONF[("configurations")]
    end

    subgraph "MySQL tradeitConnection (reads)"
        ISTK[("item_stocks")]
    end

    subgraph "pricing-manager"
        PM["AppService\n.updatePrices()"]
    end

    subgraph "MySQL steamtrade (writes)"
        IPR[("item_prices_raw")]
        PA[("price_adjuster")]
    end

    subgraph "Consumers"
        BE["tradeit-backend\ntrade evaluation"]
        NT["new-tradeit\nmarketplace display"]
        ADM["tradeit-admin\npricing overrides"]
    end

    SPS --> BPS
    BUFF --> BPS
    CSAPI --> PM
    BPS --> PM
    SNAP --> PM
    TIS --> PM
    SIS --> PM
    EOD --> PM
    PG --> PM
    CONF --> PM
    ISTK --> PM
    PM --> IPR
    PM --> PA
    IPR --> BE
    IPR --> NT
    IPR --> ADM

graph TD
    S1["1. READ buff_prices_scraper\n(CS2 appId=730 items only)"]
    S2["2. JOIN item_stocks\n(bot/container/reserved/listing stock)"]
    S3["3. FETCH csgoskins.gg /prices API\n(market prices by market_hash_name)"]
    S4["4. STABLE PRICE\nECDF + quantile (mathjs) + mean of last 30 snapshots"]
    S5["5. ASSIGN MARGINS\npricingGroups lookup by stable_price tier (cached 2 min)"]
    S6["6. MERGE TRADE STATS\ntrade_item_stats + store_item_stats (if config flag enabled)"]
    S7["7. BASE PRICES\nMultiplier enum tiers: Base=1.75, Low=1.725, High=1.775..."]
    S8["8. LOAD PREVIOUS PRICES\nitem_prices_raw (prev bot/player/stable)"]
    S9["9. LOAD EOD PRICES\nitem_eod avg/median for 7d and 30d max stock"]
    S10["10. READ RUNTIME CONFIG\nweeklyInOutRatioWeight + wantedMaxStockLowCapacityRatio"]
    S11["11. CALCULATE PER ITEM\ncurrentStock, wantedMaxStock, neededStock, deficit"]
    S12["12. ADJUST and WRITE\nspread ratio, protection rails, markup flags\n→ UPSERT item_prices_raw + price_adjuster"]

    S1 --> S2 --> S3 --> S4 --> S5 --> S6 --> S7 --> S8 --> S9 --> S10 --> S11 --> S12

    classDef read fill:#0e2a1e,stroke:#10b981,stroke-width:2px,color:#a7f3d0
    classDef calc fill:#1e2438,stroke:#a855f7,stroke-width:2px,color:#e9d5ff
    classDef write fill:#2a1218,stroke:#f43f5e,stroke-width:2px,color:#fecdd3
    classDef config fill:#2a1f0e,stroke:#f59e0b,stroke-width:2px,color:#fde68a

    class S1,S2,S3,S8,S9 read
    class S4,S5,S6,S7,S11 calc
    class S12 write
    class S10 config