logs

type Cache struct {
	// contains filtered or unexported fields
}

type CacheEntry struct {
	CachedAt  time.Time     `json:"cached_at"`
	Logs      *RunLogs      `json:"logs"`
	ChainName string        `json:"chain_name"`
	RunID     int64         `json:"run_id"`
	TTL       time.Duration `json:"ttl"`
}

type CacheStats struct {
	TotalEntries   int
	ValidEntries   int
	ExpiredEntries int
}

type Fetcher struct {
	// contains filtered or unexported fields
}

type Filter struct {
	// contains filtered or unexported fields
}

type FilterConfig struct {
	Level         FilterLevel
	SearchTerm    string
	CaseSensitive bool
	Regex         bool
	StepIndex     int // -1 for all steps
}

type FilterLevel string

type FilteredLogEntry struct {
	Original      LogEntry
	Matches       []MatchPosition
	OriginalIndex int
}

type FilteredResult struct {
	Config *FilterConfig
	Steps  []*FilteredStepLogs
}

type FilteredStepLogs struct {
	Workflow  string
	StepName  string
	Entries   []FilteredLogEntry
	StepIndex int
}

type GHFetcher struct {
	// contains filtered or unexported fields
}

type GitHubClient interface {
	GetWorkflowRun(runID int64) (*github.WorkflowRun, error)
	GetWorkflowRunJobs(runID int64) ([]github.Job, error)
}

type LogEntry struct {
	Timestamp time.Time `json:"timestamp"`
	Content   string    `json:"content"`
	Level     LogLevel  `json:"level"`     // error, warning, info, debug
	StepName  string    `json:"step_name"` // for grouping
}

type LogFetcher interface {
	FetchStepLogs(runID int64, workflow string) ([]*StepLogs, error)
}

type LogLevel string

type LogStreamer struct {
	// contains filtered or unexported fields
}

type Manager struct {
	// contains filtered or unexported fields
}

type MatchPosition struct {
	Start int
	End   int
}

type RunLogs struct {
	ChainName string      `json:"chain_name"`
	Branch    string      `json:"branch"`
	Steps     []*StepLogs `json:"steps"`
	// contains filtered or unexported fields
}

type StepLogs struct {
	FetchedAt  time.Time  `json:"fetched_at"`
	Error      error      `json:"-"`
	Workflow   string     `json:"workflow"`
	JobName    string     `json:"job_name"`
	StepName   string     `json:"step_name"`
	Status     string     `json:"status"`
	Conclusion string     `json:"conclusion"`
	Entries    []LogEntry `json:"entries"`
	StepIndex  int        `json:"step_index"`
	RunID      int64      `json:"run_id"`
}

type StreamState struct {
	StepLineCounts map[int]int // map[stepIndex]lineCount
}

type StreamUpdate struct {
	Error      error
	Status     string
	Conclusion string
	NewSteps   []*StepLogs
	RunID      int64
}