chore: update configuration for token price feature

Author: ae2079

package.json

@@ -40,6 +40,7 @@ import { SwapTransaction } from './swapTransaction';
 import { QaccPointsHistory } from './qaccPointsHistory';
 import { UserRankMaterializedView } from './userRanksMaterialized';
 import { VestingData } from './vestingData';
+import { TokenPriceHistory } from './tokenPriceHistory';
 
 export const getEntities = (): DataSourceOptions['entities'] => {
   return [
@@ -93,5 +94,6 @@ export const getEntities = (): DataSourceOptions['entities'] => {
     SwapTransaction,
     UserRankMaterializedView,
     VestingData,
+    TokenPriceHistory,
   ];
 };

src/entities/entities.ts

@@ -17,6 +17,7 @@ import { OnboardingFormResolver } from './onboardingFormResolver';
 import { RoundsResolver } from './roundsResolver';
 import { QAccResolver } from './qAccResolver';
 import { QaccPointsHistoryResolver } from './qaccPointsHistoryResolver';
+import { TokenPriceResolver } from './tokenPriceResolver';
 
 // eslint-disable-next-line @typescript-eslint/ban-types
 export const getResolvers = (): Function[] => {
@@ -44,5 +45,6 @@ export const getResolvers = (): Function[] => {
 
     QAccResolver,
     QaccPointsHistoryResolver,
+    TokenPriceResolver,
   ];
 };

src/resolvers/resolvers.ts

@@ -67,6 +67,7 @@ import { ChainType } from '../types/network';
 import { runSyncDataWithInverter } from '../services/cronJobs/syncDataWithInverter';
 import { runSyncWithAnkrTransfers } from '../services/cronJobs/syncWithAnkrTransfers';
 import { runCheckPendingSwapsCronJob } from '../services/cronJobs/syncSwapTransactions';
+import { startTokenPriceCron } from '../services/cronJobs/tokenPriceCron';
 
 Resource.validate = validate;
 
@@ -164,6 +165,8 @@ export async function bootstrap() {
 
     // runUpdateUserRanksCronJob();
 
+    startTokenPriceCron();
+
     if (process.env.ENABLE_IMPORT_LOST_DONATIONS === 'true') {
       runSyncLostDonations();
     }

src/server/bootstrap.ts

@@ -5,6 +5,7 @@ import { NonEmptyArray } from 'type-graphql';
 import { userCheck } from '../auth/userCheck';
 import { getResolvers } from '../resolvers/resolvers';
 import config from '../config';
+import { DateTimeScalar } from '../scalars/dateTime';
 
 const createSchema = async (): Promise<GraphQLSchema> => {
   // James: removing for safety. We shouldn't need to do this again except on a local dev machine
@@ -25,6 +26,7 @@ const createSchema = async (): Promise<GraphQLSchema> => {
       forbidUnknownValues: false,
       enableDebugMessages: environment !== 'production',
     },
+    scalarsMap: [{ type: Date, scalar: DateTimeScalar }],
   });
   return schema;
 };

src/server/createSchema.ts

@@ -2288,3 +2288,29 @@ query donationsByQfRoundId($qfRoundId: Int!) {
   }
 }
 `;
+
+export const getTokenPriceHistoryQuery = `
+  query GetTokenPriceHistory($tokenAddress: String!, $startTime: DateTime, $endTime: DateTime) {
+    getTokenPriceHistory(tokenAddress: $tokenAddress, startTime: $startTime, endTime: $endTime) {
+      token
+      tokenAddress
+      price
+      priceUSD
+      marketCap
+      timestamp
+    }
+  }
+`;
+
+export const getTokenMarketCapChanges24hQuery = `
+  query GetTokenMarketCapChanges24h($tokenAddress: String!) {
+    getTokenMarketCapChanges24h(tokenAddress: $tokenAddress) {
+      token
+      tokenAddress
+      price
+      priceUSD
+      marketCap
+      timestamp
+    }
+  }
+`;