Add Edo protocol support

Tzkt.Data/Models/Voting/VotingPeriod.cs

@@ -70,7 +70,8 @@ public enum PeriodKind
         Proposal,
         Exploration,
         Testing,
-        Promotion
+        Promotion,
+        Adoption
     }
 
     public enum PeriodStatus

Tzkt.Sync/Protocols/Handlers/Proto1/Validation/Validator.cs

@@ -52,9 +52,7 @@ protected virtual async Task ValidateBlockMetadata(JsonElement metadata)
             if (!Cache.Accounts.DelegateExists(Baker))
                 throw new ValidationException($"non-existent block baker");
 
-            await ValidateBlockVoting(
-                metadata.Required("level").RequiredInt32("voting_period"),
-                metadata.RequiredString("voting_period_kind"));
+            await ValidateBlockVoting(metadata);
 
             foreach (var baker in metadata.RequiredArray("deactivated").EnumerateArray())
                 if (!Cache.Accounts.DelegateExists(baker.GetString()))
@@ -65,14 +63,16 @@ protected virtual async Task ValidateBlockMetadata(JsonElement metadata)
             ValidateCycleRewards(balanceUpdates.Skip(Cycle < Protocol.NoRewardCycles ? 2 : 3));
         }
 
-        protected virtual async Task ValidateBlockVoting(int periodIndex, string periodKind)
+        protected virtual async Task ValidateBlockVoting(JsonElement metadata)
         {
+            var periodIndex = metadata.Required("level").RequiredInt32("voting_period");
+
             if (Cache.AppState.Get().VotingPeriod != periodIndex)
                 throw new ValidationException("invalid voting period index");
 
             var period = await Cache.Periods.GetAsync(periodIndex);
 
-            var kind = periodKind switch
+            var kind = metadata.RequiredString("voting_period_kind") switch
             {
                 "proposal" => PeriodKind.Proposal,
                 "exploration" => PeriodKind.Exploration,

Tzkt.Sync/Protocols/Handlers/Proto3/Validation/Validator.cs

@@ -11,15 +11,17 @@ class Validator : Proto1.Validator
     {
         public Validator(ProtocolHandler protocol) : base(protocol) { }
 
-        // new period king enum & wtf
-        protected override async Task ValidateBlockVoting(int periodIndex, string periodKind)
+        // new period kind enum & wtf
+        protected override async Task ValidateBlockVoting(JsonElement metadata)
         {
+            var periodIndex = metadata.Required("level").RequiredInt32("voting_period");
+
             if (Cache.AppState.Get().VotingPeriod != periodIndex)
                 throw new ValidationException("invalid voting period index");
 
             var period = await Cache.Periods.GetAsync(periodIndex);
 
-            var kind = periodKind switch
+            var kind = metadata.RequiredString("voting_period_kind") switch
             {
                 "proposal" => PeriodKind.Proposal,
                 "testing_vote" => PeriodKind.Exploration,

Tzkt.Sync/Protocols/Handlers/Proto6/Validation/Validator.cs

@@ -25,9 +25,7 @@ protected override async Task ValidateBlockMetadata(JsonElement metadata)
             if (!Cache.Accounts.DelegateExists(Baker))
                 throw new ValidationException($"non-existent block baker");
 
-            await ValidateBlockVoting(
-                metadata.Required("level").RequiredInt32("voting_period"),
-                metadata.RequiredString("voting_period_kind"));
+            await ValidateBlockVoting(metadata);
 
             foreach (var baker in metadata.RequiredArray("deactivated").EnumerateArray())
                 if (!Cache.Accounts.DelegateExists(baker.GetString()))

Tzkt.Sync/Protocols/Handlers/Proto8/Activation/ProtoActivator.cs

@@ -0,0 +1,7 @@
+namespace Tzkt.Sync.Protocols.Proto8
+{
+    class ProtoActivator : Proto7.ProtoActivator
+    {
+        public ProtoActivator(ProtocolHandler proto) : base(proto) { }
+    }
+}

Tzkt.Sync/Protocols/Handlers/Proto8/Commits/BakerCycleCommit.cs

@@ -0,0 +1,7 @@
+namespace Tzkt.Sync.Protocols.Proto8
+{
+    class BakerCycleCommit : Proto6.BakerCycleCommit
+    {
+        public BakerCycleCommit(ProtocolHandler protocol) : base(protocol) { }
+    }
+}

Tzkt.Sync/Protocols/Handlers/Proto8/Commits/BakingRightsCommit.cs

@@ -0,0 +1,7 @@
+namespace Tzkt.Sync.Protocols.Proto8
+{
+    class BakingRightsCommit : Proto3.BakingRightsCommit
+    {
+        public BakingRightsCommit(ProtocolHandler protocol) : base(protocol) { }
+    }
+}

Tzkt.Sync/Protocols/Handlers/Proto8/Commits/BlockCommit.cs

@@ -0,0 +1,7 @@
+namespace Tzkt.Sync.Protocols.Proto8
+{
+    class BlockCommit : Proto1.BlockCommit
+    {
+        public BlockCommit(ProtocolHandler protocol) : base(protocol) { }
+    }
+}

Tzkt.Sync/Protocols/Handlers/Proto8/Commits/CycleCommit.cs

@@ -0,0 +1,7 @@
+namespace Tzkt.Sync.Protocols.Proto8
+{
+    class CycleCommit : Proto1.CycleCommit
+    {
+        public CycleCommit(ProtocolHandler protocol) : base(protocol) { }
+    }
+}

Tzkt.Sync/Protocols/Handlers/Proto8/Commits/DeactivationCommit.cs

@@ -0,0 +1,7 @@
+namespace Tzkt.Sync.Protocols.Proto8
+{
+    class DeactivationCommit : Proto2.DeactivationCommit
+    {
+        public DeactivationCommit(ProtocolHandler protocol) : base(protocol) { }
+    }
+}

Tzkt.Sync/Protocols/Handlers/Proto8/Commits/DelegatorCycleCommit.cs

@@ -0,0 +1,7 @@
+namespace Tzkt.Sync.Protocols.Proto8
+{
+    class DelegatorCycleCommit : Proto3.DelegatorCycleCommit
+    {
+        public DelegatorCycleCommit(ProtocolHandler protocol) : base(protocol) { }
+    }
+}

Tzkt.Sync/Protocols/Handlers/Proto8/Commits/FreezerCommit.cs

@@ -0,0 +1,7 @@
+namespace Tzkt.Sync.Protocols.Proto8
+{
+    class FreezerCommit : Proto6.FreezerCommit
+    {
+        public FreezerCommit(ProtocolHandler protocol) : base(protocol) { }
+    }
+}

Tzkt.Sync/Protocols/Handlers/Proto8/Commits/Operations/ActivationsCommit.cs

@@ -0,0 +1,7 @@
+namespace Tzkt.Sync.Protocols.Proto8
+{
+    class ActivationsCommit : Proto5.ActivationsCommit
+    {
+        public ActivationsCommit(ProtocolHandler protocol) : base(protocol) { }
+    }
+}

Tzkt.Sync/Protocols/Handlers/Proto8/Commits/Operations/BallotsCommit.cs

@@ -0,0 +1,7 @@
+namespace Tzkt.Sync.Protocols.Proto8
+{
+    class BallotsCommit : Proto3.BallotsCommit
+    {
+        public BallotsCommit(ProtocolHandler protocol) : base(protocol) { }
+    }
+}

Tzkt.Sync/Protocols/Handlers/Proto8/Commits/Operations/DelegationsCommit.cs

@@ -0,0 +1,7 @@
+namespace Tzkt.Sync.Protocols.Proto8
+{
+    class DelegationsCommit : Proto1.DelegationsCommit
+    {
+        public DelegationsCommit(ProtocolHandler protocol) : base(protocol) { }
+    }
+}

Tzkt.Sync/Protocols/Handlers/Proto8/Commits/Operations/DoubleBakingCommit.cs

@@ -0,0 +1,7 @@
+namespace Tzkt.Sync.Protocols.Proto8
+{
+    class DoubleBakingCommit : Proto2.DoubleBakingCommit
+    {
+        public DoubleBakingCommit(ProtocolHandler protocol) : base(protocol) { }
+    }
+}

Tzkt.Sync/Protocols/Handlers/Proto8/Commits/Operations/DoubleEndorsingCommit.cs

@@ -0,0 +1,7 @@
+namespace Tzkt.Sync.Protocols.Proto8
+{
+    class DoubleEndorsingCommit : Proto4.DoubleEndorsingCommit
+    {
+        public DoubleEndorsingCommit(ProtocolHandler protocol) : base(protocol) { }
+    }
+}

Tzkt.Sync/Protocols/Handlers/Proto8/Commits/Operations/EndorsementsCommit.cs

@@ -0,0 +1,7 @@
+namespace Tzkt.Sync.Protocols.Proto8
+{
+    class EndorsementsCommit : Proto1.EndorsementsCommit
+    {
+        public EndorsementsCommit(ProtocolHandler protocol) : base(protocol) { }
+    }
+}

Tzkt.Sync/Protocols/Handlers/Proto8/Commits/Operations/NonceRevelationsCommit.cs

@@ -0,0 +1,7 @@
+namespace Tzkt.Sync.Protocols.Proto8
+{
+    class NonceRevelationsCommit : Proto1.NonceRevelationsCommit
+    {
+        public NonceRevelationsCommit(ProtocolHandler protocol) : base(protocol) { }
+    }
+}

Tzkt.Sync/Protocols/Handlers/Proto8/Commits/Operations/OriginationsCommit.cs

@@ -0,0 +1,7 @@
+namespace Tzkt.Sync.Protocols.Proto8
+{
+    class OriginationsCommit : Proto5.OriginationsCommit
+    {
+        public OriginationsCommit(ProtocolHandler protocol) : base(protocol) { }
+    }
+}

Tzkt.Sync/Protocols/Handlers/Proto8/Commits/Operations/ProposalsCommit.cs

@@ -0,0 +1,7 @@
+namespace Tzkt.Sync.Protocols.Proto8
+{
+    class ProposalsCommit : Proto3.ProposalsCommit
+    {
+        public ProposalsCommit(ProtocolHandler protocol) : base(protocol) { }
+    }
+}

Tzkt.Sync/Protocols/Handlers/Proto8/Commits/Operations/RevealsCommit.cs

@@ -0,0 +1,7 @@
+namespace Tzkt.Sync.Protocols.Proto8
+{
+    class RevealsCommit : Proto1.RevealsCommit
+    {
+        public RevealsCommit(ProtocolHandler protocol) : base(protocol) { }
+    }
+}

Tzkt.Sync/Protocols/Handlers/Proto8/Commits/Operations/TransactionsCommit.cs

@@ -0,0 +1,7 @@
+namespace Tzkt.Sync.Protocols.Proto8
+{
+    class TransactionsCommit : Proto5.TransactionsCommit
+    {
+        public TransactionsCommit(ProtocolHandler protocol) : base(protocol) { }
+    }
+}

Tzkt.Sync/Protocols/Handlers/Proto8/Commits/RevelationPenaltyCommit.cs

@@ -0,0 +1,7 @@
+namespace Tzkt.Sync.Protocols.Proto8
+{
+    class RevelationPenaltyCommit : Proto6.RevelationPenaltyCommit
+    {
+        public RevelationPenaltyCommit(ProtocolHandler protocol) : base(protocol) { }
+    }
+}

Tzkt.Sync/Protocols/Handlers/Proto8/Commits/SnapshotBalanceCommit.cs

@@ -0,0 +1,7 @@
+namespace Tzkt.Sync.Protocols.Proto8
+{
+    class SnapshotBalanceCommit : Proto4.SnapshotBalanceCommit
+    {
+        public SnapshotBalanceCommit(ProtocolHandler protocol) : base(protocol) { }
+    }
+}

Tzkt.Sync/Protocols/Handlers/Proto8/Commits/SoftwareCommit.cs

@@ -0,0 +1,7 @@
+namespace Tzkt.Sync.Protocols.Proto8
+{
+    class SoftwareCommit : Proto5.SoftwareCommit
+    {
+        public SoftwareCommit(ProtocolHandler protocol) : base(protocol) { }
+    }
+}

Tzkt.Sync/Protocols/Handlers/Proto8/Commits/StateCommit.cs

@@ -0,0 +1,7 @@
+namespace Tzkt.Sync.Protocols.Proto8
+{
+    class StateCommit : Proto1.StateCommit
+    {
+        public StateCommit(ProtocolHandler protocol) : base(protocol) { }
+    }
+}

Tzkt.Sync/Protocols/Handlers/Proto8/Commits/StatisticsCommit.cs

@@ -0,0 +1,7 @@
+namespace Tzkt.Sync.Protocols.Proto8
+{
+    class StatisticsCommit : Proto1.StatisticsCommit
+    {
+        public StatisticsCommit(ProtocolHandler protocol) : base(protocol) { }
+    }
+}

Tzkt.Sync/Protocols/Handlers/Proto8/Commits/VotingCommit.cs

@@ -0,0 +1,44 @@
+using System;
+using Tzkt.Data.Models;
+
+namespace Tzkt.Sync.Protocols.Proto8
+{
+    class VotingCommit : Proto5.VotingCommit
+    {
+        public VotingCommit(ProtocolHandler protocol) : base(protocol) { }
+
+        // new voting period
+        protected override ProposalStatus GetProposalStatus(Proposal proposal, VotingPeriod period)
+        {
+            if (period.Status == PeriodStatus.Success)
+                return period.Kind == PeriodKind.Adoption
+                    ? ProposalStatus.Accepted
+                    : ProposalStatus.Active;
+
+            if (period.Status == PeriodStatus.NoSupermajority)
+                return ProposalStatus.Rejected;
+
+            return ProposalStatus.Skipped;
+        }
+
+        // new voting period
+        protected override VotingPeriod StartNextPeriod(Block block, VotingPeriod current)
+        {
+            switch (current.Kind)
+            {
+                case PeriodKind.Proposal:
+                    return StartBallotPeriod(block, current, PeriodKind.Exploration);
+                case PeriodKind.Exploration:
+                    return StartWaitingPeriod(block, current, PeriodKind.Testing);
+                case PeriodKind.Testing:
+                    return StartBallotPeriod(block, current, PeriodKind.Promotion);
+                case PeriodKind.Promotion:
+                    return StartWaitingPeriod(block, current, PeriodKind.Adoption);
+                case PeriodKind.Adoption:
+                    return StartProposalPeriod(block, current);
+                default:
+                    throw new Exception("Invalid voting period kind");
+            }
+        }
+    }
+}

Tzkt.Sync/Protocols/Handlers/Proto8/Diagnostics/Diagnostics.cs

@@ -0,0 +1,9 @@
+using Tzkt.Data;
+
+namespace Tzkt.Sync.Protocols.Proto8
+{
+    class Diagnostics : Proto5.Diagnostics
+    {
+        public Diagnostics(TzktContext db, IRpc rpc) : base(db, rpc) { }
+    }
+}