Function TestAuthManager_ConcurrentAccess

pkg/api/auth_test.go:391–460

(t *testing.T)

}

func TestAuthManager_ConcurrentAccess(t *testing.T) {
	// Create a test server that simulates slow authentication
	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		if r.URL.Path == testEndpoint {
			// Add a small delay to test concurrent access
			time.Sleep(10 * time.Millisecond)

			response := map[string]interface{}{
				"data": map[string]interface{}{
					"ticket":              "concurrent-ticket",
					"CSRFPreventionToken": "concurrent-csrf",
					"username":            "testuser",
				},
			}

			w.Header().Set("Content-Type", "application/json")
			_ = json.NewEncoder(w).Encode(response)

			return
		}

		http.NotFound(w, r)
	}))
	defer server.Close()

	httpClient := &HTTPClient{
		baseURL: server.URL,
		client:  server.Client(),
	}
	logger := testutils.NewTestLogger()

	authManager := NewAuthManagerWithPassword(httpClient, "testuser", "testpass", logger)

	// Start multiple goroutines trying to authenticate concurrently
	const numGoroutines = 5
	results := make(chan *AuthToken, numGoroutines)
	errors := make(chan error, numGoroutines)

	for i := 0; i < numGoroutines; i++ {
		go func() {
			token, err := authManager.GetValidToken(context.Background())
			if err != nil {
				errors <- err
			} else {
				results <- token
			}
		}()
	}

	// Collect results
	var tokens []*AuthToken

	for i := 0; i < numGoroutines; i++ {
		select {
		case token := <-results:
			tokens = append(tokens, token)
		case err := <-errors:
			t.Errorf("Unexpected error: %v", err)