parent
63ef1f206b
commit
e8b76d07e2
4
main.go
4
main.go
|
|
@ -259,14 +259,17 @@ func once() error {
|
|||
if err != nil {
|
||||
return err
|
||||
}
|
||||
log.Printf("once: all jobs: %+v", alljobs)
|
||||
newjobs, err := dropStaleJobs(alljobs)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
log.Printf("once: new jobs: %+v", newjobs)
|
||||
jobs, err := dropBanlistJobs(newjobs)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
log.Printf("once: sending jobs: %+v", jobs)
|
||||
for i := range jobs {
|
||||
if err := sendJob(jobs[i]); err != nil {
|
||||
return err
|
||||
|
|
@ -318,6 +321,7 @@ func dropBanlistJobs(jobs []broker.Job) ([]broker.Job, error) {
|
|||
func sendJob(job broker.Job) error {
|
||||
sender := message.NewMatrix()
|
||||
payload := job.FormatMultilineText()
|
||||
log.Printf("once: send job %s if nonzero: %s", job.String(), payload)
|
||||
if len(payload) == 0 {
|
||||
return nil
|
||||
}
|
||||
|
|
|
|||
Loading…
Reference in New Issue