openapi: 3.1.0
info:
  title: TradeService API
  version: 1.0.0
security:
  - WorldMonitorKey: []
  - ApiKeyHeader: []
servers:
  - url: https://api.worldmonitor.app
paths:
  /api/trade/v1/get-trade-restrictions:
    get:
      tags:
        - TradeService
      summary: GetTradeRestrictions
      description: Get quantitative restrictions and export controls.
      operationId: GetTradeRestrictions
      parameters:
        - name: countries
          in: query
          description: |-
            WTO member codes to filter by. Empty = all.
             Accepted but currently ignored; no-op until this handler supports the parameter.
          required: false
          style: form
          explode: true
          example:
            - '840'
          schema:
            type: array
            items:
              type: string
        - name: limit
          in: query
          description: Max results to return (server caps at 100).
          required: false
          example: 25
          schema:
            type: integer
            format: int32
        - name: jmespath
          in: query
          description: >-
            Optional JMESPath expression applied server-side to project or
            reduce the JSON response before it is returned (mirrors the MCP
            jmespath argument). Invalid expressions, expressions larger than
            1024 UTF-8 bytes, or projections that exceed the 256 KB output cap
            return HTTP 400 with a {_jmespath_error, original_keys} envelope.
            Grammar and worked examples:
            https://www.worldmonitor.app/docs/mcp-jmespath.
          required: false
          example: keys(@)
          schema:
            type: string
      responses:
        '200':
          description: Successful response
          content:
            application/json:
              example:
                fetchedAt: '2026-01-15T12:00:00Z'
                restrictions:
                  - affectedCountry: US
                    description: Example WorldMonitor observation.
                    id: example-id
                    measureType: all
                    notifiedAt: '2026-01-15T12:00:00Z'
                upstreamUnavailable: true
              schema:
                $ref: '#/components/schemas/GetTradeRestrictionsResponse'
        '400':
          description: Validation error
          content:
            application/json:
              schema:
                oneOf:
                  - $ref: '#/components/schemas/ValidationError'
                  - $ref: '#/components/schemas/JmespathProjectionError'
        '401':
          description: Missing or invalid API key.
          content:
            application/json:
              schema:
                $ref: '#/components/schemas/UnauthorizedError'
        '403':
          description: >-
            API access requires an active subscription (the API key's
            subscription is inactive or expired).
          content:
            application/json:
              schema:
                $ref: '#/components/schemas/ForbiddenError'
        '429':
          description: Rate limit exceeded.
          headers:
            X-RateLimit-Limit:
              description: Maximum requests allowed in the active rate-limit window.
              schema:
                type: string
            X-RateLimit-Remaining:
              description: Requests remaining in the active rate-limit window.
              schema:
                type: string
            X-RateLimit-Reset:
              description: >-
                Unix epoch milliseconds when the active rate-limit window
                resets.
              schema:
                type: string
            Retry-After:
              description: Seconds to wait before retrying the request.
              schema:
                type: string
          content:
            application/json:
              schema:
                oneOf:
                  - $ref: '#/components/schemas/Error'
                  - $ref: '#/components/schemas/RateLimitError'
        default:
          description: Gateway or handler error response.
          content:
            application/json:
              schema:
                oneOf:
                  - $ref: '#/components/schemas/Error'
                  - $ref: '#/components/schemas/GatewayError'
  /api/trade/v1/get-tariff-trends:
    get:
      tags:
        - TradeService
      summary: GetTariffTrends
      description: >-
        Get tariff rate timeseries for a country pair. PRO-gated. Requires
        entitlement tier >= 1.
      operationId: GetTariffTrends
      security:
        - WorldMonitorKey: []
        - ApiKeyHeader: []
        - BearerAuth: []
      parameters:
        - name: reporting_country
          in: query
          description: WTO member code of reporting country (e.g. "840" = US).
          required: false
          example: '840'
          schema:
            type: string
        - name: partner_country
          in: query
          description: WTO member code of partner country (e.g. "156" = China).
          required: false
          example: '156'
          schema:
            type: string
        - name: product_sector
          in: query
          description: Product sector filter (HS chapter). Empty = aggregate.
          required: false
          example: diesel
          schema:
            type: string
        - name: years
          in: query
          description: Number of years to look back (default 10, max 30).
          required: false
          example: 1
          schema:
            type: integer
            format: int32
        - name: jmespath
          in: query
          description: >-
            Optional JMESPath expression applied server-side to project or
            reduce the JSON response before it is returned (mirrors the MCP
            jmespath argument). Invalid expressions, expressions larger than
            1024 UTF-8 bytes, or projections that exceed the 256 KB output cap
            return HTTP 400 with a {_jmespath_error, original_keys} envelope.
            Grammar and worked examples:
            https://www.worldmonitor.app/docs/mcp-jmespath.
          required: false
          example: keys(@)
          schema:
            type: string
      responses:
        '200':
          description: Successful response
          content:
            application/json:
              example:
                datapoints:
                  - boundRate: 75.25
                    indicatorCode: example
                    partnerCountry: '156'
                    productSector: diesel
                    reportingCountry: '840'
                effectiveTariffRate:
                  observationPeriod: daily
                  sourceName: WorldMonitor Analyst
                  sourceUrl: https://example.com/worldmonitor
                  tariffRate: 75.25
                  updatedAt: '2026-01-15'
                fetchedAt: '2026-01-15T12:00:00Z'
                upstreamUnavailable: true
              schema:
                $ref: '#/components/schemas/GetTariffTrendsResponse'
        '400':
          description: Validation error
          content:
            application/json:
              schema:
                oneOf:
                  - $ref: '#/components/schemas/ValidationError'
                  - $ref: '#/components/schemas/JmespathProjectionError'
        '401':
          description: Missing or invalid API key.
          content:
            application/json:
              schema:
                $ref: '#/components/schemas/UnauthorizedError'
        '403':
          description: PRO entitlement access denied.
          content:
            application/json:
              schema:
                $ref: '#/components/schemas/ForbiddenError'
        '429':
          description: Rate limit exceeded.
          headers:
            X-RateLimit-Limit:
              description: Maximum requests allowed in the active rate-limit window.
              schema:
                type: string
            X-RateLimit-Remaining:
              description: Requests remaining in the active rate-limit window.
              schema:
                type: string
            X-RateLimit-Reset:
              description: >-
                Unix epoch milliseconds when the active rate-limit window
                resets.
              schema:
                type: string
            Retry-After:
              description: Seconds to wait before retrying the request.
              schema:
                type: string
          content:
            application/json:
              schema:
                oneOf:
                  - $ref: '#/components/schemas/Error'
                  - $ref: '#/components/schemas/RateLimitError'
        default:
          description: Gateway or handler error response.
          content:
            application/json:
              schema:
                oneOf:
                  - $ref: '#/components/schemas/Error'
                  - $ref: '#/components/schemas/GatewayError'
  /api/trade/v1/get-trade-flows:
    get:
      tags:
        - TradeService
      summary: GetTradeFlows
      description: Get bilateral merchandise trade flows.
      operationId: GetTradeFlows
      parameters:
        - name: reporting_country
          in: query
          description: WTO member code of reporting country.
          required: false
          example: '840'
          schema:
            type: string
        - name: partner_country
          in: query
          description: WTO member code of partner country.
          required: false
          example: '156'
          schema:
            type: string
        - name: years
          in: query
          description: Number of years to look back (default 10, max 30).
          required: false
          example: 1
          schema:
            type: integer
            format: int32
        - name: jmespath
          in: query
          description: >-
            Optional JMESPath expression applied server-side to project or
            reduce the JSON response before it is returned (mirrors the MCP
            jmespath argument). Invalid expressions, expressions larger than
            1024 UTF-8 bytes, or projections that exceed the 256 KB output cap
            return HTTP 400 with a {_jmespath_error, original_keys} envelope.
            Grammar and worked examples:
            https://www.worldmonitor.app/docs/mcp-jmespath.
          required: false
          example: keys(@)
          schema:
            type: string
      responses:
        '200':
          description: Successful response
          content:
            application/json:
              example:
                fetchedAt: '2026-01-15T12:00:00Z'
                flows:
                  - exportValueUsd: 1.5
                    importValueUsd: 1.5
                    partnerCountry: '156'
                    productSector: diesel
                    reportingCountry: '840'
                upstreamUnavailable: true
              schema:
                $ref: '#/components/schemas/GetTradeFlowsResponse'
        '400':
          description: Validation error
          content:
            application/json:
              schema:
                oneOf:
                  - $ref: '#/components/schemas/ValidationError'
                  - $ref: '#/components/schemas/JmespathProjectionError'
        '401':
          description: Missing or invalid API key.
          content:
            application/json:
              schema:
                $ref: '#/components/schemas/UnauthorizedError'
        '403':
          description: >-
            API access requires an active subscription (the API key's
            subscription is inactive or expired).
          content:
            application/json:
              schema:
                $ref: '#/components/schemas/ForbiddenError'
        '429':
          description: Rate limit exceeded.
          headers:
            X-RateLimit-Limit:
              description: Maximum requests allowed in the active rate-limit window.
              schema:
                type: string
            X-RateLimit-Remaining:
              description: Requests remaining in the active rate-limit window.
              schema:
                type: string
            X-RateLimit-Reset:
              description: >-
                Unix epoch milliseconds when the active rate-limit window
                resets.
              schema:
                type: string
            Retry-After:
              description: Seconds to wait before retrying the request.
              schema:
                type: string
          content:
            application/json:
              schema:
                oneOf:
                  - $ref: '#/components/schemas/Error'
                  - $ref: '#/components/schemas/RateLimitError'
        default:
          description: Gateway or handler error response.
          content:
            application/json:
              schema:
                oneOf:
                  - $ref: '#/components/schemas/Error'
                  - $ref: '#/components/schemas/GatewayError'
  /api/trade/v1/get-trade-barriers:
    get:
      tags:
        - TradeService
      summary: GetTradeBarriers
      description: Get SPS/TBT barrier notifications.
      operationId: GetTradeBarriers
      parameters:
        - name: countries
          in: query
          description: |-
            WTO member codes to filter by. Empty = all.
             Accepted but currently ignored; no-op until this handler supports the parameter.
          required: false
          style: form
          explode: true
          example:
            - '840'
          schema:
            type: array
            items:
              type: string
        - name: measure_type
          in: query
          description: |-
            Filter by measure type: "SPS", "TBT", or empty for both.
             Accepted but currently ignored; no-op until this handler supports the parameter.
          required: false
          example: SPS
          schema:
            type: string
        - name: limit
          in: query
          description: Max results to return (server caps at 100).
          required: false
          example: 25
          schema:
            type: integer
            format: int32
        - name: jmespath
          in: query
          description: >-
            Optional JMESPath expression applied server-side to project or
            reduce the JSON response before it is returned (mirrors the MCP
            jmespath argument). Invalid expressions, expressions larger than
            1024 UTF-8 bytes, or projections that exceed the 256 KB output cap
            return HTTP 400 with a {_jmespath_error, original_keys} envelope.
            Grammar and worked examples:
            https://www.worldmonitor.app/docs/mcp-jmespath.
          required: false
          example: keys(@)
          schema:
            type: string
      responses:
        '200':
          description: Successful response
          content:
            application/json:
              example:
                barriers:
                  - dateDistributed: '2026-01-15'
                    id: example-id
                    measureType: SPS
                    notifyingCountry: US
                    objective: example
                fetchedAt: '2026-01-15T12:00:00Z'
                upstreamUnavailable: true
              schema:
                $ref: '#/components/schemas/GetTradeBarriersResponse'
        '400':
          description: Validation error
          content:
            application/json:
              schema:
                oneOf:
                  - $ref: '#/components/schemas/ValidationError'
                  - $ref: '#/components/schemas/JmespathProjectionError'
        '401':
          description: Missing or invalid API key.
          content:
            application/json:
              schema:
                $ref: '#/components/schemas/UnauthorizedError'
        '403':
          description: >-
            API access requires an active subscription (the API key's
            subscription is inactive or expired).
          content:
            application/json:
              schema:
                $ref: '#/components/schemas/ForbiddenError'
        '429':
          description: Rate limit exceeded.
          headers:
            X-RateLimit-Limit:
              description: Maximum requests allowed in the active rate-limit window.
              schema:
                type: string
            X-RateLimit-Remaining:
              description: Requests remaining in the active rate-limit window.
              schema:
                type: string
            X-RateLimit-Reset:
              description: >-
                Unix epoch milliseconds when the active rate-limit window
                resets.
              schema:
                type: string
            Retry-After:
              description: Seconds to wait before retrying the request.
              schema:
                type: string
          content:
            application/json:
              schema:
                oneOf:
                  - $ref: '#/components/schemas/Error'
                  - $ref: '#/components/schemas/RateLimitError'
        default:
          description: Gateway or handler error response.
          content:
            application/json:
              schema:
                oneOf:
                  - $ref: '#/components/schemas/Error'
                  - $ref: '#/components/schemas/GatewayError'
  /api/trade/v1/get-customs-revenue:
    get:
      tags:
        - TradeService
      summary: GetCustomsRevenue
      description: Get US customs duties revenue (Treasury MTS data, seeded by Railway).
      operationId: GetCustomsRevenue
      parameters:
        - name: jmespath
          in: query
          description: >-
            Optional JMESPath expression applied server-side to project or
            reduce the JSON response before it is returned (mirrors the MCP
            jmespath argument). Invalid expressions, expressions larger than
            1024 UTF-8 bytes, or projections that exceed the 256 KB output cap
            return HTTP 400 with a {_jmespath_error, original_keys} envelope.
            Grammar and worked examples:
            https://www.worldmonitor.app/docs/mcp-jmespath.
          required: false
          example: keys(@)
          schema:
            type: string
      responses:
        '200':
          description: Successful response
          content:
            application/json:
              example:
                fetchedAt: '2026-01-15T12:00:00Z'
                months:
                  - calendarMonth: 1
                    calendarYear: 1
                    fiscalYear: 1
                    fytdAmountBillions: 1.5
                    monthlyAmountBillions: 1.5
                upstreamUnavailable: true
              schema:
                $ref: '#/components/schemas/GetCustomsRevenueResponse'
        '400':
          description: Validation error
          content:
            application/json:
              schema:
                oneOf:
                  - $ref: '#/components/schemas/ValidationError'
                  - $ref: '#/components/schemas/JmespathProjectionError'
        '401':
          description: Missing or invalid API key.
          content:
            application/json:
              schema:
                $ref: '#/components/schemas/UnauthorizedError'
        '403':
          description: >-
            API access requires an active subscription (the API key's
            subscription is inactive or expired).
          content:
            application/json:
              schema:
                $ref: '#/components/schemas/ForbiddenError'
        '429':
          description: Rate limit exceeded.
          headers:
            X-RateLimit-Limit:
              description: Maximum requests allowed in the active rate-limit window.
              schema:
                type: string
            X-RateLimit-Remaining:
              description: Requests remaining in the active rate-limit window.
              schema:
                type: string
            X-RateLimit-Reset:
              description: >-
                Unix epoch milliseconds when the active rate-limit window
                resets.
              schema:
                type: string
            Retry-After:
              description: Seconds to wait before retrying the request.
              schema:
                type: string
          content:
            application/json:
              schema:
                oneOf:
                  - $ref: '#/components/schemas/Error'
                  - $ref: '#/components/schemas/RateLimitError'
        default:
          description: Gateway or handler error response.
          content:
            application/json:
              schema:
                oneOf:
                  - $ref: '#/components/schemas/Error'
                  - $ref: '#/components/schemas/GatewayError'
  /api/trade/v1/list-comtrade-flows:
    get:
      tags:
        - TradeService
      summary: ListComtradeFlows
      description: >-
        List UN Comtrade strategic commodity flows with anomaly detection.
        PRO-gated. Requires entitlement tier >= 1.
      operationId: ListComtradeFlows
      security:
        - WorldMonitorKey: []
        - ApiKeyHeader: []
        - BearerAuth: []
      parameters:
        - name: reporter_code
          in: query
          description: >-
            UN Comtrade reporter code (e.g. "842" = US, "156" = China). Empty
            returns all reporters.
          required: false
          example: '842'
          schema:
            type: string
        - name: cmd_code
          in: query
          description: >-
            HS commodity code (e.g. "2709" = crude oil). Empty returns all
            commodities.
          required: false
          example: '2709'
          schema:
            type: string
            pattern: ^\d{4,6}$
        - name: anomalies_only
          in: query
          description: >-
            If true, only return flows with a year-over-year change exceeding
            30%.
          required: false
          example: true
          schema:
            type: boolean
        - name: jmespath
          in: query
          description: >-
            Optional JMESPath expression applied server-side to project or
            reduce the JSON response before it is returned (mirrors the MCP
            jmespath argument). Invalid expressions, expressions larger than
            1024 UTF-8 bytes, or projections that exceed the 256 KB output cap
            return HTTP 400 with a {_jmespath_error, original_keys} envelope.
            Grammar and worked examples:
            https://www.worldmonitor.app/docs/mcp-jmespath.
          required: false
          example: keys(@)
          schema:
            type: string
      responses:
        '200':
          description: Successful response
          content:
            application/json:
              example:
                fetchedAt: '2026-01-15T12:00:00Z'
                flows:
                  - cmdCode: '2709'
                    cmdDesc: example
                    isAnomaly: true
                    netWeightKg: 1.5
                    partnerCode: example
                upstreamUnavailable: true
              schema:
                $ref: '#/components/schemas/ListComtradeFlowsResponse'
        '400':
          description: Validation error
          content:
            application/json:
              schema:
                oneOf:
                  - $ref: '#/components/schemas/ValidationError'
                  - $ref: '#/components/schemas/JmespathProjectionError'
        '401':
          description: Missing or invalid API key.
          content:
            application/json:
              schema:
                $ref: '#/components/schemas/UnauthorizedError'
        '403':
          description: PRO entitlement access denied.
          content:
            application/json:
              schema:
                $ref: '#/components/schemas/ForbiddenError'
        '429':
          description: Rate limit exceeded.
          headers:
            X-RateLimit-Limit:
              description: Maximum requests allowed in the active rate-limit window.
              schema:
                type: string
            X-RateLimit-Remaining:
              description: Requests remaining in the active rate-limit window.
              schema:
                type: string
            X-RateLimit-Reset:
              description: >-
                Unix epoch milliseconds when the active rate-limit window
                resets.
              schema:
                type: string
            Retry-After:
              description: Seconds to wait before retrying the request.
              schema:
                type: string
          content:
            application/json:
              schema:
                oneOf:
                  - $ref: '#/components/schemas/Error'
                  - $ref: '#/components/schemas/RateLimitError'
        default:
          description: Gateway or handler error response.
          content:
            application/json:
              schema:
                oneOf:
                  - $ref: '#/components/schemas/Error'
                  - $ref: '#/components/schemas/GatewayError'
