add latest ts for setOracles to timestamps

D8-X · Jan 11, 2025 · bb7ceda · bb7ceda
1 parent c8a84c9
commit bb7ceda
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 2 deletions.
diff --git a/packages/history/src/db/set_oracles.ts b/packages/history/src/db/set_oracles.ts
@@ -116,5 +116,19 @@ export class SetOracles {
 		}
     }
 
+	/**
+	 * Retrieve latest timestamp of SetOracles event
+	 */
+	public async getLatestTimestamp(): Promise<Date | undefined> {
+		const res = await this.prisma.perpetualLongId.findFirst({
+			select: {
+				valid_from: true,
+			},
+			orderBy: {
+				valid_from: "desc",
+			}
+		});
+		return res?.valid_from;
+	}
 
 }//class
diff --git a/packages/history/src/svc/main.ts b/packages/history/src/svc/main.ts
@@ -156,12 +156,13 @@ export const main = async () => {
 		dbLPWithdrawals,
 		dbPriceInfo,
 		dbTrades,
+		dbSetOracles,
 		httpProvider,
 		proxyContractAddr,
 		staticInfo: staticInfo,
 		eventListener: eventsListener,
 	};
-	await runHistoricalDataFilterers(hdOpts);
+	runHistoricalDataFilterers(hdOpts);
 
 	eventsListener.listen(wsProvider);
 
@@ -282,6 +283,7 @@ export interface hdFilterersOpt {
 	httpProvider: ethers.Provider;
 	proxyContractAddr: string;
 	dbTrades: TradingHistory;
+	dbSetOracles: SetOracles;
 	dbFundingRatePayments: FundingRatePayments;
 	dbEstimatedEarnings: EstimatedEarnings;
 	dbPriceInfo: PriceInfo;
@@ -295,6 +297,7 @@ export async function runHistoricalDataFilterers(opts: hdFilterersOpt) {
 		httpProvider,
 		proxyContractAddr,
 		dbTrades,
+		dbSetOracles,
 		dbFundingRatePayments,
 		dbEstimatedEarnings,
 		dbPriceInfo,
@@ -317,7 +320,7 @@ export async function runHistoricalDataFilterers(opts: hdFilterersOpt) {
 		(await dbTrades.getLatestLiquidateTimestamp()) ?? defaultDate,
 		(await dbFundingRatePayments.getLatestTimestamp()) ?? defaultDate,
 		(await dbEstimatedEarnings.getLatestTimestamp("liquidity_added")) ?? defaultDate,
-		defaultDate
+		(await dbSetOracles.getLatestTimestamp()) ?? defaultDate,
 	];
 	// Use the smallest timestamp for the start of the filter
 	let ts = tsArr.reduce(function (a, b) {