wehub-resource-sync
f99010fae1
CI / lint (push) Failing after 1s
CI / frontend (push) Failing after 1s
CI / scripts (push) Failing after 1s
CI / Go Test (ubuntu-latest) (push) Failing after 0s
CI / frontend-node-25 (push) Failing after 1s
CI / docs (push) Failing after 0s
CI / coverage (push) Failing after 0s
CI / e2e (push) Failing after 0s
Docker / build-and-push (push) Failing after 1s
CI / integration (push) Failing after 4m43s
CI / Go Test (windows-latest) (push) Has been cancelled
CI / Desktop Unit Tests (Windows) (push) Has been cancelled
Desktop Artifacts / Desktop Build (Linux (arm64)) (push) Has been cancelled
Desktop Artifacts / Desktop Build (Linux) (push) Has been cancelled
Desktop Artifacts / Desktop Build (Windows) (push) Has been cancelled
Desktop Artifacts (macOS) / Desktop Build (macOS (aarch64)) (push) Has been cancelled
Desktop Artifacts (macOS) / Desktop Build (macOS (x86_64)) (push) Has been cancelled
86 lines
2.7 KiB
Go
86 lines
2.7 KiB
Go
package service_test
|
|
|
|
import (
|
|
"context"
|
|
"net/http"
|
|
"net/http/httptest"
|
|
"net/url"
|
|
"testing"
|
|
|
|
"github.com/stretchr/testify/assert"
|
|
"github.com/stretchr/testify/require"
|
|
|
|
"go.kenn.io/agentsview/internal/service"
|
|
)
|
|
|
|
func TestHTTPBackendStats(t *testing.T) {
|
|
t.Parallel()
|
|
var gotPath string
|
|
var gotQuery url.Values
|
|
srv := httptest.NewServer(http.HandlerFunc(
|
|
func(w http.ResponseWriter, r *http.Request) {
|
|
gotPath = r.URL.Path
|
|
gotQuery = r.URL.Query()
|
|
w.Header().Set("Content-Type", "application/json")
|
|
_, _ = w.Write([]byte(`{
|
|
"schema_version": 1,
|
|
"window": {"since": "2026-04-01T00:00:00Z", "until": "2026-04-15T00:00:00Z", "days": 14},
|
|
"filters": {"agent": "codex", "projects_included": ["alpha"], "projects_excluded": ["beta"], "timezone": "UTC"},
|
|
"totals": {"sessions_all": 7}
|
|
}`))
|
|
}))
|
|
t.Cleanup(srv.Close)
|
|
svc := service.NewHTTPBackend(srv.URL, "", false)
|
|
|
|
stats, err := svc.Stats(context.Background(), service.StatsFilter{
|
|
Since: "2026-04-01",
|
|
Until: "2026-04-15",
|
|
Agent: "codex",
|
|
IncludeOneShot: true,
|
|
IncludeAutomated: true,
|
|
IncludeProjects: []string{"alpha"},
|
|
ExcludeProjects: []string{"beta"},
|
|
Timezone: "UTC",
|
|
IncludeGitOutcomes: true,
|
|
IncludeGitHubOutcomes: true,
|
|
})
|
|
|
|
require.NoError(t, err)
|
|
require.NotNil(t, stats)
|
|
assert.Equal(t, "/api/v1/session-stats", gotPath)
|
|
assert.Equal(t, "2026-04-01", gotQuery.Get("since"))
|
|
assert.Equal(t, "2026-04-15", gotQuery.Get("until"))
|
|
assert.Equal(t, "codex", gotQuery.Get("agent"))
|
|
assert.Equal(t, "true", gotQuery.Get("include_one_shot"))
|
|
assert.Equal(t, "true", gotQuery.Get("include_automated"))
|
|
assert.Equal(t, "alpha", gotQuery.Get("include_project"))
|
|
assert.Equal(t, "beta", gotQuery.Get("exclude_project"))
|
|
assert.Equal(t, "UTC", gotQuery.Get("timezone"))
|
|
assert.Equal(t, "true", gotQuery.Get("include_git_outcomes"))
|
|
assert.Equal(t, "true", gotQuery.Get("include_github_outcomes"))
|
|
assert.Equal(t, 7, stats.Totals.SessionsAll)
|
|
}
|
|
|
|
func TestHTTPBackendStatsDisablesDefaultVisibilityWithExplicitIncludes(t *testing.T) {
|
|
t.Parallel()
|
|
var gotQuery url.Values
|
|
srv := httptest.NewServer(http.HandlerFunc(
|
|
func(w http.ResponseWriter, r *http.Request) {
|
|
gotQuery = r.URL.Query()
|
|
w.Header().Set("Content-Type", "application/json")
|
|
_, _ = w.Write([]byte(`{"schema_version":1,"totals":{"sessions_all":2}}`))
|
|
}))
|
|
t.Cleanup(srv.Close)
|
|
svc := service.NewHTTPBackend(srv.URL, "", false)
|
|
|
|
stats, err := svc.Stats(context.Background(), service.StatsFilter{
|
|
Since: "28d",
|
|
Agent: "all",
|
|
})
|
|
|
|
require.NoError(t, err)
|
|
require.NotNil(t, stats)
|
|
assert.Equal(t, "true", gotQuery.Get("include_one_shot"))
|
|
assert.Equal(t, "true", gotQuery.Get("include_automated"))
|
|
}
|