c680115 radicle/crefs: Refactor `GetCanonicalRefs` — heartwood

modified crates/radicle-node/src/worker/fetch.rs

@@ -1,5 +1,3 @@

 use radicle::identity::doc::CanonicalRefsError;
 use radicle::identity::CanonicalRefs;
 pub(crate) use radicle_protocol::worker::fetch::error;
 use std::collections::BTreeSet;

@@ -9,7 +7,6 @@ use localtime::LocalTime;

 use radicle::cob::TypedId;
 use radicle::crypto::PublicKey;
 use radicle::identity::crefs::GetCanonicalRefs as _;
 use radicle::prelude::NodeId;
 use radicle::prelude::RepoId;
 use radicle::storage::git::Repository;

@@ -367,12 +364,7 @@ fn set_canonical_refs(

     applied: &Applied,
 ) -> Result<Option<UpdatedCanonicalRefs>, error::Canonical> {
     let identity = repo.identity()?;
     let rules = identity
         .canonical_refs_or_default(|| {
             Ok::<_, CanonicalRefsError>(identity.doc().default_canonical_refs()?)
         })?
         .rules()
         .clone();
     let rules = identity.doc().canonical_refs()?.rules().clone();
     let mut updated_refs = UpdatedCanonicalRefs::default();
     let refnames = applied

modified crates/radicle-remote-helper/src/push.rs

@@ -9,8 +9,6 @@ use std::process::ExitStatus;

 use std::str::FromStr;
 use std::{assert_eq, io};
 use radicle::identity::crefs::GetCanonicalRefs as _;
 use radicle::identity::doc::CanonicalRefsError;
 use radicle::node::device::Device;
 use thiserror::Error;

@@ -20,7 +18,7 @@ use radicle::cob::patch;

 use radicle::cob::patch::cache::Patches as _;
 use radicle::crypto;
 use radicle::explorer::ExplorerResource;
 use radicle::identity::{CanonicalRefs, Did};
 use radicle::identity::Did;
 use radicle::node;
 use radicle::node::{Handle, NodeId};
 use radicle::storage;

@@ -346,9 +344,7 @@ pub fn run(

                     ),
                     PushAction::PushRef { dst } => {
                         let identity = stored.identity()?;
                         let crefs = identity.canonical_refs_or_default(|| {
                             Ok::<_, CanonicalRefsError>(identity.doc().default_canonical_refs()?)
                         })?;
                         let crefs = identity.doc().canonical_refs()?;
                         let rules = crefs.rules();
                         let me = Did::from(nid);

modified crates/radicle/src/identity/crefs.rs

@@ -6,35 +6,15 @@ use super::doc::{Delegates, Payload};

 /// Implemented by any data type or store that can return [`CanonicalRefs`] and
 /// [`RawCanonicalRefs`].
 pub trait GetCanonicalRefs {
 pub trait GetRawCanonicalRefs {
     type Error: std::error::Error + Send + Sync + 'static;
     /// Retrieve the [`CanonicalRefs`], returning `Some` if they are not
     /// present, and `None` if they are missing.
     ///
     /// [`Self::Error`] is used to return any domain-specific error by the
     /// implementing type.
     fn canonical_refs(&self) -> Result<Option<CanonicalRefs>, Self::Error>;
     /// Retrieve the [`RawCanonicalRefs`], returning `Some` if they are not
     /// present, and `None` if they are missing.
     /// Retrieve the [`RawCanonicalRefs`], returning `Some` if they are
     /// present, and `None` if they are absent.
     ///
     /// [`Self::Error`] is used to return any domain-specific error by the
     /// implementing type.
     fn raw_canonical_refs(&self) -> Result<Option<RawCanonicalRefs>, Self::Error>;
     /// Retrieve the [`CanonicalRefs`], and in the case of `None`, then use the
     /// `default` function to return a default set of [`CanonicalRefs`].
     fn canonical_refs_or_default<D, E>(&self, default: D) -> Result<CanonicalRefs, E>
     where
         D: Fn() -> Result<CanonicalRefs, E>,
         E: From<Self::Error>,
     {
         match self.canonical_refs()? {
             Some(crefs) => Ok(crefs),
             None => Ok(default()?),
         }
     }
 }
 /// Configuration for canonical references and their rules.

modified crates/radicle/src/identity/doc.rs

@@ -761,6 +761,23 @@ impl Doc {

         .expect("default rules are valid"))
     }
     /// Construct the canonical references for this document.
     /// The implementation of [`crefs::RawCanonicalRefs`] is used to
     /// obtain the payload identified by [`PayloadId::canonical_refs`], if it
     /// exists.
     /// The resulting [`CanonicalRefs`] are constructed by extension with
     /// [`Self::default_branch_rule`].
     pub fn canonical_refs(&self) -> Result<CanonicalRefs, CanonicalRefsError> {
         use crefs::GetRawCanonicalRefs;
         let raw_crefs = self.raw_canonical_refs()?.unwrap_or_default();
         let mut raw_rules = raw_crefs.raw_rules().clone();
         raw_rules.extend(RawRules::from(self.default_branch_rule()?));
         let raw_crefs = RawCanonicalRefs::new(raw_rules);
         Ok(raw_crefs.try_into_canonical_refs(&mut || self.delegates.clone())?)
     }
     /// Return the associated [`Visibility`] of this document.
     pub fn visibility(&self) -> &Visibility {
         &self.visibility

@@ -928,26 +945,9 @@ pub enum CanonicalRefsError {

     DefaultBranch(#[from] DefaultBranchRuleError),
 }
 impl crefs::GetCanonicalRefs for Doc {
 impl crefs::GetRawCanonicalRefs for Doc {
     type Error = CanonicalRefsError;
     fn canonical_refs(&self) -> Result<Option<CanonicalRefs>, Self::Error> {
         let Some(raw_crefs) = self.raw_canonical_refs()? else {
             return Ok(None);
         };
         let mut raw_rules = raw_crefs.raw_rules().clone();
         let default_branch_rule = self.default_branch_rule()?;
         raw_rules.extend(RawRules::from(default_branch_rule));
         let raw_crefs = RawCanonicalRefs::new(raw_rules);
         Ok(Some(
             raw_crefs.try_into_canonical_refs(&mut || self.delegates.clone())?,
         ))
     }
     fn raw_canonical_refs(&self) -> Result<Option<RawCanonicalRefs>, Self::Error> {
         let value = self.payload.get(&PayloadId::canonical_refs());
         let crefs = value

@@ -959,13 +959,9 @@ impl crefs::GetCanonicalRefs for Doc {

     }
 }
 impl crefs::GetCanonicalRefs for RawDoc {
 impl crefs::GetRawCanonicalRefs for RawDoc {
     type Error = CanonicalRefsError;
     fn canonical_refs(&self) -> Result<Option<CanonicalRefs>, Self::Error> {
         Ok(None)
     }
     fn raw_canonical_refs(&self) -> Result<Option<RawCanonicalRefs>, Self::Error> {
         let value = self.payload.get(&PayloadId::canonical_refs());
         let crefs = value

modified crates/radicle/src/identity/doc/update.rs

@@ -6,7 +6,6 @@ use serde_json as json;

 use crate::{
     git,
     identity::crefs::GetCanonicalRefs as _,
     prelude::Did,
     storage::{refs, ReadRepository, RepositoryError},
 };

@@ -203,6 +202,7 @@ pub fn verify(raw: RawDoc) -> Result<Doc, error::DocVerification> {

     // Ensure that if we have canonical reference rules and a project, that no
     // rule exists for the default branch. This rule must be synthesized when
     // constructing the canonical reference rules.
     use super::crefs::GetRawCanonicalRefs as _;
     match raw
         .raw_canonical_refs()
         .map(|rcrefs| rcrefs.and_then(|c| project.map(|p| (c, p))))

@@ -268,10 +268,7 @@ mod test {

     use crate::{
         git,
         identity::{
             crefs::GetCanonicalRefs,
             doc::{update::error, PayloadId},
         },
         identity::doc::{update::error, PayloadId},
         prelude::RawDoc,
         test::arbitrary,
     };

@@ -351,7 +348,7 @@ mod test {

         )
         .unwrap();
         let verified = super::verify(raw).unwrap();
         let crefs = verified.canonical_refs().unwrap().unwrap();
         let crefs = verified.canonical_refs().unwrap();
         assert!(
             crefs.rules().matches(&branch).next().is_some(),
             "Default branch rule is missing!"

modified crates/radicle/src/storage/git.rs

@@ -12,7 +12,6 @@ use crypto::Verified;

 use tempfile::TempDir;
 use crate::git::canonical::Quorum;
 use crate::identity::crefs::GetCanonicalRefs as _;
 use crate::identity::doc::DocError;
 use crate::identity::{Doc, DocAt, RepoId};
 use crate::identity::{Identity, Project};

@@ -788,9 +787,7 @@ impl ReadRepository for Repository {

         let doc = self.identity_doc()?;
         let refname = doc.default_branch()?.to_owned();
         let crefs = doc.canonical_refs_or_default(|| {
             doc.default_canonical_refs().map_err(RepositoryError::from)
         })?;
         let crefs = doc.canonical_refs()?;
         Ok(crefs
             .rules()