package sentry

import (
	"io"
	"sync"
	"testing"
	"time"

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

func testTraceProfiling(t *testing.T, rate float64) (*Span, *Event) {
	ticker := setupProfilerTestTicker(io.Discard)
	defer restoreProfilerTicker()

	transport := &TransportMock{}
	ctx := NewTestContext(ClientOptions{
		Transport:          transport,
		EnableTracing:      true,
		TracesSampleRate:   1.0,
		ProfilesSampleRate: rate,
		Environment:        "env",
		Release:            "rel",
		Dist:               "dist",
	})
	span := StartSpan(ctx, "top")
	ticker.Tick()
	span.Finish()

	require.Equal(t, 1, len(transport.events))
	return span, transport.events[0]
}

func TestTraceProfiling(t *testing.T) {
	// Disable the automatically started global profiler after the test has finished.
	defer func() {
		startProfilerOnce = sync.Once{}
		if globalProfiler != nil {
			globalProfiler.Stop(true)
			globalProfiler = nil
		}
	}()

	var require = require.New(t)
	require.Nil(globalProfiler)
	var timeBeforeStarting = time.Now()
	span, event := testTraceProfiling(t, 1.0)
	require.Equal(transactionType, event.Type)
	require.NotNil(event.sdkMetaData.transactionProfile)
	var profileInfo = event.sdkMetaData.transactionProfile
	require.Equal("go", profileInfo.Platform)
	require.Equal(event.Environment, profileInfo.Environment)
	require.Equal(event.Release, profileInfo.Release)
	require.Equal(event.Dist, profileInfo.Dist)
	require.GreaterOrEqual(profileInfo.Timestamp, timeBeforeStarting)
	require.LessOrEqual(profileInfo.Timestamp, time.Now())
	require.Equal(event.EventID, profileInfo.Transaction.ID)
	require.Greater(profileInfo.Transaction.ActiveThreadID, uint64(0))
	require.Equal(span.TraceID.String(), profileInfo.Transaction.TraceID)
	validateProfile(t, profileInfo.Trace, span.EndTime.Sub(span.StartTime))
	require.NotNil(globalProfiler)
}

func TestTraceProfilingDisabled(t *testing.T) {
	if testing.Short() {
		t.Skip("Skipping in short mode because of the timeout we wait for in Tick().")
	}

	var require = require.New(t)
	_, event := testTraceProfiling(t, 0)
	require.Equal(transactionType, event.Type)
	require.Nil(event.sdkMetaData.transactionProfile)
}
func TestUpdateFromEvent(t *testing.T) {
	var require = require.New(t)

	t.Parallel()

	cases := map[string]struct {
		event    *Event
		original *profileInfo
		expected *profileInfo
	}{
		"basic": {
			event: &Event{
				Environment: "test",
				Platform:    "go",
				Release:     "v1.0.0",
				Dist:        "dist",
				EventID:     "12345",
				Contexts: map[string]Context{
					"runtime": map[string]any{"name": "go", "version": "1.16"},
					"os":      map[string]any{"name": "linux"},
					"device":  map[string]any{"arch": "x86_64"},
				},
			},
			expected: &profileInfo{
				Environment: "test",
				Platform:    "go",
				Release:     "v1.0.0",
				Dist:        "dist",
				Transaction: profileTransaction{ID: "12345"},
				Runtime:     profileRuntime{Name: "go", Version: "1.16"},
				OS:          profileOS{Name: "linux"},
				Device:      profileDevice{Architecture: "x86_64"},
			},
			original: &profileInfo{},
		},
		"values from original": {
			event: &Event{
				Environment: "test",
				Platform:    "go",
				Release:     "v1.0.0",
				Dist:        "dist",
				EventID:     "12345",
				Contexts: map[string]Context{
					"runtime": map[string]any{"name": "go"},
					"os":      map[string]any{"name": "linux"},
					"device":  map[string]any{"arch": 86},
				},
			},
			original: &profileInfo{
				Environment: "original",
				Platform:    "original",
				Release:     "original",
				Dist:        "original",
				Transaction: profileTransaction{ID: "original"},
				Runtime:     profileRuntime{Name: "original", Version: "original"},
				OS:          profileOS{Name: "original"},
				Device:      profileDevice{Architecture: "original"},
			},
			expected: &profileInfo{
				Environment: "test",
				Platform:    "go",
				Release:     "v1.0.0",
				Dist:        "dist",
				Transaction: profileTransaction{ID: "12345"},
				Runtime:     profileRuntime{Name: "go", Version: "original"},
				OS:          profileOS{Name: "linux"},
				Device:      profileDevice{Architecture: "original"},
			},
		},
	}

	for name, tc := range cases {
		tc := tc
		t.Run(name, func(t *testing.T) {
			t.Parallel()
			info := tc.original
			info.UpdateFromEvent(tc.event)
			require.Equal(tc.expected, info)
		})
	}
}