testutil

type BaseDBQueries struct {
	Queries *gen.Queries
	DB      *sql.DB
	// contains filtered or unexported fields
}

type BaseTestServices struct {
	Queries              *gen.Queries
	DB                   *sql.DB
	UserService          suser.UserService
	WorkspaceService     sworkspace.WorkspaceService
	WorkspaceUserService sworkspace.UserService
	HttpService          shttp.HTTPService
	FlowService          sflow.FlowService
	FlowVariableService  sflow.FlowVariableService
}

type ConcurrencyTestConfig struct {
	// NumGoroutines is the number of concurrent operations to run.
	// Default: 20
	NumGoroutines int

	// Timeout is the maximum duration for each operation.
	// If an operation takes longer, it's counted as a timeout (potential deadlock).
	// Default: 3 seconds
	Timeout time.Duration

	// ExpectSuccess indicates whether operations should succeed.
	// Default: true
	ExpectSuccess bool
}

type ConcurrencyTestResult struct {
	// SuccessCount is the number of operations that completed successfully.
	SuccessCount int

	// ErrorCount is the number of operations that returned errors.
	ErrorCount int

	// TimeoutCount is the number of operations that exceeded the timeout.
	// This indicates potential deadlocks or blocking issues.
	TimeoutCount int

	// AverageDuration is the mean duration of all operations.
	AverageDuration time.Duration

	// MaxDuration is the longest operation duration.
	MaxDuration time.Duration

	// MinDuration is the shortest operation duration.
	MinDuration time.Duration
}

type SyncParityTestConfig[CollItem any, SyncItem any] struct {
	// Setup performs any necessary setup (e.g., creating base entities) and returns a cleanup function if needed.
	Setup func(t *testing.T) (context.Context, func())

	// TriggerUpdate performs an action that should trigger a sync event (e.g., inserting or updating a record).
	// It should return the ID of the item being tested.
	TriggerUpdate func(ctx context.Context, t *testing.T)

	// GetCollection calls the Collection RPC and returns the list of items.
	GetCollection func(ctx context.Context, t *testing.T) []CollItem

	// StartSync starts the Sync stream and returns a channel of sync items.
	// The function should run the sync stream in a goroutine and push items to the channel.
	// It should return a cancel function to stop the stream.
	StartSync func(ctx context.Context, t *testing.T) (<-chan SyncItem, func())

	// Compare performs assertions to verify that the collection item matches the sync item.
	Compare func(t *testing.T, collItem CollItem, syncItem SyncItem)
}

type ZeroValueSyncTestConfig[FieldType any, SyncItem any] struct {
	// Setup performs any necessary setup (e.g., creating base entities) and returns:
	// - context for the test
	// - cleanup function
	Setup func(t *testing.T) (context.Context, func())

	// StartSync starts the Sync stream and returns a channel of sync items.
	// The function should run the sync stream in a goroutine and push items to the channel.
	// It should return a cancel function to stop the stream.
	StartSync func(ctx context.Context, t *testing.T) (<-chan SyncItem, func())

	// TriggerUpdate performs an update with the given field value.
	// This should call the actual RPC or service method that triggers sync events.
	TriggerUpdate func(ctx context.Context, t *testing.T, value FieldType)

	// GetActualValue retrieves the actual persisted value from the database/collection.
	// This is used to verify the value was actually saved, not just synced.
	GetActualValue func(ctx context.Context, t *testing.T) FieldType

	// ExtractSyncedValue extracts the field value from a sync item.
	// Returns the value and whether it was present in the sync message.
	ExtractSyncedValue func(t *testing.T, syncItem SyncItem) (value FieldType, present bool)

	// CompareValues compares two values for equality.
	// If nil, uses require.Equal.
	CompareValues func(t *testing.T, expected, actual FieldType)
}

type ZeroValueTestCase[T any] struct {
	// Name is the human-readable test case name
	Name string

	// InitialValue is the initial (typically non-zero) value to set
	InitialValue T

	// ZeroValue is the zero value that should be correctly persisted
	ZeroValue T
}