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 }) | ||
} | ||||
|
r48783 | /// Return the `ChangelogEntry` for the given node ID. | ||
pub fn data_for_node( | ||||
|
r46103 | &self, | ||
|
r47160 | node: NodePrefix, | ||
|
r46103 | ) -> Result<ChangelogEntry, RevlogError> { | ||
|
r48782 | let rev = self.revlog.rev_from_node(node)?; | ||
|
r48783 | self.data_for_rev(rev) | ||
|
r46103 | } | ||
|
r48783 | /// Return the `ChangelogEntry` of the given revision number. | ||
pub fn data_for_rev( | ||||
|
r46103 | &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> { | ||||
|
r48781 | self.revlog.node_from_rev(rev) | ||
|
r47478 | } | ||
|
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 | } | ||
} | ||||