ReleasePulse

id: github_release_watcher
namespace: system

description: |
  ReleasePulse runs once a day and does three things:
  checks a repo's releases, opens a GitHub issue when a new release drops,
  and remembers the last tag in the KV store so it never files twice.

inputs:
  - id: repo_owner
    type: STRING
    description: GitHub owner of the repo to watch (e.g. kestra-io)
  - id: repo_name
    type: STRING
    description: GitHub repo name to watch (e.g. kestra)

tasks:
  - id: fetch_release
    type: io.kestra.plugin.core.http.Request
    description: gets the latest release of the repo from the GitHub API
    method: GET
    uri: https://api.github.com/repos/{{ inputs.repo_owner }}/{{ inputs.repo_name
      }}/releases?per_page=1
    headers:
      Authorization: "Bearer {{ secret('GITHUB_TOKEN') }}"
      Accept: "application/vnd.github+json"

  - id: check_seen
    type: io.kestra.plugin.core.kv.GetKeys
    description: checks whether we have filed an issue before (empty list on first run)
    prefix: "releasepulse-last-tag"

  - id: process_release
    type: io.kestra.plugin.core.flow.If
    description: only continues if the repo has at least one release
    condition: "{{ (outputs.fetch_release.body | jq('length') | first) > 0 }}"
    then:
      - id: file_issue_if_new
        type: io.kestra.plugin.core.flow.If
        description: files an issue only when the tag is new (first run just saves, no
          issue)
        condition: "{{ outputs.check_seen.keys | length > 0 and
          (outputs.fetch_release.body | jq('.[0].tag_name') | first) !=
          kv('releasepulse-last-tag') }}"
        then:
          - id: create_issue
            type: io.kestra.plugin.github.issues.Create
            description: opens a GitHub issue announcing the new release
            oauthToken: "{{ secret('GITHUB_TOKEN') }}"
            repository: "{{ inputs.repo_owner }}/{{ inputs.repo_name }}"
            title: "New release: {{ outputs.fetch_release.body | jq('.[0].tag_name') | first
              }}"
            body: |
              A new release is out: **{{ outputs.fetch_release.body | jq('.[0].tag_name') | first }}**
              ({{ outputs.fetch_release.body | jq('.[0].name') | first }}).

              Release notes: {{ outputs.fetch_release.body | jq('.[0].html_url') | first }}

              _Filed automatically by ReleasePulse._
            labels:
              - release

      - id: save_seen
        type: io.kestra.plugin.core.kv.Set
        description: remembers this tag in the KV store for the next run
        key: releasepulse-last-tag
        value: "{{ outputs.fetch_release.body | jq('.[0].tag_name') | first }}"
        overwrite: true

triggers:
  - id: daily
    type: io.kestra.plugin.core.trigger.Schedule
    cron: "0 9 * * *"
    timezone: UTC
    inputs:
      repo_owner: kestra-io
      repo_name: kestra