obzenflow_core 0.2.1

Core domain layer for ObzenFlow - pure abstractions with minimal dependencies
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84

// SPDX-License-Identifier: MIT OR Apache-2.0
// SPDX-FileCopyrightText: 2025-2026 ObzenFlow Contributors
// https://obzenflow.dev

//! Web server error types

use std::fmt;

/// Errors that can occur in web server operations
#[derive(Debug)]
pub enum WebError {
    /// Server failed to start
    StartupFailed {
        message: String,
        source: Option<Box<dyn std::error::Error + Send + Sync>>,
    },

    /// Server failed to bind to address
    BindFailed {
        address: String,
        source: Option<Box<dyn std::error::Error + Send + Sync>>,
    },

    /// Endpoint registration failed
    EndpointRegistrationFailed { path: String, message: String },

    /// Request handling failed
    RequestHandlingFailed {
        message: String,
        source: Option<Box<dyn std::error::Error + Send + Sync>>,
    },

    /// Server shutdown failed
    ShutdownFailed {
        message: String,
        source: Option<Box<dyn std::error::Error + Send + Sync>>,
    },

    /// Generic implementation error
    Implementation {
        message: String,
        source: Option<Box<dyn std::error::Error + Send + Sync>>,
    },
}

impl fmt::Display for WebError {
    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
        match self {
            WebError::StartupFailed { message, .. } => {
                write!(f, "Server startup failed: {message}")
            }
            WebError::BindFailed { address, .. } => {
                write!(f, "Failed to bind to address {address}")
            }
            WebError::EndpointRegistrationFailed { path, message } => {
                write!(f, "Failed to register endpoint at {path}: {message}")
            }
            WebError::RequestHandlingFailed { message, .. } => {
                write!(f, "Request handling failed: {message}")
            }
            WebError::ShutdownFailed { message, .. } => {
                write!(f, "Server shutdown failed: {message}")
            }
            WebError::Implementation { message, .. } => {
                write!(f, "Implementation error: {message}")
            }
        }
    }
}

impl std::error::Error for WebError {
    fn source(&self) -> Option<&(dyn std::error::Error + 'static)> {
        match self {
            WebError::StartupFailed { source, .. }
            | WebError::BindFailed { source, .. }
            | WebError::RequestHandlingFailed { source, .. }
            | WebError::ShutdownFailed { source, .. }
            | WebError::Implementation { source, .. } => source
                .as_ref()
                .map(|s| s.as_ref() as &(dyn std::error::Error + 'static)),
            WebError::EndpointRegistrationFailed { .. } => None,
        }
    }
}