use raw query to delete old token prices

balancer · Jan 12, 2024 · dca33da · dca33da
1 parent 339fc55
commit dca33da
Showing 1 changed file with 3 additions and 21 deletions.
diff --git a/modules/token/lib/token-price.service.ts b/modules/token/lib/token-price.service.ts
@@ -256,28 +256,10 @@ export class TokenPriceService {
     }
 
     public async purgeOldTokenPricesForAllChains(): Promise<number> {
-        const purgeBeforeTimestamp = moment().startOf('day').subtract(180, 'days').utc().unix();
-        const oldPrices = await prisma.prismaTokenPrice.findMany({
-            where: {
-                timestamp: { lt: purgeBeforeTimestamp },
-            },
-        });
-
-        // returns all non midnight prices
-        const tobeDeleted = _.uniq(oldPrices.filter((tokenPrice) => tokenPrice.timestamp % secondsPerDay !== 0));
-
-        //apparently prisma has a limitation on delete
-        const chunks = _.chunk(tobeDeleted, 1000);
-
-        for (const chunk of chunks) {
-            await prisma.prismaTokenPrice.deleteMany({
-                where: {
-                    timestamp: { in: chunk.map((tokenPrice) => tokenPrice.timestamp) },
-                },
-            });
-        }
+        const deleted =
+            await prisma.$executeRaw`DELETE FROM "PrismaTokenPrice" WHERE DATE(to_timestamp(timestamp)) != to_timestamp(timestamp) AND to_timestamp(timestamp) < CURRENT_DATE - INTERVAL '100 days'`;
 
-        return tobeDeleted.length;
+        return deleted;
     }
 
     private async updateCandleStickData() {