mirror of
https://github.com/hanzoai/insights-go.git
synced 2026-09-30 22:46:12 +00:00
zeekay
b4e1366340
Rename Go package from posthog to insights across all 80+ files. Consumers now import as `insights "github.com/hanzoai/insights-go"` and use insights.Client, insights.Config, insights.Capture, etc. - Rename posthog.go -> insights.go, posthog_test.go -> insights_test.go - Update package declaration from posthog to insights in all .go files - Update SDKName from posthog-go to insights-go - Update DefaultEndpoint from app.posthog.com to insights.hanzo.ai - Update all FieldError/ConfigError type strings - Update User-Agent headers, log prefixes, comments, and docs - Update JSON test fixtures to match new SDK name - Update CLI, examples, extras, and sdk_compliance_adapter - Fix pre-existing go vet warnings (non-constant format strings)
109 lines
2.5 KiB
Go
109 lines
2.5 KiB
Go
package insights
|
|
|
|
import (
|
|
"net/http"
|
|
"testing"
|
|
"time"
|
|
)
|
|
|
|
func TestParseRetryAfter(t *testing.T) {
|
|
now := time.Date(2024, 1, 2, 3, 4, 5, 0, time.UTC)
|
|
|
|
tests := []struct {
|
|
name string
|
|
value string
|
|
wantDur time.Duration
|
|
wantOkay bool
|
|
}{
|
|
{
|
|
name: "seconds",
|
|
value: "5",
|
|
wantDur: 5 * time.Second,
|
|
wantOkay: true,
|
|
},
|
|
{
|
|
name: "seconds_with_spaces",
|
|
value: " 10 ",
|
|
wantDur: 10 * time.Second,
|
|
wantOkay: true,
|
|
},
|
|
{
|
|
name: "http_date",
|
|
value: now.Add(2 * time.Second).Format(http.TimeFormat),
|
|
wantDur: 2 * time.Second,
|
|
wantOkay: true,
|
|
},
|
|
{
|
|
name: "empty",
|
|
value: "",
|
|
wantDur: 0,
|
|
wantOkay: false,
|
|
},
|
|
{
|
|
name: "invalid",
|
|
value: "nope",
|
|
wantDur: 0,
|
|
wantOkay: false,
|
|
},
|
|
{
|
|
name: "zero",
|
|
value: "0",
|
|
wantDur: 0,
|
|
wantOkay: false,
|
|
},
|
|
{
|
|
name: "negative",
|
|
value: "-3",
|
|
wantDur: 0,
|
|
wantOkay: false,
|
|
},
|
|
{
|
|
name: "past_http_date",
|
|
value: now.Add(-2 * time.Second).Format(time.RFC1123),
|
|
wantDur: 0,
|
|
wantOkay: false,
|
|
},
|
|
}
|
|
|
|
for _, tc := range tests {
|
|
t.Run(tc.name, func(t *testing.T) {
|
|
gotDur, gotOkay := parseRetryAfter(tc.value, now)
|
|
if gotOkay != tc.wantOkay {
|
|
t.Fatalf("expected ok=%v, got %v", tc.wantOkay, gotOkay)
|
|
}
|
|
if gotDur != tc.wantDur {
|
|
t.Fatalf("expected duration=%v, got %v", tc.wantDur, gotDur)
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func TestIsRetryableStatus(t *testing.T) {
|
|
tests := []struct {
|
|
name string
|
|
status int
|
|
want bool
|
|
}{
|
|
{name: "request_timeout", status: http.StatusRequestTimeout, want: true},
|
|
{name: "too_many_requests", status: http.StatusTooManyRequests, want: true},
|
|
{name: "internal_server_error", status: http.StatusInternalServerError, want: true},
|
|
{name: "bad_gateway", status: http.StatusBadGateway, want: true},
|
|
{name: "service_unavailable", status: http.StatusServiceUnavailable, want: true},
|
|
{name: "gateway_timeout", status: http.StatusGatewayTimeout, want: true},
|
|
{name: "bad_request", status: http.StatusBadRequest, want: false},
|
|
{name: "unauthorized", status: http.StatusUnauthorized, want: false},
|
|
{name: "forbidden", status: http.StatusForbidden, want: false},
|
|
{name: "payload_too_large", status: http.StatusRequestEntityTooLarge, want: false},
|
|
{name: "not_found", status: http.StatusNotFound, want: false},
|
|
}
|
|
|
|
for _, tc := range tests {
|
|
t.Run(tc.name, func(t *testing.T) {
|
|
got := isRetryableStatus(tc.status)
|
|
if got != tc.want {
|
|
t.Fatalf("expected retryable=%v, got %v", tc.want, got)
|
|
}
|
|
})
|
|
}
|
|
}
|