components:
  securitySchemes:
    WorldMonitorKey:
      type: apiKey
      in: header
      name: X-WorldMonitor-Key
      description: User-issued WorldMonitor API key.
    ApiKeyHeader:
      type: apiKey
      in: header
      name: X-Api-Key
      description: Alias header for the WorldMonitor API key (X-WorldMonitor-Key).
    BearerAuth:
      type: http
      scheme: bearer
      description: >-
        Bearer token: a Clerk-issued JWT for browser session flows, passed as
        Authorization: Bearer <token>.
  schemas:
    JmespathProjectionError:
      description: >-
        Returned when a REST jmespath projection is invalid or exceeds the
        expression/output byte limits.
      properties:
        _jmespath_error:
          description: Projection error discriminator and details.
          type: string
        original_keys:
          description: Top-level keys or shape of the unprojected response.
          items:
            type: string
          type: array
      required:
        - _jmespath_error
        - original_keys
      type: object
    UnauthorizedError:
      type: object
      properties:
        error:
          type: string
          description: Human-readable error message.
      required:
        - error
      description: >-
        Returned when the API key is missing, malformed, or lacks current API
        access.
    Error:
      type: object
      properties:
        message:
          type: string
          description: Error message (e.g., 'user not found', 'database connection failed')
      description: >-
        Error is returned when a handler encounters an error. It contains a
        simple error message that the developer can customize.
    InvalidRequestBodyError:
      type: object
      description: Returned when a JSON POST request body is empty or malformed.
      properties:
        message:
          type: string
          description: Invalid request body
      required:
        - message
    GatewayError:
      type: object
      description: >-
        Returned by gateway infrastructure errors before an RPC handler runs,
        such as origin, routing, method, authentication, or quota checks.
      properties:
        error:
          oneOf:
            - type: string
            - type: object
              additionalProperties: true
          description: Gateway error reason or structured gateway failure details.
      required:
        - error
    RateLimitError:
      type: object
      description: Returned when a gateway or handler rate limit rejects the request.
      properties:
        error:
          type: string
          description: Human-readable rate-limit failure reason.
      required:
        - error
    ForbiddenError:
      type: object
      properties:
        error:
          type: string
          description: Human-readable entitlement failure reason.
        requiredTier:
          type: integer
          format: int32
          description: Minimum entitlement tier required for this endpoint.
        currentTier:
          type: integer
          format: int32
          description: Caller entitlement tier when known.
        planKey:
          type: string
          description: Caller plan key when known.
      required:
        - error
      description: >-
        Returned when a PRO-gated endpoint denies access because the caller has
        no resolved authenticated user, entitlements cannot be verified, or the
        caller lacks the required entitlement tier.
    FieldViolation:
      type: object
      properties:
        field:
          type: string
          description: >-
            The field path that failed validation (e.g., 'user.email' for nested
            fields). For header validation, this will be the header name (e.g.,
            'X-API-Key')
        description:
          type: string
          description: >-
            Human-readable description of the validation violation (e.g., 'must
            be a valid email address', 'required field missing')
      required:
        - field
        - description
      description: FieldViolation describes a single validation error for a specific field.
    ValidationError:
      type: object
      properties:
        violations:
          type: array
          items:
            $ref: '#/components/schemas/FieldViolation'
          description: List of validation violations
      required:
        - violations
      description: >-
        ValidationError is returned when request validation fails. It contains a
        list of field violations describing what went wrong.
    GetTradeRestrictionsRequest:
      type: object
      properties:
        countries:
          type: array
          items:
            type: string
            description: |-
              WTO member codes to filter by. Empty = all.
               Accepted but currently ignored; no-op until this handler supports the parameter.
        limit:
          type: integer
          format: int32
          description: Max results to return (server caps at 100).
      description: Request for quantitative restriction data.
    GetTradeRestrictionsResponse:
      type: object
      properties:
        restrictions:
          type: array
          items:
            $ref: '#/components/schemas/TradeRestriction'
        fetchedAt:
          type: string
          description: ISO 8601 timestamp when data was fetched from WTO.
        upstreamUnavailable:
          type: boolean
          description: True if upstream fetch failed and results may be stale/empty.
      description: Response containing trade restrictions and fetch metadata.
    TradeRestriction:
      type: object
      properties:
        id:
          type: string
          description: Unique restriction identifier from WTO.
        reportingCountry:
          type: string
          description: ISO 3166-1 alpha-3 or WTO member code of reporting country.
        affectedCountry:
          type: string
          description: Country affected by the restriction.
        productSector:
          type: string
          description: Product sector or HS chapter description.
        measureType:
          type: string
          description: >-
            Measure classification: "QR", "EXPORT_BAN", "IMPORT_BAN",
            "LICENSING".
        description:
          type: string
          description: Human-readable description of the measure.
        status:
          type: string
          description: 'Current status: "IN_FORCE", "TERMINATED", "NOTIFIED".'
        notifiedAt:
          type: string
          description: ISO 8601 date when measure was notified.
        sourceUrl:
          type: string
          description: WTO source document URL (must be http/https protocol).
      description: Quantitative restriction or export control measure notified to WTO.
    GetTariffTrendsRequest:
      type: object
      properties:
        reportingCountry:
          type: string
          description: WTO member code of reporting country (e.g. "840" = US).
        partnerCountry:
          type: string
          description: WTO member code of partner country (e.g. "156" = China).
        productSector:
          type: string
          description: Product sector filter (HS chapter). Empty = aggregate.
        years:
          type: integer
          format: int32
          description: Number of years to look back (default 10, max 30).
      description: Request for tariff timeseries data.
    GetTariffTrendsResponse:
      type: object
      properties:
        datapoints:
          type: array
          items:
            $ref: '#/components/schemas/TariffDataPoint'
        fetchedAt:
          type: string
          description: ISO 8601 timestamp when data was fetched from WTO.
        upstreamUnavailable:
          type: boolean
          description: True if upstream fetch failed and results may be stale/empty.
        effectiveTariffRate:
          $ref: '#/components/schemas/EffectiveTariffRate'
      description: Response containing tariff trend datapoints.
    TariffDataPoint:
      type: object
      properties:
        reportingCountry:
          type: string
          description: WTO member code of reporting country.
        partnerCountry:
          type: string
          description: WTO member code of partner country.
        productSector:
          type: string
          description: Product sector or HS chapter.
        year:
          type: integer
          format: int32
          description: Year of observation.
        tariffRate:
          type: number
          format: double
          description: Applied MFN tariff rate (percentage).
        boundRate:
          type: number
          format: double
          description: WTO bound tariff rate (percentage).
        indicatorCode:
          type: string
          description: WTO indicator code used for this datapoint.
      description: Single tariff data point for a reporter-partner-product combination.
    EffectiveTariffRate:
      type: object
      properties:
        sourceName:
          type: string
          description: Source name for the effective-rate estimate.
        sourceUrl:
          type: string
          description: Canonical source URL for the estimate/methodology.
        observationPeriod:
          type: string
          description: Human-readable observation period (for example "December 2025").
        updatedAt:
          type: string
          description: ISO 8601 date when the source page was last updated, if known.
        tariffRate:
          type: number
          format: double
          description: Effective tariff rate (percentage).
      description: >-
        Current effective tariff estimate for countries with coverage beyond WTO
        MFN baselines.
    GetTradeFlowsRequest:
      type: object
      properties:
        reportingCountry:
          type: string
          description: WTO member code of reporting country.
        partnerCountry:
          type: string
          description: WTO member code of partner country.
        years:
          type: integer
          format: int32
          description: Number of years to look back (default 10, max 30).
      description: Request for bilateral trade flow data.
    GetTradeFlowsResponse:
      type: object
      properties:
        flows:
          type: array
          items:
            $ref: '#/components/schemas/TradeFlowRecord'
        fetchedAt:
          type: string
          description: ISO 8601 timestamp when data was fetched from WTO.
        upstreamUnavailable:
          type: boolean
          description: True if upstream fetch failed and results may be stale/empty.
      description: Response containing trade flow records.
    TradeFlowRecord:
      type: object
      properties:
        reportingCountry:
          type: string
          description: WTO member code of reporting country.
        partnerCountry:
          type: string
          description: WTO member code of partner country.
        year:
          type: integer
          format: int32
          description: Year of observation.
        exportValueUsd:
          type: number
          format: double
          description: Merchandise export value in millions USD.
        importValueUsd:
          type: number
          format: double
          description: Merchandise import value in millions USD.
        yoyExportChange:
          type: number
          format: double
          description: Year-over-year export change (percentage).
        yoyImportChange:
          type: number
          format: double
          description: Year-over-year import change (percentage).
        productSector:
          type: string
          description: Product sector or HS chapter.
      description: Bilateral trade flow record for a reporting-partner pair.
    GetTradeBarriersRequest:
      type: object
      properties:
        countries:
          type: array
          items:
            type: string
            description: |-
              WTO member codes to filter by. Empty = all.
               Accepted but currently ignored; no-op until this handler supports the parameter.
        measureType:
          type: string
          description: |-
            Filter by measure type: "SPS", "TBT", or empty for both.
             Accepted but currently ignored; no-op until this handler supports the parameter.
        limit:
          type: integer
          format: int32
          description: Max results to return (server caps at 100).
      description: Request for SPS/TBT trade barrier notifications.
    GetTradeBarriersResponse:
      type: object
      properties:
        barriers:
          type: array
          items:
            $ref: '#/components/schemas/TradeBarrier'
        fetchedAt:
          type: string
          description: ISO 8601 timestamp when data was fetched from WTO.
        upstreamUnavailable:
          type: boolean
          description: True if upstream fetch failed and results may be stale/empty.
      description: Response containing trade barrier notifications.
    TradeBarrier:
      type: object
      properties:
        id:
          type: string
          description: Unique barrier notification identifier.
        notifyingCountry:
          type: string
          description: Country that notified the measure.
        title:
          type: string
          description: Title of the notification.
        measureType:
          type: string
          description: 'Measure classification: "SPS" or "TBT".'
        productDescription:
          type: string
          description: Product description or affected goods.
        objective:
          type: string
          description: Stated objective of the measure.
        status:
          type: string
          description: Status of the notification.
        dateDistributed:
          type: string
          description: ISO 8601 date when notification was distributed.
        sourceUrl:
          type: string
          description: WTO source document URL (must be http/https protocol).
      description: SPS or TBT trade barrier notification.
    GetCustomsRevenueRequest:
      type: object
    GetCustomsRevenueResponse:
      type: object
      properties:
        months:
          type: array
          items:
            $ref: '#/components/schemas/CustomsRevenueMonth'
        fetchedAt:
          type: string
        upstreamUnavailable:
          type: boolean
    CustomsRevenueMonth:
      type: object
      properties:
        recordDate:
          type: string
        fiscalYear:
          type: integer
          format: int32
        calendarYear:
          type: integer
          format: int32
        calendarMonth:
          type: integer
          format: int32
        monthlyAmountBillions:
          type: number
          format: double
        fytdAmountBillions:
          type: number
          format: double
      description: Monthly US customs duties revenue from Treasury MTS data.
    ListComtradeFlowsRequest:
      type: object
      properties:
        reporterCode:
          type: string
          description: >-
            UN Comtrade reporter code (e.g. "842" = US, "156" = China). Empty
            returns all reporters.
        cmdCode:
          type: string
          description: >-
            HS commodity code (e.g. "2709" = crude oil). Empty returns all
            commodities.
        anomaliesOnly:
          type: boolean
          description: >-
            If true, only return flows with a year-over-year change exceeding
            30%.
      description: ListComtradeFlowsRequest filters strategic commodity trade flows.
    ListComtradeFlowsResponse:
      type: object
      properties:
        flows:
          type: array
          items:
            $ref: '#/components/schemas/ComtradeFlowRecord'
        fetchedAt:
          type: string
          description: ISO 8601 timestamp when data was seeded.
        upstreamUnavailable:
          type: boolean
          description: True if seeded data is missing or stale.
      description: ListComtradeFlowsResponse contains strategic commodity trade flows.
    ComtradeFlowRecord:
      type: object
      properties:
        reporterCode:
          type: string
          description: UN Comtrade reporter code.
        reporterName:
          type: string
          description: Reporter country name.
        partnerCode:
          type: string
          description: Partner country code ("000" = world total).
        partnerName:
          type: string
          description: Partner country name.
        cmdCode:
          type: string
          description: HS commodity code.
        cmdDesc:
          type: string
          description: Commodity description.
        year:
          type: integer
          format: int32
          description: Reporting year.
        tradeValueUsd:
          type: number
          format: double
          description: Trade value in USD.
        netWeightKg:
          type: number
          format: double
          description: Net weight in kg.
        yoyChange:
          type: number
          format: double
          description: Year-over-year change (ratio, e.g. 0.35 = +35%).
        isAnomaly:
          type: boolean
          description: True if the YoY change exceeds the anomaly threshold (30%).
      description: ComtradeFlowRecord is a single bilateral commodity flow record.
