diff --git a/internal/processor/helper.go b/internal/processor/helper.go new file mode 100644 index 0000000..cb46a12 --- /dev/null +++ b/internal/processor/helper.go @@ -0,0 +1,10 @@ +package processor + +import "strings" + +func linkIsValid(link string) bool { + if strings.HasPrefix(link, "http://") || strings.HasPrefix(link, "https://") { + return true + } + return false +} diff --git a/internal/processor/service.go b/internal/processor/service.go index 01e4ef8..4544487 100644 --- a/internal/processor/service.go +++ b/internal/processor/service.go @@ -112,6 +112,10 @@ func (s *service) SendResults(ctx context.Context, chanLen uint) error { func (s *service) sendTasks(tasks []structs.Task) error { for _, tsk := range tasks { for origin, link := range tsk.Origins { + if !linkIsValid(link) { + continue + } + if origin == "surugaya" { pushTask(s.taskPublishers["surugaya"], tsk.MerchUuid, link) }