From f89ff3b428271938c99b1bb8e4fae0062b93f840 Mon Sep 17 00:00:00 2001 From: Andre Popovitch Date: Wed, 27 Nov 2024 15:21:32 -0600 Subject: [PATCH] refactor(sns): Move get_upgrade_journal to upgrade_journal.rs (#2872) This improves organization because now all the upgrade_journal logic is collected in the same file. This is just a move, no behavior was changed. --- rs/sns/governance/src/governance.rs | 41 ++++++------------------ rs/sns/governance/src/upgrade_journal.rs | 24 +++++++++++++- 2 files changed, 32 insertions(+), 33 deletions(-) diff --git a/rs/sns/governance/src/governance.rs b/rs/sns/governance/src/governance.rs index e82342dfbaf..6c0a868f522 100644 --- a/rs/sns/governance/src/governance.rs +++ b/rs/sns/governance/src/governance.rs @@ -47,16 +47,15 @@ use crate::{ GetMaturityModulationRequest, GetMaturityModulationResponse, GetMetadataRequest, GetMetadataResponse, GetMode, GetModeResponse, GetNeuron, GetNeuronResponse, GetProposal, GetProposalResponse, GetSnsInitializationParametersRequest, - GetSnsInitializationParametersResponse, GetUpgradeJournalResponse, - Governance as GovernanceProto, GovernanceError, ListNervousSystemFunctionsResponse, - ListNeurons, ListNeuronsResponse, ListProposals, ListProposalsResponse, - ManageDappCanisterSettings, ManageLedgerParameters, ManageNeuron, ManageNeuronResponse, - ManageSnsMetadata, MintSnsTokens, MintTokensRequest, MintTokensResponse, - NervousSystemFunction, NervousSystemParameters, Neuron, NeuronId, NeuronPermission, - NeuronPermissionList, NeuronPermissionType, Proposal, ProposalData, - ProposalDecisionStatus, ProposalId, ProposalRewardStatus, RegisterDappCanisters, - RewardEvent, Tally, TransferSnsTreasuryFunds, UpgradeSnsControlledCanister, Vote, - WaitForQuietState, + GetSnsInitializationParametersResponse, Governance as GovernanceProto, GovernanceError, + ListNervousSystemFunctionsResponse, ListNeurons, ListNeuronsResponse, ListProposals, + ListProposalsResponse, ManageDappCanisterSettings, ManageLedgerParameters, + ManageNeuron, ManageNeuronResponse, ManageSnsMetadata, MintSnsTokens, + MintTokensRequest, MintTokensResponse, NervousSystemFunction, NervousSystemParameters, + Neuron, NeuronId, NeuronPermission, NeuronPermissionList, NeuronPermissionType, + Proposal, ProposalData, ProposalDecisionStatus, ProposalId, ProposalRewardStatus, + RegisterDappCanisters, RewardEvent, Tally, TransferSnsTreasuryFunds, + UpgradeSnsControlledCanister, Vote, WaitForQuietState, }, }, proposal::{ @@ -5056,28 +5055,6 @@ impl Governance { self.upgrade_periodic_task_lock = None; } - pub fn get_upgrade_journal(&self) -> GetUpgradeJournalResponse { - let cached_upgrade_steps = self.proto.cached_upgrade_steps.clone(); - match cached_upgrade_steps { - Some(cached_upgrade_steps) => GetUpgradeJournalResponse { - upgrade_steps: cached_upgrade_steps.upgrade_steps, - response_timestamp_seconds: cached_upgrade_steps.response_timestamp_seconds, - target_version: self.proto.target_version.clone(), - deployed_version: self.proto.deployed_version.clone(), - // TODO(NNS1-3416): Bound the size of the response. - upgrade_journal: self.proto.upgrade_journal.clone(), - }, - None => GetUpgradeJournalResponse { - upgrade_steps: None, - response_timestamp_seconds: None, - target_version: None, - deployed_version: self.proto.deployed_version.clone(), - // TODO(NNS1-3416): Bound the size of the response. - upgrade_journal: self.proto.upgrade_journal.clone(), - }, - } - } - // This is a test-only function, so panicking should be okay. pub fn advance_target_version( &mut self, diff --git a/rs/sns/governance/src/upgrade_journal.rs b/rs/sns/governance/src/upgrade_journal.rs index a54ac2adbaa..e1bd8345dd3 100644 --- a/rs/sns/governance/src/upgrade_journal.rs +++ b/rs/sns/governance/src/upgrade_journal.rs @@ -2,7 +2,7 @@ use crate::governance::Governance; use crate::pb::v1::{ governance::{Version, Versions}, upgrade_journal_entry::{self, upgrade_outcome, upgrade_started}, - Empty, ProposalId, UpgradeJournal, UpgradeJournalEntry, + Empty, GetUpgradeJournalResponse, ProposalId, UpgradeJournal, UpgradeJournalEntry, }; impl upgrade_journal_entry::UpgradeStepsRefreshed { @@ -128,6 +128,28 @@ impl Governance { } } } + + pub fn get_upgrade_journal(&self) -> GetUpgradeJournalResponse { + let cached_upgrade_steps = self.proto.cached_upgrade_steps.clone(); + match cached_upgrade_steps { + Some(cached_upgrade_steps) => GetUpgradeJournalResponse { + upgrade_steps: cached_upgrade_steps.upgrade_steps, + response_timestamp_seconds: cached_upgrade_steps.response_timestamp_seconds, + target_version: self.proto.target_version.clone(), + deployed_version: self.proto.deployed_version.clone(), + // TODO(NNS1-3416): Bound the size of the response. + upgrade_journal: self.proto.upgrade_journal.clone(), + }, + None => GetUpgradeJournalResponse { + upgrade_steps: None, + response_timestamp_seconds: None, + target_version: None, + deployed_version: self.proto.deployed_version.clone(), + // TODO(NNS1-3416): Bound the size of the response. + upgrade_journal: self.proto.upgrade_journal.clone(), + }, + } + } } impl From for upgrade_journal_entry::Event {