darkfi/bin/drk/src/wallet_dao.rs

/* This file is part of DarkFi (https://dark.fi)
 *
 * Copyright (C) 2020-2024 Dyne.org foundation
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Affero General Public License as
 * published by the Free Software Foundation, either version 3 of the
 * License, or (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Affero General Public License for more details.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program.  If not, see <https://www.gnu.org/licenses/>.
 */

use std::{collections::HashMap, fmt};

use anyhow::{anyhow, Result};
use darkfi::{
    rpc::jsonrpc::JsonRequest, tx::Transaction, util::parse::encode_base10,
    wallet::walletdb::QueryType,
};
use darkfi_dao_contract::{
    client::{
        DaoProposeNote, DaoVoteNote, DAO_DAOS_COL_APPROVAL_RATIO_BASE,
        DAO_DAOS_COL_APPROVAL_RATIO_QUOT, DAO_DAOS_COL_BULLA_BLIND, DAO_DAOS_COL_CALL_INDEX,
        DAO_DAOS_COL_DAO_ID, DAO_DAOS_COL_GOV_TOKEN_ID, DAO_DAOS_COL_LEAF_POSITION,
        DAO_DAOS_COL_NAME, DAO_DAOS_COL_PROPOSER_LIMIT, DAO_DAOS_COL_QUORUM, DAO_DAOS_COL_SECRET,
        DAO_DAOS_COL_TX_HASH, DAO_DAOS_TABLE, DAO_PROPOSALS_COL_AMOUNT,
        DAO_PROPOSALS_COL_BULLA_BLIND, DAO_PROPOSALS_COL_CALL_INDEX, DAO_PROPOSALS_COL_DAO_ID,
        DAO_PROPOSALS_COL_LEAF_POSITION, DAO_PROPOSALS_COL_MONEY_SNAPSHOT_TREE,
        DAO_PROPOSALS_COL_OUR_VOTE_ID, DAO_PROPOSALS_COL_PROPOSAL_ID,
        DAO_PROPOSALS_COL_RECV_PUBLIC, DAO_PROPOSALS_COL_SENDCOIN_TOKEN_ID,
        DAO_PROPOSALS_COL_TX_HASH, DAO_PROPOSALS_TABLE, DAO_TREES_COL_DAOS_TREE,
        DAO_TREES_COL_PROPOSALS_TREE, DAO_TREES_TABLE, DAO_VOTES_COL_ALL_VOTE_BLIND,
        DAO_VOTES_COL_ALL_VOTE_VALUE, DAO_VOTES_COL_CALL_INDEX, DAO_VOTES_COL_PROPOSAL_ID,
        DAO_VOTES_COL_TX_HASH, DAO_VOTES_COL_VOTE_ID, DAO_VOTES_COL_VOTE_OPTION,
        DAO_VOTES_COL_YES_VOTE_BLIND, DAO_VOTES_TABLE,
    },
    model::{DaoBulla, DaoMintParams, DaoProposeParams, DaoVoteParams},
    DaoFunction,
};
use darkfi_sdk::{
    bridgetree,
    crypto::{
        poseidon_hash, Keypair, MerkleNode, MerkleTree, PublicKey, SecretKey, TokenId,
        DAO_CONTRACT_ID,
    },
    pasta::pallas,
};
use darkfi_serial::{deserialize, serialize, SerialDecodable, SerialEncodable};
use serde_json::json;

use super::Drk;

#[derive(Debug, Clone, SerialEncodable, SerialDecodable)]
/// Parameters representing a DAO to be initialized
pub struct DaoParams {
    /// The minimum amount of governance tokens needed to open a proposal
    pub proposer_limit: u64,
    /// Minimal threshold of participating total tokens needed for a proposal to pass
    pub quorum: u64,
    /// The ratio of winning/total votes needed for a proposal to pass
    pub approval_ratio_base: u64,
    pub approval_ratio_quot: u64,
    /// DAO's governance token ID
    pub gov_token_id: TokenId,
    /// Secret key for the DAO
    pub secret_key: SecretKey,
    /// DAO bulla blind
    pub bulla_blind: pallas::Base,
}

impl fmt::Display for DaoParams {
    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
        let s = format!(
            "{}\n{}\n{}: {} ({})\n{}: {} ({})\n{}: {}\n{}: {}\n{}: {}\n{}: {}\n{}: {:?}",
            "DAO Parameters",
            "==============",
            "Proposer limit",
            encode_base10(self.proposer_limit, 8),
            self.proposer_limit,
            "Quorum",
            encode_base10(self.quorum, 8),
            self.quorum,
            "Approval ratio",
            self.approval_ratio_quot as f64 / self.approval_ratio_base as f64,
            "Governance Token ID",
            self.gov_token_id,
            "Public key",
            PublicKey::from_secret(self.secret_key),
            "Secret key",
            self.secret_key,
            "Bulla blind",
            self.bulla_blind,
        );

        write!(f, "{}", s)
    }
}

#[derive(Debug, Clone)]
/// Parameters representing an intialized DAO, optionally deployed on-chain
pub struct Dao {
    /// Numeric identifier for the DAO
    pub id: u64,
    /// Named identifier for the DAO
    pub name: String,
    /// The minimum amount of governance tokens needed to open a proposal
    pub proposer_limit: u64,
    /// Minimal threshold of participating total tokens needed for a proposal to pass
    pub quorum: u64,
    /// The ratio of winning/total votes needed for a proposal to pass
    pub approval_ratio_base: u64,
    pub approval_ratio_quot: u64,
    /// DAO's governance token ID
    pub gov_token_id: TokenId,
    /// Secret key for the DAO
    pub secret_key: SecretKey,
    /// DAO bulla blind
    pub bulla_blind: pallas::Base,
    /// Leaf position of the DAO in the Merkle tree of DAOs
    pub leaf_position: Option<bridgetree::Position>,
    /// The transaction hash where the DAO was deployed
    pub tx_hash: Option<blake3::Hash>,
    /// The call index in the transaction where the DAO was deployed
    pub call_index: Option<u32>,
}

