Taskfile.yml

version: '3'

vars:
  SCP_URL: https://cloud.nas-test.synadia.io/api/core/beta
  ACCOUNT: 2lsqayf1NIFEvVwRdTXlAonrGbO
  VERSION:
    sh: git describe --tags --always --abbrev=0 --match='v[0-9]*.[0-9]*.[0-9]*' 2> /dev/null | sed 's/^.//'
  COMMIT_HASH:
    sh: git rev-parse --short HEAD
  BUILD_DATE:
    sh: date '+%Y-%m-%dT%H:%M:%S'
  LD_FLAGS:
    sh: echo "-X main.Version={{.VERSION}} -X main.CommitHash={{.COMMIT_HASH}} -X main.BuildTimestamp={{.BUILD_DATE}}"

tasks:
  setup:
    desc: Setup development environment
    cmds:
      - go install github.com/goreleaser/goreleaser/v2@v2.12.5
      - go install github.com/golangci/golangci-lint/v2/cmd/golangci-lint@latest

  fmt:
    cmds:
      - gofmt -w -s .
      - goimports -w -local github.com/wombatwisdom/wombat .
      - go mod tidy

  format:check:
    desc: Check code formatting
    cmds:
      - |
        if [ -n "$(gofmt -l .)" ]; then
          echo "Code is not formatted. Please run 'task fmt'"
          gofmt -l .
          exit 1
        fi

  lint:
    desc: Run golangci-lint & vet
    cmds:
      - go vet {{.GO_FLAGS}} ./...
      - golangci-lint run ./...

  check:
    desc: Run all code quality checks (lint, format, vet)
    cmds:
      - task: lint
      - task: format:check

  clean:
    desc: Clean up the project
    cmds:
      - rm -rf target/*

  models:deps:
    cmds:
      - go install github.com/atombender/go-jsonschema@84c8d2b98bf0373873df8a353b122530a7110c70

  models:generate:
    desc: Generate models from local schema
    deps:
      - models:deps
    requires:
      vars:
        - CONNECT_NODE_LOCATION
    cmds:
      - go-jsonschema --struct-name-from-title
        --package model
        --schema-output=io.synadia.connect.v1.model.secret=model/secret.go
        --schema-output=io.synadia.connect.v1.model.secret.summary=model/secret.go
        --schema-output=io.synadia.connect.v1.control.secret.list.request=model/secret_list.go
        --schema-output=io.synadia.connect.v1.control.secret.list.response=model/secret_list.go
        --schema-output=io.synadia.connect.v1.control.secret.delete.request=model/secret_delete.go
        --schema-output=io.synadia.connect.v1.control.secret.delete.response=model/secret_delete.go
        --schema-output=io.synadia.connect.v1.control.secret.set.request=model/secret_set.go
        --schema-output=io.synadia.connect.v1.control.secret.set.response=model/secret_set.go
        --schema-output=io.synadia.connect.v1.library=model/library.go
        --schema-output=io.synadia.connect.v1.model.metrics=model/connector_models.go
        --schema-output=io.synadia.connect.v1.model.nats_config=model/connector_models.go
        --schema-output=io.synadia.connect.v1.model.connector=model/connector_models.go
        --schema-output=io.synadia.connect.v1.model.connector.start.options=model/connector_models.go
        --schema-output=io.synadia.connect.v1.model.connector.summary=model/connector_models.go
        --schema-output=io.synadia.connect.v1.model.connector.instance=model/connector_models.go
        --schema-output=io.synadia.connect.v1.model.connector.instances=model/connector_models.go
        --schema-output=io.synadia.connect.v1.model.connector.status=model/connector_models.go
        --schema-output=io.synadia.connect.v1.model.connector.steps=model/connector_models.go
        --schema-output=io.synadia.connect.v1.model.connector.steps.consumer=model/connector_models.go
        --schema-output=io.synadia.connect.v1.model.connector.steps.producer=model/connector_models.go
        --schema-output=io.synadia.connect.v1.model.connector.steps.source=model/connector_models.go
        --schema-output=io.synadia.connect.v1.model.connector.steps.sink=model/connector_models.go
        --schema-output=io.synadia.connect.v1.model.connector.steps.transformer=model/connector_models.go
        --schema-output=io.synadia.connect.v1.model.connector.steps.transformer.composite=model/connector_models.go
        --schema-output=io.synadia.connect.v1.model.connector.steps.transformer.mapping=model/connector_models.go
        --schema-output=io.synadia.connect.v1.model.connector.steps.transformer.service=model/connector_models.go
        --schema-output=io.synadia.connect.v1.model.connector.steps.transformer.explode=model/connector_models.go
        --schema-output=io.synadia.connect.v1.model.connector.steps.transformer.combine=model/connector_models.go
        --schema-output=io.synadia.connect.v1.control.connector.create.request=model/connector_create.go
        --schema-output=io.synadia.connect.v1.control.connector.create.response=model/connector_create.go
        --schema-output=io.synadia.connect.v1.control.connector.delete.request=model/connector_delete.go
        --schema-output=io.synadia.connect.v1.control.connector.delete.response=model/connector_delete.go
        --schema-output=io.synadia.connect.v1.control.connector.get.request=model/connector_get.go
        --schema-output=io.synadia.connect.v1.control.connector.get.response=model/connector_get.go
        --schema-output=io.synadia.connect.v1.control.connector.list.request=model/connector_list.go
        --schema-output=io.synadia.connect.v1.control.connector.list.response=model/connector_list.go
        --schema-output=io.synadia.connect.v1.control.connector.patch.request=model/connector_patch.go
        --schema-output=io.synadia.connect.v1.control.connector.patch.response=model/connector_patch.go
        --schema-output=io.synadia.connect.v1.control.connector.instances.request=model/connector_instances.go
        --schema-output=io.synadia.connect.v1.control.connector.instances.response=model/connector_instances.go
        --schema-output=io.synadia.connect.v1.control.connector.start.request=model/connector_start.go
        --schema-output=io.synadia.connect.v1.control.connector.start.response=model/connector_start.go
        --schema-output=io.synadia.connect.v1.control.connector.status.request=model/connector_status.go
        --schema-output=io.synadia.connect.v1.control.connector.status.response=model/connector_status.go
        --schema-output=io.synadia.connect.v1.control.connector.stop.request=model/connector_stop.go
        --schema-output=io.synadia.connect.v1.control.connector.stop.response=model/connector_stop.go
        {{.CONNECT_NODE_LOCATION}}/model/schemas/*.schema.json

      - go-jsonschema --struct-name-from-title
        --package model
        --schema-output=io.synadia.connect.v1.library.spec=model/crawler.go
        {{.CONNECT_NODE_LOCATION}}/crawler/v1/*.schema.json

      - go-jsonschema --struct-name-from-title
        --package spec
        --schema-output=io.synadia.connect.v1.spec=spec/spec.go
        --schema-output=io.synadia.connect.v1.spec.connector=spec/connector.go
        --schema-output=io.synadia.connect.v1.spec.connector.steps=spec/connector.go
        --schema-output=io.synadia.connect.v1.spec.connector.steps.consumer=spec/connector.go
        --schema-output=io.synadia.connect.v1.spec.connector.steps.producer=spec/connector.go
        --schema-output=io.synadia.connect.v1.spec.connector.steps.transformer=spec/connector.go
        --schema-output=io.synadia.connect.v1.spec.connector.steps.source=spec/connector.go
        --schema-output=io.synadia.connect.v1.spec.connector.steps.sink=spec/connector.go
        --schema-output=io.synadia.connect.v1.spec.metrics=spec/common.go
        --schema-output=io.synadia.connect.v1.spec.nats_config=spec/common.go
        spec/schemas/*.schema.json

  build:
    generates:
      - target/connect
    env:
      GOOS: "{{.GOOS}}"
      GOARCH: "{{.GOARCH}}"
    cmds:
      - go mod tidy
      - go build -ldflags="{{.LD_FLAGS}}" -o target/connect cmd/connect/*.go

  test:
    cmds:
      - go run github.com/onsi/ginkgo/v2/ginkgo -r -cover --coverpkg=github.com/synadia-io/connect/... --compilers=4

  install:
    deps:
      - build
    cmds:
      - mkdir -p ~/.local/bin
      - cp target/connect ~/.local/bin/connect

  docs:verify:links:
    desc: Verify all documentation links are valid
    cmds:
      - |
        echo "🔍 Verifying documentation links..."
        broken_links_file=$(mktemp)
        echo "0" > "$broken_links_file"
        
        # Find all markdown files
        for file in $(find . -name "*.md" -not -path "./target/*"); do
          echo "Checking: $file"
        
          # Extract local markdown links [text](./path.md) or [text](path.md)
          if grep -oE '\[.*\]\(\./[^)]*\.md\)|\[.*\]\([^)]*\.md\)' "$file" 2>/dev/null; then
            grep -oE '\[.*\]\(\./[^)]*\.md\)|\[.*\]\([^)]*\.md\)' "$file" 2>/dev/null | while read -r link; do
              # Extract just the file path from the link
              path=$(echo "$link" | sed -E 's/.*\(([^)]*)\).*/\1/')
        
              # Convert relative path to absolute
              if [[ "$path" == ./* ]]; then
                # Remove leading ./
                rel_path="${path#./}"
                abs_path="$(dirname "$file")/$rel_path"
              elif [[ "$path" == ../* ]]; then
                abs_path="$(dirname "$file")/$path"
              else
                abs_path="$(dirname "$file")/$path"
              fi
        
              # Check if file exists
              if [[ ! -f "$abs_path" ]]; then
                echo "❌ Broken link in $file: $path → $abs_path"
                current_count=$(cat "$broken_links_file")
                echo $((current_count + 1)) > "$broken_links_file"
              fi
            done
          fi
        done
        
        broken_links=$(cat "$broken_links_file")
        rm "$broken_links_file"
        
        if [[ $broken_links -eq 0 ]]; then
          echo "✅ All documentation links are valid!"
        else
          echo "❌ Found $broken_links broken links"
          exit 1
        fi

  # Release Management
  release:snapshot:
    desc: Create a local snapshot release (no git operations)
    cmds:
      - goreleaser release --snapshot --clean --skip=publish

  release:rc:
    desc: Create a release candidate
    vars:
      CURRENT_TAG:
        sh: git describe --tags --always --abbrev=0 --match='v[0-9]*.[0-9]*.[0-9]*' 2>/dev/null || echo "v0.0.0"
      NEXT_RC:
        sh: |
          if [ -z "{{.VERSION}}" ]; then
            current_tag=$(git describe --tags --always --abbrev=0 --match='v[0-9]*.[0-9]*.[0-9]*' 2>/dev/null || echo "v0.0.0")
            if echo "$current_tag" | grep -q "\-rc"; then
              # Extract base version and RC number
              base=$(echo "$current_tag" | sed 's/-rc.*//')
              rc_num=$(echo "$current_tag" | sed 's/.*-rc//')
              next_rc=$((rc_num + 1))
              echo "${base}-rc${next_rc}" | sed 's/^v//'
            else
              # No RC suffix, this is a new RC series
              echo "${current_tag}-rc1" | sed 's/^v//'
            fi
          else
            echo "{{.VERSION}}"
          fi
      TAG_VERSION: "v{{.NEXT_RC}}"
    cmds:
      - task: release:check
      - task: check
      - task: test
      - |
        echo "Creating release candidate: {{.TAG_VERSION}}"
        
        # Validate version format
        if ! echo "{{.NEXT_RC}}" | grep -qE '^[0-9]+\.[0-9]+\.[0-9]+(-rc[0-9]+)?$'; then
          echo "Error: Invalid version format. Expected: X.Y.Z or X.Y.Z-rcN"
          exit 1
        fi
        
        # Check if tag already exists
        if git rev-parse "{{.TAG_VERSION}}" >/dev/null 2>&1; then
          echo "Error: Tag {{.TAG_VERSION}} already exists"
          exit 1
        fi
        
        # Create and push tag
        git tag -a "{{.TAG_VERSION}}" -m "Release candidate {{.TAG_VERSION}}"
        git push origin "{{.TAG_VERSION}}"
        
        echo "✅ Tag {{.TAG_VERSION}} created and pushed"
        echo "GitHub Actions will now create the release using goreleaser"

  release:final:
    desc: Create a final release
    vars:
      CURRENT_TAG:
        sh: git describe --tags --always --abbrev=0 --match='v[0-9]*.[0-9]*.[0-9]*' 2>/dev/null || echo "v0.0.0"
      FINAL_VERSION:
        sh: |
          if [ -z "{{.VERSION}}" ]; then
            current_tag=$(git describe --tags --always --abbrev=0 --match='v[0-9]*.[0-9]*.[0-9]*' 2>/dev/null || echo "v0.0.0")
            # Remove RC suffix if present
            echo "$current_tag" | sed 's/-rc.*//' | sed 's/^v//'
          else
            echo "{{.VERSION}}"
          fi
      TAG_VERSION: "v{{.FINAL_VERSION}}"
    cmds:
      - task: release:check
      - task: check
      - task: test
      - |
        echo "Creating final release: {{.TAG_VERSION}}"
        
        # Validate version format (no RC suffix allowed)
        if ! echo "{{.FINAL_VERSION}}" | grep -qE '^[0-9]+\.[0-9]+\.[0-9]+$'; then
          echo "Error: Invalid version format. Expected: X.Y.Z (no RC suffix)"
          exit 1
        fi
        
        # Check if tag already exists
        if git rev-parse "{{.TAG_VERSION}}" >/dev/null 2>&1; then
          echo "Error: Tag {{.TAG_VERSION}} already exists"
          exit 1
        fi
        
        # Create and push tag
        git tag -a "{{.TAG_VERSION}}" -m "Release {{.TAG_VERSION}}"
        git push origin "{{.TAG_VERSION}}"
        
        echo "✅ Tag {{.TAG_VERSION}} created and pushed"
        echo "GitHub Actions will now create the release using goreleaser"

  release:check:
    desc: Pre-release checks
    cmds:
      - |
        # Check for uncommitted changes
        if [ -n "$(git status --porcelain)" ]; then
          echo "Error: Uncommitted changes detected. Please commit or stash changes before releasing."
          exit 1
        fi
      - |
        # Check we're on main branch
        BRANCH=$(git rev-parse --abbrev-ref HEAD)
        if [ "$BRANCH" != "main" ]; then
          echo "Error: Releases must be created from main branch. Currently on: $BRANCH"
          exit 1
        fi
      - |
        # Ensure we have latest changes
        git fetch origin main
        if [ $(git rev-list HEAD...origin/main --count) -gt 0 ]; then
          echo "Error: Local main branch is not up to date with origin. Please pull latest changes."
          exit 1
        fi
      - echo "✅ Pre-release checks passed"

  release:validate:
    desc: Validate version format
    vars:
      VERSION: '{{.VERSION | default ""}}'
    cmds:
      - |
        if [ -z "{{.VERSION}}" ]; then
          echo "Error: VERSION not provided"
          echo "Usage: task release:validate VERSION=X.Y.Z[-rcN]"
          exit 1
        fi
        
        if echo "{{.VERSION}}" | grep -qE '^[0-9]+\.[0-9]+\.[0-9]+(-rc[0-9]+)?$'; then
          echo "✅ Valid version format: {{.VERSION}}"
        else
          echo "❌ Invalid version format: {{.VERSION}}"
          echo "Expected format: X.Y.Z or X.Y.Z-rcN"
          exit 1
        fi

  release:list:
    desc: List recent releases
    cmds:
      - gh release list --limit 20

  release:current:
    desc: Show current version
    cmds:
      - |
        CURRENT=$(git describe --tags --abbrev=0 --match="v*" 2>/dev/null || echo "v0.0.0")
        echo "Current version: $CURRENT"
        
        # Check if there are commits since last tag
        if [ "$CURRENT" != "v0.0.0" ]; then
          COMMITS_SINCE=$(git rev-list --count $CURRENT..HEAD)
          if [ $COMMITS_SINCE -gt 0 ]; then
            echo "Commits since $CURRENT: $COMMITS_SINCE"
          fi
        fi