Daily Tennis Fixtures Pull to Internal Storage

id: tennis-fixtures-daily
namespace: company.team
description: |
  Once a day, pull the tennis fixtures (the scheduled match slate) from the
  Live Tennis API with the HTTP Request task, normalize the response into a
  tidy list with JSONata, persist it to internal storage for downstream tasks,
  and log a one-line summary. A single daily call fits comfortably inside the
  free-tier quota.

inputs:
  - id: tour
    type: SELECT
    defaults: ""
    required: false
    values:
      - ""
      - atp
      - wta
      - challenger
      - itf
      - juniors
    description: >
      Tour filter (bounded set). Leave as the empty option to return across
      every tour.

tasks:
  - id: fetch_fixtures
    type: io.kestra.plugin.core.http.Request
    description: >
      Fetch today's fixture slate. The API key is read from the
      LIVETENNISAPI_KEY secret as the X-API-Key header, never hardcoded.
    uri: "https://api.livetennisapi.com/api/public/v1/fixtures{{ inputs.tour != '' ?
      '?tour=' ~ inputs.tour : '' }}"
    method: GET
    headers:
      X-API-Key: "{{ secret('LIVETENNISAPI_KEY') }}"
      Accept: "application/json"
    options:
      allowFailed: false
    retry:
      type: exponential
      interval: PT2S
      maxInterval: PT20S
      maxAttempts: 3

  - id: build_fixtures
    type: io.kestra.plugin.transform.jsonata.TransformValue
    description: >
      Normalize the response envelope and project each fixture down to the
      fields a schedule view needs. Tolerant of the envelope key so a single
      expression covers fixtures / matches / data.
    from: "{{ outputs.fetch_fixtures.body }}"
    expression: |
      (
        $fixtures := $exists(fixtures) ? fixtures : ($exists(matches) ? matches : ($exists(data) ? data : []));
        {
          "fetched_at": $now(),
          "count": $count($fixtures),
          "fixtures": $fixtures.{
            "id": id,
            "tour": tour,
            "status": status,
            "reason": reason,
            "start_time": start_time,
            "p1": players.p1.name,
            "p2": players.p2.name
          }
        }
      )

  - id: store_fixtures
    type: io.kestra.plugin.core.storage.Write
    description: >
      Persist the normalized fixtures to internal storage so downstream tasks (a
      warehouse load, a calendar sync, a preview email) can consume it via
      outputs.store_fixtures.uri.
    content: "{{ outputs.build_fixtures.value | json }}"
    extension: ".json"

  - id: log_summary
    type: io.kestra.plugin.core.log.Log
    description: Record how many fixtures were pulled this run.
    message: "Tennis fixtures pull: {{ outputs.build_fixtures.value | jq('.count') |
      first }} fixture(s) (tour filter: '{{ inputs.tour }}')."

triggers:
  - id: every_morning
    type: io.kestra.plugin.core.trigger.Schedule
    description: >
      Once per day at 07:00 server time. A single daily fixtures call is well
      inside the free key's 100 req/day and 30 req/min limits, leaving plenty of
      headroom for a windowed live-scores poll alongside it.
    cron: "0 7 * * *"

errors:
  - id: on_error
    type: io.kestra.plugin.core.log.Log
    level: ERROR
    message: "tennis-fixtures-daily failed: {{ error.message }}"

outputs:
  - id: fixtures_file
    type: STRING
    value: "{{ outputs.store_fixtures.uri }}"
  - id: fixture_count
    type: STRING
    value: "{{ outputs.build_fixtures.value | jq('.count') | first }}"