Merge pull request #309 from cardanoapi/feat/active-delegators

reeshavacharya · web-flow · commit 88dd505c96aa · 2025-01-17T10:15:36.000+05:45
Feat/active delegators
diff --git a/dbsync-api/src/controllers/drep.ts b/dbsync-api/src/controllers/drep.ts
@@ -8,6 +8,8 @@ import {
     fetchDrepActiveDelegation,
     fetchDrepRegistrationDetails,
     fetchDrepVoteDetails,
+    fetchDrepActiveDelegators,
+    fetchDrepDelegationHistory,
 } from '../repository/drep'
 import { DrepSortType, DrepStatusType } from '../types/drep'
 
@@ -46,7 +48,7 @@ const getDrepDelegationDetails = async (req: Request, res: Response) => {
     if (dRepId && !isHexValue(dRepId)) {
         return res.status(400).json({ message: 'Provide a valid Drep ID' })
     }
-    const result = await fetchDrepDelegationDetails(dRepId)
+    const result = await fetchDrepDelegationHistory(dRepId)
     return res.status(200).json(result)
 }
 
@@ -68,11 +70,21 @@ const getDrepActiveDelegation = async (req: Request, res: Response) => {
     return res.status(200).json(result)
 }
 
+const getDrepActiveDelegators = async (req: Request, res: Response) => {
+    const dRepId = convertToHexIfBech32(req.params.id as string)
+    if (dRepId && !isHexValue(dRepId)) {
+        return res.status(400).json({ message: 'Provide a valid Drep ID' })
+    }
+    const activeDelegators = await fetchDrepActiveDelegators(dRepId)
+    return res.status(200).json(activeDelegators)
+}
+
 router.get('/', handlerWrapper(getDrepList))
 router.get('/:id', handlerWrapper(getDrepDetails))
 router.get('/:id/vote', handlerWrapper(getDrepVoteDetails))
 router.get('/:id/delegation', handlerWrapper(getDrepDelegationDetails))
 router.get('/:id/registration', handlerWrapper(getDrepRegistrationDetails))
-router.get('/:id/active-delegation', handlerWrapper(getDrepActiveDelegation))
+router.get('/:id/live-delegation', handlerWrapper(getDrepActiveDelegation))
+router.get('/:id/live-delegators', handlerWrapper(getDrepActiveDelegators))
 
 export default router
diff --git a/dbsync-api/src/helpers/validator.ts b/dbsync-api/src/helpers/validator.ts
@@ -25,6 +25,10 @@ export function validateHash(value:string) {
   }else return regex.test(value)
 }
 
