package integration

import (
	"encoding/json"
	"fmt"
	"io"
	"testing"
	"time"

	"github.com/stretchr/testify/assert"
	"github.com/stretchr/testify/require"
)

// ==============================================================================
// Analytics API Tests - Reports and Dashboards
// ==============================================================================

// TestAnalyticsAPI_Reports tests the /analytics/reports endpoint
func TestAnalyticsAPI_Reports(t *testing.T) {
	if testing.Short() {
		t.Skip("Skipping integration test")
	}

	client := newHTTPClient(t)

	t.Run("List_Reports", func(t *testing.T) {
		resp, err := client.request("GET", "/services/data/v63.0/analytics/reports", nil)
		require.NoError(t, err)
		defer resp.Body.Close()

		// Accept 200 OK or 404 (if endpoint not fully registered)
		assert.True(t, resp.StatusCode == 200 || resp.StatusCode == 404,
			"Expected 200 or 404, got %d", resp.StatusCode)

		body, _ := io.ReadAll(resp.Body)
		t.Logf("Reports list response: %s", string(body)[:min(200, len(body))])
	})

	t.Run("Create_And_Run_Report", func(t *testing.T) {
		// Create a simple report
		reportDef := map[string]interface{}{
			"Name":          fmt.Sprintf("Test Report %d", time.Now().UnixNano()%100000),
			"Description":   "Integration test report",
			"ObjectApiName": "Account",
			"Columns":       []string{"Name", "Id"},
		}

		resp, err := client.request("POST", "/services/data/v63.0/analytics/reports", reportDef)
		require.NoError(t, err)
		defer resp.Body.Close()

		body, _ := io.ReadAll(resp.Body)
		t.Logf("Create report response (%d): %s", resp.StatusCode, string(body)[:min(200, len(body))])

		// Accept 201 Created, 200 OK, 400/422 if schema doesn't match, or 404 if endpoint not registered
		assert.True(t, resp.StatusCode == 201 || resp.StatusCode == 200 || resp.StatusCode == 400 || resp.StatusCode == 422 || resp.StatusCode == 404,
			"Expected 200/201/400/404/422, got %d", resp.StatusCode)
	})
}

// TestAnalyticsAPI_Dashboards tests the /analytics/dashboards endpoint
func TestAnalyticsAPI_Dashboards(t *testing.T) {
	if testing.Short() {
		t.Skip("Skipping integration test")
	}

	client := newHTTPClient(t)

	t.Run("List_Dashboards", func(t *testing.T) {
		resp, err := client.request("GET", "/services/data/v63.0/analytics/dashboards", nil)
		require.NoError(t, err)
		defer resp.Body.Close()

		// Accept 200 OK or 404 (if endpoint not fully registered)
		assert.True(t, resp.StatusCode == 200 || resp.StatusCode == 404,
			"Expected 200 or 404, got %d", resp.StatusCode)

		body, _ := io.ReadAll(resp.Body)
		t.Logf("Dashboards list: %s", string(body)[:min(200, len(body))])
	})
}

// ==============================================================================
// Limits API Test
// ==============================================================================

// TestLimitsAPI tests the /limits endpoint
func TestLimitsAPI(t *testing.T) {
	if testing.Short() {
		t.Skip("Skipping integration test")
	}

	client := newHTTPClient(t)

	t.Run("Get_Limits", func(t *testing.T) {
		resp, err := client.request("GET", "/services/data/v63.0/limits", nil)
		require.NoError(t, err)
		defer resp.Body.Close()

		assert.Equal(t, 200, resp.StatusCode, "Should return 200 OK")

		var result map[string]interface{}
		json.NewDecoder(resp.Body).Decode(&result)

		// Verify some common limit keys exist
		t.Logf("Limits response has %d entries", len(result))
		assert.NotEmpty(t, result, "Limits should not be empty")
	})
}

// ==============================================================================
// External ID API Tests
// ==============================================================================

// TestExternalID_Operations tests PATCH/GET by external ID
func TestExternalID_Operations(t *testing.T) {
	if testing.Short() {
		t.Skip("Skipping integration test")
	}

	client := newHTTPClient(t)
	sf := newGoSFClient(t)

	// First, we need an object with an external ID field
	// For now, test the endpoint responds correctly even if field doesn't exist

	t.Run("Get_By_ExternalID_NonExistent", func(t *testing.T) {
		resp, err := client.request("GET", "/services/data/v63.0/sobjects/Account/external/ExternalId__c/test-ext-id", nil)
		require.NoError(t, err)
		defer resp.Body.Close()

		// Accept 404 (field or record not found) or 400 (field doesn't exist)
		assert.True(t, resp.StatusCode == 404 || resp.StatusCode == 400,
			"Expected 404 or 400, got %d", resp.StatusCode)
	})

	t.Run("Upsert_By_ExternalID", func(t *testing.T) {
		payload := map[string]interface{}{
			"Name": "Upsert Test Account",
		}

		resp, err := client.request("PATCH", "/services/data/v63.0/sobjects/Account/external/ExternalId__c/test-ext-upsert", payload)
		require.NoError(t, err)
		defer resp.Body.Close()

		body, _ := io.ReadAll(resp.Body)
		t.Logf("Upsert response (%d): %s", resp.StatusCode, string(body)[:min(200, len(body))])

		// Accept 201 (created), 200 (updated), 204 (no content), or 400/404 (field doesn't exist)
		assert.True(t, resp.StatusCode == 201 || resp.StatusCode == 200 || resp.StatusCode == 204 || resp.StatusCode == 400 || resp.StatusCode == 404,
			"Expected 200/201/204/400/404, got %d", resp.StatusCode)
	})

	_ = sf // Keep reference
}

// min helper for Go < 1.21
func min(a, b int) int {
	if a < b {
		return a
	}
	return b
}