god-eye/internal/scheduler/alerter.go

package scheduler

import (
	"bytes"
	"context"
	"encoding/json"
	"fmt"
	"net/http"
	"time"

	"god-eye/internal/diff"
)

// WebhookAlerter POSTs the diff report JSON to an arbitrary URL. Works
// with generic webhook consumers; Slack/Discord get dedicated adapters
// later in F5.3 when bespoke formatting matters.
type WebhookAlerter struct {
	URL     string
	Timeout time.Duration
}

// NewWebhookAlerter returns a WebhookAlerter with sane defaults.
func NewWebhookAlerter(url string) *WebhookAlerter {
	return &WebhookAlerter{URL: url, Timeout: 10 * time.Second}
}

func (a *WebhookAlerter) Name() string { return "webhook" }

func (a *WebhookAlerter) Notify(ctx context.Context, r *diff.Report) error {
	body, err := json.Marshal(r)
	if err != nil {
		return err
	}
	client := &http.Client{Timeout: a.Timeout}
	req, err := http.NewRequestWithContext(ctx, "POST", a.URL, bytes.NewReader(body))
	if err != nil {
		return err
	}
	req.Header.Set("Content-Type", "application/json")
	req.Header.Set("User-Agent", "god-eye-v2")
	resp, err := client.Do(req)
	if err != nil {
		return err
	}
	defer resp.Body.Close()
	if resp.StatusCode >= 400 {
		return fmt.Errorf("webhook returned %d", resp.StatusCode)
	}
	return nil
}

// StdoutAlerter prints meaningful changes to stdout. Useful for smoke
// testing and for users who pipe god-eye output into grep/jq.
type StdoutAlerter struct{}

func (StdoutAlerter) Name() string { return "stdout" }

func (StdoutAlerter) Notify(_ context.Context, r *diff.Report) error {
	for _, c := range r.Changes {
		fmt.Printf("[DIFF %s] %s  %s → %s  (%s)\n", r.Target, c.Kind, c.Before, c.After, c.Host)
	}
	return nil
}