Fix scheduled campaigns not finishing. Closes #2480.

knadh · knadh · commit 71ae2bbc0902 · 2025-05-25T11:57:48.000+05:30
diff --git a/internal/manager/pipe.go b/internal/manager/pipe.go
@@ -224,7 +224,7 @@ func (p *pipe) cleanup() {
 	}
 
 	// If a running campaign has exhausted subscribers, it's finished.
-	if c.Status == models.CampaignStatusRunning {
+	if c.Status == models.CampaignStatusRunning || c.Status == models.CampaignStatusScheduled {
 		c.Status = models.CampaignStatusFinished
 		if err := p.m.store.UpdateCampaignStatus(p.camp.ID, models.CampaignStatusFinished); err != nil {
 			p.m.log.Printf("error finishing campaign (%s): %v", p.camp.Name, err)

Original file line number	Diff line number	Diff line change
`@@ -224,7 +224,7 @@ func (p *pipe) cleanup() {`
`224`	`224`	`}`
`225`	`225`
`226`	`226`	`// If a running campaign has exhausted subscribers, it's finished.`
`227`		`- if c.Status == models.CampaignStatusRunning {`
	`227`	`+ if c.Status == models.CampaignStatusRunning \|\| c.Status == models.CampaignStatusScheduled {`
`228`	`228`	`c.Status = models.CampaignStatusFinished`
`229`	`229`	`if err := p.m.store.UpdateCampaignStatus(p.camp.ID, models.CampaignStatusFinished); err != nil {`
`230`	`230`	`p.m.log.Printf("error finishing campaign (%s): %v", p.camp.Name, err)`