WIP: integrate lqt voting in pcli

crates/bin/pcli/src/command/tx.rs

@@ -22,6 +22,7 @@ use ibc_types::core::{
     client::Height as IbcHeight,
 };
 use ibc_types::lightclients::tendermint::client_state::ClientState as TendermintClientState;
+use lqt_vote::LqtVoteCmd;
 use rand_core::OsRng;
 use regex::Regex;
 
@@ -82,6 +83,7 @@ use clap::Parser;
 
 mod auction;
 mod liquidity_position;
+mod lqt_vote;
 mod proposal;
 mod replicate;
 
@@ -311,6 +313,8 @@ pub enum TxCmd {
         /// The transaction to be broadcast
         transaction: PathBuf,
     },
+    #[clap(display_order = 700)]
+    LqtVote(LqtVoteCmd),
 }
 
 /// Vote on a governance proposal.
@@ -368,6 +372,7 @@ impl TxCmd {
             TxCmd::Auction(_) => false,
             TxCmd::Broadcast { .. } => false,
             TxCmd::RegisterForwardingAccount { .. } => false,
+            TxCmd::LqtVote(cmd) => cmd.offline(),
         }
     }
 
@@ -1553,6 +1558,7 @@ impl TxCmd {
 
                 println!("Noble response: {:?}", r);
             }
+            TxCmd::LqtVote(cmd) => cmd.exec(app, gas_prices).await?,
         }
 
         Ok(())

crates/bin/pcli/src/command/tx/lqt_vote.rs

@@ -0,0 +1,128 @@
+use std::collections::BTreeMap;
+
+use anyhow::anyhow;
+use penumbra_sdk_asset::{
+    asset::{self, REGISTRY},
+    Value,
+};
+use penumbra_sdk_fee::{FeeTier, GasPrices};
+use penumbra_sdk_keys::Address;
+use penumbra_sdk_num::Amount;
+use penumbra_sdk_proto::core::component::sct::v1::{
+    query_service_client::QueryServiceClient as SctQueryServiceClient, EpochByHeightRequest,
+};
+use penumbra_sdk_sct::epoch::Epoch;
+use penumbra_sdk_view::{Planner, ViewClient};
+use rand_core::OsRng;
+
+use crate::App;
+
+async fn fetch_epoch(app: &mut App) -> anyhow::Result<Epoch> {
+    let mut sct_client = SctQueryServiceClient::new(app.pd_channel().await?);
+    let latest_sync_height = app.view().status().await?.full_sync_height;
+    let epoch = sct_client
+        .epoch_by_height(EpochByHeightRequest {
+            height: latest_sync_height,
+        })
+        .await?
+        .into_inner()
+        .epoch
+        .expect("epoch must be available")
+        .into();
+    Ok(epoch)
+}
+
+/// Vote in the current round of the liquidity tournament.
+///
+/// This will plan a transaction which directs all available voting power to a single asset.
+#[derive(Debug, clap::Parser)]
+pub struct LqtVoteCmd {
+    /// The denom string for the asset being voted for.
+    vote: String,
+    /// If provided, make the rewards recipient a particular address instead.
+    ///
+    /// This can also be an integer, indicating an ephemeral address of a sub-account.
+    #[clap(short, long)]
+    rewards_recipient: Option<String>,
+    /// The selected fee tier.
+    #[clap(short, long, default_value_t)]
+    fee_tier: FeeTier,
+}
+
+impl LqtVoteCmd {
+    pub fn offline(&self) -> bool {
+        false
+    }
+
+    fn rewards_addr(&self, app: &App) -> anyhow::Result<Address> {
+        let to_parse = match &self.rewards_recipient {
+            None => {
+                return Ok(app
+                    .config
+                    .full_viewing_key
+                    .ephemeral_address(OsRng, Default::default())
+                    .0)
+            }
+            Some(x) => x,
+        };
+        let maybe_index: Option<u32> = to_parse.parse().ok();
+        if let Some(i) = maybe_index {
+            return Ok(app
+                .config
+                .full_viewing_key
+                .ephemeral_address(OsRng, i.into())
+                .0);
+        }
+        to_parse
+            .parse()
+            .map_err(|_| anyhow!("failed to parse address '{}'", to_parse))
+    }
+
+    pub async fn exec(&self, app: &mut App, gas_prices: GasPrices) -> anyhow::Result<()> {
+        let vote_meta = REGISTRY
+            .parse_denom(&self.vote)
+            .ok_or_else(|| anyhow!("failed to parse denom: '{}'", &self.vote))?;
+        let vote_denom = vote_meta.base_denom();
+
+        let epoch = fetch_epoch(app).await?;
+        let voting_notes = app.view().lqt_voting_notes(epoch.index, None).await?;
+
+        let mut planner = Planner::new(OsRng);
+
+        planner
+            .set_gas_prices(gas_prices)
+            .set_fee_tier(self.fee_tier);
+
+        // First, tell the planner to make all the necessary votes.
+        planner.lqt_vote(
+            u16::try_from(epoch.index)?,
+            vote_denom,
+            self.rewards_addr(app)?,
+            &voting_notes,
+        );
+        // We also want to go ahead and do the consolidation thing,
+        // to reduce the number of votes we need in the next epoch.
+        // To do so, we need to spend all of these notes, and produce one output per
+        // delegator token.
+        let mut totals: BTreeMap<asset::Id, Amount> = Default::default();
+        for note in voting_notes {
+            let value = note.note.value();
+            planner.spend(note.note, note.position);
+            *totals.entry(value.asset_id).or_insert(Amount::zero()) += value.amount;
+        }
+        let change_addr = app
+            .config
+            .full_viewing_key
+            .ephemeral_address(OsRng, Default::default())
+            .0;
+        planner.change_address(change_addr.clone());
+        for (asset_id, amount) in totals {
+            planner.output(Value { asset_id, amount }, change_addr.clone());
+        }
+
+        let plan = planner.plan(app.view(), Default::default()).await?;
+        app.build_and_submit_transaction(plan).await?;
+
+        Ok(())
+    }
+}

