[SERVICES-2465] Fix tokens previous 7 days price

src/modules/tokens/models/tokens.filter.args.ts

@@ -7,6 +7,7 @@ export enum TokensSortableFields {
     PREVIOUS_24H_PRICE = 'previous_24h_price',
     PREVIOUS_7D_PRICE = 'previous_7d_price',
     PREVIOUS_24H_VOLUME = 'previous_24h_volume',
+    PRICE_CHANGE_7D = 'price_change_7d',
     PRICE_CHANGE_24H = 'price_change_24h',
     VOLUME_CHANGE_24H = 'volume_change_24h',
     TRADES_COUNT_CHANGE_24H = 'trades_count_change_24h',

src/modules/tokens/services/token.compute.service.ts

@@ -281,6 +281,22 @@ export class TokenComputeService implements ITokenComputeService {
         return currentPriceBN.dividedBy(previous24hPrice).toNumber();
     }
 
+    async computeTokenPriceChange7d(tokenID: string): Promise<number> {
+        const [currentPrice, previous7dPrice] = await Promise.all([
+            this.tokenPriceDerivedUSD(tokenID),
+            this.tokenPrevious7dPrice(tokenID),
+        ]);
+
+        const currentPriceBN = new BigNumber(currentPrice);
+        const previous7dPriceBN = new BigNumber(previous7dPrice);
+
+        if (previous7dPriceBN.isZero()) {
+            return 0;
+        }
+
+        return currentPriceBN.dividedBy(previous7dPriceBN).toNumber();
+    }
+
     @ErrorLoggerAsync({
         logArgs: true,
     })

src/modules/tokens/services/token.service.ts

@@ -228,6 +228,13 @@ export class TokenService {
                     ),
                 );
                 break;
+            case TokensSortableFields.PRICE_CHANGE_7D:
+                sortFieldData = await Promise.all(
+                    tokenIDs.map((tokenID) =>
+                        this.tokenCompute.computeTokenPriceChange7d(tokenID),
+                    ),
+                );
+                break;
             case TokensSortableFields.PRICE_CHANGE_24H:
                 sortFieldData = await Promise.all(
                     tokenIDs.map((tokenID) =>

src/services/analytics/timescaledb/timescaledb.query.service.ts

@@ -127,7 +127,7 @@ export class TimescaleDBQueryService implements AnalyticsQueryInterface {
                 .select("time_bucket_gapfill('1 day', time) as day")
                 .addSelect(
                     `locf(last(last, time) ${
-                        start ? `, (${previousValue.getQuery()})` : ''
+                        start || time ? `, (${previousValue.getQuery()})` : ''
                     }) as last`,
                 )
                 .where('series = :series', { series })