Fix: IPFS queue

dipdup-io · Jan 17, 2022 · 6836b36 · 6836b36
1 parent a4d18d7
commit 6836b36
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git 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
@@ -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]
 			}
 		}