links validator

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
+}

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)
 			}