1use bstr::{BStr, ByteSlice};
2use gix_error::ExnMessageResult;
3
4use crate::parse::parse_signature;
5use crate::{Commit, CommitRef, TagRef};
6
7pub const SIGNATURE_FIELD_NAME: &str = "gpgsig";
9pub const SIGNATURE_FIELD_NAME_SHA256: &str = "gpgsig-sha256";
11
12pub fn signature_field_name(hash_kind: gix_hash::Kind) -> &'static str {
14 #[cfg(feature = "sha256")]
15 if hash_kind == gix_hash::Kind::Sha256 {
16 return SIGNATURE_FIELD_NAME_SHA256;
17 }
18 let _ = hash_kind;
19 SIGNATURE_FIELD_NAME
20}
21
22mod decode;
23pub mod message;
25
26#[derive(PartialEq, Eq, Debug, Hash, Ord, PartialOrd, Clone, Copy)]
30#[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
31pub struct MessageRef<'a> {
32 #[cfg_attr(feature = "serde", serde(borrow))]
35 pub title: &'a BStr,
36 pub body: Option<&'a BStr>,
40}
41
42pub mod ref_iter;
44
45mod write;
46
47impl<'a> CommitRef<'a> {
49 pub fn from_bytes(mut data: &'a [u8], object_hash: gix_hash::Kind) -> ExnMessageResult<CommitRef<'a>> {
52 let input = &mut data;
53 match decode::commit(input, object_hash) {
54 Ok(tag) => Ok(tag),
55 Err(err) => Err(err),
56 }
57 }
58}
59
60impl<'a> CommitRef<'a> {
62 pub fn tree(&self) -> gix_hash::ObjectId {
64 gix_hash::ObjectId::from_hex(self.tree).expect("prior validation of tree hash during parsing")
65 }
66
67 pub fn parents(&self) -> impl Iterator<Item = gix_hash::ObjectId> + '_ {
69 self.parents
70 .iter()
71 .map(|hex_hash| gix_hash::ObjectId::from_hex(hex_hash).expect("prior validation of hashes during parsing"))
72 }
73
74 pub fn extra_headers(&self) -> ExtraHeaders<impl Iterator<Item = (&BStr, &BStr)>> {
76 ExtraHeaders::new(
77 self.extra_headers.iter().map(|(k, v)| (*k, v.as_ref())),
78 self.tree().kind(),
79 )
80 }
81
82 pub fn author(&self) -> ExnMessageResult<gix_actor::SignatureRef<'a>> {
86 parse_signature(self.author).map(|signature| signature.trim())
87 }
88
89 pub fn committer(&self) -> ExnMessageResult<gix_actor::SignatureRef<'a>> {
93 parse_signature(self.committer).map(|signature| signature.trim())
94 }
95
96 pub fn message(&self) -> MessageRef<'a> {
98 MessageRef::from_bytes(self.message)
99 }
100
101 pub fn time(&self) -> ExnMessageResult<gix_date::Time> {
103 parse_signature(self.committer).map(|signature| signature.time().unwrap_or_default())
104 }
105}
106
107impl CommitRef<'_> {
109 pub fn into_owned(self) -> ExnMessageResult<Commit> {
111 self.try_into()
112 }
113
114 pub fn to_owned(self) -> ExnMessageResult<Commit> {
116 self.try_into()
117 }
118}
119
120impl Commit {
121 pub fn extra_headers(&self) -> ExtraHeaders<impl Iterator<Item = (&BStr, &BStr)>> {
123 ExtraHeaders::new(
124 self.extra_headers.iter().map(|(k, v)| (k.as_bstr(), v.as_bstr())),
125 self.tree.kind(),
126 )
127 }
128}
129
130pub struct ExtraHeaders<I> {
132 inner: I,
133 hash_kind: gix_hash::Kind,
134}
135
136impl<'a, I> ExtraHeaders<I>
138where
139 I: Iterator<Item = (&'a BStr, &'a BStr)>,
140{
141 pub fn new(iter: I, hash_kind: gix_hash::Kind) -> Self {
143 ExtraHeaders { inner: iter, hash_kind }
144 }
145
146 pub fn find(mut self, name: &str) -> Option<&'a BStr> {
148 self.inner
149 .find_map(move |(k, v)| if k == name.as_bytes().as_bstr() { Some(v) } else { None })
150 }
151
152 pub fn find_pos(self, name: &str) -> Option<usize> {
154 self.inner
155 .enumerate()
156 .find_map(|(pos, (field, _value))| (field == name).then_some(pos))
157 }
158
159 pub fn find_all(self, name: &'a str) -> impl Iterator<Item = &'a BStr> {
161 self.inner
162 .filter_map(move |(k, v)| if k == name.as_bytes().as_bstr() { Some(v) } else { None })
163 }
164
165 pub fn mergetags(self) -> impl Iterator<Item = ExnMessageResult<TagRef<'a>>> {
170 let hash_kind = self.hash_kind;
171 self.find_all("mergetag").map(move |b| TagRef::from_bytes(b, hash_kind))
172 }
173
174 pub fn pgp_signature(self) -> Option<&'a BStr> {
176 let field_name = signature_field_name(self.hash_kind);
177 self.find(field_name)
178 }
179}