fix(cardano-serices): add (partial) stake pool parameters to stake pool registration certificates

Author: iccicci

packages/cardano-services/src/ChainHistory/DbSyncChainHistory/mappers.ts

@@ -5,6 +5,7 @@ import {
   BlockOutputModel,
   CertificateModel,
   MultiAssetModel,
+  PoolRegisterCertModel,
   ProtocolParametersUpdateModel,
   RedeemerModel,
   ScriptModel,
@@ -191,6 +192,17 @@ const mapDrepDelegation = ({
         __typename: 'AlwaysAbstain'
       };
 
+const mapPoolParameters = (certModel: WithCertType<PoolRegisterCertModel>): Cardano.PoolParameters => ({
+  cost: BigInt(certModel.fixed_cost),
+  id: certModel.pool_id as unknown as Cardano.PoolId,
+  margin: Cardano.FractionUtils.toFraction(certModel.margin),
+  owners: [],
+  pledge: BigInt(certModel.pledge),
+  relays: [],
+  rewardAccount: certModel.reward_account as Cardano.RewardAccount,
+  vrf: certModel.vrf_key_hash.toString('hex') as Cardano.VrfVkHex
+});
+
 // eslint-disable-next-line complexity
 export const mapCertificate = (
   certModel: WithCertType<CertificateModel>
@@ -209,7 +221,7 @@ export const mapCertificate = (
       __typename: Cardano.CertificateType.PoolRegistration,
       cert_index: certModel.cert_index,
       deposit: BigInt(certModel.deposit),
-      poolParameters: null as unknown as Cardano.PoolParameters
+      poolParameters: mapPoolParameters(certModel)
     } as WithCertIndex<Cardano.HydratedPoolRegistrationCertificate>;
 
   if (isMirCertModel(certModel)) {

packages/cardano-services/src/ChainHistory/DbSyncChainHistory/queries.ts

@@ -250,15 +250,21 @@ export const findPoolRetireCertsTxIds = `
 export const findPoolRegisterCertsByTxIds = `
 	SELECT
 		cert.cert_index AS cert_index,
-		pool."view" AS pool_id,
+		pool.view AS pool_id,
 		tx.hash AS tx_id,
 		CASE
 			WHEN cert.deposit IS NULL THEN '0'
 			ELSE cert.deposit
-		END AS deposit
+		END AS deposit,
+		stake_address.view AS reward_account,
+		pledge,
+		fixed_cost,
+		margin,
+		vrf_key_hash
 	FROM tx
 	JOIN pool_update AS cert ON cert.registered_tx_id = tx.id
 	JOIN pool_hash AS pool ON pool.id = cert.hash_id
+	JOIN stake_address ON stake_address.id = reward_addr_id
 	WHERE tx.id = ANY($1)
 	ORDER BY tx.id ASC`;
 

packages/cardano-services/src/ChainHistory/DbSyncChainHistory/types.ts

@@ -178,6 +178,11 @@ export interface PoolRetireCertModel extends CertificateModel {
 export interface PoolRegisterCertModel extends CertificateModel {
   pool_id: string;
   deposit: string;
+  reward_account: string;
+  pledge: string;
+  fixed_cost: string;
+  margin: number;
+  vrf_key_hash: Buffer;
 }
 
 export interface MirCertModel extends CertificateModel {

packages/cardano-services/test/ChainHistory/DbSyncChainHistoryProvider/mappers.test.ts

@@ -34,6 +34,7 @@ const blockHash = '7a48b034645f51743550bbaf81f8a14771e58856e031eb63844738ca8ad72
 const poolId = 'pool1zuevzm3xlrhmwjw87ec38mzs02tlkwec9wxpgafcaykmwg7efhh';
 const datetime = '2022-05-10T19:22:43.620Z';
 const vrfKey = 'vrf_vk19j362pkr4t9y0m3qxgmrv0365vd7c4ze03ny4jh84q8agjy4ep4s99zvg8';
+const vrfKeyHash = '220ba9398e3e5fae23a83d0d5927649d577a5f69d6ef1d5253c259d9393ba294';
 const genesisLeaderHash = 'eff1b5b26e65b791d6f236c7c0264012bd1696759d22bdb4dd0f6f56';
 const transactionHash = 'cefd2fcf657e5e5d6c35975f4e052f427819391b153ebb16ad8aa107ba5a3819';
 const sourceTransactionHash = 'cefd2fcf657e5e5d6c35975f4e052f427819391b153ebb16ad8aa107ba5a3812';
@@ -292,14 +293,28 @@ describe('chain history mappers', () => {
       const result = mappers.mapCertificate({
         ...baseCertModel,
         deposit: '500000000',
+        fixed_cost: '390000000',
+        margin: 0.15,
+        pledge: '420000000',
         pool_id: poolId,
-        type: 'register'
+        reward_account: stakeAddress,
+        type: 'register',
+        vrf_key_hash: Buffer.from(vrfKeyHash, 'hex')
       } as WithCertType<PoolRegisterCertModel>);
       expect(result).toEqual<WithCertIndex<Cardano.HydratedPoolRegistrationCertificate>>({
         __typename: Cardano.CertificateType.PoolRegistration,
         cert_index: 0,
         deposit: 500_000_000n,
-        poolParameters: null as unknown as Cardano.PoolParameters
+        poolParameters: {
+          cost: 390_000_000n,
+          id: poolId as Cardano.PoolId,
+          margin: { denominator: 20, numerator: 3 },
+          owners: [],
+          pledge: 420_000_000n,
+          relays: [],
+          rewardAccount: stakeAddress as Cardano.RewardAccount,
+          vrf: vrfKeyHash as Cardano.VrfVkHex
+        }
       });
     });
     test('map MirCertModel to Cardano.MirCertificate', () => {