feat: add proposal vote cli arg

CHANGELOG_PENDING.md

@@ -1,5 +1,7 @@
 # Unreleased Changes
 
+- [#3275](https://github.com/livepeer/go-livepeer/pull/3275) - Provide AI orchestrators with a way to vote on active proposal through the CLI.
+
 ## v0.X.X
 
 ### Breaking Changes 🚨🚨

cmd/livepeer_cli/livepeer_cli.go

@@ -112,7 +112,8 @@ func (w *wizard) initializeOptions() []wizardOpt {
 		}, testnet: true},
 		{desc: "Sign a message", invoke: w.signMessage},
 		{desc: "Sign typed data", invoke: w.signTypedData},
-		{desc: "Vote in a poll", invoke: w.vote, orchestrator: true},
+		{desc: "Vote in a governance poll", invoke: w.vote, orchestrator: true},
+		{desc: "Vote on a treasury proposal", invoke: w.voteOnProposal, orchestrator: true},
 		{desc: "Set max ticket face value", invoke: w.setMaxFaceValue, orchestrator: true},
 		{desc: "Set price for broadcaster", invoke: w.setPriceForBroadcaster, orchestrator: true},
 		{desc: "Set maximum sessions", invoke: w.setMaxSessions, orchestrator: true, notOrchestrator: false},

cmd/livepeer_cli/wizard_transcoder.go

@@ -278,6 +278,64 @@
 	fmt.Printf("\nVote success tx=0x%x\n", []byte(result))
 }
 
+func (w *wizard) voteOnProposal() {
+	if w.offchain {
+		glog.Error("Cannot vote in 'offchain' mode")
+		return
+	}
+
+	fmt.Print("Enter the proposal ID you want to vote on -")
+	proposalID := w.readStringAndValidate(func(in string) (string, error) {
+		if _, ok := new(big.Int).SetString(in, 10); !ok {
+			return "", fmt.Errorf("invalid proposal ID id=%v", in)
+		}
+		return in, nil
+	})
+
+	var (
+		confirm = "n"
+		choice  = types.ProposalVoteChoice(-1)
+	)
+
+	for confirm == "n" {
+		w.showProposalVoteChoices()
+
+		for {
+			fmt.Printf("Enter the ID of the choice you want to vote for -")
+			choice = types.ProposalVoteChoice(w.readInt())
+			if choice.IsValid() {
+				break
+			}
+			fmt.Println("Must enter a valid ID")
+		}
+
+		fmt.Printf("Are you sure you want to vote \"%v\"? (y/n) -", choice.String())
+		confirm = w.readStringYesOrNo()
+	}
+
+	fmt.Printf("Do you want to provide a reason for your vote? (y/n) -")
+	provideReason := w.readStringYesOrNo()
+	var reason string
+	if provideReason == "y" {
+		fmt.Print("Enter your reason -")
+		reason = w.readString()
+	}
+
+	data := url.Values{
+		"proposalID": {proposalID},
+		"support":    {fmt.Sprintf("%v", int(choice))},
+		"reason":     {reason},
+	}
+
+	result, ok := httpPostWithParams(fmt.Sprintf("http://%v:%v/voteOnProposal", w.host, w.httpPort), data)
+
+	if !ok {
+		fmt.Printf("Error voting: %s\n", result)
+		return
+	}
+	fmt.Printf("\nVote success tx=0x%x\n", []byte(result))
+}
+
 func (w *wizard) showVoteChoices() {
 	wtr := tabwriter.NewWriter(os.Stdout, 0, 8, 1, '\t', 0)
 	fmt.Fprintln(wtr, "Identifier\tVoting Choices")
@@ -287,6 +345,15 @@
 	wtr.Flush()
 }
 
+func (w *wizard) showProposalVoteChoices() {
+	wtr := tabwriter.NewWriter(os.Stdout, 0, 8, 1, '\t', 0)
+	fmt.Fprintln(wtr, "Identifier\tVoting Choices")
+	for _, choice := range types.ProposalVoteChoices {
+		fmt.Fprintf(wtr, "%v\t%v\n", int(choice), choice.String())
+	}
+	wtr.Flush()
+}
+
 func flipPerc(perc *big.Int) *big.Int {
 	return new(big.Int).Sub(hundredPercent, perc)
 }