impl Dao {
    pub fn bulla(&self) -> DaoBulla {
        let (x, y) = PublicKey::from_secret(self.secret_key).xy();

        DaoBulla::from(poseidon_hash([
            pallas::Base::from(self.proposer_limit),
            pallas::Base::from(self.quorum),
            pallas::Base::from(self.approval_ratio_quot),
            pallas::Base::from(self.approval_ratio_base),
            self.gov_token_id.inner(),
            x,
            y,
            self.bulla_blind,
        ]))
    }

    pub fn keypair(&self) -> Keypair {
        let public = PublicKey::from_secret(self.secret_key);
        Keypair { public, secret: self.secret_key }
    }
}

impl fmt::Display for Dao {
    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
        let s = format!(
            "{}\n{}\n{}: {}\n{}: {}\n{}: {} ({})\n{}: {} ({})\n{}: {}\n{}: {}\n{}: {}\n{}: {}\n{}: {:?}\n{}: {:?}\n{}: {:?}\n{}: {:?}",
            "DAO Parameters",
            "==============",
            "Name",
            self.name,
            "Bulla",
            self.bulla(),
            "Proposer limit",
            encode_base10(self.proposer_limit, 8),
            self.proposer_limit,
            "Quorum",
            encode_base10(self.quorum, 8),
            self.quorum,
            "Approval ratio",
            self.approval_ratio_quot as f64 / self.approval_ratio_base as f64,
            "Governance Token ID",
            self.gov_token_id,
            "Public key",
            PublicKey::from_secret(self.secret_key),
            "Secret key",
            self.secret_key,
            "Bulla blind",
            self.bulla_blind,
            "Leaf position",
            self.leaf_position,
            "Tx hash",
            self.tx_hash,
            "Call idx",
            self.call_index,
        );

        write!(f, "{}", s)
    }
}

#[derive(Debug, Clone)]
/// Parameters representing an initialized DAO proposal, optionally deployed on-chain
pub struct DaoProposal {
    /// Numeric identifier for the proposal
    pub id: u64,
    /// The DAO bulla related to this proposal
    pub dao_bulla: DaoBulla,
    /// Recipient of this proposal's funds
    pub recipient: PublicKey,
    /// Amount of this proposal
    pub amount: u64,
    /// Token ID to be sent
    pub token_id: TokenId,
    /// Proposal's bulla blind
    pub bulla_blind: pallas::Base,
    /// Leaf position of this proposal in the Merkle tree of proposals
    pub leaf_position: Option<bridgetree::Position>,
    /// Snapshotted Money Merkle tree
    pub money_snapshot_tree: Option<MerkleTree>,
    /// Transaction hash where this proposal was proposed
    pub tx_hash: Option<blake3::Hash>,
    /// call index in the transaction where this proposal was proposed
    pub call_index: Option<u32>,
    /// The vote ID we've voted on this proposal
    pub vote_id: Option<pallas::Base>,
}

impl DaoProposal {
    pub fn bulla(&self) -> pallas::Base {
        let (dest_x, dest_y) = self.recipient.xy();

        poseidon_hash([
            dest_x,
            dest_y,
            pallas::Base::from(self.amount),
            self.token_id.inner(),
            self.dao_bulla.inner(),
            self.bulla_blind,
        ])
    }
}

impl fmt::Display for DaoProposal {
    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
        let s = format!(
            concat!(
                "Proposal parameters\n",
                "===================\n",
                "DAO Bulla: {}\n",
                "Recipient: {}\n",
                "Proposal amount: {} ({})\n",
                "Proposal Token ID: {:?}\n",
                "Proposal bulla blind: {:?}\n",
                "Proposal leaf position: {:?}\n",
                "Proposal tx hash: {:?}\n",
                "Proposal call index: {:?}\n",
                "Proposal vote ID: {:?}",
            ),
            self.dao_bulla,
            self.recipient,
            encode_base10(self.amount, 8),
            self.amount,
            self.token_id,
            self.bulla_blind,
            self.leaf_position,
            self.tx_hash,
            self.call_index,
            self.vote_id,
        );

        write!(f, "{}", s)
    }
}

#[derive(Debug, Clone)]
/// Parameters representing a vote we've made on a DAO proposal
pub struct DaoVote {
    /// Numeric identifier for the vote
    pub id: u64,
    /// Numeric identifier for the proposal related to this vote
    pub proposal_id: u64,
    /// The vote
    pub vote_option: bool,
    /// Blinding factor for the yes vote
    pub yes_vote_blind: pallas::Scalar,
    /// Value of all votes
    pub all_vote_value: u64,
    /// Blinding facfor of all votes
    pub all_vote_blind: pallas::Scalar,
    /// Transaction hash where this vote was casted
    pub tx_hash: Option<blake3::Hash>,
    /// call index in the transaction where this vote was casted
    pub call_index: Option<u32>,
}

impl Drk {
    /// Initialize wallet with tables for the DAO contract
    pub async fn initialize_dao(&self) -> Result<()> {
        let wallet_schema = include_str!("../../../src/contract/dao/wallet.sql");

        // We perform a request to darkfid with the schema to initialize
        // the necessary tables in the wallet.
        let req = JsonRequest::new("wallet.exec_sql", json!([wallet_schema]));
        let rep = self.rpc_client.request(req).await?;

        if rep == true {
            eprintln!("Successfully initialized wallet schema for the DAO contract");
        } else {
            eprintln!("[initialize_dao] Got unexpected reply from darkfid: {}", rep);
        }

        // Check if we have to initialize the Merkle trees.
        // We check if one exists, but we actually create two. This should be written
        // a bit better and safer.
        let mut tree_needs_init = false;
        let query = format!("SELECT {} FROM {}", DAO_TREES_COL_DAOS_TREE, DAO_TREES_TABLE);
        let params = json!([query, QueryType::Blob as u8, DAO_TREES_COL_DAOS_TREE]);
        let req = JsonRequest::new("wallet.query_row_single", params);

        // For now, on success, we don't care what's returned, but in the future
        // we should actually check it.
        // TODO: The RPC needs a better variant for errors so detailed inspection
        //       can be done with error codes and all that.
        if (self.rpc_client.request(req).await).is_err() {
            tree_needs_init = true;
        }

        if tree_needs_init {
            eprintln!("Initializing DAO Merkle trees");
            let tree = MerkleTree::new(100);
            self.put_dao_trees(&tree, &tree).await?;
            eprintln!("Successfully initialized Merkle trees for the DAO contract");
        }

        Ok(())
    }

