Competitor radar

nika: v1
workflow: competitor-radar
description: "Sitemap → parallel page reads → one competitive brief + ping"

model: mock/echo            # swap for anthropic/claude-sonnet-4-6

vars:
  competitor_sitemap: "https://competitor.example.com/sitemap.xml"

secrets:
  team_webhook:
    source: env
    key: TEAM_WEBHOOK_URL
    egress:                       # sanction the one send · the secret IS the URL
      - to: "nika:notify"
        host_from_self: true

tasks:
  - id: map
    invoke:
      tool: "nika:fetch"
      args:
        url: "${{ vars.competitor_sitemap }}"
        mode: sitemap
    output:
      recent: ".urls[:8]"             # cap the radar at the 8 freshest pages

  - id: pages
    depends_on: [map]
    for_each: ${{ tasks.map.recent }}
    max_parallel: 4                    # be polite · 4 fetches in flight max
    fail_fast: false                   # one dead page must not kill the radar
    on_error:
      recover: null                    # a dead page yields null at its index · the radar lives
    timeout: "30s"
    retry:
      max_attempts: 3
      backoff_strategy: exponential
      jitter: true
    invoke:
      tool: "nika:fetch"
      args:
        url: "${{ item }}"
        mode: article

  - id: digest
    depends_on: [pages]
    infer:
      prompt: |
        These are the pages a competitor published recently ·
        ${{ tasks.pages.output }}
        Write the Monday brief · what they shipped · what it signals ·
        what we should watch. One page, plain words.

  - id: save
    depends_on: [digest]
    invoke:
      tool: "nika:write"
      args:
        path: "./radar/competitor-brief.md"
        content: "${{ tasks.digest.output }}"
        create_dirs: true

  - id: ping
    depends_on: [save]
    invoke:
      tool: "nika:notify"
      args:
        channel: webhook
        target: "${{ secrets.team_webhook }}"
        message: "Competitor radar is ready · ./radar/competitor-brief.md"
        severity: info

outputs:
  brief: ${{ tasks.digest.output }}