package spindle

import (
	"errors"
	"fmt"
	"net/http"
	"testing"

	"tangled.org/core/spindle/db"
)

func TestNotifyEventRefusedCommitCarriesAStatusTheKnotDrops(t *testing.T) {
	e := newPushEnv(t)
	push := e.firstPush(t)
	e.w.mu.Lock()
	e.w.cgi = nil
	e.w.mu.Unlock()

	_, err := e.notify(e.n.s, push)
	var coded interface{ HTTPStatus() int }
	if !errors.As(err, &coded) {
		t.Fatalf("err = %v, want one that carries a status", err)
	}
	status := coded.HTTPStatus()
	if status < 400 || status >= 500 || status == http.StatusRequestTimeout || status == http.StatusTooManyRequests {
		t.Fatalf("status = %d, want a 4xx the knot drops the event on", status)
	}
}

func TestNotifyEventBannedRepoIsAnsweredWithNoPipeline(t *testing.T) {
	e := newPushEnv(t)
	if err := e.n.s.db.PutBan(db.BanEntry{SubjectDid: testRepoDid}); err != nil {
		t.Fatal(err)
	}

	uri, err := e.notify(e.n.s, e.firstPush(t))
	if err != nil || uri != "" {
		t.Fatalf("answered %q, %v, want an empty answer without an error", uri, err)
	}
	e.wantPipelines(t, 0, "for a banned repo")
}

func TestNotifyEventFailedPushFiresItsWebhookOnceAcrossRetries(t *testing.T) {
	h := newHookEnv(t)
	for range 3 {
		if _, err := h.notifyErr(pushEvent("refs/heads/main")); err == nil {
			t.Fatal("setup: the push was handled although the knot has no git")
		}
	}
	h.expectPush(t)
	h.expectNoPush(t, "a retry of a failed push fired the webhook again")
}

func TestNotifyEventMalformedShasCarryAStatusTheKnotDrops(t *testing.T) {
	e := newPushEnv(t)
	push := e.firstPush(t)
	push.EventPush.NewSha = "not-a-sha"

	_, err := e.notify(e.n.s, push)
	var coded interface{ HTTPStatus() int }
	if !errors.As(err, &coded) || coded.HTTPStatus() != http.StatusUnprocessableEntity {
		t.Fatalf("err = %v, want a 422", err)
	}
}

func TestARefusalFromAnyFetchCarriesAStatusTheKnotDrops(t *testing.T) {
	// the pipeline fetch comes back wrapped, refusedAsStatus has to unwrap it
	err := refusedAsStatus(fmt.Errorf("loading pipeline: %w", errRevRefused))

	var coded interface{ HTTPStatus() int }
	if !errors.As(err, &coded) || coded.HTTPStatus() != http.StatusUnprocessableEntity {
		t.Fatalf("err = %v, want a 422", err)
	}
	if plain := errors.New("couldn't fetch the push from the knot"); refusedAsStatus(plain) != plain {
		t.Fatal("an error the knot may retry was given a status")
	}
}