debuginfo

type CallDetails struct {
	// Identification
	Name       string
	ShardIndex int
	Attempt    int
	JobID      string

	// Status
	ExecutionStatus string
	BackendStatus   string
	ReturnCode      *int

	// Timing
	Start       time.Time
	End         time.Time
	VMStartTime time.Time
	VMEndTime   time.Time

	// Execution
	CommandLine string
	Backend     string
	CallRoot    string

	// Logs
	Stdout        string
	Stderr        string
	MonitoringLog string

	// Docker
	DockerImage     string
	DockerImageUsed string
	DockerSize      string

	// Resources
	CPU         string
	Memory      string
	Disk        string
	Preemptible string
	Zones       string

	// Cache
	CacheHit    bool
	CacheResult string

	// Cost
	VMCostPerHour float64

	// Preemption stats (calculated from all attempts of this task)
	PreemptionStats *PreemptionStats

	// Inputs/Outputs
	Inputs  map[string]interface{}
	Outputs map[string]interface{}

	// Events
	ExecutionEvents []ExecutionEvent

	// Labels
	Labels map[string]string

	// Failures (task-level errors)
	Failures []Failure

	// SubWorkflow
	SubWorkflowID       string
	SubWorkflowMetadata *WorkflowMetadata

	// Cache for expensive calculations
	EfficiencyReport *monitoring.EfficiencyReport
}

type DebugInfo struct {
	Metadata   *WorkflowMetadata
	Root       *TreeNode
	Visible    []*TreeNode
	Preemption *WorkflowPreemptionSummary
}

type ExecutionEvent struct {
	Description string
	Start       time.Time
	End         time.Time
}

type Failure struct {
	Message  string
	CausedBy []Failure
}

type NodeType int

type PreemptionStats struct {
	TotalAttempts   int     // Total number of attempts for this task/shard
	PreemptedCount  int     // Number of times preempted (attempts - 1)
	IsPreemptible   bool    // Whether the task was configured as preemptible
	EfficiencyScore float64 // 1.0 = first try success, lower = more preemptions
	MaxPreemptible  int     // Max preemptible attempts from config
}

type ProblematicTask struct {
	Name            string
	ShardCount      int     // Number of shards (0 or 1 means non-scattered)
	Attempts        int     // Total attempts across all shards
	Preemptions     int     // Total preemptions across all shards
	EfficiencyScore float64 // Average efficiency across all shards

	// Cost-weighted metrics
	TotalCost      float64 // Total cost across all shards (resource-hours)
	WastedCost     float64 // Cost of failed attempts (resource-hours)
	CostEfficiency float64 // 1 - (WastedCost / TotalCost)
	ImpactPercent  float64 // WastedCost / WorkflowTotalWastedCost × 100
}

type TreeNode struct {
	ID            string
	Name          string
	Type          NodeType
	Status        string
	Duration      time.Duration
	Start         time.Time
	End           time.Time
	Expanded      bool
	Children      []*TreeNode
	Parent        *TreeNode
	CallData      *CallDetails
	SubWorkflowID string
	Depth         int
}

type Usecase interface {
	ParseMetadata(data []byte) (*WorkflowMetadata, error)
	BuildTree(wm *WorkflowMetadata) *TreeNode
	GetVisibleNodes(root *TreeNode) []*TreeNode
	AddSubWorkflowChildren(node *TreeNode, subWM *WorkflowMetadata, baseDepth int)
	CalculateWorkflowPreemptionSummary(workflowID, workflowName string, calls map[string][]CallDetails) *WorkflowPreemptionSummary
	// High-level orchestration: parse metadata, build tree, visible nodes, and preemption summary
	GetDebugInfo(data []byte) (*DebugInfo, error)
}

type WorkflowMetadata struct {
	// Basic info
	ID           string
	Name         string
	Status       string
	Start        time.Time
	End          time.Time
	WorkflowRoot string
	WorkflowLog  string

	// Submitted files
	SubmittedWorkflow string
	SubmittedInputs   string
	SubmittedOptions  string

	// Language
	WorkflowLanguage        string
	WorkflowLanguageVersion string

	// Calls (task name -> list of call attempts/shards)
	Calls map[string][]CallDetails

	// Outputs
	Outputs map[string]interface{}

	// Inputs
	Inputs map[string]interface{}

	// Labels
	Labels map[string]string

	// Failures (workflow-level errors before calls execute)
	Failures []Failure
}

type WorkflowPreemptionSummary struct {
	TotalTasks        int               // Total number of tasks/shards
	PreemptibleTasks  int               // Number of preemptible tasks
	TotalAttempts     int               // Total attempts across all tasks
	TotalPreemptions  int               // Total preemptions across all tasks
	OverallEfficiency float64           // Average efficiency (0-1)
	ProblematicTasks  []ProblematicTask // Tasks with low efficiency

	// Cost-weighted metrics
	TotalCost      float64 // Total cost of all attempts (resource-hours)
	WastedCost     float64 // Cost of failed attempts (resource-hours)
	CostEfficiency float64 // 1 - (WastedCost / TotalCost)
	CostUnit       string  // Unit for cost display (e.g., "resource-hours")
}