feat: created a query to get the token price based on its latest swap

Author: mschead

indexer/src/kadena-server/config/graphql-types.ts

@@ -765,6 +765,7 @@ export type Query = {
    *       Example of the input needed for a type `code` query: `gasLimitEstimate(input: "{\"code\":\"(coin.details \\\"k:1234\\\")\",\"chainId\":\"3\"}")`
    */
   gasLimitEstimate: Array<GasLimitEstimation>;
+  getTokenPrice?: Maybe<TokenPriceInKda>;
   /** Get the configuration of the graph. */
   graphConfiguration: GraphConfiguration;
   /** Get the height of the block with the highest height. */
@@ -903,6 +904,10 @@ export type QueryGasLimitEstimateArgs = {
   input: Array<Scalars['String']['input']>;
 };
 
+export type QueryGetTokenPriceArgs = {
+  moduleName?: InputMaybe<Scalars['String']['input']>;
+};
+
 export type QueryLiquidityPositionsArgs = {
   after?: InputMaybe<Scalars['String']['input']>;
   before?: InputMaybe<Scalars['String']['input']>;
@@ -1271,6 +1276,11 @@ export type TokenPrice = {
   updatedAt: Scalars['DateTime']['output'];
 };
 
+export type TokenPriceInKda = {
+  __typename?: 'TokenPriceInKda';
+  amount?: Maybe<Scalars['Decimal']['output']>;
+};
+
 /** A transaction. */
 export type Transaction = Node & {
   __typename?: 'Transaction';
@@ -1850,6 +1860,7 @@ export type ResolversTypes = {
   TimeFrame: TimeFrame;
   Token: ResolverTypeWrapper<Token>;
   TokenPrice: ResolverTypeWrapper<TokenPrice>;
+  TokenPriceInKda: ResolverTypeWrapper<TokenPriceInKda>;
   Transaction: ResolverTypeWrapper<
     Omit<Transaction, 'cmd' | 'orphanedTransactions' | 'result'> & {
       cmd: ResolversTypes['TransactionCommand'];
@@ -2113,6 +2124,7 @@ export type ResolversParentTypes = {
   Subscription: {};
   Token: Token;
   TokenPrice: TokenPrice;
+  TokenPriceInKda: TokenPriceInKda;
   Transaction: Omit<Transaction, 'cmd' | 'orphanedTransactions' | 'result'> & {
     cmd: ResolversParentTypes['TransactionCommand'];
     orphanedTransactions?: Maybe<Array<Maybe<ResolversParentTypes['Transaction']>>>;
@@ -3049,6 +3061,12 @@ export type QueryResolvers<
     ContextType,
     RequireFields<QueryGasLimitEstimateArgs, 'input'>
   >;
+  getTokenPrice?: Resolver<
+    Maybe<ResolversTypes['TokenPriceInKda']>,
+    ParentType,
+    ContextType,
+    Partial<QueryGetTokenPriceArgs>
+  >;
   graphConfiguration?: Resolver<ResolversTypes['GraphConfiguration'], ParentType, ContextType>;
   lastBlockHeight?: Resolver<Maybe<ResolversTypes['BigInt']>, ParentType, ContextType>;
   liquidityPositions?: Resolver<
@@ -3495,6 +3513,15 @@ export type TokenPriceResolvers<
   __isTypeOf?: IsTypeOfResolverFn<ParentType, ContextType>;
 };
 
+export type TokenPriceInKdaResolvers<
+  ContextType = any,
+  ParentType extends
+    ResolversParentTypes['TokenPriceInKda'] = ResolversParentTypes['TokenPriceInKda'],
+> = {
+  amount?: Resolver<Maybe<ResolversTypes['Decimal']>, ParentType, ContextType>;
+  __isTypeOf?: IsTypeOfResolverFn<ParentType, ContextType>;
+};
+
 export type TransactionResolvers<
   ContextType = any,
   ParentType extends ResolversParentTypes['Transaction'] = ResolversParentTypes['Transaction'],
@@ -3804,6 +3831,7 @@ export type Resolvers<ContextType = any> = {
   Subscription?: SubscriptionResolvers<ContextType>;
   Token?: TokenResolvers<ContextType>;
   TokenPrice?: TokenPriceResolvers<ContextType>;
+  TokenPriceInKda?: TokenPriceInKdaResolvers<ContextType>;
   Transaction?: TransactionResolvers<ContextType>;
   TransactionCapability?: TransactionCapabilityResolvers<ContextType>;
   TransactionCommand?: TransactionCommandResolvers<ContextType>;

indexer/src/kadena-server/config/schema.graphql

@@ -431,6 +431,8 @@ type Query {
     protocolAddress: String
   ): DexMetrics! @complexity(value: 1)
 
+  getTokenPrice(moduleName: String): TokenPriceInKda
+
   """
   Get price for a specific token
   """
@@ -442,6 +444,10 @@ type Query {
   tokenPrices(protocolAddress: String): [TokenPrice!]! @complexity(value: 1)
 }
 
+type TokenPriceInKda {
+  amount: Decimal
+}
+
 type QueryTransactionsByPactCodeConnection {
   edges: [QueryTransactionsByPactCodeConnectionEdge!]!
   pageInfo: PageInfo!

indexer/src/kadena-server/resolvers/index.ts

@@ -104,6 +104,7 @@ import { transfersNonFungibleChainAccountResolver } from '@/kadena-server/resolv
 import { totalCountNonFungibleChainAccountTransfersConnectionResolver } from '@/kadena-server/resolvers/fields/non-fungible-chain-account/transfers-connection/total-count-non-fungible-chain-account-transfers-connection-resolver';
 import { totalCountQueryBlocksFromHeightConnectionResolver } from '@/kadena-server/resolvers/fields/query-blocks-from-height-connection/total-count-query-blocks-from-height-connection-resolver';
 import { transactionsByPactCodeQueryResolver } from '@/kadena-server/resolvers/query/transactions-by-pact-code-query-resolver';
+import { getTokenPriceQueryResolver } from '@/kadena-server/resolvers/query/get-token-price-resolver';
 /**
  * Complete resolver map for the GraphQL API
  *
@@ -157,6 +158,7 @@ export const resolvers: Resolvers<ResolverContext> = {
     transactionsByPublicKey: transactionsByPublicKeyQueryResolver,
     transfers: transfersQueryResolver,
     tokens: tokensQueryResolver,
+    getTokenPrice: getTokenPriceQueryResolver,
     pool: poolQueryResolver,
     poolTransactions: poolTransactionsQueryResolver,
     liquidityPositions: liquidityPositionsQueryResolver,

indexer/src/kadena-server/resolvers/query/get-token-price-resolver.ts

@@ -0,0 +1,35 @@
+import { rootPgPool } from '@/config/database';
+import { ResolverContext } from '@/kadena-server/config/apollo-server-config';
+import { QueryGetTokenPriceArgs, QueryResolvers } from '@/kadena-server/config/graphql-types';
+import Decimal from 'decimal.js';
+
+export const getTokenPriceQueryResolver: QueryResolvers<ResolverContext>['getTokenPrice'] = async (
+  _parent: unknown,
+  args: QueryGetTokenPriceArgs,
+) => {
+  const query = `
+    SELECT t.result
+    FROM public."Transactions" t
+    WHERE t.result::text LIKE '%' || $1 || '%'
+    ORDER BY t.creationtime DESC, t.id DESC
+    LIMIT 1
+  `;
+
+  const res: any = await rootPgPool.query(query, [args.moduleName]);
+
+  const data = res.rows?.[0]?.result?.data;
+  if (!data?.[0]?.token || !data?.[1]?.token) {
+    return null;
+  }
+
+  const isFirstElementTheKdaToken = data?.[0]?.token === 'coin';
+  const firstValue = data?.[0]?.amount?.decimal ?? data?.[0]?.amount?.integer ?? data?.[0]?.amount;
+  const secondValue = data?.[1]?.amount?.decimal ?? data?.[1]?.amount?.integer ?? data?.[1]?.amount;
+
+  const kadenaValue = isFirstElementTheKdaToken ? firstValue : secondValue;
+  const tokenValue = isFirstElementTheKdaToken ? secondValue : firstValue;
+  const amount = new Decimal(tokenValue).div(new Decimal(kadenaValue)).toNumber();
+  return {
+    amount,
+  };
+};