Method processSendJob

internal/web/server.go:865–991

processSendJob runs in a background goroutine to send emails

(job *Job, toSend []BrokerWithStatus, sender email.Sender)

// processSendJob runs in a background goroutine to send emails
func (s *Server) processSendJob(job *Job, toSend []BrokerWithStatus, sender email.Sender) {
	sent := 0
	failed := 0
	rateLimitMs := s.config.Options.RateLimitMs
	if rateLimitMs == 0 {
		rateLimitMs = 2000 // Default 2 second delay
	}

	// Set daily limit based on provider
	dailyLimit := DailyLimitSMTP // Default for SMTP
	if s.config.Email.Provider == "sendgrid" {
		dailyLimit = DailyLimitSendGrid
	} else if s.config.Email.Provider == "resend" {
		dailyLimit = DailyLimitResend
	}
	job.DailyLimit = dailyLimit

	// Track remaining brokers for persistence
	remaining := make([]string, len(toSend))
	for i, b := range toSend {
		remaining[i] = b.ID
	}

	for i, b := range toSend {
		// Check if job was cancelled
		if job.IsCancelled() {
			break
		}

		// Check daily limit
		if sent >= dailyLimit {
			job.DaySent = sent
			job.Status = JobStatusPaused
			job.Error = fmt.Sprintf("Daily limit of %d emails reached. Remaining %d brokers will be sent when you restart tomorrow.", dailyLimit, len(remaining))
			s.saveJobProgress(job, sent, failed, remaining)
			log.Printf("Job paused: daily limit of %d reached, %d remaining", dailyLimit, len(remaining))
			return
		}

		// Update current broker
		job.Update(sent, failed, b.Name)

		// Generate email
		rendered, err := s.tmplEngine.Render("generic", s.config.Profile, b.Broker)
		if err != nil {
			failed++
			job.Update(sent, failed, b.Name)
			// Remove from remaining even on failure
			remaining = remaining[1:]
			s.saveJobProgress(job, sent, failed, remaining)
			continue
		}

		msg := email.Message{
			To:      b.Email,
			From:    s.config.Email.From,
			Subject: rendered.Subject,
			Body:    rendered.Body,