integrationtest

type BatchServerInfo struct {
	BatchID      int
	ServiceNames []string
	ServerBin    string
	ServerDir    string
}

type BatchStats struct {
	TotalBatches int
	BuildTimes   []time.Duration
	TestTimes    []time.Duration
}

type CacheEntry struct {
	Passed   bool      `json:"passed"`
	TestedAt time.Time `json:"tested_at"`
}

type FailedSpec struct {
	Spec  string
	Error error
}

type IntegrationResult struct {
	Spec             string
	Path             string
	OperationID      string
	Method           string
	Ok               bool
	StatusCode       int
	GenerateErr      string
	Validated        bool
	ValidationMethod string
	BatchID          int // Batch number (0 = individual mode)
}

type PipelineConfig struct {
	SandboxDir   string
	RuntimeOpts  *RuntimeOptions
	BasePort     int
	MaxFails     int
	TotalSpecs   int
	TotalBatches int
	OnResult     func(result IntegrationResult, stats *ServiceStats, completed, total int)
	OnBatchStart func(batchID, totalBatches, servicesInBatch int, batchSizeBytes int64)
	OnBatchDone  func(batchID, totalBatches, servicesInBatch int, buildTime, testTime time.Duration)
	// OnBatchPhase is called when a batch phase starts/ends (phase: "setup", "build")
	OnBatchPhase func(batchID int, phase string, done bool, elapsed time.Duration)
	// InterruptCh is an optional channel that signals when to abort and report partial results
	InterruptCh <-chan struct{}
	// Cache is an optional result cache to skip previously passing specs
	Cache *ResultCache
	// BatchPrepTimeout is the maximum time allowed for batch preparation (setup + build + server start)
	// Default: 5 minutes
	BatchPrepTimeout time.Duration
}

type PreparedBatch struct {
	Info        *BatchServerInfo
	ServerProc  *ServerProcess
	ServerURL   string
	Port        int
	Specs       []string      // Original spec paths for this batch
	Error       error         // Error during preparation (only set if entire batch failed)
	FailedSpecs []FailedSpec  // Services that failed during setup/generate (batch continues with rest)
	BuildTime   time.Duration // Time spent building this batch
	BatchID     int
}

type ResultCache struct {
	Entries map[string]CacheEntry `json:"entries"` // key is spec path
	// contains filtered or unexported fields
}

type RuntimeOptions struct {
	CodegenConfigPath      string        `env:"CODEGEN_CONFIG"`
	ServiceConfigPath      string        `env:"SERVICE_CONFIG"`
	SpecsBaseDir           string        `env:"SPECS_BASE_DIR"`
	MaxConcurrency         int           `env:"MAX_CONCURRENCY" envDefault:"8"`
	BatchSizeMB            int           `env:"BATCH_SIZE_MB" envDefault:"6"`
	BatchConcurrency       int           `env:"BATCH_CONCURRENCY" envDefault:"2"`
	MaxSpecSizeMB          int           `env:"MAX_SPEC_SIZE_MB" envDefault:"10"`
	SimplifyThresholdMB    int           `env:"SIMPLIFY_THRESHOLD_MB" envDefault:"3"`
	ServiceGenerateTimeout time.Duration `env:"SERVICE_GENERATE_TIMEOUT" envDefault:"5m"`
	NoCache                bool          `env:"NO_CACHE" envDefault:"false"`
	ClearCache             bool          `env:"CLEAR_CACHE" envDefault:"false"`
	MaxFails               int           `env:"MAX_FAILS" envDefault:"500"`
	RandomSpecs            int           `env:"RANDOM_SPECS" envDefault:"0"`

	// Computed fields (not from env)
	BatchSizeBytes         int64
	MaxSpecSizeBytes       int64
	SimplifyThresholdBytes int64
}

type ServerProcess struct {
	Cmd    *exec.Cmd
	Stdout *bytes.Buffer
	Stderr *bytes.Buffer
	// contains filtered or unexported fields
}

type ServiceStats struct {
	Name      string
	Endpoints int
	Tested    int
	Success   int
	Fails     int
	LOC       int
	TTE       time.Duration // Time To Execute (test execution)
}

type ServiceTestResult struct {
	Spec            string
	Results         []IntegrationResult
	TotalEndpoints  int
	TestedEndpoints int
	TestDuration    float64 // Test execution time in seconds
}