From 392400bd44d7256d0df441150eb9855eb76cc68d Mon Sep 17 00:00:00 2001 From: nquidox Date: Mon, 6 Oct 2025 23:13:45 +0300 Subject: [PATCH] task sorter fix --- internal/processor/service.go | 19 +++++++++++++++---- 1 file changed, 15 insertions(+), 4 deletions(-) diff --git a/internal/processor/service.go b/internal/processor/service.go index c088665..ca2827c 100644 --- a/internal/processor/service.go +++ b/internal/processor/service.go @@ -39,16 +39,27 @@ func (p *Processor) StartWork(receivedTasks []shared.TaskResponse) { func (p *Processor) sortTasks(receivedTasks []shared.TaskResponse) map[string][]shared.Task { sorted := make(map[string][]shared.Task, len(receivedTasks)) + log.WithField("count", len(receivedTasks)).Debug("Sorting tasks") for _, task := range receivedTasks { - log.WithField("task", task).Debug("Sorting tasks") - switch { - case task.OriginSurugayaLink != "": + if task.OriginSurugayaLink != "" { + log.WithFields(log.Fields{ + "origin": shared.OriginSurugaya, + "uuid": task.MerchUuid, + }).Debug("Task") + sorted[shared.OriginSurugaya] = append(sorted[shared.OriginSurugaya], shared.Task{ MerchUuid: task.MerchUuid, Origin: shared.OriginSurugaya, Link: task.OriginSurugayaLink, }) - case task.OriginMandarakeLink != "": + } + + if task.OriginMandarakeLink != "" { + log.WithFields(log.Fields{ + "origin": shared.OriginMandarake, + "uuid": task.MerchUuid, + }).Debug("Task") + sorted[shared.OriginMandarake] = append(sorted[shared.OriginMandarake], shared.Task{ MerchUuid: task.MerchUuid, Origin: shared.OriginMandarake,