Merge pull request #101 from bloxbean/issue_99

Update according new Cardano node v10

core/src/main/java/com/bloxbean/cardano/yaci/core/protocol/handshake/util/N2CVersionTableConstant.java

@@ -26,6 +26,7 @@ public class N2CVersionTableConstant {
     public final static long PROTOCOL_V15 = 32783;
     public final static long PROTOCOL_V16 = 32784;
     public final static long PROTOCOL_V17 = 32785;
+    public final static long PROTOCOL_V18 = 32786;
 
     public static VersionTable v1AndAbove(long networkMagic) {
         OldN2CVersionData oldVersionData = new OldN2CVersionData(networkMagic);
@@ -49,6 +50,7 @@ public static VersionTable v1AndAbove(long networkMagic) {
         versionTableMap.put(PROTOCOL_V15, versionData);
         versionTableMap.put(PROTOCOL_V16, versionData);
         versionTableMap.put(PROTOCOL_V17, versionData);
+        versionTableMap.put(PROTOCOL_V18, versionData);
 
         return new VersionTable(versionTableMap);
     }

core/src/main/java/com/bloxbean/cardano/yaci/core/protocol/handshake/util/N2NVersionTableConstant.java

@@ -18,6 +18,7 @@ public class N2NVersionTableConstant {
     public final static long PROTOCOL_V11 = 11;
     public final static long PROTOCOL_V12 = 12;
     public final static long PROTOCOL_V13 = 13;
+    public final static long PROTOCOL_V14 = 14;
 
     public static VersionTable v4AndAbove(long networkMagic) {
         N2NVersionData versionData = new N2NVersionData(networkMagic, true);
@@ -33,6 +34,7 @@ public static VersionTable v4AndAbove(long networkMagic) {
         versionTableMap.put(PROTOCOL_V11, versionData);
         versionTableMap.put(PROTOCOL_V12, versionData);
         versionTableMap.put(PROTOCOL_V13, versionData);
+        versionTableMap.put(PROTOCOL_V14, versionData);
 
         return new VersionTable(versionTableMap);
     }
@@ -48,6 +50,7 @@ public static VersionTable v11AndAbove(long networkMagic, boolean initiatorOnlyD
         versionTableMap.put(PROTOCOL_V11, versionData);
         versionTableMap.put(PROTOCOL_V12, versionData);
         versionTableMap.put(PROTOCOL_V13, versionData);
+        versionTableMap.put(PROTOCOL_V14, versionData);
 
         return new VersionTable(versionTableMap);
     }

core/src/main/java/com/bloxbean/cardano/yaci/core/protocol/localstate/queries/GetFuturePParamsQuery.java

@@ -0,0 +1,335 @@
+package com.bloxbean.cardano.yaci.core.protocol.localstate.queries;
+
+import co.nstant.in.cbor.model.*;
+import com.bloxbean.cardano.client.util.Tuple;
+import com.bloxbean.cardano.yaci.core.model.DrepVoteThresholds;
+import com.bloxbean.cardano.yaci.core.model.PoolVotingThresholds;
+import com.bloxbean.cardano.yaci.core.model.ProtocolParamUpdate;
+import com.bloxbean.cardano.yaci.core.protocol.handshake.messages.AcceptVersion;
+import com.bloxbean.cardano.yaci.core.protocol.localstate.api.Era;
+import com.bloxbean.cardano.yaci.core.protocol.localstate.api.EraQuery;
+import com.bloxbean.cardano.yaci.core.util.CborSerializationUtil;
+import com.bloxbean.cardano.yaci.core.util.HexUtil;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.ToString;
+
+import java.math.BigDecimal;
+import java.math.BigInteger;
+import java.util.LinkedHashMap;
+import java.util.List;
+
+import static com.bloxbean.cardano.yaci.core.util.CborSerializationUtil.*;
+
+@Getter
+@AllArgsConstructor
+@ToString
+public class GetFuturePParamsQuery implements EraQuery<GetFuturePParamsQueryResult> {
+    private Era era;
+
+    public GetFuturePParamsQuery() {
+        this.era = Era.Conway;
+    }
+
+    @Override
+    public DataItem serialize(AcceptVersion protocolVersion) {
+        Array queryArray = new Array();
+        queryArray.add(new UnsignedInteger(33));
+
+        return wrapWithOuterArray(queryArray);
+    }
+
+    @Override
+    public GetFuturePParamsQueryResult deserializeResult(AcceptVersion protocolVersion, DataItem[] di) {
+        var resultDI = extractResultArray(di[0]);
+        var outerArray = (Array)resultDI.get(0);
+
+        if (outerArray.getDataItems().isEmpty()) {
+            return new GetFuturePParamsQueryResult(null);
+        }
+
+        Array futurePParamArray = (Array)outerArray.getDataItems().get(0);
+        ProtocolParamUpdate futureProtocolParam = deserializePPResult(futurePParamArray.getDataItems());
+
+        return new GetFuturePParamsQueryResult(futureProtocolParam);
+    }
+
+    public ProtocolParamUpdate deserializePPResult(List<DataItem> paramsDIList) {
+        if (paramsDIList.isEmpty()) {
+            return null;
+        }
+
+        DataItem itemDI = paramsDIList.get(0);
+        Integer minFeeA = itemDI != null ? toInt(itemDI) : null;
+
+        itemDI = paramsDIList.get(1);
+        Integer minFeeB = itemDI != null ? toInt(itemDI) : null;
+
+        itemDI = paramsDIList.get(2);
+        Integer maxBlockSize = itemDI != null ? toInt(itemDI) : null;
+
+        itemDI = paramsDIList.get(3);
+        Integer maxTxSize = itemDI != null ? toInt(itemDI) : null;
+
+        itemDI = paramsDIList.get(4);
+        Integer maxBlockHeaderSize = itemDI != null ? toInt(itemDI) : null;
+
+        itemDI = paramsDIList.get(5);
+        BigInteger keyDeposit = itemDI != null ? toBigInteger(itemDI) : null;
+
+        itemDI = paramsDIList.get(6);
+        BigInteger poolDeposit = itemDI != null ? toBigInteger(itemDI) : null;
+
+        itemDI = paramsDIList.get(7);
+        Integer maxEpoch = itemDI != null ? toInt(itemDI) : null;
+
+        itemDI = paramsDIList.get(8);
+        Integer nOpt = itemDI != null ? toInt(itemDI) : null;
+
+        itemDI = paramsDIList.get(9);
+        BigDecimal poolPledgeInfluence = itemDI != null ? toRationalNumber(itemDI) : null;
+
+        itemDI = paramsDIList.get(10);
+        BigDecimal expansionRate = itemDI != null ? toRationalNumber(itemDI) : null;
+
+        itemDI = paramsDIList.get(11);
+        BigDecimal treasuryGrowthRate = itemDI != null ? toRationalNumber(itemDI) : null;
+
+        Integer protocolMajorVersion = null;
+        Integer protocolMinorVersion = null;
+        itemDI = paramsDIList.get(12);
+        if (itemDI != null) {
+            List<DataItem> protocolVersions = ((Array) itemDI).getDataItems();
+            protocolMajorVersion = toInt(protocolVersions.get(0));
+            protocolMinorVersion = toInt(protocolVersions.get(1));
+        }
+
+        itemDI = paramsDIList.get(13);
+        BigInteger minPoolCost = itemDI != null ? toBigInteger(itemDI) : null;
+
+        itemDI = paramsDIList.get(14);
+        BigInteger adaPerUtxoBytes = itemDI != null ? toBigInteger(itemDI) : null;
+
+        //CostModels
+        java.util.Map<Integer, String> costModelMap = null;
+        itemDI = paramsDIList.get(15);
+        if (itemDI != null) {
+            costModelMap = new LinkedHashMap<>();
+            Map itemDIMap = (Map) itemDI;
+            for (DataItem key : itemDIMap.getKeys()) {
+                Integer version = toInt(key);
+                String costModel = HexUtil.encodeHexString(CborSerializationUtil.serialize(itemDIMap.get(key)));
+                costModelMap.put(version, costModel);
+            }
+        }
+
+        //exUnits prices
+        BigDecimal priceMem = null;
+        BigDecimal priceSteps = null;
+        itemDI = paramsDIList.get(16);
+        if (itemDI != null) {
+            List<DataItem> exUnitPriceList = ((Array) itemDI).getDataItems();
+            Tuple<BigDecimal, BigDecimal> tuple = getExUnitPrices(exUnitPriceList);
+            priceMem = tuple._1;
+            priceSteps = tuple._2;
+        }
+
+        //max tx exunits
+        BigInteger maxTxExMem = null;
+        BigInteger maxTxExSteps = null;
+        itemDI = paramsDIList.get(17);
+        if (itemDI != null) {
+            List<DataItem> exUnits = ((Array) itemDI).getDataItems();
+            Tuple<BigInteger, BigInteger> tuple = getExUnits(exUnits);
+            maxTxExMem = tuple._1;
+            maxTxExSteps = tuple._2;
+        }
+
+        //max block exunits
+        BigInteger maxBlockExMem = null;
+        BigInteger maxBlockExSteps = null;
+        itemDI = paramsDIList.get(18);
+        if (itemDI != null) {
+            List<DataItem> exUnits = ((Array) itemDI).getDataItems();
+            Tuple<BigInteger, BigInteger> tuple = getExUnits(exUnits);
+            maxBlockExMem = tuple._1;
+            maxBlockExSteps = tuple._2;
+        }
+
+        itemDI = paramsDIList.get(19);
+        Long maxValueSize = itemDI != null ? toLong(itemDI) : null;
+
+        itemDI = paramsDIList.get(20);
+        Integer collateralPercent = itemDI != null ? toInt(itemDI) : null;
+
+        Integer maxCollateralInputs = null;
+        itemDI = paramsDIList.get(21);
+        maxCollateralInputs = itemDI != null ? toInt(itemDI) : null;
+
+        //Pool Voting Threshold
+        itemDI = paramsDIList.get(22);
+        BigDecimal motionNoConfidence = null;
+        BigDecimal committeeNormal = null;
+        BigDecimal committeeNoConfidence = null;
+        BigDecimal hardForkInitiation = null;
+        BigDecimal ppSecurityGroup = null;
+        if (itemDI != null) {
+            List<DataItem> poolVotingThresholdList = ((Array) itemDI).getDataItems();
+            if (poolVotingThresholdList.size() != 5)
+                throw new IllegalStateException("Invalid pool voting threshold list");
+
+            var pvtMotionNoConfidenceDI = (RationalNumber) poolVotingThresholdList.get(0);
+            var pvtCommitteeNormalDI = (RationalNumber) poolVotingThresholdList.get(1);
+            var pvtCommitteeNoConfidenceDI = (RationalNumber) poolVotingThresholdList.get(2);
+            var pvtHardForkInitiationDI = (RationalNumber) poolVotingThresholdList.get(3);
+            var pvtPPSecurityGroupDI = (RationalNumber) poolVotingThresholdList.get(4);
+
+            motionNoConfidence = toRationalNumber(pvtMotionNoConfidenceDI);
+            committeeNormal = toRationalNumber(pvtCommitteeNormalDI);
+            committeeNoConfidence = toRationalNumber(pvtCommitteeNoConfidenceDI);
+            hardForkInitiation = toRationalNumber(pvtHardForkInitiationDI);
+            ppSecurityGroup = toRationalNumber(pvtPPSecurityGroupDI);
+        }
+
+        //DRep voting thresholds
+        itemDI = paramsDIList.get(23);
+        BigDecimal dvtMotionNoConfidence = null;
+        BigDecimal dvtCommitteeNormal = null;
+        BigDecimal dvtCommitteeNoConfidence = null;
+        BigDecimal dvtUpdateToConstitution = null;
+        BigDecimal dvtHardForkInitiation = null;
+        BigDecimal dvtPPNetworkGroup = null;
+        BigDecimal dvtPPEconomicGroup = null;
+        BigDecimal dvtPPTechnicalGroup = null;
+        BigDecimal dvtPPGovGroup = null;
+        BigDecimal dvtTreasuryWithdrawal = null;
+
+        if (itemDI != null) {
+            List<DataItem> dRepVotingThresholdList = ((Array) itemDI).getDataItems();
+            if (dRepVotingThresholdList.size() != 10)
+                throw new IllegalStateException("Invalid dRep voting threshold list");
+
+            var dvtMotionNoConfidenceDI = (RationalNumber) dRepVotingThresholdList.get(0);
+            var dvtCommitteeNormalDI = (RationalNumber) dRepVotingThresholdList.get(1);
+            var dvtCommitteeNoConfidenceDI = (RationalNumber) dRepVotingThresholdList.get(2);
+            var dvtUpdateToConstitutionDI = (RationalNumber) dRepVotingThresholdList.get(3);
+            var dvtHardForkInitiationDI = (RationalNumber) dRepVotingThresholdList.get(4);
+            var dvtPPNetworkGroupDI = (RationalNumber) dRepVotingThresholdList.get(5);
+            var dvtPPEconomicGroupDI = (RationalNumber) dRepVotingThresholdList.get(6);
+            var dvtPPTechnicalGroupDI = (RationalNumber) dRepVotingThresholdList.get(7);
+            var dvtPPGovGroupDI = (RationalNumber) dRepVotingThresholdList.get(8);
+            var dvtTreasuryWithdrawalDI = (RationalNumber) dRepVotingThresholdList.get(9);
+
+            dvtMotionNoConfidence = toRationalNumber(dvtMotionNoConfidenceDI);
+            dvtCommitteeNormal = toRationalNumber(dvtCommitteeNormalDI);
+            dvtCommitteeNoConfidence = toRationalNumber(dvtCommitteeNoConfidenceDI);
+            dvtUpdateToConstitution = toRationalNumber(dvtUpdateToConstitutionDI);
+            dvtHardForkInitiation = toRationalNumber(dvtHardForkInitiationDI);
+            dvtPPNetworkGroup = toRationalNumber(dvtPPNetworkGroupDI);
+            dvtPPEconomicGroup = toRationalNumber(dvtPPEconomicGroupDI);
+            dvtPPTechnicalGroup = toRationalNumber(dvtPPTechnicalGroupDI);
+            dvtPPGovGroup = toRationalNumber(dvtPPGovGroupDI);
+            dvtTreasuryWithdrawal = toRationalNumber(dvtTreasuryWithdrawalDI);
+        }
+
+        itemDI = paramsDIList.get(24);
+        Integer minCommitteeSize = itemDI != null ? toInt(itemDI) : null;
+
+        itemDI = paramsDIList.get(25);
+        Integer committeeTermLimit = itemDI != null ? toInt(itemDI) : null;
+
+        itemDI = paramsDIList.get(26);
+        Integer governanceActionValidityPeriod = itemDI != null ? toInt(itemDI) : null;
+
+        itemDI = paramsDIList.get(27);
+        BigInteger governanceActionDeposit = itemDI != null ? toBigInteger(itemDI) : null;
+
+        itemDI = paramsDIList.get(28);
+        BigInteger drepDeposit = itemDI != null ? toBigInteger(itemDI) : null;
+
+        itemDI = paramsDIList.get(29);
+        Integer drepInactivityPeriod = itemDI != null ? toInt(itemDI) : null;
+
+        BigDecimal minFeeRefScriptCostPerByte = null;
+        if (paramsDIList.size() > 30) {
+            itemDI = paramsDIList.get(30);
+            minFeeRefScriptCostPerByte = itemDI != null ? toRationalNumber(itemDI) : null;
+        }
+
+        return ProtocolParamUpdate.builder()
+                .minFeeA(minFeeA)
+                .minFeeB(minFeeB)
+                .maxBlockSize(maxBlockSize)
+                .maxTxSize(maxTxSize)
+                .maxBlockHeaderSize(maxBlockHeaderSize)
+                .keyDeposit(keyDeposit)
+                .poolDeposit(poolDeposit)
+                .maxEpoch(maxEpoch)
+                .nOpt(nOpt)
+                .poolPledgeInfluence(poolPledgeInfluence)
+                .expansionRate(expansionRate)
+                .treasuryGrowthRate(treasuryGrowthRate)
+                .protocolMajorVer(protocolMajorVersion)
+                .protocolMinorVer(protocolMinorVersion)
+                .minPoolCost(minPoolCost)
+                .adaPerUtxoByte(adaPerUtxoBytes)
+                .costModels(costModelMap)
+                .priceMem(priceMem)
+                .priceStep(priceSteps)
+                .maxTxExMem(maxTxExMem)
+                .maxTxExSteps(maxTxExSteps)
+                .maxBlockExMem(maxBlockExMem)
+                .maxBlockExSteps(maxBlockExSteps)
+                .maxValSize(maxValueSize)
+                .collateralPercent(collateralPercent)
+                .maxCollateralInputs(maxCollateralInputs)
+                .poolVotingThresholds(PoolVotingThresholds.builder()
+                        .pvtMotionNoConfidence(motionNoConfidence)
+                        .pvtCommitteeNormal(committeeNormal)
+                        .pvtCommitteeNoConfidence(committeeNoConfidence)
+                        .pvtHardForkInitiation(hardForkInitiation)
+                        .pvtPPSecurityGroup(ppSecurityGroup)
+                        .build())
+                .drepVotingThresholds(DrepVoteThresholds.builder()
+                        .dvtMotionNoConfidence(dvtMotionNoConfidence)
+                        .dvtCommitteeNormal(dvtCommitteeNormal)
+                        .dvtCommitteeNoConfidence(dvtCommitteeNoConfidence)
+                        .dvtUpdateToConstitution(dvtUpdateToConstitution)
+                        .dvtHardForkInitiation(dvtHardForkInitiation)
+                        .dvtPPNetworkGroup(dvtPPNetworkGroup)
+                        .dvtPPEconomicGroup(dvtPPEconomicGroup)
+                        .dvtPPTechnicalGroup(dvtPPTechnicalGroup)
+                        .dvtPPGovGroup(dvtPPGovGroup)
+                        .dvtTreasuryWithdrawal(dvtTreasuryWithdrawal)
+                        .build())
+                .committeeMinSize(minCommitteeSize)
+                .committeeMaxTermLength(committeeTermLimit)
+                .govActionLifetime(governanceActionValidityPeriod)
+                .govActionDeposit(governanceActionDeposit)
+                .drepDeposit(drepDeposit)
+                .drepActivity(drepInactivityPeriod)
+                .minFeeRefScriptCostPerByte(minFeeRefScriptCostPerByte)
+                .build();
+    }
+
+    private Tuple<BigInteger, BigInteger> getExUnits(List<DataItem> exunits) {
+        BigInteger mem = toBigInteger(exunits.get(0));
+
+        BigInteger steps = null;
+        if (exunits.size() > 1)
+            steps = toBigInteger(exunits.get(1));
+
+        return new Tuple<>(mem, steps);
+    }
+
+    private Tuple<BigDecimal, BigDecimal> getExUnitPrices(List<DataItem> exunits) {
+        RationalNumber memPriceRN = (RationalNumber) exunits.get(0);
+        RationalNumber stepPriceRN = (RationalNumber) exunits.get(1);
+
+        BigDecimal memPrice = toRationalNumber(memPriceRN);
+        BigDecimal stepPrice = toRationalNumber(stepPriceRN);
+
+        return new Tuple<>(memPrice, stepPrice);
+    }
+
+}

core/src/main/java/com/bloxbean/cardano/yaci/core/protocol/localstate/queries/GetFuturePParamsQueryResult.java

@@ -0,0 +1,14 @@
+package com.bloxbean.cardano.yaci.core.protocol.localstate.queries;
+
+import com.bloxbean.cardano.yaci.core.model.ProtocolParamUpdate;
+import com.bloxbean.cardano.yaci.core.protocol.localstate.api.QueryResult;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.ToString;
+
+@Getter
+@AllArgsConstructor
+@ToString
+public class GetFuturePParamsQueryResult implements QueryResult {
+    private ProtocolParamUpdate futurePParams;
+}