From 852fdc27974199ddf4af8e827b9b0a1666dc8637 Mon Sep 17 00:00:00 2001
From: gmbronco <83549293+gmbronco@users.noreply.github.com>
Date: Tue, 5 Dec 2023 18:16:59 +0100
Subject: [PATCH] fix: uncommenting updates

---
 modules/pool/lib/pool-usd-data.service.ts | 89 +++++++++++------------
 1 file changed, 42 insertions(+), 47 deletions(-)

diff --git a/modules/pool/lib/pool-usd-data.service.ts b/modules/pool/lib/pool-usd-data.service.ts
index 9734446d..7125c5d6 100644
--- a/modules/pool/lib/pool-usd-data.service.ts
+++ b/modules/pool/lib/pool-usd-data.service.ts
@@ -287,9 +287,8 @@ export class PoolUsdDataService {
             const lifetimeVolume = Math.min(parseFloat(pool.totalSwapVolume), max);
             const lifetimeSwapFees = Math.min(parseFloat(pool.totalSwapFee), max);
 
-            // updates.push(
-            try {
-                await prisma.prismaPoolDynamicData.update({
+            updates.push(
+                prisma.prismaPoolDynamicData.update({
                     where: { id_chain: { id: pool.id, chain: this.chain } },
                     data: {
                         lifetimeVolume: lifetimeVolume,
@@ -297,56 +296,52 @@ export class PoolUsdDataService {
                         holdersCount: parseInt(pool.holdersCount) + (staked?._count.userAddress || 0),
                         swapsCount: parseInt(pool.swapsCount),
                     },
-                });
-            } catch (e) {
-                console.error(`Error updating lifetime values for pool ${pool.id} (${pool.name})`);
-                throw e;
-            }
-            // );
+                }),
+            );
 
             const snapshots = await prisma.prismaPoolSnapshot.findMany({
                 where: { poolId: pool.id, chain: this.chain },
             });
 
-            // if (snapshots.length > 0) {
-            //     const sharePriceAth = _.orderBy(snapshots, 'sharePrice', 'desc')[0];
-            //     const sharePriceAtl = _.orderBy(snapshots, 'sharePrice', 'asc')[0];
-            //     const totalLiquidityAth = _.orderBy(snapshots, 'totalLiquidity', 'desc')[0];
-            //     const totalLiquidityAtl = _.orderBy(snapshots, 'totalLiquidity', 'asc')[0];
-            //     const volume24hAth = _.orderBy(snapshots, 'volume24h', 'desc')[0];
-            //     const volume24hAtl = _.orderBy(snapshots, 'volume24h', 'asc')[0];
-            //     const fees24hAth = _.orderBy(snapshots, 'fees24h', 'desc')[0];
-            //     const fees24hAtl = _.orderBy(snapshots, 'fees24h', 'asc')[0];
-
-            //     updates.push(
-            //         prisma.prismaPoolDynamicData.update({
-            //             where: { id_chain: { id: pool.id, chain: this.chain } },
-            //             data: {
-            //                 sharePriceAth: sharePriceAth.sharePrice,
-            //                 sharePriceAthTimestamp: sharePriceAth.timestamp,
-            //                 sharePriceAtl: sharePriceAtl.sharePrice,
-            //                 sharePriceAtlTimestamp: sharePriceAtl.timestamp,
-
-            //                 totalLiquidityAth: totalLiquidityAth.totalLiquidity,
-            //                 totalLiquidityAthTimestamp: totalLiquidityAth.timestamp,
-            //                 totalLiquidityAtl: totalLiquidityAtl.totalLiquidity,
-            //                 totalLiquidityAtlTimestamp: totalLiquidityAtl.timestamp,
-
-            //                 volume24hAth: volume24hAth.volume24h,
-            //                 volume24hAthTimestamp: volume24hAth.timestamp,
-            //                 volume24hAtl: volume24hAtl.volume24h,
-            //                 volume24hAtlTimestamp: volume24hAtl.timestamp,
-
-            //                 fees24hAth: fees24hAth.fees24h,
-            //                 fees24hAthTimestamp: fees24hAth.timestamp,
-            //                 fees24hAtl: fees24hAtl.fees24h,
-            //                 fees24hAtlTimestamp: fees24hAtl.timestamp,
-            //             },
-            //         }),
-            //     );
-            // }
+            if (snapshots.length > 0) {
+                const sharePriceAth = _.orderBy(snapshots, 'sharePrice', 'desc')[0];
+                const sharePriceAtl = _.orderBy(snapshots, 'sharePrice', 'asc')[0];
+                const totalLiquidityAth = _.orderBy(snapshots, 'totalLiquidity', 'desc')[0];
+                const totalLiquidityAtl = _.orderBy(snapshots, 'totalLiquidity', 'asc')[0];
+                const volume24hAth = _.orderBy(snapshots, 'volume24h', 'desc')[0];
+                const volume24hAtl = _.orderBy(snapshots, 'volume24h', 'asc')[0];
+                const fees24hAth = _.orderBy(snapshots, 'fees24h', 'desc')[0];
+                const fees24hAtl = _.orderBy(snapshots, 'fees24h', 'asc')[0];
+
+                updates.push(
+                    prisma.prismaPoolDynamicData.update({
+                        where: { id_chain: { id: pool.id, chain: this.chain } },
+                        data: {
+                            sharePriceAth: sharePriceAth.sharePrice,
+                            sharePriceAthTimestamp: sharePriceAth.timestamp,
+                            sharePriceAtl: sharePriceAtl.sharePrice,
+                            sharePriceAtlTimestamp: sharePriceAtl.timestamp,
+
+                            totalLiquidityAth: totalLiquidityAth.totalLiquidity,
+                            totalLiquidityAthTimestamp: totalLiquidityAth.timestamp,
+                            totalLiquidityAtl: totalLiquidityAtl.totalLiquidity,
+                            totalLiquidityAtlTimestamp: totalLiquidityAtl.timestamp,
+
+                            volume24hAth: volume24hAth.volume24h,
+                            volume24hAthTimestamp: volume24hAth.timestamp,
+                            volume24hAtl: volume24hAtl.volume24h,
+                            volume24hAtlTimestamp: volume24hAtl.timestamp,
+
+                            fees24hAth: fees24hAth.fees24h,
+                            fees24hAthTimestamp: fees24hAth.timestamp,
+                            fees24hAtl: fees24hAtl.fees24h,
+                            fees24hAtlTimestamp: fees24hAtl.timestamp,
+                        },
+                    }),
+                );
+            }
         }
 
-        // await prismaBulkExecuteOperations(updates);
+        await prismaBulkExecuteOperations(updates);
     }
 }