alopex_cli/
error.rs

1//! Error types for Alopex CLI
2//!
3//! This module defines CLI-specific error types using thiserror.
4
5use thiserror::Error;
6
7/// CLI-specific error type.
8///
9/// This enum represents all possible errors that can occur during CLI operations.
10#[derive(Error, Debug)]
11pub enum CliError {
12    /// An error from the underlying database layer.
13    #[error("Database error: {0}")]
14    Database(#[from] alopex_embedded::Error),
15
16    /// An I/O error occurred.
17    #[error("IO error: {0}")]
18    Io(#[from] std::io::Error),
19
20    /// An invalid argument was provided.
21    #[error("Invalid argument: {0}")]
22    InvalidArgument(String),
23
24    /// A specified profile was not found.
25    #[error("プロファイル '{0}' が見つかりません。alopex profile list で一覧を確認してください。")]
26    #[allow(dead_code)]
27    ProfileNotFound(String),
28
29    /// Conflicting CLI options were provided.
30    #[error(
31        "`--profile` と `--data-dir` は同時に指定できません。どちらか一方を使用してください。"
32    )]
33    #[allow(dead_code)]
34    ConflictingOptions,
35
36    /// A transaction ID is invalid.
37    #[error(
38        "トランザクション ID '{0}' は無効です。alopex kv txn begin で新しいトランザクションを開始してください。"
39    )]
40    #[allow(dead_code)]
41    InvalidTransactionId(String),
42
43    /// A transaction timed out and was rolled back.
44    #[error(
45        "トランザクション '{0}' がタイムアウトしました（60秒）。自動的にロールバックされました。"
46    )]
47    #[allow(dead_code)]
48    TransactionTimeout(String),
49
50    /// No SQL query was provided.
51    #[error("SQL クエリを指定してください。引数、-f オプション、または標準入力から入力できます。")]
52    #[allow(dead_code)]
53    NoQueryProvided,
54
55    /// An unknown index type was specified.
56    #[error("未知のインデックスタイプ: '{0}'。許可値: minmax, bloom")]
57    #[allow(dead_code)]
58    UnknownIndexType(String),
59
60    /// An unknown compression type was specified.
61    #[error("未知の圧縮形式: '{0}'。許可値: lz4, zstd, none")]
62    #[allow(dead_code)]
63    UnknownCompressionType(String),
64
65    /// File format is incompatible with the CLI version.
66    #[error("ファイルフォーマット v{file} は CLI v{cli} でサポートされていません。CLI をアップグレードしてください。")]
67    #[allow(dead_code)]
68    IncompatibleVersion { cli: String, file: String },
69
70    /// An S3-related error occurred.
71    #[error("S3 error: {0}")]
72    #[allow(dead_code)]
73    S3(String),
74
75    /// Credentials are missing or invalid.
76    #[error("Credentials error: {0}")]
77    Credentials(String),
78
79    /// A parsing error occurred.
80    #[error("Parse error: {0}")]
81    #[allow(dead_code)]
82    Parse(String),
83
84    /// A JSON serialization/deserialization error occurred.
85    #[error("JSON error: {0}")]
86    Json(#[from] serde_json::Error),
87}
88
89/// Type alias for CLI results.
90pub type Result<T> = std::result::Result<T, CliError>;
91
92/// Handle an error by printing it and exiting.
93///
94/// If `verbose` is true, prints the debug format (with stack trace info).
95/// Otherwise, prints the display format (user-friendly message).
96pub fn handle_error(error: CliError, verbose: bool) {
97    if verbose {
98        eprintln!("Error: {:?}", error); // Debug format with stack trace
99    } else {
100        eprintln!("Error: {}", error); // Display format
101    }
102    std::process::exit(1);
103}
104
105#[cfg(test)]
106mod tests {
107    use super::*;
108
109    #[test]
110    fn test_invalid_argument_error() {
111        let err = CliError::InvalidArgument("test message".to_string());
112        assert_eq!(format!("{}", err), "Invalid argument: test message");
113    }
114
115    #[test]
116    fn test_s3_error() {
117        let err = CliError::S3("bucket not found".to_string());
118        assert_eq!(format!("{}", err), "S3 error: bucket not found");
119    }
120
121    #[test]
122    fn test_credentials_error() {
123        let err = CliError::Credentials("AWS_ACCESS_KEY_ID not set".to_string());
124        assert_eq!(
125            format!("{}", err),
126            "Credentials error: AWS_ACCESS_KEY_ID not set"
127        );
128    }
129
130    #[test]
131    fn test_parse_error() {
132        let err = CliError::Parse("invalid JSON".to_string());
133        assert_eq!(format!("{}", err), "Parse error: invalid JSON");
134    }
135
136    #[test]
137    fn test_io_error_from() {
138        let io_err = std::io::Error::new(std::io::ErrorKind::NotFound, "file not found");
139        let err: CliError = io_err.into();
140        assert!(matches!(err, CliError::Io(_)));
141    }
142}
alopex_cli/error.rs

alopex_cli/
error.rs
