1use std::{error::Error, fmt, path::Path};
5
6use crate::object::{ChangeId, ContentHash, TreeError};
7
8#[derive(Debug, Clone, PartialEq)]
10pub struct RecoveryDetails {
11 pub kind: &'static str,
12 pub error: String,
13 pub hint: String,
14 pub unsafe_condition: String,
15 pub would_change: String,
16 pub preserved: String,
17 pub recovery_commands: Option<Vec<String>>,
22}
23
24impl RecoveryDetails {
25 pub fn safety_refusal(
26 kind: &'static str,
27 error: impl Into<String>,
28 hint: impl Into<String>,
29 unsafe_condition: impl Into<String>,
30 would_change: impl Into<String>,
31 already_preserved: impl Into<String>,
32 ) -> Self {
33 Self {
34 kind,
35 error: error.into(),
36 hint: hint.into(),
37 unsafe_condition: unsafe_condition.into(),
38 would_change: would_change.into(),
39 preserved: already_preserved.into(),
40 recovery_commands: None,
41 }
42 }
43
44 #[must_use]
48 pub fn with_recovery_commands(mut self, commands: Vec<String>) -> Self {
49 self.recovery_commands = Some(commands);
50 self
51 }
52
53 pub fn invalid_usage(
54 kind: &'static str,
55 error: impl Into<String>,
56 hint: impl Into<String>,
57 ) -> Self {
58 Self::safety_refusal(
59 kind,
60 error,
61 hint,
62 "the command arguments do not describe a valid operation",
63 "running with ambiguous or invalid arguments could target the wrong repository state or metadata",
64 "no repository objects, refs, metadata, or worktree files were changed",
65 )
66 }
67
68 pub fn feature_unavailable(command: &str, feature: &str) -> Self {
69 Self::safety_refusal(
70 "feature_unavailable",
71 format!("{command} requires building heddle with --features {feature}"),
72 format!(
73 "Use a binary built with the `{feature}` feature, or rerun without the feature-specific flag."
74 ),
75 format!("this heddle binary was built without the `{feature}` feature"),
76 format!("{command} cannot run because the requested analysis engine is unavailable"),
77 "repository state, refs, and worktree files were left unchanged",
78 )
79 }
80
81 pub fn serialization_error(detail: impl fmt::Display) -> Self {
82 Self::safety_refusal(
83 "state_corrupted",
84 "Repository state is corrupted or unreadable",
85 "Inspect repository integrity before attempting repair.",
86 format!("a stored repository object failed to decode: {detail}"),
87 "continuing would read or write through repository state Heddle cannot decode",
88 "the command stopped before mutating repository state; intact objects were left unchanged",
89 )
90 }
91
92 pub fn repository_integrity_error(error: impl Into<String>) -> Self {
93 Self::safety_refusal(
94 "repository_integrity_error",
95 error,
96 "Inspect repository integrity, then restore or repair the reported object/ref.",
97 "repository object or ref integrity did not pass validation",
98 "continuing could compound corruption or hide the missing object",
99 "the command stopped before applying the requested mutation",
100 )
101 }
102
103 pub fn repository_not_found(path: &Path) -> Self {
104 Self::safety_refusal(
105 "repository_not_found",
106 format!("repository not found at {}", path.display()),
107 "Initialize the requested repository before running repository commands.",
108 format!("no Heddle repository was found at '{}'", path.display()),
109 "the command cannot inspect or change repository state until initialization",
110 "no repository objects, refs, metadata, or worktree files were changed",
111 )
112 }
113
114 pub fn state_not_found(state_id: impl fmt::Display) -> Self {
115 Self::safety_refusal(
116 "state_not_found",
117 format!("State not found: {state_id}"),
118 "List recent states with `heddle log`, then choose an existing state id.",
119 "the requested state id does not exist in this repository",
120 "continuing with a guessed state could target the wrong history point",
121 "repository state, refs, metadata, and worktree files were left unchanged",
122 )
123 }
124}
125
126impl fmt::Display for RecoveryDetails {
127 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
128 write!(
129 f,
130 "{}. Unsafe: {}. Would change: {}. Preserved: {}.",
131 self.error, self.unsafe_condition, self.would_change, self.preserved
132 )?;
133 Ok(())
134 }
135}
136
137impl Error for RecoveryDetails {}
138
139#[derive(Debug, thiserror::Error)]
141pub enum HeddleError {
142 #[error("{0}")]
143 Recovery(Box<RecoveryDetails>),
144 #[error("object not found: {0}")]
145 NotFound(String),
146 #[error("No merge in progress")]
147 NoMergeInProgress,
148 #[error("state not found: {0}")]
149 StateNotFound(ChangeId),
150 #[error("invalid object: {0}")]
151 InvalidObject(String),
152 #[error("repository not found at {0}")]
153 RepositoryNotFound(std::path::PathBuf),
154 #[error("repository already exists at {0}")]
155 RepositoryExists(std::path::PathBuf),
156 #[error(
157 "repository config at {path} uses repository format {found} but this binary supports {supported}; upgrade heddle or run `heddle migrate`"
158 )]
159 RepositoryFormatTooNew {
160 path: std::path::PathBuf,
161 found: u32,
162 supported: u32,
163 },
164 #[error("io error: {0}")]
165 Io(#[from] std::io::Error),
166 #[error("serialization error: {0}")]
167 Serialization(String),
168 #[error("configuration error: {0}")]
169 Config(String),
170 #[error("configuration parse error at {path}: {source}")]
171 ConfigParse {
172 path: std::path::PathBuf,
173 #[source]
178 source: toml::de::Error,
179 },
180 #[error(
181 "invalid {key}: '{value}' — valid values are {} (in {path})",
182 valid_values.join(" or ")
183 )]
184 ConfigInvalidValue {
185 path: std::path::PathBuf,
186 key: String,
187 value: String,
188 valid_values: Vec<String>,
189 },
190 #[error("conflict: {0}")]
191 Conflict(String),
192 #[error("compression error: {0}")]
193 Compression(String),
194 #[error("invalid ref name: {0}")]
195 InvalidRefName(String),
196 #[error("file too large: {0} bytes")]
197 InvalidFileSize(u64),
198 #[error("symlink target escapes repository: {0}")]
199 InvalidSymlinkTarget(std::path::PathBuf),
200 #[error("object corruption: expected {expected}, found {found}")]
201 Corruption {
202 expected: ContentHash,
203 found: ContentHash,
204 },
205 #[error(
206 "missing {object_type} object: {id} (run `heddle fsck --full` to inspect store integrity)"
207 )]
208 MissingObject { object_type: String, id: String },
209 #[error("invalid tree entry: {0}")]
210 InvalidTreeEntry(#[from] TreeError),
211}
212
213impl HeddleError {
214 pub fn recovery(details: RecoveryDetails) -> Self {
215 HeddleError::Recovery(Box::new(details))
216 }
217}
218
219impl From<rmp_serde::encode::Error> for HeddleError {
220 fn from(e: rmp_serde::encode::Error) -> Self {
221 HeddleError::Serialization(e.to_string())
222 }
223}
224
225impl From<rmp_serde::decode::Error> for HeddleError {
226 fn from(e: rmp_serde::decode::Error) -> Self {
227 HeddleError::Serialization(e.to_string())
228 }
229}
230
231impl From<toml::de::Error> for HeddleError {
232 fn from(e: toml::de::Error) -> Self {
233 HeddleError::Config(e.to_string())
234 }
235}
236
237impl From<toml::ser::Error> for HeddleError {
238 fn from(e: toml::ser::Error) -> Self {
239 HeddleError::Config(e.to_string())
240 }
241}
242
243impl From<serde_json::Error> for HeddleError {
244 fn from(e: serde_json::Error) -> Self {
245 HeddleError::Serialization(e.to_string())
246 }
247}
248
249pub type Result<T> = std::result::Result<T, HeddleError>;
251
252#[cfg(test)]
253mod tests {
254 use super::{HeddleError, RecoveryDetails};
255
256 #[test]
257 fn safety_refusal_formats_domain_details() {
258 let details = RecoveryDetails::safety_refusal(
259 "example",
260 "error",
261 "hint",
262 "unsafe",
263 "would change",
264 "preserved",
265 );
266
267 assert_eq!(
268 details.to_string(),
269 "error. Unsafe: unsafe. Would change: would change. Preserved: preserved."
270 );
271 }
272
273 #[test]
274 fn recovery_error_displays_structured_error_copy() {
275 let err = HeddleError::recovery(RecoveryDetails::serialization_error("bad marker"));
276
277 assert!(err.to_string().contains("Repository state is corrupted"));
278 assert!(!err.to_string().contains("heddle fsck --full"));
279 }
280}