From df777da631bdae4995820df1cebc3b37356254d4 Mon Sep 17 00:00:00 2001
From: skakac <uncut.wz@gmail.com>
Date: Fri, 25 Oct 2024 18:43:15 +0200
Subject: [PATCH] Skip deletion and smaller chunks

---
 src/jobs/sync.job.ts | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

diff --git a/src/jobs/sync.job.ts b/src/jobs/sync.job.ts
index 84bd7ec..afe4f80 100644
--- a/src/jobs/sync.job.ts
+++ b/src/jobs/sync.job.ts
@@ -52,9 +52,10 @@ async function handle() {
         (token) => `${token.address}:${token.chainId}`
     )
 
-    const deleteTokens = currentTokens.filter((token) => {
-        return !newMints.includes(`${token.address}:${token.chainId}`)
-    })
+    const deleteTokens = [];
+    // currentTokens.filter((token) => {
+    //     return !newMints.includes(`${token.address}:${token.chainId}`)
+    // })
 
     const updateTokens = currentTokens.filter((token) => {
         return newMints.includes(`${token.address}:${token.chainId}`)
@@ -93,7 +94,7 @@ async function handle() {
     // }
 
 
-    const insertTokensBatches = _.chunk(insertTokens, 4000);
+    const insertTokensBatches = _.chunk(insertTokens, 2000);
     for (const insertTokensBatch of insertTokensBatches) {
         session = await mongoose.connection.startSession()
         try {
@@ -131,7 +132,7 @@ async function handle() {
         }
     }
 
-    const updateTokensBatches = _.chunk(updateTokens, 4000);
+    const updateTokensBatches = _.chunk(updateTokens, 1000);
     for (const updateTokensBatch of updateTokensBatches) {
         session = await mongoose.connection.startSession()
         try {