From 6836b36c55e30a342c49b7932e3477efaa723116 Mon Sep 17 00:00:00 2001
From: Artem <aopoltorzhicky@gmail.com>
Date: Mon, 17 Jan 2022 14:42:53 +0300
Subject: [PATCH] Fix: IPFS queue
---
cmd/metadata/service/contract.go | 4 ++--
cmd/metadata/service/token.go | 3 ++-
2 files changed, 4 insertions(+), 3 deletions(-)
diff --git a/cmd/metadata/service/contract.go b/cmd/metadata/service/contract.go
index 10f568f..b28e3f3 100644
--- a/cmd/metadata/service/contract.go
+++ b/cmd/metadata/service/contract.go
@@ -101,6 +101,8 @@ func (s *ContractService) manager(ctx context.Context) {
continue
}
+ s.queue.Add(contracts[i].ID)
+
if ipfs.Is(contracts[i].Link) {
link, err := s.db.IPFSLinkByURL(contracts[i].Link)
if err == nil {
@@ -115,8 +117,6 @@ func (s *ContractService) manager(ctx context.Context) {
log.Err(err).Msg("contract IPFSLinkByURL")
}
}
-
- s.queue.Add(contracts[i].ID)
s.tasks <- &contracts[i]
}
}
diff --git a/cmd/metadata/service/token.go b/cmd/metadata/service/token.go
index b51a0b3..64aa629 100644
--- a/cmd/metadata/service/token.go
+++ b/cmd/metadata/service/token.go
@@ -101,6 +101,8 @@ func (s *TokenService) manager(ctx context.Context) {
continue
}
+ s.queue.Add(tokens[i].ID)
+
if ipfs.Is(tokens[i].Link) {
link, err := s.repo.IPFSLinkByURL(tokens[i].Link)
if err == nil {
@@ -116,7 +118,6 @@ func (s *TokenService) manager(ctx context.Context) {
}
}
- s.queue.Add(tokens[i].ID)
s.tasks <- &tokens[i]
}
}