crates/bin/pcli/src/terminal.rs

@@ -160,6 +160,7 @@ fn pretty_print_transaction_plan(
             ActionPlan::ActionDutchAuctionEnd(_) => None,
             ActionPlan::ActionDutchAuctionWithdraw(_) => None,
             ActionPlan::IbcAction(_) => todo!(),
+            ActionPlan::ActionLiquidityTournamentVote(_) => None,
         }
     }
 

crates/core/app/src/action_handler/actions.rs

@@ -56,7 +56,7 @@ impl AppActionHandler for Action {
             Action::ActionDutchAuctionSchedule(action) => action.check_stateless(()).await,
             Action::ActionDutchAuctionEnd(action) => action.check_stateless(()).await,
             Action::ActionDutchAuctionWithdraw(action) => action.check_stateless(()).await,
-            Action::ActionLiquidityTournamentVote(_action) => todo!(),
+            Action::ActionLiquidityTournamentVote(action) => action.check_stateless(context).await,
         }
     }
 
@@ -98,7 +98,7 @@ impl AppActionHandler for Action {
             Action::ActionDutchAuctionSchedule(action) => action.check_historical(state).await,
             Action::ActionDutchAuctionEnd(action) => action.check_historical(state).await,
             Action::ActionDutchAuctionWithdraw(action) => action.check_historical(state).await,
-            Action::ActionLiquidityTournamentVote(_action) => todo!(),
+            Action::ActionLiquidityTournamentVote(action) => action.check_historical(state).await,
         }
     }
 
@@ -140,7 +140,7 @@ impl AppActionHandler for Action {
             Action::ActionDutchAuctionSchedule(action) => action.check_and_execute(state).await,
             Action::ActionDutchAuctionEnd(action) => action.check_and_execute(state).await,
             Action::ActionDutchAuctionWithdraw(action) => action.check_and_execute(state).await,
-            Action::ActionLiquidityTournamentVote(_action) => todo!(),
+            Action::ActionLiquidityTournamentVote(action) => action.check_and_execute(state).await,
         }
     }
 }

crates/core/app/src/action_handler/actions/submit.rs

@@ -93,6 +93,7 @@ impl AppActionHandler for ProposalSubmit {
                             anyhow::bail!("invalid action in Community Pool spend proposal (not allowed to manipulate proposals from within proposals)")
                         }
                         ValidatorDefinition(_)
+                        | ActionLiquidityTournamentVote(_)
                         | IbcAction(_)
                         | ValidatorVote(_)
                         | PositionOpen(_)
@@ -356,6 +357,7 @@ async fn build_community_pool_transaction(
             effect_hash: Some(effect_hash),
             spend_auths: Default::default(),
             delegator_vote_auths: Default::default(),
+            lqt_vote_auths: Default::default(),
         },
     )
 }

crates/core/component/funding/Cargo.toml

@@ -60,6 +60,7 @@ penumbra-sdk-shielded-pool = {workspace = true, default-features = false}
 penumbra-sdk-stake = {workspace = true, default-features = false}
 penumbra-sdk-tct = {workspace = true, default-features = false}
 penumbra-sdk-txhash = {workspace = true, default-features = false}
+rand = {workspace = true}
 serde = {workspace = true, features = ["derive"]}
 tendermint = {workspace = true}
 tracing = {workspace = true}

crates/core/component/funding/src/liquidity_tournament/mod.rs

@@ -1,8 +1,10 @@
 mod action;
+mod plan;
 mod view;
 
 pub mod proof;
 pub use action::{ActionLiquidityTournamentVote, LiquidityTournamentVoteBody};
+pub use plan::ActionLiquidityTournamentVotePlan;
 pub use view::ActionLiquidityTournamentVoteView;
 
 /// The maximum number of allowable bytes in the denom string.