patrickandClaude Sonnet 5
7996c3e96f
CI / Web-Barrierefreiheitspruefung (axe, Tastatur, Reflow, Textabstaende) (push) Canceled after 0s
CI / Core-Modul (Build/Vet/Test) (push) Canceled after 0s
CI / DMS Security-Test-Gate (AC5, Merge-Gate) (push) Canceled after 0s
CI / DMS-Modul Supply-Chain-Scan (govulncheck) (push) Canceled after 0s
CI / Web (dms-browser) (push) Canceled after 0s
CI / Web (pdf-viewer) (push) Canceled after 0s
CI / Web (shl) (push) Canceled after 0s
Supply-Chain-Scan (Go) / govulncheck (push) Canceled after 0s
CI / DMS-Modul (Lint/Build/Test/Coverage/Artefakt) (push) Canceled after 0s
Neue Pakete connect/internal/httpclient, auditclient, audittrail (Muster aus archive/internal/*, CMP-04): Verbindung anlegen/aendern (credential.Store.PutWithActor) und Sync-Ausfuehrung (syncjob.Store.CompleteRunAudited) melden je einen Audit-Eintrag an Cores zentrales Audit-Log (AUD-01). Ausfall des Audit-Dienstes puffert outage-tolerant in connect_audit_outbox statt den Fachvorgang zu blockieren (AC3). Co-Authored-By: Claude Sonnet 5 <noreply@anthropic.com>
55 lines
1.5 KiB
Go
55 lines
1.5 KiB
Go
package httpclient
|
|
|
|
import (
|
|
"net/http"
|
|
"net/http/httptest"
|
|
"strings"
|
|
"testing"
|
|
"time"
|
|
)
|
|
|
|
func TestDefaultHasTimeout(t *testing.T) {
|
|
if Default().Timeout != DefaultTimeout || DefaultTimeout <= 0 {
|
|
t.Fatalf("timeout = %s", Default().Timeout)
|
|
}
|
|
}
|
|
|
|
func TestClientGivesUpOnHangingServer(t *testing.T) {
|
|
release := make(chan struct{})
|
|
srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { <-release }))
|
|
defer srv.Close()
|
|
defer close(release)
|
|
|
|
start := time.Now()
|
|
resp, err := New(200 * time.Millisecond).Get(srv.URL)
|
|
if err == nil {
|
|
_ = resp.Body.Close()
|
|
t.Fatal("kein fehler bei haengendem server")
|
|
}
|
|
if elapsed := time.Since(start); elapsed > 5*time.Second {
|
|
t.Fatalf("aufruf dauerte %s", elapsed)
|
|
}
|
|
}
|
|
|
|
func TestClientDoesNotFollowRedirects(t *testing.T) {
|
|
target := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
|
t.Error("weiterleitungsziel wurde aufgerufen (Service-Token-Leck)")
|
|
}))
|
|
defer target.Close()
|
|
redirector := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
|
http.Redirect(w, r, target.URL, http.StatusTemporaryRedirect)
|
|
}))
|
|
defer redirector.Close()
|
|
|
|
req, _ := http.NewRequest(http.MethodPost, redirector.URL, strings.NewReader("x"))
|
|
req.Header.Set("X-Service-Token", "geheim")
|
|
resp, err := Default().Do(req)
|
|
if err != nil {
|
|
t.Fatalf("do: %v", err)
|
|
}
|
|
defer func() { _ = resp.Body.Close() }()
|
|
if resp.StatusCode != http.StatusTemporaryRedirect {
|
|
t.Fatalf("status = %d, erwartet 307", resp.StatusCode)
|
|
}
|
|
}
|