    /// Fetch all DAO secret keys from the wallet
    pub async fn get_dao_secrets(&self) -> Result<Vec<SecretKey>> {
        let daos = self.get_daos().await?;
        let mut ret = Vec::with_capacity(daos.len());
        for dao in daos {
            ret.push(dao.secret_key);
        }

        Ok(ret)
    }

    /// Replace the DAO Merkle trees in the wallet.
    pub async fn put_dao_trees(
        &self,
        daos_tree: &MerkleTree,
        proposals_tree: &MerkleTree,
    ) -> Result<()> {
        let query = format!(
            "DELETE FROM {}; INSERT INTO {} ({}, {}) VALUES (?1, ?2);",
            DAO_TREES_TABLE, DAO_TREES_TABLE, DAO_TREES_COL_DAOS_TREE, DAO_TREES_COL_PROPOSALS_TREE,
        );

        let params = json!([
            query,
            QueryType::Blob as u8,
            serialize(daos_tree),
            QueryType::Blob as u8,
            serialize(proposals_tree),
        ]);

        let req = JsonRequest::new("wallet.exec_sql", params);
        let _ = self.rpc_client.request(req).await?;

        Ok(())
    }

    /// Fetch DAO Merkle trees from the wallet
    pub async fn get_dao_trees(&self) -> Result<(MerkleTree, MerkleTree)> {
        let query = format!("SELECT * FROM {}", DAO_TREES_TABLE);

        let params = json!([
            query,
            QueryType::Blob as u8,
            DAO_TREES_COL_DAOS_TREE,
            QueryType::Blob as u8,
            DAO_TREES_COL_PROPOSALS_TREE,
        ]);

        let req = JsonRequest::new("wallet.query_row_single", params);
        let rep = self.rpc_client.request(req).await?;

        let daos_tree_bytes: Vec<u8> = serde_json::from_value(rep[0].clone())?;
        let daos_tree = deserialize(&daos_tree_bytes)?;

        let proposals_tree_bytes: Vec<u8> = serde_json::from_value(rep[1].clone())?;
        let proposals_tree = deserialize(&proposals_tree_bytes)?;

        Ok((daos_tree, proposals_tree))
    }

    /// Reset the DAO Merkle trees in the wallet
    pub async fn reset_dao_trees(&self) -> Result<()> {
        eprintln!("Resetting DAO Merkle trees");
        let tree = MerkleTree::new(100);
        self.put_dao_trees(&tree, &tree).await?;
        eprintln!("Successfully reset DAO Merkle trees");

        Ok(())
    }

    /// Reset confirmed DAOs in the wallet
    pub async fn reset_daos(&self) -> Result<()> {
        eprintln!("Resetting DAO confirmations");
        let daos = self.get_daos().await?;
        self.unconfirm_daos(&daos).await?;
        eprintln!("Successfully unconfirmed DAOs");

        Ok(())
    }

    pub async fn reset_dao_proposals(&self) -> Result<()> {
        eprintln!("Resetting DAO proposals");
        let query = format!("DELETE FROM {};", DAO_PROPOSALS_TABLE);

        let params = json!([query]);

        let req = JsonRequest::new("wallet.exec_sql", params);
        let _ = self.rpc_client.request(req).await?;

        Ok(())
    }

    pub async fn reset_dao_votes(&self) -> Result<()> {
        eprintln!("Resetting DAO votes");
        let query = format!("DELETE FROM {};", DAO_VOTES_TABLE);

        let params = json!([query]);

        let req = JsonRequest::new("wallet.exec_sql", params);
        let _ = self.rpc_client.request(req).await?;

        Ok(())
    }

    pub async fn get_dao_id_by_alias(&self, alias_filter: &str) -> Result<u64> {
        let query = format!(
            "SELECT {}, {} FROM {}",
            DAO_DAOS_COL_DAO_ID, DAO_DAOS_COL_NAME, DAO_DAOS_TABLE,
        );
        let params = json!([
            query,
            QueryType::Integer as u8,
            DAO_DAOS_COL_DAO_ID,
            QueryType::Text as u8,
            DAO_DAOS_COL_NAME,
        ]);

        let req = JsonRequest::new("wallet.query_row_multi", params);
        let rep = self.rpc_client.request(req).await?;

        // The returned thing should be an array of found rows.
        let Some(rows) = rep.as_array() else {
            return Err(anyhow!("[get_dao_id_by_alias] Unexpected response from darkfid: {}", rep))
        };

        for row in rows {
            let Some(row) = row.as_array() else {
                return Err(anyhow!(
                    "[get_dao_id_by_alias] Unexpected response from darkfid: {}",
                    rep
                ))
            };

            let alias: String = serde_json::from_value(row[1].clone())?;
            if alias != alias_filter {
                continue
            }

            let dao_id: u64 = serde_json::from_value(row[0].clone())?;
            return Ok(dao_id)
        }

        Err(anyhow!("[get_dao_id_by_alias] DAO not found"))
    }

    /// Convenience function. Interprets the alias either as the DAO alias or its ID
    pub async fn get_dao_id(&self, alias: &str) -> Result<u64> {
        if let Ok(id) = self.get_dao_id_by_alias(alias).await {
            return Ok(id)
        }
        Ok(alias.parse()?)
    }