+export function fromHex(prefix: string, hex: string) {
+  return bech32.encode(prefix, bech32.toWords(Buffer.from(hex, "hex")));
+}
+
 export function validateAddress(value: string): boolean {
   if (isHexValue(value)){
     return value.length === 56 || value.length === 58
diff --git a/dbsync-api/src/repository/drep.ts b/dbsync-api/src/repository/drep.ts
@@ -2,7 +2,7 @@ import { prisma } from '../config/db'
 import { Prisma } from '@prisma/client'
 import { combineArraysWithSameObjectKey, formatResult } from '../helpers/formatter'
 import { DrepSortType, DrepStatusType } from '../types/drep'
-import { isHexValue } from '../helpers/validator'
+import { fromHex, isHexValue } from '../helpers/validator'
 
 export const fetchDrepList = async (page = 1, size = 10, search = '', status?: DrepStatusType, sort?: DrepSortType) => {
     const result = (await prisma.$queryRaw`
@@ -352,6 +352,7 @@ export const fetchDrepVoteDetails = async (dRepId: string) => {
     return result[0].votes
 }
 
+// drep delegation historty
 export const fetchDrepDelegationDetails = async (dRepId: string) => {
     const delegateDetails = prisma.$queryRaw`
       with delegator as (select *, ROW_NUMBER() OVER (PARTITION BY addr_id order by tx_id desc) AS rn
@@ -459,77 +460,71 @@ export const fetchDrepRegistrationDetails = async (dRepId: string) => {
 
 export const fetchDrepActiveDelegation = async (drepId: string) => {
     const result = (await prisma.$queryRaw`
-        WITH latest AS (
+        WITH liveRecord AS (WITH latest AS (
+            WITH stakes AS (
+                SELECT DISTINCT sa.id AS id, sa.view AS stakeAddress
+                FROM delegation_vote dv
+                JOIN drep_hash dh ON dh.id = dv.drep_hash_id
+                JOIN stake_address sa ON sa.id = dv.addr_id
+                WHERE dh.raw = DECODE(${drepId}, 'hex')
+            )
             SELECT 
-                sa.view AS stake_view,
-                dh.view AS dh_view,
-                sa.id AS stake_addr_id,
-                dh.raw,
-                dh.id,
-                ROW_NUMBER() OVER (PARTITION BY sa.id ORDER BY dv.tx_id DESC) AS rn
-            FROM stake_address sa
-            JOIN delegation_vote dv ON sa.id = dv.addr_id
-            JOIN drep_hash dh ON dh.id = dv.drep_hash_id
-            ORDER BY dv.tx_id DESC
+                stakes.stakeAddress,
+                stakes.id
+            FROM stakes
+            JOIN LATERAL (
+                SELECT 
+                    ENCODE(tx.hash, 'hex') AS tx_id,
+                    b.epoch_no,
+                    b.time,
+                    dh.raw AS raw_check
+                FROM delegation_vote dv
+                JOIN drep_hash dh ON dh.id = dv.drep_hash_id
+                JOIN tx ON tx.id = dv.tx_id
+                JOIN block b ON b.id = tx.block_id
+                WHERE dv.addr_id = stakes.id
+                ORDER BY dv.tx_id DESC
+                LIMIT 1
+            ) AS subquery ON subquery.raw_check = DECODE(${drepId}, 'hex')
+            GROUP BY stakes.stakeAddress, stakes.id
+            ORDER BY stakes.id
         )
         SELECT 
-            dh.view, 
-            latest.stake_view, 
-            SUM(uv.value) AS total_value,
-            (SELECT SUM(amount) 
+            COUNT(DISTINCT(latest.stakeAddress)) AS activeDelegators,
+            COALESCE(SUM(uv.value), 0) + 
+            COALESCE((
+                SELECT SUM(amount) 
                 FROM reward r
-                WHERE r.addr_id = latest.stake_addr_id
+                WHERE r.addr_id = latest.id
                 AND r.earned_epoch > 
                     (SELECT blka.epoch_no
                     FROM withdrawal w
                     JOIN tx txa ON txa.id = w.tx_id
                     JOIN block blka ON blka.id = txa.block_id
-                    WHERE w.addr_id = latest.stake_addr_id
+                    WHERE w.addr_id = latest.id
                     ORDER BY w.tx_id DESC
-                    LIMIT 1)) AS rewardBalance,
-            (SELECT SUM(amount) 
+                    LIMIT 1)
+            ), 0) +
+            COALESCE((
+                SELECT SUM(amount) 
                 FROM reward_rest r
-                WHERE r.addr_id = latest.stake_addr_id
-                    AND r.earned_epoch > 
-                        (SELECT blka.epoch_no
-                        FROM withdrawal w
-                        JOIN tx txa ON txa.id = w.tx_id
-                        JOIN block blka ON blka.id = txa.block_id
-                        WHERE w.addr_id = latest.stake_addr_id
-                        ORDER BY w.tx_id DESC
-                        LIMIT 1)) AS rewardRestBalance
-        FROM drep_hash dh
-        JOIN latest ON dh.id = latest.id
-        JOIN utxo_view uv ON uv.stake_address_id = latest.stake_addr_id
-        WHERE latest.rn = 1
-        AND (dh.view != 'drep_always_no_confidence' 
-            OR dh.view != 'drep_always_abstain')
-        AND dh.raw = decode(${drepId}, 'hex')
-        GROUP BY latest.stake_addr_id, dh.view, latest.stake_view;
+                WHERE r.addr_id = latest.id
+                AND r.earned_epoch > 
+                    (SELECT blka.epoch_no
+                    FROM withdrawal w
+                    JOIN tx txa ON txa.id = w.tx_id
+                    JOIN block blka ON blka.id = txa.block_id
+                    WHERE w.addr_id = latest.id
+                    ORDER BY w.tx_id DESC
+                    LIMIT 1)
+            ), 0) AS liveVotingPower
+        FROM latest
+        LEFT JOIN utxo_view uv ON uv.stake_address_id = latest.id
+        GROUP BY latest.stakeAddress, latest.id)
+        SELECT SUM(activedelegators) as activeDelegators, SUM(livevotingpower) as liveVotingPower 
+        FROM liveRecord
     `) as Record<string, any>[]
 
-    const response: Record<string, any> = {}
-
-    for (const row of result) {
-        const { view: drepId, stake_view: stakeView, total_value, rewardbalance, rewardrestbalance } = row
-
-        const totalRewardBalance: BigInt =
-            (rewardbalance != null ? BigInt(rewardbalance) : BigInt(0)) +
-            (rewardrestbalance != null ? BigInt(rewardrestbalance) : BigInt(0))
-
-        if (!response[drepId]) {
-            response[drepId] = {
-                delegators: [],
-            }
-        }
-
-        response[drepId].delegators.push({
-            [stakeView]: {
-                utxoBalance: BigInt(total_value).toString(),
-                rewardBalance: totalRewardBalance.toString(),
-            },
-        })
-    }
     const latestEpoch = await prisma.epoch.findFirst({
         orderBy: {
             start_time: 'desc',
@@ -546,25 +541,173 @@ export const fetchDrepActiveDelegation = async (drepId: string) => {
             epoch_no: latestEpoch ? (latestEpoch.no as number) : 0,
         },
     })
+    const totalVotingPower = drepDistr._sum.amount as bigint
+    const decimalInfluence = Number(result[0].livevotingpower) / Number(totalVotingPower)
+    const influence = (decimalInfluence * 100).toFixed(4) + '%'
+    const response = {
+        liveDelegators: result[0].activedelegators ? parseInt(result[0].activedelegators) : 0,
+        liveVotingPower: result[0].livevotingpower ? result[0].livevotingpower.toString() : '0',
+        influence: influence,
+    }
+    return response
+}
+
+export const fetchDrepActiveDelegators = async (dRepId: string) => {
+    const result = (await prisma.$queryRaw`
+        WITH latest AS (
+            WITH stakes AS (
+                SELECT DISTINCT sa.id AS id, sa.view AS stakeAddress
+                FROM delegation_vote dv
+                JOIN drep_hash dh ON dh.id = dv.drep_hash_id
+                JOIN stake_address sa ON sa.id = dv.addr_id
+                WHERE dh.raw = DECODE(${dRepId}, 'hex')
+            )
+            SELECT 
+                stakes.stakeAddress,
+                stakes.id,
+                JSON_AGG(
+                    JSON_BUILD_OBJECT(
+                        'txId', subquery.tx_id,
+                        'epoch', subquery.epoch_no,
+                        'time', subquery.time
+                    )
+                ) AS delegations
+            FROM stakes
+            JOIN LATERAL (
+                SELECT 
+                    ENCODE(tx.hash, 'hex') AS tx_id,
+                    b.epoch_no,
+                    b.time,
+                    dh.raw AS raw_check
+                FROM delegation_vote dv
+                JOIN drep_hash dh ON dh.id = dv.drep_hash_id
+                JOIN tx ON tx.id = dv.tx_id
+                JOIN block b ON b.id = tx.block_id
+                WHERE dv.addr_id = stakes.id
+                ORDER BY dv.tx_id DESC
+                LIMIT 1
+            ) AS subquery ON subquery.raw_check = DECODE(${dRepId}, 'hex')
+            GROUP BY stakes.stakeAddress, stakes.id
+            ORDER BY stakes.id
+        )
+        SELECT 
+            latest.stakeAddress,
+            latest.delegations::text,
+            COALESCE(SUM(uv.value), 0) AS utxo,
+            (SELECT SUM(amount) 
+                    FROM reward r
+                    WHERE r.addr_id = latest.id
+                    AND r.earned_epoch > 
+                        (SELECT blka.epoch_no
+                        FROM withdrawal w
+                        JOIN tx txa ON txa.id = w.tx_id
+                        JOIN block blka ON blka.id = txa.block_id
+                        WHERE w.addr_id = latest.id
+                        ORDER BY w.tx_id DESC
+                        LIMIT 1)) AS rewardBalance,
+            (SELECT SUM(amount) 
+                    FROM reward_rest r
+                    WHERE r.addr_id = latest.id
+                        AND r.earned_epoch > 
+                            (SELECT blka.epoch_no
+                            FROM withdrawal w
+                            JOIN tx txa ON txa.id = w.tx_id
+                            JOIN block blka ON blka.id = txa.block_id
+                            WHERE w.addr_id = latest.id
+                            ORDER BY w.tx_id DESC
+                            LIMIT 1)) AS rewardRestBalance
+        FROM latest
+        LEFT JOIN utxo_view uv ON uv.stake_address_id = latest.id
+        GROUP BY latest.stakeAddress, latest.id, latest.delegations::text;
+    `) as Record<string, any>[]
+    const parsedResult = () => {
+        return result.map((item) => ({
+            stakeAddress: item.stakeaddress,
+            delegatedAt: JSON.parse(item.delegations)[0],
+            balance: {
+                utxo: item.utxo.toString(),
+                reward: item.rewardbalance ? item.rewardbalance.toString() : '0',
+                rewardRest: item.rewardrestbalance ? item.rewardrestbalance.toString() : '0',
+            },
+        }))
+    }
+    return parsedResult()
+}
 
-    const calculateSum = (data: Record<string, any>): string => {
-        let totalSum = BigInt(0)
-        for (const drepId in data) {
-            const delegators = data[drepId].delegators
-            for (const delegator of delegators) {
-                for (const stakeView in delegator) {
-                    const { utxoBalance, rewardBalance } = delegator[stakeView]
-                    totalSum += BigInt(utxoBalance) + BigInt(rewardBalance)
+export const fetchDrepDelegationHistory = async (dRepId: string) => {
+    const result = (await prisma.$queryRaw`
+        WITH stakes AS (
+            SELECT DISTINCT sa.id AS id, sa.view AS stake
+            FROM delegation_vote dv
+                JOIN drep_hash dh ON dh.id = dv.drep_hash_id
+                JOIN stake_address sa ON sa.id = dv.addr_id
+            WHERE dh.raw = DECODE(${dRepId}, 'hex')
+        )
+        SELECT 
+            stakes.stake,
+            JSON_AGG(
+                JSON_BUILD_OBJECT(
+                    'drep', dh.view,
+                    'tx_id', ENCODE(tx.hash, 'hex'),
+                    'epoch_no', b.epoch_no,
+                    'time', b.time
+                ) ORDER BY dv.tx_id DESC
+            ) AS delegations
+        FROM delegation_vote dv
+        JOIN stakes ON dv.addr_id = stakes.id
+        JOIN drep_hash dh ON dh.id = dv.drep_hash_id
+        JOIN tx ON tx.id = dv.tx_id
+        JOIN block b ON b.id = tx.block_id
+        GROUP BY stakes.stake
+        ORDER BY stakes.stake;    
+    `) as Record<string, any>[]
+
+    const processDelegations = (data: any[], bech32Drep: string) => {
+        type DelegationInfo = { tx_id: string; epoch_no: number; time: string }
+        type DelegationHistory = { joined?: DelegationInfo; left?: DelegationInfo }
+        type Result = {
+            stakeAddress: string
+            delegation: DelegationHistory[]
+        }
+
+        const result = []
+
+        for (const stakeData of data) {
+            const stakeAddress = stakeData.stake
+            const delegations = stakeData.delegations
+
+            let partialResult: Result = {
+                stakeAddress: stakeAddress,
+                delegation: [],
+            }
+
+            let joinedFound = false
+            let delegationHistory: DelegationHistory = { joined: undefined, left: undefined }
+            let stakeDelegationHistory: DelegationHistory[] = []
+
+            for (let i = delegations.length - 1; i >= 0; i--) {
+                const delegation = delegations[i]
+                const { drep, tx_id, epoch_no, time } = delegation
+
+                if (drep === bech32Drep) {
+                    delegationHistory.joined = { tx_id, epoch_no, time }
+                    joinedFound = true
+                } else if (joinedFound) {
+                    delegationHistory.left = { tx_id, epoch_no, time }
+                    stakeDelegationHistory.push(delegationHistory)
+                    delegationHistory = { joined: undefined, left: undefined }
+                    joinedFound = false
                 }
             }
+            if (delegationHistory.joined || delegationHistory.left) {
+                stakeDelegationHistory.push(delegationHistory)
+            }
+            partialResult.delegation = stakeDelegationHistory
+            result.push(partialResult)
         }
-        return totalSum.toString()
-    }
 
-    const votingPower = calculateSum(response)
-    const totalVotingPower = drepDistr._sum.amount as bigint
-    const decimalInfluence = Number(votingPower) / Number(totalVotingPower)
-    const influence = (decimalInfluence * 100).toFixed(4) + '%'
-    response.influence = influence
-    return response
+        return result
+    }
+    const drepbech32 = fromHex('drep', dRepId)
+    return processDelegations(result, drepbech32)
 }
diff --git a/dbsync-api/swagger.yaml b/dbsync-api/swagger.yaml
