feat(admin): stream account batch operations

Author: james-6-23

admin/handler.go

@@ -312,6 +312,79 @@ func TestRefreshAccountReturnsRefreshFailure(t *testing.T) {
 	}
 }
 
+func TestBatchRefreshAccountsReportsCounts(t *testing.T) {
+	gin.SetMode(gin.TestMode)
+
+	handler := &Handler{
+		refreshAccount: func(_ context.Context, id int64) error {
+			if id == 8 {
+				return errors.New("upstream unavailable")
+			}
+			return nil
+		},
+	}
+
+	recorder := httptest.NewRecorder()
+	ctx, _ := gin.CreateTestContext(recorder)
+	ctx.Request = httptest.NewRequest(http.MethodPost, "/api/admin/accounts/batch-refresh", strings.NewReader(`{"ids":[7,8,7,0]}`))
+
+	handler.BatchRefreshAccounts(ctx)
+
+	if recorder.Code != http.StatusOK {
+		t.Fatalf("status = %d, want %d", recorder.Code, http.StatusOK)
+	}
+
+	var payload map[string]any
+	if err := json.Unmarshal(recorder.Body.Bytes(), &payload); err != nil {
+		t.Fatalf("decode response: %v", err)
+	}
+	if got := payload["success"]; got != float64(1) {
+		t.Fatalf("success = %v, want 1", got)
+	}
+	if got := payload["failed"]; got != float64(1) {
+		t.Fatalf("failed = %v, want 1", got)
+	}
+}
+
+func TestBatchRefreshAccountsStreamsProgress(t *testing.T) {
+	gin.SetMode(gin.TestMode)
+
+	handler := &Handler{
+		refreshAccount: func(_ context.Context, id int64) error {
+			if id == 8 {
+				return errors.New("账号 8 不存在")
+			}
+			return nil
+		},
+	}
+
+	recorder := httptest.NewRecorder()
+	ctx, _ := gin.CreateTestContext(recorder)
+	ctx.Request = httptest.NewRequest(http.MethodPost, "/api/admin/accounts/batch-refresh?stream=true", strings.NewReader(`{"ids":[7,8]}`))
+
+	handler.BatchRefreshAccounts(ctx)
+
+	if recorder.Code != http.StatusOK {
+		t.Fatalf("status = %d, want %d", recorder.Code, http.StatusOK)
+	}
+	if got := recorder.Header().Get("Content-Type"); !strings.Contains(got, "text/event-stream") {
+		t.Fatalf("content-type = %q, want event-stream", got)
+	}
+	body := recorder.Body.String()
+	for _, want := range []string{
+		`"type":"start"`,
+		`"type":"progress"`,
+		`"type":"complete"`,
+		`"action":"batch_refresh"`,
+		`"success":1`,
+		`"failed":1`,
+	} {
+		if !strings.Contains(body, want) {
+			t.Fatalf("stream body missing %s:\n%s", want, body)
+		}
+	}
+}
+
 func TestResetAccountStatusSyncsPlanMetadata(t *testing.T) {
 	gin.SetMode(gin.TestMode)
 

admin/handler_test.go

@@ -20,6 +20,7 @@ type messageResponse struct {
 type statsResponse struct {
 	Total         int   `json:"total"`
 	Available     int   `json:"available"`
+	RateLimited   int   `json:"rate_limited"`
 	Error         int   `json:"error"`
 	TodayRequests int64 `json:"today_requests"`
 }

admin/responses.go

@@ -82,6 +82,7 @@ func TestStatsResponse(t *testing.T) {
 	resp := statsResponse{
 		Total:         10,
 		Available:     8,
+		RateLimited:   1,
 		Error:         2,
 		TodayRequests: 1000,
 	}
@@ -104,6 +105,9 @@ func TestStatsResponse(t *testing.T) {
 	if available, ok := decoded["available"]; !ok || available != float64(8) {
 		t.Errorf("expected JSON to contain \"available\" field = 8, got %v", available)
 	}
+	if rateLimited, ok := decoded["rate_limited"]; !ok || rateLimited != float64(1) {
+		t.Errorf("expected JSON to contain \"rate_limited\" field = 1, got %v", rateLimited)
+	}
 	if errorField, ok := decoded["error"]; !ok || errorField != float64(2) {
 		t.Errorf("expected JSON to contain \"error\" field = 2, got %v", errorField)
 	}
@@ -307,6 +311,7 @@ func TestStatsResponseJSON(t *testing.T) {
 	resp := statsResponse{
 		Total:         10,
 		Available:     8,
+		RateLimited:   1,
 		Error:         2,
 		TodayRequests: 1000,
 	}