    /// Import given DAO params into the wallet with a given name.
    pub async fn import_dao(&self, dao_name: String, dao_params: DaoParams) -> Result<()> {
        // First let's check if we've imported this DAO with the given name before.
        let daos = self.get_daos().await?;
        if daos.iter().any(|x| x.name == dao_name) {
            return Err(anyhow!("This DAO has already been imported"))
        }

        eprintln!("Importing \"{}\" DAO into the wallet", dao_name);

        let query = format!(
            "INSERT INTO {} ({}, {}, {}, {}, {}, {}, {}, {}) VALUES (?1, ?2, ?3, ?4, ?5, ?6, ?7, ?8);",
            DAO_DAOS_TABLE,
            DAO_DAOS_COL_NAME,
            DAO_DAOS_COL_PROPOSER_LIMIT,
            DAO_DAOS_COL_QUORUM,
            DAO_DAOS_COL_APPROVAL_RATIO_BASE,
            DAO_DAOS_COL_APPROVAL_RATIO_QUOT,
            DAO_DAOS_COL_GOV_TOKEN_ID,
            DAO_DAOS_COL_SECRET,
            DAO_DAOS_COL_BULLA_BLIND,
        );

        let params = json!([
            query,
            QueryType::Text as u8,
            dao_name,
            QueryType::Blob as u8,
            serialize(&dao_params.proposer_limit),
            QueryType::Blob as u8,
            serialize(&dao_params.quorum),
            QueryType::Integer as u8,
            dao_params.approval_ratio_base,
            QueryType::Integer as u8,
            dao_params.approval_ratio_quot,
            QueryType::Blob as u8,
            serialize(&dao_params.gov_token_id),
            QueryType::Blob as u8,
            serialize(&dao_params.secret_key),
            QueryType::Blob as u8,
            serialize(&dao_params.bulla_blind),
        ]);

        let req = JsonRequest::new("wallet.exec_sql", params);
        let _ = self.rpc_client.request(req).await?;
        eprintln!("DAO imported successfully");

        Ok(())
    }

    /// List DAO(s) imported in the wallet. If an ID is given, just print the
    /// metadata for that specific one, if found.
    pub async fn dao_list(&self, dao_id: Option<u64>) -> Result<()> {
        if let Some(dao_id) = dao_id {
            return self.dao_list_single(dao_id).await
        }

        let daos = self.get_daos().await?;
        for dao in daos {
            println!("[{}] {}", dao.id, dao.name);
        }

        Ok(())
    }

    async fn dao_list_single(&self, dao_id: u64) -> Result<()> {
        let dao = self.get_dao_by_id(dao_id).await?;

        println!("{}", dao);

        Ok(())
    }

    /// Fetch a DAO given a numeric ID
    pub async fn get_dao_by_id(&self, dao_id: u64) -> Result<Dao> {
        let daos = self.get_daos().await?;

        let Some(dao) = daos.iter().find(|x| x.id == dao_id) else {
            return Err(anyhow!("DAO not found in wallet"))
        };

        Ok(dao.clone())
    }

    /// Fetch all known DAOs from the wallet.
    pub async fn get_daos(&self) -> Result<Vec<Dao>> {
        let query = format!("SELECT * FROM {}", DAO_DAOS_TABLE);

        let params = json!([
            query,
            QueryType::Integer as u8,
            DAO_DAOS_COL_DAO_ID,
            QueryType::Text as u8,
            DAO_DAOS_COL_NAME,
            QueryType::Blob as u8,
            DAO_DAOS_COL_PROPOSER_LIMIT,
            QueryType::Blob as u8,
            DAO_DAOS_COL_QUORUM,
            QueryType::Integer as u8,
            DAO_DAOS_COL_APPROVAL_RATIO_BASE,
            QueryType::Integer as u8,
            DAO_DAOS_COL_APPROVAL_RATIO_QUOT,
            QueryType::Blob as u8,
            DAO_DAOS_COL_GOV_TOKEN_ID,
            QueryType::Blob as u8,
            DAO_DAOS_COL_SECRET,
            QueryType::Blob as u8,
            DAO_DAOS_COL_BULLA_BLIND,
            QueryType::OptionBlob as u8,
            DAO_DAOS_COL_LEAF_POSITION,
            QueryType::OptionBlob as u8,
            DAO_DAOS_COL_TX_HASH,
            QueryType::OptionInteger as u8,
            DAO_DAOS_COL_CALL_INDEX,
        ]);

        let req = JsonRequest::new("wallet.query_row_multi", params);
        let rep = self.rpc_client.request(req).await?;

        let Some(rows) = rep.as_array() else {
            return Err(anyhow!("[get_daos] Unexpected response from darkfid: {}", rep))
        };

        let mut daos = Vec::with_capacity(rows.len());

        for row in rows {
            let Some(row) = row.as_array() else {
                return Err(anyhow!("[get_daos] Unexpected response from darkfid: {}", rep))
            };

            let id: u64 = serde_json::from_value(row[0].clone())?;

            let name: String = serde_json::from_value(row[1].clone())?;

            let proposer_limit_bytes: Vec<u8> = serde_json::from_value(row[2].clone())?;
            let proposer_limit = deserialize(&proposer_limit_bytes)?;

            let quorum_bytes: Vec<u8> = serde_json::from_value(row[3].clone())?;
            let quorum = deserialize(&quorum_bytes)?;

            let approval_ratio_base = serde_json::from_value(row[4].clone())?;
            let approval_ratio_quot = serde_json::from_value(row[5].clone())?;

            let gov_token_bytes: Vec<u8> = serde_json::from_value(row[6].clone())?;
            let gov_token_id = deserialize(&gov_token_bytes)?;

            let secret_bytes: Vec<u8> = serde_json::from_value(row[7].clone())?;
            let secret_key = deserialize(&secret_bytes)?;

            let bulla_blind_bytes: Vec<u8> = serde_json::from_value(row[8].clone())?;
            let bulla_blind = deserialize(&bulla_blind_bytes)?;

            let leaf_position_bytes: Vec<u8> = serde_json::from_value(row[9].clone())?;
            let tx_hash_bytes: Vec<u8> = serde_json::from_value(row[10].clone())?;
            let call_index = serde_json::from_value(row[11].clone())?;

            let leaf_position = if leaf_position_bytes.is_empty() {
                None
            } else {
                Some(deserialize(&leaf_position_bytes)?)
            };

            let tx_hash =
                if tx_hash_bytes.is_empty() { None } else { Some(deserialize(&tx_hash_bytes)?) };

            let dao = Dao {
                id,
                name,
                proposer_limit,
                quorum,
                approval_ratio_base,
                approval_ratio_quot,
                gov_token_id,
                secret_key,
                bulla_blind,
                leaf_position,
                tx_hash,
                call_index,
            };

            daos.push(dao);
        }

        // Here we sort the vec by ID. The SQL SELECT statement does not guarantee
        // this, so just do it here.
        daos.sort_by(|a, b| a.id.cmp(&b.id));
        Ok(daos)
    }

