rusk-wallet: Add moonlight support

Also included in the PR is the following is the addition of functions
that return a key for a given index

rusk-wallet/src/cache.rs

@@ -239,6 +239,12 @@ impl Ord for NoteData {
     }
 }
 
+impl AsRef<Note> for NoteData {
+    fn as_ref(&self) -> &Note {
+        &self.note
+    }
+}
+
 impl Serializable<{ u64::SIZE + Note::SIZE }> for NoteData {
     type Error = dusk_bytes::Error;
     /// Converts a Note into a byte representation

rusk-wallet/src/clients.rs

@@ -8,7 +8,8 @@ mod sync;
 
 use dusk_bytes::Serializable;
 use execution_core::{
-    transfer::{phoenix::Prove, Transaction},
+    signatures::bls::PublicKey as AccountPublicKey,
+    transfer::{moonlight::AccountData, phoenix::Prove, Transaction},
     Error as ExecutionCoreError,
 };
 use flume::Receiver;
@@ -139,15 +140,15 @@ impl State {
     /// Skips writing the proof for non phoenix transactions
     pub fn prove_and_propagate(
         &self,
-        utx: Transaction,
+        tx: Transaction,
     ) -> Result<Transaction, Error> {
         let status = self.status;
         let prover = &self.prover;
-        let mut utx = utx;
+        let mut tx = tx;
 
-        if let Transaction::Phoenix(tx) = &mut utx {
+        if let Transaction::Phoenix(utx) = &mut tx {
             let status = self.status;
-            let proof = tx.proof();
+            let proof = utx.proof();
 
             status("Attempt to prove tx...");
 
@@ -158,12 +159,12 @@ impl State {
                     ExecutionCoreError::PhoenixCircuit(e.to_string())
                 })?;
 
-            tx.set_proof(proof);
+            utx.set_proof(proof);
 
             status("Proving sucesss!");
         }
 
-        let tx_bytes = utx.to_var_bytes();
+        let tx_bytes = tx.to_var_bytes();
 
         status("Attempt to preverify tx...");
         let preverify_req = RuskRequest::new("preverify", tx_bytes.clone());
@@ -175,7 +176,7 @@ impl State {
         let _ = self.client.call(2, "Chain", &propagate_req).wait()?;
         status("Transaction propagated!");
 
-        Ok(utx)
+        Ok(tx)
     }
 
     /// Find notes for a view key, starting from the given block height.
@@ -215,6 +216,27 @@ impl State {
         inputs
     }
 
+    pub(crate) fn fetch_account(
+        &self,
+        pk: &AccountPublicKey,
+    ) -> Result<AccountData, Error> {
+        let status = self.status;
+        status("Fetching account-data...");
+
+        let account = self
+            .client
+            .contract_query::<_, 1024>(TRANSFER_CONTRACT, "account", pk)
+            .wait()?;
+        let account = rkyv::from_bytes(&account).map_err(|_| Error::Rkyv)?;
+        status("account-data received!");
+
+        let account_address = pk.to_bytes().to_vec();
+        let account_address = bs58::encode(account_address).into_string();
+        println!("Account address: {}", account_address);
+
+        Ok(account)
+    }
+
     pub(crate) fn fetch_notes(
         &self,
         pk: &PhoenixPublicKey,

rusk-wallet/src/clients/sync.rs

@@ -25,17 +25,17 @@ pub(crate) async fn sync_db(
 ) -> Result<(), Error> {
     let seed = store.get_seed();
 
-    let addresses: Vec<(PhoenixSecretKey, PhoenixViewKey, PhoenixPublicKey)> =
-        (0..MAX_ADDRESSES)
-            .map(|i| {
-                let i = i as u8;
-                (
-                    derive_phoenix_sk(seed, i),
-                    derive_phoenix_vk(seed, i),
-                    derive_phoenix_pk(seed, i),
-                )
-            })
-            .collect();
+    let keys: Vec<(PhoenixSecretKey, PhoenixViewKey, PhoenixPublicKey)> = (0
+        ..MAX_ADDRESSES)
+        .map(|i| {
+            let i = i as u8;
+            (
+                derive_phoenix_sk(seed, i),
+                derive_phoenix_vk(seed, i),
+                derive_phoenix_pk(seed, i),
+            )
+        })
+        .collect();
 
     status("Getting cached note position...");
 
@@ -87,7 +87,7 @@ pub(crate) async fn sync_db(
         buffer = leaf_chunk.remainder().to_vec();
     }
 
-    for (sk, vk, pk) in addresses.iter() {
+    for (sk, vk, pk) in keys.iter() {
         for (block_height, note) in note_data.iter() {
             if vk.owns(note.stealth_address()) {
                 let nullifier = note.gen_nullifier(sk);
@@ -108,7 +108,7 @@ pub(crate) async fn sync_db(
 
     // Remove spent nullifiers from live notes
     // zerorize all the secret keys
-    for (mut sk, _, pk) in addresses {
+    for (mut sk, _, pk) in keys {
         let nullifiers: Vec<BlsScalar> = cache.unspent_notes_id(&pk)?;
 
         if !nullifiers.is_empty() {