GitHub Issue Priority Triage and Discord Digest

id: github-issue-triage-discord-digest
namespace: company.team

inputs:
  - id: repository_owner
    type: STRING
    defaults: "kestra-io"
    description: GitHub organization or account name owning the repository.

  - id: repository_name
    type: STRING
    defaults: "kestra"
    description: Name of the GitHub repository to inspect.

  - id: max_issues
    type: INT
    defaults: 15
    description: Maximum number of recently updated open issues to fetch.

tasks:
  - id: fetch_recent_issues
    type: io.kestra.plugin.core.http.Request
    description: Query the GitHub REST API for recently updated open issues.
    uri: "https://api.github.com/repos/{{ inputs.repository_owner }}/{{
      inputs.repository_name }}/issues?state=open&per_page={{ inputs.max_issues
      }}&sort=updated&direction=desc"
    method: GET
    headers:
      Accept: "application/vnd.github+json"
      Authorization: "Bearer {{ secret('GITHUB_TOKEN') }}"
      X-GitHub-Api-Version: "2022-11-28"

  - id: process_issues_loop
    type: io.kestra.plugin.core.flow.Loop
    description: Iterate through fetched issues and inspect priority labels.
    values: "{{ outputs.fetch_recent_issues.body }}"
    tasks:
      - id: check_if_urgent
        type: io.kestra.plugin.core.flow.If
        description: Detect whether the issue contains bug, critical, urgent, or
          priority labels.
        condition: "{{ (fromJson(item.value).labels | jq('[.[].name | select(. ==
          \"bug\" or . == \"critical\" or . == \"urgent\" or . == \"priority\")]
          | length') | first) > 0 }}"
        then:
          - id: alert_discord_urgent
            type: io.kestra.plugin.discord.DiscordIncomingWebhook
            description: Send an actionable embed card for the urgent issue to the team
              Discord channel.
            url: "{{ secret('DISCORD_WEBHOOK_URL') }}"
            payload: |
              {
                "embeds": [
                  {
                    "title": "🚨 High-Priority Issue: {{ fromJson(item.value).title | replace('\"', '\\\"') }}",
                    "url": "{{ fromJson(item.value).html_url }}",
                    "description": "Opened by **@{{ fromJson(item.value).user.login }}**",
                    "color": 15158332,
                    "fields": [
                      {
                        "name": "Issue Number",
                        "value": "#{{ fromJson(item.value).number }}",
                        "inline": true
                      },
                      {
                        "name": "State",
                        "value": "{{ fromJson(item.value).state | upper }}",
                        "inline": true
                      }
                    ],
                    "footer": {
                      "text": "Kestra Automated Issue Triage"
                    }
                  }
                ]
              }
        else:
          - id: log_routine_issue
            type: io.kestra.plugin.core.log.Log
            description: Record standard issues in execution logs without triggering Discord
              alerts.
            message: "Routine issue passed: #{{ fromJson(item.value).number }} - {{
              fromJson(item.value).title }}"

  - id: send_completion_log
    type: io.kestra.plugin.core.log.Log
    description: Output triage execution summary.
    message: "Triage completed for repository: {{ inputs.repository_owner }}/{{
      inputs.repository_name }}."

errors:
  - id: alert_api_failure
    type: io.kestra.plugin.discord.DiscordIncomingWebhook
    description: Notify Discord if GitHub API requests fail due to rate limiting,
      network errors, or auth problems.
    url: "{{ secret('DISCORD_WEBHOOK_URL') }}"
    payload: |
      {
        "content": "⚠️ **Kestra Pipeline Warning:** Failed to fetch or process GitHub issues for `{{ inputs.repository_owner }}/{{ inputs.repository_name }}`. Check token permissions and API rate limits."
      }

triggers:
  - id: weekday_schedule
    type: io.kestra.plugin.core.trigger.Schedule
    description: Scheduled run every weekday at 09:00 UTC (shipped disabled by default).
    cron: "0 9 * * 1-5"
    disabled: true