changelog.rs
67 lines
| 1.9 KiB
| application/rls-services+xml
|
RustLexer
|
r47172 | use crate::errors::HgError; | ||
|
r46782 | use crate::repo::Repo; | ||
|
r46103 | use crate::revlog::revlog::{Revlog, RevlogError}; | ||
use crate::revlog::Revision; | ||||
|
r47478 | use crate::revlog::{Node, NodePrefix}; | ||
|
r46103 | |||
/// A specialized `Revlog` to work with `changelog` data format. | ||||
pub struct Changelog { | ||||
/// The generic `revlog` format. | ||||
|
r47162 | pub(crate) revlog: Revlog, | ||
|
r46103 | } | ||
impl Changelog { | ||||
/// Open the `changelog` of a repository given by its root. | ||||
|
r48777 | pub fn open(repo: &Repo) -> Result<Self, HgError> { | ||
|
r46782 | let revlog = Revlog::open(repo, "00changelog.i", None)?; | ||
|
r46103 | Ok(Self { revlog }) | ||
} | ||||
/// Return the `ChangelogEntry` a given node id. | ||||
pub fn get_node( | ||||
&self, | ||||
|
r47160 | node: NodePrefix, | ||
|
r46103 | ) -> Result<ChangelogEntry, RevlogError> { | ||
let rev = self.revlog.get_node_rev(node)?; | ||||
self.get_rev(rev) | ||||
} | ||||
/// Return the `ChangelogEntry` of a given node revision. | ||||
pub fn get_rev( | ||||
&self, | ||||
rev: Revision, | ||||
) -> Result<ChangelogEntry, RevlogError> { | ||||
let bytes = self.revlog.get_rev_data(rev)?; | ||||
Ok(ChangelogEntry { bytes }) | ||||
} | ||||
|
r47478 | |||
pub fn node_from_rev(&self, rev: Revision) -> Option<&Node> { | ||||
Some(self.revlog.index.get_entry(rev)?.hash()) | ||||
} | ||||
|
r46103 | } | ||
/// `Changelog` entry which knows how to interpret the `changelog` data bytes. | ||||
#[derive(Debug)] | ||||
pub struct ChangelogEntry { | ||||
/// The data bytes of the `changelog` entry. | ||||
bytes: Vec<u8>, | ||||
} | ||||
impl ChangelogEntry { | ||||
/// Return an iterator over the lines of the entry. | ||||
pub fn lines(&self) -> impl Iterator<Item = &[u8]> { | ||||
self.bytes | ||||
.split(|b| b == &b'\n') | ||||
.filter(|line| !line.is_empty()) | ||||
} | ||||
/// Return the node id of the `manifest` referenced by this `changelog` | ||||
/// entry. | ||||
|
r48778 | pub fn manifest_node(&self) -> Result<Node, HgError> { | ||
Node::from_hex_for_repo( | ||||
self.lines() | ||||
.next() | ||||
.ok_or_else(|| HgError::corrupted("empty changelog entry"))?, | ||||
) | ||||
|
r46103 | } | ||
} | ||||