merch-tracker-v2/task-processor
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Compare commits

base: merch-tracker-v2:9e85dddcf54a002aff173f05135bd4e78463e83c
Branches Tags
merch-tracker-v2:main
merch-tracker-v2:v0.1.6
...
compare: merch-tracker-v2:e8767446fde6614696fbdced3d388f65320a4439
Branches Tags
merch-tracker-v2:main
merch-tracker-v2:v0.1.6

2 commits
9e85dddcf5 ... e8767446fd

Author SHA1 Message Date
nquidox
e8767446fd update 2025-10-06 18:56:39 +03:00
nquidox
e4c6932a7a debug log 2025-10-06 18:54:41 +03:00
2 changed files with 5 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

5
.gitignore vendored
View file

@ -1,3 +1,6 @@
.idea .idea
cmd/build.sh cmd/build.sh
cmd/parserService cmd/parserService
.directory
*.sh
*.tar

1
internal/processor/service.go
View file

@ -40,6 +40,7 @@ func (p *Processor) StartWork(receivedTasks []shared.TaskResponse) {
func (p *Processor) sortTasks(receivedTasks []shared.TaskResponse) map[string][]shared.Task { func (p *Processor) sortTasks(receivedTasks []shared.TaskResponse) map[string][]shared.Task {
sorted := make(map[string][]shared.Task, len(receivedTasks)) sorted := make(map[string][]shared.Task, len(receivedTasks))
for _, task := range receivedTasks { for _, task := range receivedTasks {
log.WithField("task", task).Debug("Sorting tasks")
switch { switch {
case task.OriginSurugayaLink != "": case task.OriginSurugayaLink != "":
sorted[shared.OriginSurugaya] = append(sorted[shared.OriginSurugaya], shared.Task{ sorted[shared.OriginSurugaya] = append(sorted[shared.OriginSurugaya], shared.Task{