Expose the queue of votes to process (#42)

canister/can.did

@@ -37,6 +37,7 @@ type NeuronPairPublic = record {
   nns_neuron_id : nat64;
   wtn_neuron_id : blob;
 };
+type NnsVote = record { adopt : bool; proposal_id : nat64 };
 type QueryStats = record {
   response_payload_bytes_total : nat;
   num_instructions_total : nat;
@@ -56,10 +57,20 @@ type RegisterNeuronPairError = variant {
   GovernanceError : record { int32; text };
 };
 type Result = variant { Ok : nat64; Err : RegisterNeuronPairError };
+type VoteToProcess = variant {
+  NnsVote : record { nat64; NnsVote };
+  PendingWtnVote : record { nat64; WtnVote };
+};
+type WtnVote = record {
+  nns_proposal_id : nat64;
+  adopt : bool;
+  wtn_proposal_id : nat64;
+};
 service : (InitOrUpgradeArgs) -> {
   deregister_neuron_pair : (DeregisterNeuronPairArgs) -> (bool);
   list_neuron_pairs : () -> (vec NeuronPairPublic) query;
   logs : () -> (vec text) query;
   register_neuron_pair : (RegisterNeuronPairArgs) -> (Result);
   status : () -> (CanisterStatusResponse);
+  votes_to_process : () -> (vec VoteToProcess) query;
 }

canister/src/lib.rs

@@ -44,19 +44,19 @@ impl InitOrUpgradeArgs {
     }
 }
 
-#[derive(Serialize, Deserialize, Debug)]
+#[derive(CandidType, Serialize, Deserialize, Clone, Debug)]
 enum VoteToProcess {
     NnsVote(u64, NnsVote),
     PendingWtnVote(u64, WtnVote),
 }
 
-#[derive(Serialize, Deserialize, Debug)]
+#[derive(CandidType, Serialize, Deserialize, Clone, Debug)]
 struct NnsVote {
     proposal_id: u64,
     adopt: bool,
 }
 
-#[derive(Serialize, Deserialize, Debug)]
+#[derive(CandidType, Serialize, Deserialize, Clone, Debug)]
 struct WtnVote {
     nns_proposal_id: u64,
     wtn_proposal_id: u64,

canister/src/queries/mod.rs

@@ -1,2 +1,3 @@
 mod list_neuron_pairs;
 mod logs;
+mod votes_to_process;

canister/src/queries/votes_to_process.rs

@@ -0,0 +1,7 @@
+use crate::{state, VoteToProcess};
+use ic_cdk::query;
+
+#[query]
+fn votes_to_process() -> Vec<VoteToProcess> {
+    state::read(|s| s.votes_to_process())
+}

canister/src/state.rs

@@ -145,6 +145,10 @@ impl State {
         self.votes_to_process.pop_front()
     }
 
+    pub fn votes_to_process(&self) -> Vec<VoteToProcess> {
+        self.votes_to_process.iter().cloned().collect()
+    }
+
     pub fn votes_to_process_count(&self) -> usize {
         self.votes_to_process.len()
     }