    /// Fetch known unspent balances from the wallet for the given DAO ID
    pub async fn dao_balance(&self, dao_id: u64) -> Result<HashMap<String, u64>> {
        let daos = self.get_daos().await?;
        let Some(dao) = daos.get(dao_id as usize - 1) else {
            return Err(anyhow!("DAO with ID {} not found in wallet", dao_id))
        };

        let mut coins = self.get_coins(false).await?;
        coins.retain(|x| x.0.note.spend_hook == DAO_CONTRACT_ID.inner());
        coins.retain(|x| x.0.note.user_data == dao.bulla().inner());

        // Fill this map with balances
        let mut balmap: HashMap<String, u64> = HashMap::new();

        for coin in coins {
            let mut value = coin.0.note.value;

            if let Some(prev) = balmap.get(&coin.0.note.token_id.to_string()) {
                value += prev;
            }

            balmap.insert(coin.0.note.token_id.to_string(), value);
        }

        Ok(balmap)
    }

    /// Fetch all known DAO proposals from the wallet given a DAO ID
    pub async fn get_dao_proposals(&self, dao_id: u64) -> Result<Vec<DaoProposal>> {
        let daos = self.get_daos().await?;
        let Some(dao) = daos.get(dao_id as usize - 1) else {
            return Err(anyhow!("DAO with ID {} not found in wallet", dao_id))
        };

        let query = format!(
            "SELECT * FROM {} WHERE {} = {}",
            DAO_PROPOSALS_TABLE, DAO_PROPOSALS_COL_DAO_ID, dao_id
        );

        let params = json!([
            query,
            QueryType::Integer as u8,
            DAO_PROPOSALS_COL_PROPOSAL_ID,
            QueryType::Integer as u8,
            DAO_PROPOSALS_COL_DAO_ID,
            QueryType::Blob as u8,
            DAO_PROPOSALS_COL_RECV_PUBLIC,
            QueryType::Blob as u8,
            DAO_PROPOSALS_COL_AMOUNT,
            QueryType::Blob as u8,
            DAO_PROPOSALS_COL_SENDCOIN_TOKEN_ID,
            QueryType::Blob as u8,
            DAO_PROPOSALS_COL_BULLA_BLIND,
            QueryType::OptionBlob as u8,
            DAO_PROPOSALS_COL_LEAF_POSITION,
            QueryType::OptionBlob as u8,
            DAO_PROPOSALS_COL_MONEY_SNAPSHOT_TREE,
            QueryType::OptionBlob as u8,
            DAO_PROPOSALS_COL_TX_HASH,
            QueryType::OptionInteger as u8,
            DAO_PROPOSALS_COL_CALL_INDEX,
            QueryType::OptionBlob as u8,
            DAO_PROPOSALS_COL_OUR_VOTE_ID,
        ]);

        let req = JsonRequest::new("wallet.query_row_multi", params);
        let rep = self.rpc_client.request(req).await?;

        let Some(rows) = rep.as_array() else {
            return Err(anyhow!("[get_proposals] Unexpected response from darkfid: {}", rep))
        };

        let mut proposals = Vec::with_capacity(rows.len());

        for row in rows {
            let Some(row) = row.as_array() else {
                return Err(anyhow!("[get_proposals] Unexpected response from darkfid: {}", rep))
            };

            let id: u64 = serde_json::from_value(row[0].clone())?;

            let dao_id: u64 = serde_json::from_value(row[1].clone())?;
            assert!(dao_id == dao.id);
            let dao_bulla = dao.bulla();

            let recipient_bytes: Vec<u8> = serde_json::from_value(row[2].clone())?;
            let recipient = deserialize(&recipient_bytes)?;

            let amount_bytes: Vec<u8> = serde_json::from_value(row[3].clone())?;
            let amount = deserialize(&amount_bytes)?;

            let token_id_bytes: Vec<u8> = serde_json::from_value(row[4].clone())?;
            let token_id = deserialize(&token_id_bytes)?;

            let bulla_blind_bytes: Vec<u8> = serde_json::from_value(row[5].clone())?;
            let bulla_blind = deserialize(&bulla_blind_bytes)?;

            let leaf_position_bytes: Vec<u8> = serde_json::from_value(row[6].clone())?;

            let money_snapshot_tree_bytes: Vec<u8> = serde_json::from_value(row[7].clone())?;

            let tx_hash_bytes: Vec<u8> = serde_json::from_value(row[8].clone())?;

            let call_index = serde_json::from_value(row[9].clone())?;

            let vote_id_bytes: Vec<u8> = serde_json::from_value(row[10].clone())?;

            let leaf_position = if leaf_position_bytes.is_empty() {
                None
            } else {
                Some(deserialize(&leaf_position_bytes)?)
            };

            let money_snapshot_tree = if money_snapshot_tree_bytes.is_empty() {
                None
            } else {
                Some(deserialize(&money_snapshot_tree_bytes)?)
            };

            let tx_hash =
                if tx_hash_bytes.is_empty() { None } else { Some(deserialize(&tx_hash_bytes)?) };

            let vote_id =
                if vote_id_bytes.is_empty() { None } else { Some(deserialize(&vote_id_bytes)?) };

            let proposal = DaoProposal {
                id,
                dao_bulla,
                recipient,
                amount,
                token_id,
                bulla_blind,
                leaf_position,
                money_snapshot_tree,
                tx_hash,
                call_index,
                vote_id,
            };

            proposals.push(proposal);
        }

        // Here we sort the vec by ID. The SQL SELECT statement does not guarantee
        // this, so just do it here.
        proposals.sort_by(|a, b| a.id.cmp(&b.id));
        Ok(proposals)
    }