eth/client.go

@@ -12,6 +12,7 @@
 //go:generate abigen --abi protocol/abi/Minter.json --pkg contracts --type Minter --out contracts/minter.go
 //go:generate abigen --abi protocol/abi/LivepeerTokenFaucet.json --pkg contracts --type LivepeerTokenFaucet --out contracts/livepeerTokenFaucet.go
 //go:generate abigen --abi protocol/abi/Poll.json --pkg contracts --type Poll --out contracts/poll.go
+//go:generate abigen --abi protocol/abi/LivepeerGovernor.json --pkg contracts --type Governor --out contracts/LivepeerGovernor.go
 import (
 	"context"
 	"fmt"
@@ -113,6 +114,8 @@
 
 	// Governance
 	Vote(ethcommon.Address, *big.Int) (*types.Transaction, error)
+	ProposalVote(*big.Int, uint8) (*types.Transaction, error)
+	ProposalVoteWithReason(*big.Int, uint8, string) (*types.Transaction, error)
 
 	// Helpers
 	ContractAddresses() map[string]ethcommon.Address
@@ -130,15 +133,16 @@
 	transOpts      bind.TransactOpts
 	transOptsMu    sync.RWMutex
 
-	controllerAddr      ethcommon.Address
-	tokenAddr           ethcommon.Address
-	serviceRegistryAddr ethcommon.Address
-	bondingManagerAddr  ethcommon.Address
-	ticketBrokerAddr    ethcommon.Address
-	roundsManagerAddr   ethcommon.Address
-	minterAddr          ethcommon.Address
-	verifierAddr        ethcommon.Address
-	faucetAddr          ethcommon.Address
+	controllerAddr       ethcommon.Address
+	tokenAddr            ethcommon.Address
+	serviceRegistryAddr  ethcommon.Address
+	bondingManagerAddr   ethcommon.Address
+	ticketBrokerAddr     ethcommon.Address
+	roundsManagerAddr    ethcommon.Address
+	minterAddr           ethcommon.Address
+	verifierAddr         ethcommon.Address
+	faucetAddr           ethcommon.Address
+	livepeerGovernorAddr ethcommon.Address
 
 	// Contracts
 	controller          *contracts.Controller
@@ -149,6 +153,7 @@
 	roundsManager       *contracts.RoundsManager
 	minter              *contracts.Minter
 	livepeerTokenFaucet *contracts.LivepeerTokenFaucet
+	livepeerGovernor    *contracts.Governor
 
 	// for L1 contracts backwards-compatibility
 	l1BondingManager *contracts.L1BondingManager
@@ -325,6 +330,23 @@
 
 	glog.V(common.SHORT).Infof("LivepeerTokenFaucet: %v", c.faucetAddr.Hex())
 
+	livepeerGovernorAddr, err := c.GetContract(crypto.Keccak256Hash([]byte("LivepeerGovernor")))
+	if err != nil {
+		glog.Errorf("Error getting Governor address: %v", err)
+		return err
+	}
+
+	c.livepeerGovernorAddr = livepeerGovernorAddr
+
+	governor, err := contracts.NewGovernor(livepeerGovernorAddr, c.backend)
+	if err != nil {
+		glog.Errorf("Error creating Governor binding: %v", err)
+		return err
+	}
+	c.livepeerGovernor = governor
+
+	glog.V(common.SHORT).Infof("LivepeerGovernor: %v", c.livepeerGovernorAddr.Hex())
+
 	return nil
 }
 
@@ -990,6 +1012,14 @@
 	return poll.Vote(opts, choiceID)
 }
 
+func (c *client) ProposalVote(proposalId *big.Int, support uint8) (*types.Transaction, error) {
+	return c.livepeerGovernor.CastVote(c.transactOpts(), proposalId, support)
+}
+
+func (c *client) ProposalVoteWithReason(proposalId *big.Int, support uint8, reason string) (*types.Transaction, error) {
+	return c.livepeerGovernor.CastVoteWithReason(c.transactOpts(), proposalId, support, reason)
+}
+
 func (c *client) Reward() (*types.Transaction, error) {
 	addr := c.accountManager.Account().Address