Merge pull request #366 from hack-a-chain-software/old-graphql

refactor: removed old graphql code

Author: 0xneves

README.md

@@ -4,7 +4,6 @@
 [![Lint](https://github.com/hack-a-chain-software/indexer-kadena/actions/workflows/lint.yml/badge.svg)](https://github.com/hack-a-chain-software/indexer-kadena/actions/workflows/lint.yml)
 
 - [`@kadena-indexer/indexer`](indexer/README.md): The indexer package, which is responsible for scanning and storing blocks for Kadena blockchain.
-- [`@kadena-indexer/terraform`](terraform/README.md): The Terraform configuration for provisioning the infrastructure required to run the indexer and the node.
 - [`@kadena-indexer/backfill`](backfill/README.md): The backfill package, which is responsible for backfilling the indexer data.
 
 ## Requirements

indexer/package.json

@@ -39,8 +39,6 @@
     "papaparse": "^5.5.2",
     "pg": "^8.11.3",
     "pg-hstore": "^2.3.4",
-    "postgraphile": "^4.13.0",
-    "postgraphile-plugin-connection-filter": "^2.3.0",
     "prom-client": "^15.1.0",
     "sequelize": "^6.37.0",
     "subscriptions-transport-ws": "^0.11.0",

indexer/src/index.ts

@@ -3,7 +3,7 @@
  * This file orchestrates the initialization and execution of various services based on command line arguments.
  * The indexer supports multiple operation modes:
  * - Streaming blockchain data
- * - Running GraphQL servers (both Postgraphile and Kadena schema based)
+ * - Running GraphQL server
  * - Backfilling guards
  * - Processing missing blocks
  * - Database initialization
@@ -44,9 +44,8 @@ const options = program.opts();
  * The function handles different operational modes:
  * - Database initialization
  * - Blockchain data streaming
- * - Guard backfilling
- * - Missing blocks processing
- * - GraphQL server initialization (both Postgraphile and Kadena schema versions)
+ * - Token Pairs backfilling
+ * - GraphQL server initialization
  *
  * TODO: [OPTIMIZATION] Consider implementing a more modular approach for service initialization
  * that would allow easier addition of new services without modifying this main function.

indexer/src/models/balance.ts

@@ -18,7 +18,6 @@
 import { Model, DataTypes, Optional } from 'sequelize';
 import { sequelize } from '../config/database';
 import Contract from './contract';
-import { gql, makeExtendSchemaPlugin } from 'postgraphile';
 
 /**
  * Interface defining the attributes of a Balance.
@@ -219,103 +218,4 @@ Balance.belongsTo(Contract, {
   as: 'contract',
 });
 
-/**
- * GraphQL extension plugin for querying token holders.
- *
- * This plugin extends the GraphQL schema to provide a specialized endpoint
- * for retrieving token holder information for a specific module/contract.
- * It includes pagination support for handling large token holder lists
- * efficiently and provides calculated percentage ownership statistics.
- *
- * The resolver calls a database function that optimizes holder calculations
- * and pagination for better performance.
- *
- * The makeExtendSchemaPlugin function is a PostGraphile utility that:
- * 1. Allows extending the auto-generated GraphQL schema with custom queries and types
- * 2. Provides type safety and integration with PostGraphile's plugin system
- * 3. Maintains compatibility with PostGraphile's existing resolvers and connections
- * 4. Enables custom database access patterns while preserving GraphQL conventions
- *
- * In this implementation, it creates:
- * - A 'getHolders' query that accepts pagination parameters and a moduleName
- * - Custom types for the response structure following Relay connection specifications
- * - A resolver that calls a specialized database function for optimal performance
- */
-export const getHoldersPlugin = makeExtendSchemaPlugin(build => {
-  return {
-    typeDefs: gql`
-      extend type Query {
-        getHolders(
-          moduleName: String!
-          before: String
-          after: String
-          first: Int
-          last: Int
-        ): HolderResponse
-      }
-
-      type HolderResponse {
-        edges: [HolderEdge]
-        pageInfo: PageInfo
-        totalCount: Int
-      }
-
-      type HolderEdge {
-        cursor: String
-        node: HolderNode
-      }
-
-      type HolderNode {
-        address: String
-        quantity: Float
-        percentage: Float
-      }
-    `,
-    resolvers: {
-      Query: {
-        getHolders: async (_query, args, context, _resolveInfo) => {
-          const { moduleName, before, after, first, last } = args;
-          const { rootPgPool } = context;
-
-          // Call the specialized database function with cursor-based pagination parameters
-          const { rows } = await rootPgPool.query(
-            `SELECT * FROM get_holders_by_module($1::VARCHAR, $2::VARCHAR, $3::VARCHAR, $4::INT, $5::INT)`,
-            [moduleName, before, after, first, last],
-          );
-
-          // Transform the database results into Relay-compatible connection format
-          const holders = rows.map((row: any) => ({
-            cursor: Buffer.from(row.row_id.toString()).toString('base64'),
-            node: {
-              address: row.address,
-              quantity: row.quantity,
-              percentage: row.percentage,
-            },
-          }));
-
-          // Calculate pagination metadata based on results
-          const hasNextPage = first ? holders.length === first : false;
-          const hasPreviousPage = last ? holders.length === last : !!after;
-
-          const endCursor = hasNextPage ? holders[holders.length - 1].cursor : null;
-          const startCursor = holders.length > 0 ? holders[0].cursor : null;
-          const totalCount = holders.length;
-
-          // Return a properly structured Relay connection response
-          return {
-            edges: holders,
-            pageInfo: {
-              endCursor,
-              hasNextPage,
-              hasPreviousPage,
-              startCursor,
-            },
-            totalCount,
-          };
-        },
-      },
-    },
-  };
-});
-
 export default Balance;

indexer/src/models/block.ts

@@ -5,13 +5,10 @@
  * Each block contains metadata about the block itself, references to related blocks,
  * and cryptographic information needed for blockchain verification.
  *
- * The module also exports a PostGraphile plugin that extends the GraphQL schema
- * with custom block queries for API consumers.
  */
 
 import { Model, DataTypes } from 'sequelize';
 import { sequelize } from '../config/database';
-import { gql, makeExtendSchemaPlugin } from 'postgraphile';
 
 /**
  * Interface defining the attributes of a Block.
@@ -250,121 +247,4 @@ Block.init(
   },
 );
 
-/**
- * PostGraphile plugin that extends the GraphQL schema with custom Block queries.
- * This allows API consumers to query blocks by height and perform search operations
- * across blocks, transactions, addresses, and tokens.
- *
- * TODO: [OPTIMIZATION] Consider implementing caching mechanisms for frequently used queries
- * to improve API response times.
- */
-export const blockQueryPlugin = makeExtendSchemaPlugin(build => {
-  return {
-    typeDefs: gql`
-      extend type Query {
-        blockByHeight(height: Int!, chainId: Int!): Block
-        searchAll(searchTerm: String!, limit: Int!, heightFilter: Int): SearchAllResult
-      }
-
-      type SearchAllResult {
-        blocks: [Block]
-        transactions: [Transaction]
-        addresses: [Balance]
-        tokens: [Contract]
-      }
-    `,
-    resolvers: {
-      Query: {
-        /**
-         * Resolver to find a block by its height and chain ID.
-         * Uses a direct SQL query for optimal performance.
-         */
-        blockByHeight: async (_query, args, context, resolveInfo) => {
-          const { height, chainId } = args;
-          const { rootPgPool } = context;
-          const { rows } = await rootPgPool.query(
-            `SELECT * FROM public."Blocks" WHERE height = $1 AND "chainId" = $2`,
-            [height, chainId],
-          );
-          return rows[0];
-        },
-
-        /**
-         * Resolver for the searchAll query that searches across multiple entities.
-         * Performs parallel queries for different entity types and combines the results.
-         *
-         * TODO: [OPTIMIZATION] This function performs multiple separate queries that could
-         * potentially be optimized or consolidated for better performance.
-         */
-        searchAll: async (_query, args, context, resolveInfo) => {
-          const { searchTerm, limit, heightFilter } = args;
-          const { rootPgPool } = context;
-
-          // Query to search for blocks by various hash fields
-          const blocksQuery = `
-          SELECT * FROM public."Blocks" WHERE LOWER(hash) = LOWER($1) 
-          UNION ALL
-          SELECT * FROM public."Blocks" WHERE LOWER(parent) = LOWER($1) 
-          UNION ALL
-          SELECT * FROM public."Blocks" WHERE LOWER("payloadHash") = LOWER($1) 
-          UNION ALL
-          SELECT * FROM public."Blocks" WHERE LOWER("transactionsHash") = LOWER($1) 
-          UNION ALL
-          SELECT * FROM public."Blocks" WHERE LOWER("outputsHash") = LOWER($1) 
-          UNION ALL
-          SELECT * FROM public."Blocks" WHERE height = $3
-          LIMIT $2;
-        `;
-
-          // Query to search for transactions by various identifiers
-          const transactionsQuery = `
-          SELECT * FROM public."Transactions" WHERE LOWER(requestkey) = LOWER($1)
-          UNION ALL
-          SELECT * FROM public."Transactions" WHERE LOWER(txid) = LOWER($1)
-          UNION ALL
-          SELECT * FROM public."Transactions" WHERE LOWER(pactid) = LOWER($1)
-          UNION ALL
-          SELECT * FROM public."Transactions" WHERE LOWER(sender) = LOWER($1)
-          LIMIT $2;
-        `;
-
-          // Query to search for accounts/addresses
-          const addressesQuery = `
-          SELECT DISTINCT account, module, qualname, network, -1 as "chainId"
-          FROM public."Balances"
-          WHERE LOWER(account) = LOWER($1)
-          ORDER BY account ASC
-          LIMIT $2
-        `;
-
-          // Query to search for token contracts
-          const tokensQuery = `
-          SELECT DISTINCT network, type, module, precision, -1 as "chainId" 
-          FROM public."Contracts"
-          WHERE (type = 'fungible' OR type = 'poly-fungible')
-            AND LOWER(module) LIKE LOWER($1)
-          LIMIT $2
-        `;
-
-          // Execute all queries in parallel for better performance
-          const [blocks, transactions, addresses, tokens] = await Promise.all([
-            rootPgPool.query(blocksQuery, [`${searchTerm}`, limit, heightFilter]),
-            rootPgPool.query(transactionsQuery, [`${searchTerm}`, limit]),
-            rootPgPool.query(addressesQuery, [`${searchTerm}`, limit]),
-            rootPgPool.query(tokensQuery, [`%${searchTerm}%`, limit]),
-          ]);
-
-          // Combine and return the search results
-          return {
-            blocks: blocks.rows,
-            transactions: transactions.rows,
-            addresses: addresses.rows,
-            tokens: tokens.rows,
-          };
-        },
-      },
-    },
-  };
-});
-
 export default Block;