    /// Fetch a DAO proposal by its ID
    pub async fn get_dao_proposal_by_id(&self, proposal_id: u64) -> Result<DaoProposal> {
        let query = format!(
            "SELECT * FROM {} WHERE {} = {}",
            DAO_PROPOSALS_TABLE, DAO_PROPOSALS_COL_PROPOSAL_ID, proposal_id
        );

        let params = json!([
            query,
            QueryType::Integer as u8,
            DAO_PROPOSALS_COL_PROPOSAL_ID,
            QueryType::Integer as u8,
            DAO_PROPOSALS_COL_DAO_ID,
            QueryType::Blob as u8,
            DAO_PROPOSALS_COL_RECV_PUBLIC,
            QueryType::Blob as u8,
            DAO_PROPOSALS_COL_AMOUNT,
            QueryType::Blob as u8,
            DAO_PROPOSALS_COL_SENDCOIN_TOKEN_ID,
            QueryType::Blob as u8,
            DAO_PROPOSALS_COL_BULLA_BLIND,
            QueryType::OptionBlob as u8,
            DAO_PROPOSALS_COL_LEAF_POSITION,
            QueryType::OptionBlob as u8,
            DAO_PROPOSALS_COL_MONEY_SNAPSHOT_TREE,
            QueryType::OptionBlob as u8,
            DAO_PROPOSALS_COL_TX_HASH,
            QueryType::OptionInteger as u8,
            DAO_PROPOSALS_COL_CALL_INDEX,
            QueryType::OptionBlob as u8,
            DAO_PROPOSALS_COL_OUR_VOTE_ID,
        ]);

        let req = JsonRequest::new("wallet.query_row_single", params);
        let rep = self.rpc_client.request(req).await?;

        let Some(row) = rep.as_array() else {
            return Err(anyhow!("[get_proposal_by_id] Unexpected response from darkfid: {}", rep))
        };

        let id: u64 = serde_json::from_value(row[0].clone())?;
        let dao_id: u64 = serde_json::from_value(row[1].clone())?;

        let recipient_bytes: Vec<u8> = serde_json::from_value(row[2].clone())?;
        let recipient = deserialize(&recipient_bytes)?;

        let amount_bytes: Vec<u8> = serde_json::from_value(row[3].clone())?;
        let amount = deserialize(&amount_bytes)?;

        let token_id_bytes: Vec<u8> = serde_json::from_value(row[4].clone())?;
        let token_id = deserialize(&token_id_bytes)?;

        let bulla_blind_bytes: Vec<u8> = serde_json::from_value(row[5].clone())?;
        let bulla_blind = deserialize(&bulla_blind_bytes)?;

        let leaf_position_bytes: Vec<u8> = serde_json::from_value(row[6].clone())?;

        let money_snapshot_tree_bytes: Vec<u8> = serde_json::from_value(row[7].clone())?;

        let tx_hash_bytes: Vec<u8> = serde_json::from_value(row[8].clone())?;

        let call_index = serde_json::from_value(row[9].clone())?;

        let vote_id_bytes: Vec<u8> = serde_json::from_value(row[10].clone())?;

        let leaf_position = if leaf_position_bytes.is_empty() {
            None
        } else {
            Some(deserialize(&leaf_position_bytes)?)
        };

        let tx_hash =
            if tx_hash_bytes.is_empty() { None } else { Some(deserialize(&tx_hash_bytes)?) };

        let money_snapshot_tree = if money_snapshot_tree_bytes.is_empty() {
            None
        } else {
            Some(deserialize(&money_snapshot_tree_bytes)?)
        };

        let vote_id =
            if vote_id_bytes.is_empty() { None } else { Some(deserialize(&vote_id_bytes)?) };

        let dao = self.get_dao_by_id(dao_id).await?;

        let proposal = DaoProposal {
            id,
            dao_bulla: dao.bulla(),
            recipient,
            amount,
            token_id,
            bulla_blind,
            leaf_position,
            money_snapshot_tree,
            tx_hash,
            call_index,
            vote_id,
        };

        Ok(proposal)
    }

    // Fetch all known DAO proposal votes from the wallet given a proposal ID
    pub async fn get_dao_proposal_votes(&self, proposal_id: u64) -> Result<Vec<DaoVote>> {
        let query = format!(
            "SELECT * FROM {} WHERE {} = {}",
            DAO_VOTES_TABLE, DAO_VOTES_COL_PROPOSAL_ID, proposal_id
        );

        let params = json!([
            query,
            QueryType::Integer as u8,
            DAO_VOTES_COL_VOTE_ID,
            QueryType::Integer as u8,
            DAO_VOTES_COL_PROPOSAL_ID,
            QueryType::Integer as u8,
            DAO_VOTES_COL_VOTE_OPTION,
            QueryType::Blob as u8,
            DAO_VOTES_COL_YES_VOTE_BLIND,
            QueryType::Blob as u8,
            DAO_VOTES_COL_ALL_VOTE_VALUE,
            QueryType::Blob as u8,
            DAO_VOTES_COL_ALL_VOTE_BLIND,
            QueryType::OptionBlob as u8,
            DAO_VOTES_COL_TX_HASH,
            QueryType::OptionInteger as u8,
            DAO_VOTES_COL_CALL_INDEX,
        ]);

        let req = JsonRequest::new("wallet.query_row_multi", params);
        let rep = self.rpc_client.request(req).await?;

        let Some(rows) = rep.as_array() else {
            return Err(anyhow!(
                "[get_dao_proposal_votes] Unexpected response from darkfid: {}",
                rep
            ))
        };

        let mut votes = Vec::with_capacity(rows.len());

        for row in rows {
            let Some(row) = row.as_array() else {
                return Err(anyhow!(
                    "[get_dao_proposal_votes] Unexpected response from darkfid: {}",
                    rep
                ))
            };

            let id: u64 = serde_json::from_value(row[0].clone())?;
            let proposal_id: u64 = serde_json::from_value(row[1].clone())?;
            let vote_option: u32 = serde_json::from_value(row[2].clone())?;
            let vote_option = vote_option != 0;

            let yes_vote_blind_bytes: Vec<u8> = serde_json::from_value(row[3].clone())?;
            let yes_vote_blind = deserialize(&yes_vote_blind_bytes)?;

            let all_vote_value_bytes: Vec<u8> = serde_json::from_value(row[4].clone())?;
            let all_vote_value = deserialize(&all_vote_value_bytes)?;

            let all_vote_blind_bytes: Vec<u8> = serde_json::from_value(row[5].clone())?;
            let all_vote_blind = deserialize(&all_vote_blind_bytes)?;

            let tx_hash_bytes: Vec<u8> = serde_json::from_value(row[6].clone())?;

            let call_index = serde_json::from_value(row[7].clone())?;

            let tx_hash =
                if tx_hash_bytes.is_empty() { None } else { Some(deserialize(&tx_hash_bytes)?) };

            let vote = DaoVote {
                id,
                proposal_id,
                vote_option,
                yes_vote_blind,
                all_vote_value,
                all_vote_blind,
                tx_hash,
                call_index,
            };

            votes.push(vote);
        }

        Ok(votes)
    }

