Add committee change events (#3158)

* Add committee change events * Update src/Neo/SmartContract/Native/NeoToken.cs * Update src/Neo/SmartContract/Native/NeoToken.cs
neo-project · Feb 26, 2024 · 0de52d2 · 0de52d2
1 parent d4564d1
commit 0de52d2
Showing 1 changed file with 17 additions and 1 deletion.
diff --git a/src/Neo/SmartContract/Native/NeoToken.cs b/src/Neo/SmartContract/Native/NeoToken.cs
@@ -63,6 +63,9 @@ public sealed class NeoToken : FungibleToken<NeoToken.NeoAccountState>
            "from", ContractParameterType.PublicKey,
            "to", ContractParameterType.PublicKey,
            "amount", ContractParameterType.Integer)]
+        [ContractEvent(3, name: "CommitteeChanged",
+           "old", ContractParameterType.Array,
+           "new", ContractParameterType.Array)]
         internal NeoToken() : base()
         {
             this.TotalAmount = 100000000 * Factor;
@@ -192,10 +195,23 @@ internal override ContractTask OnPersist(ApplicationEngine engine)
             // Set next committee
             if (ShouldRefreshCommittee(engine.PersistingBlock.Index, engine.ProtocolSettings.CommitteeMembersCount))
             {
-                StorageItem storageItem = engine.Snapshot.GetAndChange(CreateStorageKey(Prefix_Committee));
+                var storageItem = engine.Snapshot.GetAndChange(CreateStorageKey(Prefix_Committee));
                 var cachedCommittee = storageItem.GetInteroperable<CachedCommittee>();
+
+                var prevCommittee = cachedCommittee.Select(u => u.PublicKey).ToArray();
+
                 cachedCommittee.Clear();
                 cachedCommittee.AddRange(ComputeCommitteeMembers(engine.Snapshot, engine.ProtocolSettings));
+
+                var newCommittee = cachedCommittee.Select(u => u.PublicKey).ToArray();
+
+                if (!newCommittee.SequenceEqual(prevCommittee))
+                {
+                    engine.SendNotification(Hash, "CommitteeChanged", new VM.Types.Array(engine.ReferenceCounter) {
+                        new VM.Types.Array(engine.ReferenceCounter, prevCommittee.Select(u => (ByteString)u.ToArray())) ,
+                        new VM.Types.Array(engine.ReferenceCounter, newCommittee.Select(u => (ByteString)u.ToArray()))
+                    });
+                }
             }
             return ContractTask.CompletedTask;
         }