diff --git a/packages/indexer/src/indexers/amm-market/amm-market-account-interval-indexer.ts b/packages/indexer/src/indexers/amm-market/amm-market-account-interval-indexer.ts index 7f35a15c..1025a783 100644 --- a/packages/indexer/src/indexers/amm-market/amm-market-account-interval-indexer.ts +++ b/packages/indexer/src/indexers/amm-market/amm-market-account-interval-indexer.ts @@ -41,7 +41,7 @@ export const AmmMarketAccountIntervalFetchIndexer: IntervalFetchIndexer = { } return res; } catch (e) { - logger.error("general error with indexing amm market account info:", e); + logger.errorWithChatBotAlert("general error with indexing amm market account info:", e); return Err({ type: AmmAccountIntervalIndexerError.General }); } }, diff --git a/packages/indexer/src/indexers/amm-market/utils.ts b/packages/indexer/src/indexers/amm-market/utils.ts index 955c80b7..dd5a9a31 100644 --- a/packages/indexer/src/indexers/amm-market/utils.ts +++ b/packages/indexer/src/indexers/amm-market/utils.ts @@ -64,8 +64,8 @@ export async function indexAmmMarketAccountWithContext( updatedSlot: context ? BigInt(context.slot) : BigInt(ammMarketAccount.oracle.lastUpdatedSlot.toNumber()), - lastObservation: ammMarketAccount.oracle.lastObservation, - lastPrice: ammMarketAccount.oracle.lastPrice + lastObservation: ammMarketAccount.oracle.lastObservation.toNumber(), + lastPrice: ammMarketAccount.oracle.lastPrice.toNumber() }; // TODO batch commits across inserts - maybe with event queue