    /// Append data related to DAO contract transactions into the wallet database.
    /// Optionally, if `confirm` is true, also append the data in the Merkle trees, etc.
    pub async fn apply_tx_dao_data(&self, tx: &Transaction, confirm: bool) -> Result<()> {
        let cid = *DAO_CONTRACT_ID;
        let mut daos = self.get_daos().await?;
        let mut daos_to_confirm = vec![];
        let (mut daos_tree, mut proposals_tree) = self.get_dao_trees().await?;

        // DAOs that have been minted
        let mut new_dao_bullas: Vec<(DaoBulla, Option<blake3::Hash>, u32)> = vec![];
        // DAO proposals that have been minted
        let mut new_dao_proposals: Vec<(
            DaoProposeParams,
            Option<MerkleTree>,
            Option<blake3::Hash>,
            u32,
        )> = vec![];
        let mut our_proposals: Vec<DaoProposal> = vec![];
        // DAO votes that have been seen
        let mut new_dao_votes: Vec<(DaoVoteParams, Option<blake3::Hash>, u32)> = vec![];
        let mut dao_votes: Vec<DaoVote> = vec![];

        // Run through the transaction and see what we got:
        for (i, call) in tx.calls.iter().enumerate() {
            if call.contract_id == cid && call.data[0] == DaoFunction::Mint as u8 {
                eprintln!("Found Dao::Mint in call {}", i);
                let params: DaoMintParams = deserialize(&call.data[1..])?;
                let tx_hash = if confirm { Some(blake3::hash(&serialize(tx))) } else { None };
                new_dao_bullas.push((params.dao_bulla, tx_hash, i as u32));
                continue
            }

            if call.contract_id == cid && call.data[0] == DaoFunction::Propose as u8 {
                eprintln!("Found Dao::Propose in call {}", i);
                let params: DaoProposeParams = deserialize(&call.data[1..])?;
                let tx_hash = if confirm { Some(blake3::hash(&serialize(tx))) } else { None };
                // We need to clone the tree here for reproducing the snapshot Merkle root
                let money_tree = if confirm { Some(self.get_money_tree().await?) } else { None };
                new_dao_proposals.push((params, money_tree, tx_hash, i as u32));
                continue
            }

            if call.contract_id == cid && call.data[0] == DaoFunction::Vote as u8 {
                eprintln!("Found Dao::Vote in call {}", i);
                let params: DaoVoteParams = deserialize(&call.data[1..])?;
                let tx_hash = if confirm { Some(blake3::hash(&serialize(tx))) } else { None };
                new_dao_votes.push((params, tx_hash, i as u32));
                continue
            }

            if call.contract_id == cid && call.data[0] == DaoFunction::Exec as u8 {
                // This seems to not need any special action
                eprintln!("Found Dao::Exec in call {}", i);
                continue
            }
        }

        // This code should only be executed when finalized blocks are being scanned.
        // Here we write the tx metadata, and actually do Merkle tree appends so we
        // have to make sure it's the same for everyone.
        if confirm {
            for new_bulla in new_dao_bullas {
                daos_tree.append(MerkleNode::from(new_bulla.0.inner()));
                for dao in daos.iter_mut() {
                    if dao.bulla() == new_bulla.0 {
                        eprintln!(
                            "Found minted DAO {}, noting down for wallet update",
                            new_bulla.0
                        );
                        // We have this DAO imported in our wallet. Add the metadata:
                        dao.leaf_position = daos_tree.mark();
                        dao.tx_hash = new_bulla.1;
                        dao.call_index = Some(new_bulla.2);
                        daos_to_confirm.push(dao.clone());
                    }
                }
            }

            for proposal in new_dao_proposals {
                proposals_tree.append(MerkleNode::from(proposal.0.proposal_bulla.inner()));

                // If we're able to decrypt this note, that's the way to link it
                // to a specific DAO.
                for dao in &daos {
                    if let Ok(note) = proposal.0.note.decrypt::<DaoProposeNote>(&dao.secret_key) {
                        // We managed to decrypt it. Let's place this in a proper
                        // DaoProposal object. We assume we can just increment the
                        // ID by looking at how many proposals we already have.
                        // We also assume we don't mantain duplicate DAOs in the
                        // wallet.
                        eprintln!("Managed to decrypt DAO proposal note");
                        let daos_proposals = self.get_dao_proposals(dao.id).await?;
                        let our_prop = DaoProposal {
                            // This ID stuff is flaky.
                            id: daos_proposals.len() as u64 + our_proposals.len() as u64 + 1,
                            dao_bulla: dao.bulla(),
                            recipient: note.proposal.dest,
                            amount: note.proposal.amount,
                            token_id: note.proposal.token_id,
                            bulla_blind: note.proposal.blind,
                            leaf_position: proposals_tree.mark(),
                            money_snapshot_tree: proposal.1,
                            tx_hash: proposal.2,
                            call_index: Some(proposal.3),
                            vote_id: None,
                        };

                        our_proposals.push(our_prop);
                        break
                    }
                }
            }

            for vote in new_dao_votes {
                for dao in &daos {
                    if let Ok(note) = vote.0.note.decrypt::<DaoVoteNote>(&dao.secret_key) {
                        eprintln!("Managed to decrypt DAO proposal vote note");
                        let daos_proposals = self.get_dao_proposals(dao.id).await?;
                        let mut proposal_id = None;

                        for i in daos_proposals {
                            if i.bulla() == vote.0.proposal_bulla.inner() {
                                proposal_id = Some(i.id);
                                break
                            }
                        }

                        if proposal_id.is_none() {
                            eprintln!("Warning: Decrypted DaoVoteNote but did not find proposal");
                            break
                        }

                        let v = DaoVote {
                            id: 0,
                            proposal_id: proposal_id.unwrap(),
                            vote_option: note.vote_option,
                            yes_vote_blind: note.yes_vote_blind,
                            all_vote_value: note.all_vote_value,
                            all_vote_blind: note.all_vote_blind,
                            tx_hash: vote.1,
                            call_index: Some(vote.2),
                        };

                        dao_votes.push(v);
                    }
                }
            }
        }

        if confirm {
            self.put_dao_trees(&daos_tree, &proposals_tree).await?;
            self.confirm_daos(&daos_to_confirm).await?;
            self.put_dao_proposals(&our_proposals).await?;
            self.put_dao_votes(&dao_votes).await?;
        }

        Ok(())
    }

