niuniu/lijiaoqiao
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor(token-runtime): extract in-memory stores

Browse Source
This commit is contained in:
Your Name
2026-04-14 10:55:28 +08:00
parent cd26802d7d
commit 975ef73b8d
7 changed files with 328 additions and 166 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
platform-token-runtime/internal/httpapi/token_api_test.go
View File

@@ -17,7 +17,7 @@ func TestTokenAPIIssueAndIntrospect(t *testing.T) {
t.Parallel()
runtime := service.NewInMemoryTokenRuntime(nil)
auditor := service.NewMemoryAuditEmitter()
auditor := service.NewMemoryAuditStore()
api := NewTokenAPI(runtime, auditor, func() time.Time {
return time.Date(2026, 3, 30, 15, 50, 0, 0, time.UTC)
})
@@ -66,7 +66,7 @@ func TestTokenAPIIssueIdempotencyConflict(t *testing.T) {
t.Parallel()
runtime := service.NewInMemoryTokenRuntime(nil)
api := NewTokenAPI(runtime, service.NewMemoryAuditEmitter(), time.Now)
api := NewTokenAPI(runtime, service.NewMemoryAuditStore(), time.Now)
mux := http.NewServeMux()
api.Register(mux)
@@ -107,7 +107,7 @@ func TestTokenAPIRefreshAndRevoke(t *testing.T) {
now := time.Date(2026, 3, 30, 16, 0, 0, 0, time.UTC)
runtime := service.NewInMemoryTokenRuntime(func() time.Time { return now })
api := NewTokenAPI(runtime, service.NewMemoryAuditEmitter(), func() time.Time { return now })
api := NewTokenAPI(runtime, service.NewMemoryAuditStore(), func() time.Time { return now })
mux := http.NewServeMux()
api.Register(mux)
@@ -162,7 +162,7 @@ func TestTokenAPIMissingHeaders(t *testing.T) {
t.Parallel()
runtime := service.NewInMemoryTokenRuntime(nil)
api := NewTokenAPI(runtime, service.NewMemoryAuditEmitter(), time.Now)
api := NewTokenAPI(runtime, service.NewMemoryAuditStore(), time.Now)
mux := http.NewServeMux()
api.Register(mux)
@@ -184,7 +184,7 @@ func TestTokenAPIAuditEventsQuery(t *testing.T) {
t.Parallel()
runtime := service.NewInMemoryTokenRuntime(nil)
auditor := service.NewMemoryAuditEmitter()
auditor := service.NewMemoryAuditStore()
api := NewTokenAPI(runtime, auditor, time.Now)
mux := http.NewServeMux()
api.Register(mux)
@@ -227,6 +227,25 @@ func TestTokenAPIAuditEventsQuery(t *testing.T) {
}
}
func TestTokenAPIAuditEventsReady(t *testing.T) {
t.Parallel()
runtime := service.NewInMemoryTokenRuntime(nil)
auditor := service.NewMemoryAuditStore()
api := NewTokenAPI(runtime, auditor, time.Now)
mux := http.NewServeMux()
api.Register(mux)
req := httptest.NewRequest(http.MethodGet, "/api/v1/platform/tokens/audit-events?limit=3", nil)
req.Header.Set("X-Request-Id", "req-audit-ready")
rec := httptest.NewRecorder()
mux.ServeHTTP(rec, req)
if rec.Code != http.StatusOK {
t.Fatalf("expected ready audit query endpoint: code=%d body=%s", rec.Code, rec.Body.String())
}
}
func TestTokenAPIAuditEventsNotReady(t *testing.T) {
t.Parallel()