Crontab - update code for capture more faster

Author: axe31803

internal/repository/nft_auctions_available.go

@@ -4,7 +4,6 @@ import (
 	"context"
 	"dapp-moderator/internal/entity"
 	"dapp-moderator/utils"
-	"go.mongodb.org/mongo-driver/bson/primitive"
 	"strings"
 	"time"
 
@@ -67,12 +66,13 @@ func (r *Repository) NftWithoutCapturedImage(contractAddress string, offset int,
 		bson.D{
 			{"$match",
 				bson.D{
+					{"token_id", "156"},
 					{"collection_address", strings.ToLower(contractAddress)},
-					{"image_capture_at", bson.D{{"$in", bson.A{
-						"",
-						primitive.Null{},
-					},
-					}}},
+					//{"image_capture_at", bson.D{{"$in", bson.A{
+					//	"",
+					//	primitive.Null{},
+					//},
+					//}}},
 				},
 			},
 		},

internal/repository/soul_image_histories.go

@@ -19,11 +19,14 @@ func (r *Repository) InsertSoulImageHistory(obj *entity.SoulImageHistories) erro
 }
 
 // aggregate data to view_soul_nfts
-func (r *Repository) PrepareSoulData(wg *sync.WaitGroup) error {
+func (r *Repository) PrepareSoulData(wg *sync.WaitGroup, nfts []string) error {
 	defer wg.Done()
 
 	fAll := bson.A{
-		bson.D{{"$match", bson.D{{"collection_address", strings.ToLower(os.Getenv("SOUL_CONTRACT"))}}}},
+		bson.D{{"$match", bson.D{
+			{"collection_address", strings.ToLower(os.Getenv("SOUL_CONTRACT"))},
+			{"token_id", bson.M{"$in": nfts}},
+		}}},
 		bson.D{
 			{"$lookup",
 				bson.D{

internal/usecase/soul_nft_image.go

@@ -80,6 +80,11 @@ func (u *Usecase) SoulNftImageCrontab() error {
 			break
 		}
 
+		tokenIDs := []string{}
+		for _, nft := range nfts {
+			tokenIDs = append(tokenIDs, nft.TokenID)
+		}
+
 		var wg1 sync.WaitGroup
 		var wg2 sync.WaitGroup
 		var wg3 sync.WaitGroup
@@ -127,7 +132,7 @@ func (u *Usecase) SoulNftImageCrontab() error {
 					ReplacedTraits:   soulImage.ReplacedTraits,
 				})
 
-				if len(*soulImage.ReplacedTraits) == 0 { //only use the original replaced
+				if len(*soulImage.ReplacedTraits) == 1 { //only use the original replaced
 					wg3.Add(1)
 					image := output[0].CapturedImage
 					traits := output[0].Traits
@@ -147,7 +152,7 @@ func (u *Usecase) SoulNftImageCrontab() error {
 					//send discord notification
 					out.Nft.Image = image
 					out.Nft.ImageCapture = image
-					u.NewSoulTokenMintedNotify(&out.Nft)
+					//u.NewSoulTokenMintedNotify(&out.Nft)
 				}
 			}
 
@@ -160,7 +165,7 @@ func (u *Usecase) SoulNftImageCrontab() error {
 		//load data for homepage
 		wgPrepareData := sync.WaitGroup{}
 		wgPrepareData.Add(1)
-		go u.Repo.PrepareSoulData(&wgPrepareData)
+		go u.Repo.PrepareSoulData(&wgPrepareData, tokenIDs)
 		wgPrepareData.Wait()
 
 		page++
@@ -280,7 +285,7 @@ func (u *Usecase) SoulNftImageHistoriesCrontab(specialNfts []string) error {
 
 		wgPrepareData := sync.WaitGroup{}
 		wgPrepareData.Add(1)
-		go u.Repo.PrepareSoulData(&wgPrepareData)
+		go u.Repo.PrepareSoulData(&wgPrepareData, tokenIDs)
 		wgPrepareData.Wait()
 
 		page++