    /// Confirm already imported DAO metadata into the wallet.
    /// Here we just write the leaf position, tx hash, and call index.
    /// Panics if the fields are None.
    pub async fn confirm_daos(&self, daos: &[Dao]) -> Result<()> {
        for dao in daos {
            let query = format!(
                "UPDATE {} SET {} = ?1, {} = ?2, {} = ?3 WHERE {} = {};",
                DAO_DAOS_TABLE,
                DAO_DAOS_COL_LEAF_POSITION,
                DAO_DAOS_COL_TX_HASH,
                DAO_DAOS_COL_CALL_INDEX,
                DAO_DAOS_COL_DAO_ID,
                dao.id,
            );

            let params = json!([
                query,
                QueryType::Blob as u8,
                serialize(&dao.leaf_position.unwrap()),
                QueryType::Blob as u8,
                serialize(&dao.tx_hash.unwrap()),
                QueryType::Integer as u8,
                dao.call_index.unwrap(),
            ]);

            let req = JsonRequest::new("wallet.exec_sql", params);
            let _ = self.rpc_client.request(req).await?;
        }

        Ok(())
    }

    /// Unconfirm imported DAOs by removing the leaf position, txid, and call index.
    pub async fn unconfirm_daos(&self, daos: &[Dao]) -> Result<()> {
        for dao in daos {
            let query = format!(
                "UPDATE {} SET {} = ?1, {} = ?2, {} = ?3 WHERE {} = {};",
                DAO_DAOS_TABLE,
                DAO_DAOS_COL_LEAF_POSITION,
                DAO_DAOS_COL_TX_HASH,
                DAO_DAOS_COL_CALL_INDEX,
                DAO_DAOS_COL_DAO_ID,
                dao.id,
            );

            let params = json!([
                query,
                QueryType::OptionBlob as u8,
                None::<Vec<u8>>,
                QueryType::OptionBlob as u8,
                None::<Vec<u8>>,
                QueryType::OptionInteger as u8,
                None::<u64>,
            ]);

            let req = JsonRequest::new("wallet.exec_sql", params);
            let _ = self.rpc_client.request(req).await?;
        }

        Ok(())
    }

    /// Import given DAO proposals into the wallet
    pub async fn put_dao_proposals(&self, proposals: &[DaoProposal]) -> Result<()> {
        let daos = self.get_daos().await?;

        for proposal in proposals {
            let Some(dao) = daos.iter().find(|x| x.bulla() == proposal.dao_bulla) else {
                return Err(anyhow!("[put_dao_proposals] Couldn't find respective DAO"))
            };

            let query = format!(
                "INSERT INTO {} ({}, {}, {}, {}, {}, {}, {}, {}, {}) VALUES (?1, ?2, ?3, ?4, ?5, ?6, ?7, ?8, ?9);",
                DAO_PROPOSALS_TABLE,
                DAO_PROPOSALS_COL_DAO_ID,
                DAO_PROPOSALS_COL_RECV_PUBLIC,
                DAO_PROPOSALS_COL_AMOUNT,
                DAO_PROPOSALS_COL_SENDCOIN_TOKEN_ID,
                DAO_PROPOSALS_COL_BULLA_BLIND,
                DAO_PROPOSALS_COL_LEAF_POSITION,
                DAO_PROPOSALS_COL_MONEY_SNAPSHOT_TREE,
                DAO_PROPOSALS_COL_TX_HASH,
                DAO_PROPOSALS_COL_CALL_INDEX,
            );

            let params = json!([
                query,
                QueryType::Integer as u8,
                dao.id,
                QueryType::Blob as u8,
                serialize(&proposal.recipient),
                QueryType::Blob as u8,
                serialize(&proposal.amount),
                QueryType::Blob as u8,
                serialize(&proposal.token_id),
                QueryType::Blob as u8,
                serialize(&proposal.bulla_blind),
                QueryType::Blob as u8,
                serialize(&proposal.leaf_position.unwrap()),
                QueryType::Blob as u8,
                serialize(&proposal.money_snapshot_tree.clone().unwrap()),
                QueryType::Blob as u8,
                serialize(&proposal.tx_hash.unwrap()),
                QueryType::Integer as u8,
                proposal.call_index,
            ]);

            let req = JsonRequest::new("wallet.exec_sql", params);
            let _ = self.rpc_client.request(req).await?;
        }

        Ok(())
    }

    /// Import given DAO votes into the wallet
    pub async fn put_dao_votes(&self, votes: &[DaoVote]) -> Result<()> {
        for vote in votes {
            eprintln!("Importing DAO vote into wallet");

            let query = format!(
                "INSERT INTO {} ({}, {}, {}, {}, {}, {}, {}) VALUES (?1, ?2, ?3, ?4, ?5, ?6, ?7);",
                DAO_VOTES_TABLE,
                DAO_VOTES_COL_PROPOSAL_ID,
                DAO_VOTES_COL_VOTE_OPTION,
                DAO_VOTES_COL_YES_VOTE_BLIND,
                DAO_VOTES_COL_ALL_VOTE_VALUE,
                DAO_VOTES_COL_ALL_VOTE_BLIND,
                DAO_VOTES_COL_TX_HASH,
                DAO_VOTES_COL_CALL_INDEX,
            );

            let params = json!([
                query,
                QueryType::Integer as u8,
                vote.proposal_id,
                QueryType::Integer as u8,
                vote.vote_option as u64,
                QueryType::Blob as u8,
                serialize(&vote.yes_vote_blind),
                QueryType::Blob as u8,
                serialize(&vote.all_vote_value),
                QueryType::Blob as u8,
                serialize(&vote.all_vote_blind),
                QueryType::Blob as u8,
                serialize(&vote.tx_hash.unwrap()),
                QueryType::Integer as u8,
                vote.call_index.unwrap(),
            ]);

            let req = JsonRequest::new("wallet.exec_sql", params);
            let _ = self.rpc_client.request(req).await?;
            eprintln!("DAO vote added to wallet");
        }

        Ok(())
    }
}