Merge branch 'main' into release/4.0

Author: igorls

.github/workflows/dev.yml

@@ -0,0 +1,21 @@
+name: DEV Build with Node.js CI
+
+on:
+  push:
+    branches: [ "3.5.0-esm" ]
+
+jobs:
+  build:
+    runs-on: ubuntu-latest
+    strategy:
+      matrix:
+        node-version: [22.x, 23.x]
+    steps:
+    - uses: actions/checkout@v4
+    - name: Use Node.js ${{ matrix.node-version }}
+      uses: actions/setup-node@v4
+      with:
+        node-version: ${{ matrix.node-version }}
+        cache: 'npm'
+    - run: npm ci --ignore-scripts
+    - run: npm run build

api/routes/v2-state/get_top_holders/get_top_holders.ts

@@ -0,0 +1,63 @@
+import { timedQuery } from "../../../helpers/functions";
+import { FastifyInstance, FastifyReply, FastifyRequest } from "fastify";
+import { getSkipLimit } from "../../v2-history/get_actions/functions";
+
+async function getTopHolders(fastify: FastifyInstance, request: FastifyRequest) {
+
+    const query: any = request.query;
+
+    const response: any = {
+        contract: query.contract,
+        symbol: undefined,
+        holders: []
+    };
+
+    const { skip, limit } = getSkipLimit(request.query);
+
+    const maxDocs = fastify.manager.config.api.limits.get_top_holders ?? 500;
+
+    const terms: any[] = [];
+
+
+    if (query.contract) {
+        terms.push({ "term": { "code": { "value": query.contract } } });
+    }
+
+    if (query.symbol) {
+        terms.push({ "term": { "symbol": { "value": query.symbol } } });
+        response.symbol = query.symbol;
+    }
+
+
+    const stateResult = await fastify.elastic.search<any>({
+        "index": fastify.manager.chain + '-table-accounts-*',
+        "size": (limit > maxDocs ? maxDocs : limit) || 50,
+        "from": skip || 0,
+        body: {
+            sort: {
+                amount: {
+                    order: "desc"
+                }
+            },
+            query: { bool: { "must": terms } }
+        }
+    });
+
+    response.holders = stateResult.body.hits.hits.map((doc: any) => {
+        return {
+            owner: doc._source.scope,
+            amount: doc._source.amount,
+            symbol: doc._source.symbol,
+            updated_on: doc._source.block_num
+        };
+    });
+
+    return response;
+
+}
+
+export function getTopHoldersHandler(fastify: FastifyInstance, route: string) {
+    return async (request: FastifyRequest, reply: FastifyReply) => {
+        reply.send(await timedQuery(getTopHolders, fastify, request, route));
+    }
+}

api/routes/v2-state/get_top_holders/index.ts

@@ -0,0 +1,31 @@
+import {FastifyInstance} from "fastify";
+import {addApiRoute, extendQueryStringSchema, getRouteName} from "../../../helpers/functions";
+import { getTopHoldersHandler } from "./get_top_holders";
+
+export default function (fastify: FastifyInstance, opts: any, next) {
+    const schema = {
+        description: 'get the list of top holders for a given token',
+        summary: 'get top token holders',
+        tags: ['accounts'],
+        querystring: extendQueryStringSchema({
+            "contract": {
+                description: 'token contract account name',
+                type: 'string',
+                minLength: 1,
+                maxLength: 12
+            },
+            "symbol": {
+                    description: 'filter by token symbol',
+                    type: 'string'
+                },
+        }, ["contract"])
+    };
+    addApiRoute(
+        fastify,
+        'GET',
+        getRouteName(__filename),
+        getTopHoldersHandler,
+        schema
+    );
+    next();
+}

package-lock.json

@@ -24,7 +24,7 @@
   },
   "license": "MIT",
   "dependencies": {
-    "@elastic/elasticsearch": "9.0.2",
+    "@elastic/elasticsearch":"9.0.3",
     "@eosrio/node-abieos": "4.0.2-2039717",
     "@eosrio/hyperion-plugin-core": "^0.1.0",
     "@fastify/autoload": "6.3.1",