writers

type FileLogEntry struct {
	Level   string      `json:"level"`
	Message string      `json:"message"`
	Time    string      `json:"time,omitempty"`
	Prefix  string      `json:"prefix,omitempty"`
	Extra   interface{} `json:"-"`
}

type IChannelWriter interface {
	IWriter
	Start() error
	Stop() error
	IsRunning() bool
}

type ILogStore interface {
	// Store adds a log entry to the store (non-blocking, async safe)
	Store(entry models.LogEvent) error

	// GetByCorrelation retrieves all logs for a correlation ID, ordered by timestamp
	GetByCorrelation(correlationID string) ([]models.LogEvent, error)

	// GetByCorrelationWithLevel retrieves logs for a correlation ID filtered by minimum level
	GetByCorrelationWithLevel(correlationID string, minLevel log.Level) ([]models.LogEvent, error)

	// GetSince retrieves all logs since a given timestamp
	GetSince(since time.Time) ([]models.LogEvent, error)

	// GetRecent retrieves the N most recent log entries
	GetRecent(limit int) ([]models.LogEvent, error)

	// GetCorrelationIDs returns all active correlation IDs
	GetCorrelationIDs() []string

	// Close cleans up resources
	Close() error
}

type IMemoryWriter interface {
	IWriter

	// GetEntries retrieves all log entries for a specific correlation ID
	GetEntries(correlationID string) (map[string]string, error)

	// GetAllEntries retrieves all log entries across all correlation IDs
	GetAllEntries() (map[string]string, error)

	// GetEntriesWithLevel retrieves log entries filtered by minimum log level
	GetEntriesWithLevel(correlationID string, minLevel log.Level) (map[string]string, error)

	// GetStoredCorrelationIDs returns all correlation IDs that have stored logs
	GetStoredCorrelationIDs() []string

	// GetEntriesWithLimit retrieves the most recent log entries up to the specified limit
	GetEntriesWithLimit(limit int) (map[string]string, error)

	// GetEntriesSince retrieves all log entries since a given timestamp (for WebSocket queries)
	GetEntriesSince(since time.Time) ([]models.LogEvent, error)

	// GetStore returns the underlying log store for use with other writers
	GetStore() ILogStore

	// Close closes the memory writer and any underlying resources
	Close() error
}

type IWriter interface {
	WithLevel(level log.Level) IWriter
	Write(p []byte) (n int, err error)
	GetFilePath() string // Returns the file path if this is a file writer, empty string otherwise
	Close() error
}

type StoredLogEntry struct {
	LogEvent  models.LogEvent `json:"log_event"`
	ExpiresAt time.Time       `json:"expires_at"`
}