monitor

type CampaignStats struct {
	JobID             string                      `json:"job_id"`
	StartTime         time.Time                   `json:"start_time"`
	TotalRecipients   int                         `json:"total_recipients"`
	PendingCount      int                         `json:"pending_count"`
	SendingCount      int                         `json:"sending_count"`
	SentCount         int                         `json:"sent_count"`
	FailedCount       int                         `json:"failed_count"`
	RetryCount        int                         `json:"retry_count"`
	EmailsPerSecond   float64                     `json:"emails_per_second"`
	EstimatedTimeLeft string                      `json:"estimated_time_left"`
	AvgDurationMs     float64                     `json:"avg_duration_ms"`
	Recipients        map[string]*RecipientStatus `json:"recipients"`
	DomainBreakdown   map[string]int              `json:"domain_breakdown"`
	SMTPResponseCodes map[string]int              `json:"smtp_response_codes"`
	ConfigSummary     ConfigSummary               `json:"config_summary"`
	LogEntries        []LogEntry                  `json:"log_entries"`
}

type ConfigSummary struct {
	CSVFile           string `json:"csv_file"`
	SheetURL          string `json:"sheet_url"`
	TemplateFile      string `json:"template_file"`
	ConcurrentWorkers int    `json:"concurrent_workers"`
	BatchSize         int    `json:"batch_size"`
	RetryLimit        int    `json:"retry_limit"`
	FilterExpression  string `json:"filter_expression"`
}

type EmailStatus string

type LogEntry struct {
	Timestamp time.Time `json:"timestamp"`
	Level     string    `json:"level"`
	Message   string    `json:"message"`
	Email     string    `json:"email,omitempty"`
}

type Monitor interface {
	// InitializeCampaign sets up campaign tracking
	InitializeCampaign(jobID string, config ConfigSummary, totalRecipients int)

	// InitializePending registers a batch of recipients in the Pending state
	// under a single lock acquisition. Use this in place of N sequential
	// UpdateRecipientStatus calls when seeding the dashboard at dispatch start.
	InitializePending(emails []string)

	// UpdateRecipientStatus updates the status of a specific recipient
	UpdateRecipientStatus(email string, status EmailStatus, duration time.Duration, errorMsg string)

	// AddSMTPResponse records an SMTP response code
	AddSMTPResponse(code string)

	// AddLogEntry adds a log entry to the monitoring dashboard
	AddLogEntry(level, message, email string)
}

type NoOpMonitor struct{}

type RecipientStatus struct {
	Email       string      `json:"email"`
	Status      EmailStatus `json:"status"`
	Attempts    int         `json:"attempts"`
	LastAttempt time.Time   `json:"last_attempt"`
	Error       string      `json:"error,omitempty"`
	Duration    int64       `json:"duration_ms"` // Duration in milliseconds
	// contains filtered or unexported fields
}

type SSEClient struct {
	Chan chan CampaignStats

	RemoteAddr string
	// contains filtered or unexported fields
}

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