1#![cfg_attr(not(test), deny(clippy::unwrap_used, clippy::expect_used))]
2use serde::{Deserialize, Serialize};
9use std::fmt;
10use thiserror::Error;
11
12pub type Result<T> = std::result::Result<T, Error>;
14
15#[derive(Error, Debug, Clone, PartialEq)]
31pub struct Error {
32 pub code: ErrorCode,
34
35 pub message: String,
37
38 pub context: Option<ErrorContext>,
40}
41
42impl fmt::Display for Error {
44 #[inline]
45 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
46 write!(f, "{}: {}", self.code, self.message)?;
47 if let Some(ref ctx) = self.context {
48 write!(f, " ({ctx})")?;
49 }
50 Ok(())
51 }
52}
53
54impl Error {
55 #[inline]
57 #[must_use]
58 pub const fn code(&self) -> ErrorCode {
59 self.code
60 }
61
62 #[inline]
64 #[must_use]
65 pub const fn family_prefix(&self) -> &'static str {
66 self.code.family_prefix()
67 }
68}
69
70#[derive(Debug, Clone, Copy, PartialEq, Eq, Hash, Serialize, Deserialize)]
102#[allow(non_camel_case_types)] pub enum ErrorCode {
104 CBKP001_SYNTAX,
109 CBKP011_UNSUPPORTED_CLAUSE,
111 CBKP021_ODO_NOT_TAIL,
113 CBKP022_NESTED_ODO,
115 CBKP023_ODO_REDEFINES,
117 CBKP051_UNSUPPORTED_EDITED_PIC,
119 CBKP101_INVALID_PIC,
121
122 CBKS121_COUNTER_NOT_FOUND,
127 CBKS141_RECORD_TOO_LARGE,
129 CBKS301_ODO_CLIPPED,
131 CBKS302_ODO_RAISED,
133 CBKS601_RENAME_UNKNOWN_FROM,
135 CBKS602_RENAME_UNKNOWN_THRU,
137 CBKS603_RENAME_NOT_CONTIGUOUS,
139 CBKS604_RENAME_REVERSED_RANGE,
141 CBKS605_RENAME_FROM_CROSSES_GROUP,
143 CBKS606_RENAME_THRU_CROSSES_GROUP,
145 CBKS607_RENAME_CROSSES_OCCURS,
147 CBKS608_RENAME_QUALIFIED_NAME_NOT_FOUND,
149 CBKS609_RENAME_OVER_REDEFINES,
151 CBKS610_RENAME_MULTIPLE_REDEFINES,
153 CBKS611_RENAME_PARTIAL_OCCURS,
155 CBKS612_RENAME_ODO_NOT_SUPPORTED,
157 CBKS701_PROJECTION_INVALID_ODO,
159 CBKS702_PROJECTION_UNRESOLVED_ALIAS,
161 CBKS703_PROJECTION_FIELD_NOT_FOUND,
163
164 CBKR101_FIXED_RECORD_ERROR,
169 CBKR201_RDW_READ_ERROR,
171 CBKR202_RDW_WRITE_ERROR,
174 CBKR211_RDW_RESERVED_NONZERO,
176
177 CBKC201_JSON_WRITE_ERROR,
182 CBKC301_INVALID_EBCDIC_BYTE,
184
185 CBKD101_INVALID_FIELD_TYPE,
190 CBKD301_RECORD_TOO_SHORT,
192 CBKD302_EDITED_PIC_NOT_IMPLEMENTED,
194 CBKD401_COMP3_INVALID_NIBBLE,
196 CBKD410_ZONED_OVERFLOW,
198 CBKD411_ZONED_BAD_SIGN,
200 CBKD412_ZONED_BLANK_IS_ZERO,
202 CBKD413_ZONED_INVALID_ENCODING,
204 CBKD414_ZONED_MIXED_ENCODING,
206 CBKD415_ZONED_ENCODING_AMBIGUOUS,
208 CBKD421_EDITED_PIC_INVALID_FORMAT,
210 CBKD422_EDITED_PIC_SIGN_MISMATCH,
212 CBKD423_EDITED_PIC_BLANK_WHEN_ZERO,
214 CBKD431_FLOAT_NAN,
218 CBKD432_FLOAT_INFINITY,
222
223 CBKI001_INVALID_STATE,
228 CBKI002_TOO_MANY_ERRORS,
231
232 CBKE501_JSON_TYPE_MISMATCH,
237 CBKE505_SCALE_MISMATCH,
239 CBKE510_NUMERIC_OVERFLOW,
241 CBKE515_STRING_LENGTH_VIOLATION,
243 CBKE521_ARRAY_LEN_OOB,
245 CBKE530_SIGN_SEPARATE_ENCODE_ERROR,
247 CBKE531_FLOAT_ENCODE_OVERFLOW,
249
250 CBKF001_FILE_READ_ERROR,
255 CBKF102_RECORD_LENGTH_INVALID,
257 CBKF104_RDW_SUSPECT_ASCII,
259 CBKF221_RDW_UNDERFLOW,
261
262 CBKA001_BASELINE_ERROR,
267
268 CBKW001_SCHEMA_CONVERSION,
273 CBKW002_TYPE_MAPPING,
275 CBKW003_DECIMAL_OVERFLOW,
277 CBKW004_BATCH_BUILD,
279 CBKW005_PARQUET_WRITE,
281}
282
283impl fmt::Display for ErrorCode {
284 #[inline]
285 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
286 let code_str = match self {
287 ErrorCode::CBKP001_SYNTAX => "CBKP001_SYNTAX",
288 ErrorCode::CBKP011_UNSUPPORTED_CLAUSE => "CBKP011_UNSUPPORTED_CLAUSE",
289 ErrorCode::CBKP021_ODO_NOT_TAIL => "CBKP021_ODO_NOT_TAIL",
290 ErrorCode::CBKP022_NESTED_ODO => "CBKP022_NESTED_ODO",
291 ErrorCode::CBKP023_ODO_REDEFINES => "CBKP023_ODO_REDEFINES",
292 ErrorCode::CBKP051_UNSUPPORTED_EDITED_PIC => "CBKP051_UNSUPPORTED_EDITED_PIC",
293 ErrorCode::CBKP101_INVALID_PIC => "CBKP101_INVALID_PIC",
294 ErrorCode::CBKS121_COUNTER_NOT_FOUND => "CBKS121_COUNTER_NOT_FOUND",
295 ErrorCode::CBKS141_RECORD_TOO_LARGE => "CBKS141_RECORD_TOO_LARGE",
296 ErrorCode::CBKS301_ODO_CLIPPED => "CBKS301_ODO_CLIPPED",
297 ErrorCode::CBKS302_ODO_RAISED => "CBKS302_ODO_RAISED",
298 ErrorCode::CBKS601_RENAME_UNKNOWN_FROM => "CBKS601_RENAME_UNKNOWN_FROM",
299 ErrorCode::CBKS602_RENAME_UNKNOWN_THRU => "CBKS602_RENAME_UNKNOWN_THRU",
300 ErrorCode::CBKS603_RENAME_NOT_CONTIGUOUS => "CBKS603_RENAME_NOT_CONTIGUOUS",
301 ErrorCode::CBKS604_RENAME_REVERSED_RANGE => "CBKS604_RENAME_REVERSED_RANGE",
302 ErrorCode::CBKS605_RENAME_FROM_CROSSES_GROUP => "CBKS605_RENAME_FROM_CROSSES_GROUP",
303 ErrorCode::CBKS606_RENAME_THRU_CROSSES_GROUP => "CBKS606_RENAME_THRU_CROSSES_GROUP",
304 ErrorCode::CBKS607_RENAME_CROSSES_OCCURS => "CBKS607_RENAME_CROSSES_OCCURS",
305 ErrorCode::CBKS608_RENAME_QUALIFIED_NAME_NOT_FOUND => {
306 "CBKS608_RENAME_QUALIFIED_NAME_NOT_FOUND"
307 }
308 ErrorCode::CBKS609_RENAME_OVER_REDEFINES => "CBKS609_RENAME_OVER_REDEFINES",
309 ErrorCode::CBKS610_RENAME_MULTIPLE_REDEFINES => "CBKS610_RENAME_MULTIPLE_REDEFINES",
310 ErrorCode::CBKS611_RENAME_PARTIAL_OCCURS => "CBKS611_RENAME_PARTIAL_OCCURS",
311 ErrorCode::CBKS612_RENAME_ODO_NOT_SUPPORTED => "CBKS612_RENAME_ODO_NOT_SUPPORTED",
312 ErrorCode::CBKS701_PROJECTION_INVALID_ODO => "CBKS701_PROJECTION_INVALID_ODO",
313 ErrorCode::CBKS702_PROJECTION_UNRESOLVED_ALIAS => "CBKS702_PROJECTION_UNRESOLVED_ALIAS",
314 ErrorCode::CBKS703_PROJECTION_FIELD_NOT_FOUND => "CBKS703_PROJECTION_FIELD_NOT_FOUND",
315 ErrorCode::CBKR101_FIXED_RECORD_ERROR => "CBKR101_FIXED_RECORD_ERROR",
316 ErrorCode::CBKR201_RDW_READ_ERROR => "CBKR201_RDW_READ_ERROR",
317 ErrorCode::CBKR202_RDW_WRITE_ERROR => "CBKR202_RDW_WRITE_ERROR",
318 ErrorCode::CBKR211_RDW_RESERVED_NONZERO => "CBKR211_RDW_RESERVED_NONZERO",
319 ErrorCode::CBKC201_JSON_WRITE_ERROR => "CBKC201_JSON_WRITE_ERROR",
320 ErrorCode::CBKC301_INVALID_EBCDIC_BYTE => "CBKC301_INVALID_EBCDIC_BYTE",
321 ErrorCode::CBKD101_INVALID_FIELD_TYPE => "CBKD101_INVALID_FIELD_TYPE",
322 ErrorCode::CBKD301_RECORD_TOO_SHORT => "CBKD301_RECORD_TOO_SHORT",
323 ErrorCode::CBKD302_EDITED_PIC_NOT_IMPLEMENTED => "CBKD302_EDITED_PIC_NOT_IMPLEMENTED",
324 ErrorCode::CBKD401_COMP3_INVALID_NIBBLE => "CBKD401_COMP3_INVALID_NIBBLE",
325 ErrorCode::CBKD410_ZONED_OVERFLOW => "CBKD410_ZONED_OVERFLOW",
326 ErrorCode::CBKD411_ZONED_BAD_SIGN => "CBKD411_ZONED_BAD_SIGN",
327 ErrorCode::CBKD412_ZONED_BLANK_IS_ZERO => "CBKD412_ZONED_BLANK_IS_ZERO",
328 ErrorCode::CBKD413_ZONED_INVALID_ENCODING => "CBKD413_ZONED_INVALID_ENCODING",
329 ErrorCode::CBKD414_ZONED_MIXED_ENCODING => "CBKD414_ZONED_MIXED_ENCODING",
330 ErrorCode::CBKD415_ZONED_ENCODING_AMBIGUOUS => "CBKD415_ZONED_ENCODING_AMBIGUOUS",
331 ErrorCode::CBKD421_EDITED_PIC_INVALID_FORMAT => "CBKD421_EDITED_PIC_INVALID_FORMAT",
332 ErrorCode::CBKD422_EDITED_PIC_SIGN_MISMATCH => "CBKD422_EDITED_PIC_SIGN_MISMATCH",
333 ErrorCode::CBKD423_EDITED_PIC_BLANK_WHEN_ZERO => "CBKD423_EDITED_PIC_BLANK_WHEN_ZERO",
334 ErrorCode::CBKD431_FLOAT_NAN => "CBKD431_FLOAT_NAN",
335 ErrorCode::CBKD432_FLOAT_INFINITY => "CBKD432_FLOAT_INFINITY",
336 ErrorCode::CBKI001_INVALID_STATE => "CBKI001_INVALID_STATE",
337 ErrorCode::CBKI002_TOO_MANY_ERRORS => "CBKI002_TOO_MANY_ERRORS",
338 ErrorCode::CBKE501_JSON_TYPE_MISMATCH => "CBKE501_JSON_TYPE_MISMATCH",
339 ErrorCode::CBKE505_SCALE_MISMATCH => "CBKE505_SCALE_MISMATCH",
340 ErrorCode::CBKE510_NUMERIC_OVERFLOW => "CBKE510_NUMERIC_OVERFLOW",
341 ErrorCode::CBKE515_STRING_LENGTH_VIOLATION => "CBKE515_STRING_LENGTH_VIOLATION",
342 ErrorCode::CBKE521_ARRAY_LEN_OOB => "CBKE521_ARRAY_LEN_OOB",
343 ErrorCode::CBKE530_SIGN_SEPARATE_ENCODE_ERROR => "CBKE530_SIGN_SEPARATE_ENCODE_ERROR",
344 ErrorCode::CBKE531_FLOAT_ENCODE_OVERFLOW => "CBKE531_FLOAT_ENCODE_OVERFLOW",
345 ErrorCode::CBKF001_FILE_READ_ERROR => "CBKF001_FILE_READ_ERROR",
346 ErrorCode::CBKF102_RECORD_LENGTH_INVALID => "CBKF102_RECORD_LENGTH_INVALID",
347 ErrorCode::CBKF104_RDW_SUSPECT_ASCII => "CBKF104_RDW_SUSPECT_ASCII",
348 ErrorCode::CBKF221_RDW_UNDERFLOW => "CBKF221_RDW_UNDERFLOW",
349 ErrorCode::CBKA001_BASELINE_ERROR => "CBKA001_BASELINE_ERROR",
350 ErrorCode::CBKW001_SCHEMA_CONVERSION => "CBKW001_SCHEMA_CONVERSION",
351 ErrorCode::CBKW002_TYPE_MAPPING => "CBKW002_TYPE_MAPPING",
352 ErrorCode::CBKW003_DECIMAL_OVERFLOW => "CBKW003_DECIMAL_OVERFLOW",
353 ErrorCode::CBKW004_BATCH_BUILD => "CBKW004_BATCH_BUILD",
354 ErrorCode::CBKW005_PARQUET_WRITE => "CBKW005_PARQUET_WRITE",
355 };
356 write!(f, "{code_str}")
357 }
358}
359
360impl ErrorCode {
361 #[inline]
363 #[must_use]
364 pub const fn family_prefix(self) -> &'static str {
365 match self {
366 Self::CBKP001_SYNTAX
367 | Self::CBKP011_UNSUPPORTED_CLAUSE
368 | Self::CBKP021_ODO_NOT_TAIL
369 | Self::CBKP022_NESTED_ODO
370 | Self::CBKP023_ODO_REDEFINES
371 | Self::CBKP051_UNSUPPORTED_EDITED_PIC
372 | Self::CBKP101_INVALID_PIC => "CBKP",
373 Self::CBKS121_COUNTER_NOT_FOUND
374 | Self::CBKS141_RECORD_TOO_LARGE
375 | Self::CBKS301_ODO_CLIPPED
376 | Self::CBKS302_ODO_RAISED
377 | Self::CBKS601_RENAME_UNKNOWN_FROM
378 | Self::CBKS602_RENAME_UNKNOWN_THRU
379 | Self::CBKS603_RENAME_NOT_CONTIGUOUS
380 | Self::CBKS604_RENAME_REVERSED_RANGE
381 | Self::CBKS605_RENAME_FROM_CROSSES_GROUP
382 | Self::CBKS606_RENAME_THRU_CROSSES_GROUP
383 | Self::CBKS607_RENAME_CROSSES_OCCURS
384 | Self::CBKS608_RENAME_QUALIFIED_NAME_NOT_FOUND
385 | Self::CBKS609_RENAME_OVER_REDEFINES
386 | Self::CBKS610_RENAME_MULTIPLE_REDEFINES
387 | Self::CBKS611_RENAME_PARTIAL_OCCURS
388 | Self::CBKS612_RENAME_ODO_NOT_SUPPORTED
389 | Self::CBKS701_PROJECTION_INVALID_ODO
390 | Self::CBKS702_PROJECTION_UNRESOLVED_ALIAS
391 | Self::CBKS703_PROJECTION_FIELD_NOT_FOUND => "CBKS",
392 Self::CBKR101_FIXED_RECORD_ERROR
393 | Self::CBKR201_RDW_READ_ERROR
394 | Self::CBKR202_RDW_WRITE_ERROR
395 | Self::CBKR211_RDW_RESERVED_NONZERO => "CBKR",
396 Self::CBKC201_JSON_WRITE_ERROR | Self::CBKC301_INVALID_EBCDIC_BYTE => "CBKC",
397 Self::CBKD101_INVALID_FIELD_TYPE
398 | Self::CBKD301_RECORD_TOO_SHORT
399 | Self::CBKD302_EDITED_PIC_NOT_IMPLEMENTED
400 | Self::CBKD401_COMP3_INVALID_NIBBLE
401 | Self::CBKD410_ZONED_OVERFLOW
402 | Self::CBKD411_ZONED_BAD_SIGN
403 | Self::CBKD412_ZONED_BLANK_IS_ZERO
404 | Self::CBKD413_ZONED_INVALID_ENCODING
405 | Self::CBKD414_ZONED_MIXED_ENCODING
406 | Self::CBKD415_ZONED_ENCODING_AMBIGUOUS
407 | Self::CBKD421_EDITED_PIC_INVALID_FORMAT
408 | Self::CBKD422_EDITED_PIC_SIGN_MISMATCH
409 | Self::CBKD423_EDITED_PIC_BLANK_WHEN_ZERO
410 | Self::CBKD431_FLOAT_NAN
411 | Self::CBKD432_FLOAT_INFINITY => "CBKD",
412 Self::CBKI001_INVALID_STATE | Self::CBKI002_TOO_MANY_ERRORS => "CBKI",
413 Self::CBKE501_JSON_TYPE_MISMATCH
414 | Self::CBKE505_SCALE_MISMATCH
415 | Self::CBKE510_NUMERIC_OVERFLOW
416 | Self::CBKE515_STRING_LENGTH_VIOLATION
417 | Self::CBKE521_ARRAY_LEN_OOB
418 | Self::CBKE530_SIGN_SEPARATE_ENCODE_ERROR
419 | Self::CBKE531_FLOAT_ENCODE_OVERFLOW => "CBKE",
420 Self::CBKF001_FILE_READ_ERROR
421 | Self::CBKF102_RECORD_LENGTH_INVALID
422 | Self::CBKF104_RDW_SUSPECT_ASCII
423 | Self::CBKF221_RDW_UNDERFLOW => "CBKF",
424 Self::CBKA001_BASELINE_ERROR => "CBKA",
425 Self::CBKW001_SCHEMA_CONVERSION
426 | Self::CBKW002_TYPE_MAPPING
427 | Self::CBKW003_DECIMAL_OVERFLOW
428 | Self::CBKW004_BATCH_BUILD
429 | Self::CBKW005_PARQUET_WRITE => "CBKW",
430 }
431 }
432}
433
434#[derive(Debug, Clone, PartialEq)]
440pub struct ErrorContext {
441 pub record_index: Option<u64>,
446
447 pub field_path: Option<String>,
452
453 pub byte_offset: Option<u64>,
457
458 pub line_number: Option<u32>,
462
463 pub details: Option<String>,
467}
468
469impl fmt::Display for ErrorContext {
470 #[inline]
471 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
472 let mut parts = Vec::new();
473
474 if let Some(record) = self.record_index {
475 parts.push(format!("record {record}"));
476 }
477 if let Some(ref path) = self.field_path {
478 parts.push(format!("field {path}"));
479 }
480 if let Some(offset) = self.byte_offset {
481 parts.push(format!("offset {offset}"));
482 }
483 if let Some(line) = self.line_number {
484 parts.push(format!("line {line}"));
485 }
486 if let Some(ref details) = self.details {
487 parts.push(details.clone());
488 }
489
490 write!(f, "{}", parts.join(", "))
491 }
492}
493
494impl Error {
495 #[inline]
523 pub fn new(code: ErrorCode, message: impl Into<String>) -> Self {
524 Self {
525 code,
526 message: message.into(),
527 context: None,
528 }
529 }
530
531 #[must_use]
533 #[inline]
534 pub fn with_context(mut self, context: ErrorContext) -> Self {
535 self.context = Some(context);
536 self
537 }
538
539 #[must_use]
541 #[inline]
542 pub fn with_record(mut self, record_index: u64) -> Self {
543 let context = self.context.get_or_insert(ErrorContext {
544 record_index: None,
545 field_path: None,
546 byte_offset: None,
547 line_number: None,
548 details: None,
549 });
550 context.record_index = Some(record_index);
551 self
552 }
553
554 #[must_use]
556 #[inline]
557 pub fn with_field(mut self, field_path: impl Into<String>) -> Self {
558 let context = self.context.get_or_insert(ErrorContext {
559 record_index: None,
560 field_path: None,
561 byte_offset: None,
562 line_number: None,
563 details: None,
564 });
565 context.field_path = Some(field_path.into());
566 self
567 }
568
569 #[must_use]
571 #[inline]
572 pub fn with_offset(mut self, byte_offset: u64) -> Self {
573 let context = self.context.get_or_insert(ErrorContext {
574 record_index: None,
575 field_path: None,
576 byte_offset: None,
577 line_number: None,
578 details: None,
579 });
580 context.byte_offset = Some(byte_offset);
581 self
582 }
583}
584
585#[macro_export]
587macro_rules! error {
588 ($code:expr, $msg:expr) => {
589 $crate::Error::new($code, $msg)
590 };
591 ($code:expr, $fmt:expr, $($arg:tt)*) => {
592 $crate::Error::new($code, format!($fmt, $($arg)*))
593 };
594}
595
596#[cfg(test)]
597#[allow(clippy::expect_used)]
598#[allow(clippy::unwrap_used)] mod tests {
600 use super::*;
601
602 #[test]
603 fn test_error_code_serialization() {
604 let code = ErrorCode::CBKD411_ZONED_BAD_SIGN;
605 let json = serde_json::to_string(&code).unwrap();
606 assert_eq!(json, "\"CBKD411_ZONED_BAD_SIGN\"");
607
608 let deserialized: ErrorCode = serde_json::from_str(&json).unwrap();
609 assert_eq!(deserialized, code);
610 }
611
612 #[test]
613 fn test_error_display_format() {
614 let error = Error::new(
615 ErrorCode::CBKD411_ZONED_BAD_SIGN,
616 "Invalid sign zone in field",
617 );
618 let display = format!("{error}");
619 assert_eq!(
620 display,
621 "CBKD411_ZONED_BAD_SIGN: Invalid sign zone in field"
622 );
623 }
624
625 #[test]
626 fn test_error_with_context_display() {
627 let error =
628 Error::new(ErrorCode::CBKD411_ZONED_BAD_SIGN, "Test error").with_field("AMOUNT");
629 let display = format!("{error}");
630 assert!(display.contains("CBKD411_ZONED_BAD_SIGN: Test error"));
631 assert!(display.contains("field AMOUNT"));
632 }
633
634 #[test]
635 fn test_error_static_message() {
636 let error = Error::new(ErrorCode::CBKD411_ZONED_BAD_SIGN, "Static message");
637 assert_eq!(error.message, "Static message");
638 assert_eq!(error.code, ErrorCode::CBKD411_ZONED_BAD_SIGN);
639 assert!(error.context.is_none());
640 }
641
642 #[test]
643 fn test_error_dynamic_message() {
644 let field = "AMOUNT";
645 let error = Error::new(
646 ErrorCode::CBKD411_ZONED_BAD_SIGN,
647 format!("Dynamic message for field {field}"),
648 );
649 assert_eq!(error.message, "Dynamic message for field AMOUNT");
650 }
651
652 #[test]
653 fn test_error_macro_static() {
654 let err = error!(ErrorCode::CBKP001_SYNTAX, "Empty copybook");
655 assert_eq!(err.code, ErrorCode::CBKP001_SYNTAX);
656 assert_eq!(err.message, "Empty copybook");
657 }
658
659 #[test]
660 fn test_error_macro_formatted() {
661 let field = "CUSTOMER_ID";
662 let err = error!(
663 ErrorCode::CBKD301_RECORD_TOO_SHORT,
664 "Field {} missing", field
665 );
666 assert_eq!(err.code, ErrorCode::CBKD301_RECORD_TOO_SHORT);
667 assert!(err.message.contains("CUSTOMER_ID"));
668 }
669
670 #[test]
675 fn test_error_code_accessor() {
676 let err = Error::new(ErrorCode::CBKE510_NUMERIC_OVERFLOW, "overflow");
677 assert_eq!(err.code(), ErrorCode::CBKE510_NUMERIC_OVERFLOW);
678 }
679
680 #[test]
681 fn test_error_family_prefix_via_error() {
682 let err = Error::new(ErrorCode::CBKR211_RDW_RESERVED_NONZERO, "reserved");
683 assert_eq!(err.family_prefix(), "CBKR");
684 }
685
686 #[test]
687 fn test_error_with_record_builder() {
688 let err = Error::new(ErrorCode::CBKD301_RECORD_TOO_SHORT, "short").with_record(7);
689 let ctx = err.context.as_ref().unwrap();
690 assert_eq!(ctx.record_index, Some(7));
691 assert!(ctx.field_path.is_none());
692 assert!(ctx.byte_offset.is_none());
693 }
694
695 #[test]
696 fn test_error_with_offset_builder() {
697 let err = Error::new(ErrorCode::CBKD301_RECORD_TOO_SHORT, "short").with_offset(128);
698 let ctx = err.context.as_ref().unwrap();
699 assert_eq!(ctx.byte_offset, Some(128));
700 assert!(ctx.record_index.is_none());
701 assert!(ctx.field_path.is_none());
702 }
703
704 #[test]
705 fn test_error_chained_context_builders() {
706 let err = Error::new(ErrorCode::CBKD401_COMP3_INVALID_NIBBLE, "bad nibble")
707 .with_record(10)
708 .with_field("CUSTOMER.BALANCE")
709 .with_offset(64);
710 let ctx = err.context.as_ref().unwrap();
711 assert_eq!(ctx.record_index, Some(10));
712 assert_eq!(ctx.field_path.as_deref(), Some("CUSTOMER.BALANCE"));
713 assert_eq!(ctx.byte_offset, Some(64));
714 assert!(ctx.line_number.is_none());
715 assert!(ctx.details.is_none());
716 }
717
718 #[test]
719 fn test_error_with_context_sets_full_context() {
720 let ctx = ErrorContext {
721 record_index: Some(99),
722 field_path: Some("ROOT.CHILD".into()),
723 byte_offset: Some(512),
724 line_number: Some(42),
725 details: Some("extra detail".into()),
726 };
727 let err = Error::new(ErrorCode::CBKP001_SYNTAX, "bad syntax").with_context(ctx);
728 let c = err.context.as_ref().unwrap();
729 assert_eq!(c.record_index, Some(99));
730 assert_eq!(c.field_path.as_deref(), Some("ROOT.CHILD"));
731 assert_eq!(c.byte_offset, Some(512));
732 assert_eq!(c.line_number, Some(42));
733 assert_eq!(c.details.as_deref(), Some("extra detail"));
734 }
735
736 #[test]
741 fn test_error_clone_equality() {
742 let err1 = Error::new(ErrorCode::CBKE501_JSON_TYPE_MISMATCH, "mismatch")
743 .with_field("AMOUNT")
744 .with_record(3);
745 let err2 = err1.clone();
746 assert_eq!(err1, err2);
747 assert_eq!(err1.code, err2.code);
748 assert_eq!(err1.message, err2.message);
749 assert_eq!(err1.context, err2.context);
750 }
751
752 #[test]
753 fn test_error_code_copy_clone_hash() {
754 use std::collections::HashSet;
755 let code = ErrorCode::CBKP001_SYNTAX;
756 let copy = code;
757 assert_eq!(code, copy);
758
759 let mut set = HashSet::new();
760 set.insert(ErrorCode::CBKP001_SYNTAX);
761 set.insert(ErrorCode::CBKD301_RECORD_TOO_SHORT);
762 set.insert(ErrorCode::CBKP001_SYNTAX); assert_eq!(set.len(), 2);
764 }
765
766 #[test]
767 fn test_error_implements_std_error() {
768 let err = Error::new(ErrorCode::CBKD411_ZONED_BAD_SIGN, "bad sign");
769 let std_err: &dyn std::error::Error = &err;
770 assert!(std_err.source().is_none());
772 assert!(!std_err.to_string().is_empty());
773 }
774
775 #[test]
780 fn test_error_context_display_empty() {
781 let ctx = ErrorContext {
782 record_index: None,
783 field_path: None,
784 byte_offset: None,
785 line_number: None,
786 details: None,
787 };
788 assert_eq!(format!("{ctx}"), "");
789 }
790
791 #[test]
792 fn test_error_context_display_record_only() {
793 let ctx = ErrorContext {
794 record_index: Some(42),
795 field_path: None,
796 byte_offset: None,
797 line_number: None,
798 details: None,
799 };
800 assert_eq!(format!("{ctx}"), "record 42");
801 }
802
803 #[test]
804 fn test_error_context_display_line_number_only() {
805 let ctx = ErrorContext {
806 record_index: None,
807 field_path: None,
808 byte_offset: None,
809 line_number: Some(15),
810 details: None,
811 };
812 assert_eq!(format!("{ctx}"), "line 15");
813 }
814
815 #[test]
816 fn test_error_context_display_details_only() {
817 let ctx = ErrorContext {
818 record_index: None,
819 field_path: None,
820 byte_offset: None,
821 line_number: None,
822 details: Some("expected 8 bytes, got 4".into()),
823 };
824 assert_eq!(format!("{ctx}"), "expected 8 bytes, got 4");
825 }
826
827 #[test]
832 fn test_all_cbkp_codes_have_cbkp_prefix() {
833 let codes = [
834 ErrorCode::CBKP001_SYNTAX,
835 ErrorCode::CBKP011_UNSUPPORTED_CLAUSE,
836 ErrorCode::CBKP021_ODO_NOT_TAIL,
837 ErrorCode::CBKP022_NESTED_ODO,
838 ErrorCode::CBKP023_ODO_REDEFINES,
839 ErrorCode::CBKP051_UNSUPPORTED_EDITED_PIC,
840 ErrorCode::CBKP101_INVALID_PIC,
841 ];
842 for code in codes {
843 assert_eq!(code.family_prefix(), "CBKP", "failed for {code}");
844 }
845 }
846
847 #[test]
848 fn test_all_cbks_codes_have_cbks_prefix() {
849 let codes = [
850 ErrorCode::CBKS121_COUNTER_NOT_FOUND,
851 ErrorCode::CBKS141_RECORD_TOO_LARGE,
852 ErrorCode::CBKS301_ODO_CLIPPED,
853 ErrorCode::CBKS302_ODO_RAISED,
854 ErrorCode::CBKS601_RENAME_UNKNOWN_FROM,
855 ErrorCode::CBKS602_RENAME_UNKNOWN_THRU,
856 ErrorCode::CBKS603_RENAME_NOT_CONTIGUOUS,
857 ErrorCode::CBKS604_RENAME_REVERSED_RANGE,
858 ErrorCode::CBKS605_RENAME_FROM_CROSSES_GROUP,
859 ErrorCode::CBKS606_RENAME_THRU_CROSSES_GROUP,
860 ErrorCode::CBKS607_RENAME_CROSSES_OCCURS,
861 ErrorCode::CBKS608_RENAME_QUALIFIED_NAME_NOT_FOUND,
862 ErrorCode::CBKS609_RENAME_OVER_REDEFINES,
863 ErrorCode::CBKS610_RENAME_MULTIPLE_REDEFINES,
864 ErrorCode::CBKS611_RENAME_PARTIAL_OCCURS,
865 ErrorCode::CBKS612_RENAME_ODO_NOT_SUPPORTED,
866 ErrorCode::CBKS701_PROJECTION_INVALID_ODO,
867 ErrorCode::CBKS702_PROJECTION_UNRESOLVED_ALIAS,
868 ErrorCode::CBKS703_PROJECTION_FIELD_NOT_FOUND,
869 ];
870 for code in codes {
871 assert_eq!(code.family_prefix(), "CBKS", "failed for {code}");
872 }
873 }
874
875 #[test]
876 fn test_all_cbkd_codes_have_cbkd_prefix() {
877 let codes = [
878 ErrorCode::CBKD101_INVALID_FIELD_TYPE,
879 ErrorCode::CBKD301_RECORD_TOO_SHORT,
880 ErrorCode::CBKD302_EDITED_PIC_NOT_IMPLEMENTED,
881 ErrorCode::CBKD401_COMP3_INVALID_NIBBLE,
882 ErrorCode::CBKD410_ZONED_OVERFLOW,
883 ErrorCode::CBKD411_ZONED_BAD_SIGN,
884 ErrorCode::CBKD412_ZONED_BLANK_IS_ZERO,
885 ErrorCode::CBKD413_ZONED_INVALID_ENCODING,
886 ErrorCode::CBKD414_ZONED_MIXED_ENCODING,
887 ErrorCode::CBKD415_ZONED_ENCODING_AMBIGUOUS,
888 ErrorCode::CBKD421_EDITED_PIC_INVALID_FORMAT,
889 ErrorCode::CBKD422_EDITED_PIC_SIGN_MISMATCH,
890 ErrorCode::CBKD423_EDITED_PIC_BLANK_WHEN_ZERO,
891 ErrorCode::CBKD431_FLOAT_NAN,
892 ErrorCode::CBKD432_FLOAT_INFINITY,
893 ];
894 for code in codes {
895 assert_eq!(code.family_prefix(), "CBKD", "failed for {code}");
896 }
897 }
898
899 #[test]
900 fn test_all_cbke_codes_have_cbke_prefix() {
901 let codes = [
902 ErrorCode::CBKE501_JSON_TYPE_MISMATCH,
903 ErrorCode::CBKE505_SCALE_MISMATCH,
904 ErrorCode::CBKE510_NUMERIC_OVERFLOW,
905 ErrorCode::CBKE515_STRING_LENGTH_VIOLATION,
906 ErrorCode::CBKE521_ARRAY_LEN_OOB,
907 ErrorCode::CBKE530_SIGN_SEPARATE_ENCODE_ERROR,
908 ErrorCode::CBKE531_FLOAT_ENCODE_OVERFLOW,
909 ];
910 for code in codes {
911 assert_eq!(code.family_prefix(), "CBKE", "failed for {code}");
912 }
913 }
914
915 #[test]
916 fn test_remaining_family_prefixes() {
917 assert_eq!(
918 ErrorCode::CBKR211_RDW_RESERVED_NONZERO.family_prefix(),
919 "CBKR"
920 );
921 assert_eq!(ErrorCode::CBKC201_JSON_WRITE_ERROR.family_prefix(), "CBKC");
922 assert_eq!(
923 ErrorCode::CBKC301_INVALID_EBCDIC_BYTE.family_prefix(),
924 "CBKC"
925 );
926 assert_eq!(ErrorCode::CBKI001_INVALID_STATE.family_prefix(), "CBKI");
927 assert_eq!(ErrorCode::CBKI002_TOO_MANY_ERRORS.family_prefix(), "CBKI");
928 assert_eq!(
929 ErrorCode::CBKF102_RECORD_LENGTH_INVALID.family_prefix(),
930 "CBKF"
931 );
932 assert_eq!(ErrorCode::CBKF104_RDW_SUSPECT_ASCII.family_prefix(), "CBKF");
933 assert_eq!(ErrorCode::CBKF221_RDW_UNDERFLOW.family_prefix(), "CBKF");
934 assert_eq!(ErrorCode::CBKA001_BASELINE_ERROR.family_prefix(), "CBKA");
935 assert_eq!(ErrorCode::CBKW001_SCHEMA_CONVERSION.family_prefix(), "CBKW");
936 assert_eq!(ErrorCode::CBKW002_TYPE_MAPPING.family_prefix(), "CBKW");
937 assert_eq!(ErrorCode::CBKW003_DECIMAL_OVERFLOW.family_prefix(), "CBKW");
938 assert_eq!(ErrorCode::CBKW004_BATCH_BUILD.family_prefix(), "CBKW");
939 assert_eq!(ErrorCode::CBKW005_PARQUET_WRITE.family_prefix(), "CBKW");
940 }
941
942 #[test]
947 fn test_error_code_display_starts_with_family_prefix() {
948 let representative_codes = [
949 ErrorCode::CBKP001_SYNTAX,
950 ErrorCode::CBKS121_COUNTER_NOT_FOUND,
951 ErrorCode::CBKR211_RDW_RESERVED_NONZERO,
952 ErrorCode::CBKC201_JSON_WRITE_ERROR,
953 ErrorCode::CBKD401_COMP3_INVALID_NIBBLE,
954 ErrorCode::CBKI001_INVALID_STATE,
955 ErrorCode::CBKI002_TOO_MANY_ERRORS,
956 ErrorCode::CBKE501_JSON_TYPE_MISMATCH,
957 ErrorCode::CBKF102_RECORD_LENGTH_INVALID,
958 ErrorCode::CBKA001_BASELINE_ERROR,
959 ErrorCode::CBKW001_SCHEMA_CONVERSION,
960 ];
961 for code in representative_codes {
962 let display = format!("{code}");
963 let prefix = code.family_prefix();
964 assert!(
965 display.starts_with(prefix),
966 "{display} should start with {prefix}"
967 );
968 }
969 }
970
971 #[test]
976 fn test_error_code_serde_roundtrip_all_families() {
977 let codes = [
978 ErrorCode::CBKP001_SYNTAX,
979 ErrorCode::CBKS121_COUNTER_NOT_FOUND,
980 ErrorCode::CBKR211_RDW_RESERVED_NONZERO,
981 ErrorCode::CBKC201_JSON_WRITE_ERROR,
982 ErrorCode::CBKD401_COMP3_INVALID_NIBBLE,
983 ErrorCode::CBKI001_INVALID_STATE,
984 ErrorCode::CBKI002_TOO_MANY_ERRORS,
985 ErrorCode::CBKE501_JSON_TYPE_MISMATCH,
986 ErrorCode::CBKF102_RECORD_LENGTH_INVALID,
987 ErrorCode::CBKA001_BASELINE_ERROR,
988 ErrorCode::CBKW001_SCHEMA_CONVERSION,
989 ];
990 for code in codes {
991 let json = serde_json::to_string(&code).unwrap();
992 let roundtripped: ErrorCode = serde_json::from_str(&json).unwrap();
993 assert_eq!(roundtripped, code, "round-trip failed for {code}");
994 }
995 }
996
997 #[test]
998 fn test_error_code_deserialization_from_string() {
999 let json = r#""CBKP101_INVALID_PIC""#;
1000 let code: ErrorCode = serde_json::from_str(json).unwrap();
1001 assert_eq!(code, ErrorCode::CBKP101_INVALID_PIC);
1002 }
1003
1004 #[test]
1005 fn test_error_code_deserialization_invalid_rejects() {
1006 let json = r#""NOT_A_REAL_CODE""#;
1007 let result: std::result::Result<ErrorCode, _> = serde_json::from_str(json);
1008 assert!(result.is_err());
1009 }
1010
1011 #[test]
1016 fn test_error_macro_multiple_format_args() {
1017 let field = "AMOUNT";
1018 let expected = 8;
1019 let actual = 4;
1020 let err = error!(
1021 ErrorCode::CBKD301_RECORD_TOO_SHORT,
1022 "Field {} expected {} bytes, got {}", field, expected, actual
1023 );
1024 assert_eq!(err.message, "Field AMOUNT expected 8 bytes, got 4");
1025 }
1026}