feat(task): auto remove error subscribe

indes · Oct 20, 2019 · 8460065 · 8460065
1 parent 5262435
commit 8460065
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/bot/service.go b/bot/service.go
@@ -117,7 +117,8 @@ func BroadNews(source *model.Source, subs []model.Subscribe, contents []model.Co
 					DisableNotification:   disableNotification,
 				})
 				if err != nil {
-					log.Println(err)
+					log.Println(err, " [unsubscribe]")
+					_ = sub.Unsub()
 				}
 			} else {
 				message = `
@@ -146,7 +147,8 @@ func BroadNews(source *model.Source, subs []model.Subscribe, contents []model.Co
 					DisableNotification:   disableNotification,
 				})
 				if err != nil {
-					log.Println(err)
+					log.Println(err, " [unsubscribe]")
+					_ = sub.Unsub()
 				}
 			}
 		}