allsource_core/lib.rs
1//! # AllSource Core - High-Performance Event Store
2//!
3//! A high-performance event sourcing platform built in Rust, following Clean Architecture principles.
4//!
5//! ## Architecture Overview
6//!
7//! The codebase follows a layered Clean Architecture:
8//!
9//! ```text
10//! ┌─────────────────────────────────────────────────────────────┐
11//! │ Infrastructure Layer │
12//! │ (HTTP handlers, WebSocket, persistence, security) │
13//! │ infrastructure::web, infrastructure::persistence, │
14//! │ infrastructure::security, infrastructure::repositories │
15//! ├─────────────────────────────────────────────────────────────┤
16//! │ Application Layer │
17//! │ (Use cases, services, DTOs) │
18//! │ application::use_cases, application::services, │
19//! │ application::dto │
20//! ├─────────────────────────────────────────────────────────────┤
21//! │ Domain Layer │
22//! │ (Entities, value objects, repository traits) │
23//! │ domain::entities, domain::value_objects, │
24//! │ domain::repositories │
25//! └─────────────────────────────────────────────────────────────┘
26//! ```
27//!
28//! ## Module Organization
29//!
30//! - **domain**: Core business entities, value objects, and repository traits
31//! - **application**: Use cases, services, and DTOs that orchestrate domain logic
32//! - **infrastructure**: Concrete implementations (web, persistence, security)
33//!
34//! ## Quick Start
35//!
36//! ```rust,ignore
37//! use allsource_core::{EventStore, Event, IngestEventRequest};
38//!
39//! let store = EventStore::new();
40//! let event = Event::from_strings(
41//! "user.created".to_string(),
42//! "user-123".to_string(),
43//! "default".to_string(),
44//! serde_json::json!({"name": "Alice"}),
45//! None,
46//! )?;
47//! store.ingest(event)?;
48//! ```
49
50// Safety: no unsafe code allowed in this crate
51#![forbid(unsafe_code)]
52// Development suppressions — tighten progressively
53#![allow(dead_code)]
54#![allow(unused_variables)]
55#![allow(deprecated)]
56// Clippy — allow patterns justified by architecture
57#![allow(clippy::too_many_arguments)]
58#![allow(clippy::type_complexity)]
59#![allow(clippy::module_inception)]
60
61// =============================================================================
62// Clean Architecture Layers
63// =============================================================================
64
65/// Layer 1: Domain Layer - Enterprise Business Rules
66///
67/// Contains pure business entities, value objects, and repository traits.
68/// This layer has ZERO external dependencies.
69pub mod domain;
70
71/// Layer 2: Application Layer - Application Business Rules
72///
73/// Contains use cases that orchestrate domain entities and services.
74/// Depends only on the domain layer.
75pub mod application;
76
77/// Layer 3: Infrastructure Layer - Interface Adapters
78///
79/// Contains concrete implementations of abstractions.
80/// Depends on domain and application layers.
81pub mod infrastructure;
82
83// =============================================================================
84// Shared Modules
85// =============================================================================
86
87/// Error types for the entire crate
88pub mod error;
89
90/// Main EventStore facade
91pub mod store;
92
93/// Advanced security module (anomaly detection, encryption, KMS)
94pub mod security;
95
96/// Shared test fixture builders for integration tests and cross-crate use
97pub mod test_utils;
98
99// =============================================================================
100// Public API - Commonly Used Types
101// =============================================================================
102
103// Domain layer exports
104pub use domain::{entities, entities::Event, repositories};
105
106// Application layer exports
107pub use application::{
108 dto::{IngestEventRequest, QueryEventsRequest},
109 services::{
110 AnalyticsEngine, Pipeline, PipelineConfig, PipelineManager, ProjectionManager,
111 ReplayManager, SchemaRegistry, TenantManager,
112 },
113};
114
115// Infrastructure layer exports
116pub use infrastructure::{
117 persistence::{
118 CompactionConfig, CompactionManager, EventIndex, ParquetStorage, SnapshotConfig,
119 SnapshotManager, WALConfig, WriteAheadLog,
120 },
121 security::{AuthManager, Permission, RateLimiter, Role},
122 web::{WebSocketManager, serve},
123};
124
125// Error handling
126pub use error::{AllSourceError, Result};
127
128// =============================================================================
129// Backward-Compatible Aliases (for binaries and external users)
130// =============================================================================
131
132/// Auth module re-export for backward compatibility
133pub mod auth {
134 pub use crate::infrastructure::security::{AuthManager, Permission, Role};
135}
136
137/// Rate limiting module re-export
138pub mod rate_limit {
139 pub use crate::infrastructure::security::rate_limit::{RateLimitConfig, RateLimiter};
140}
141
142/// Tenant module re-export
143pub mod tenant {
144 pub use crate::{
145 application::services::tenant_service::{TenantManager, TenantQuotas},
146 domain::entities::Tenant,
147 };
148}
149
150/// Config module re-export
151pub mod config {
152 pub use crate::infrastructure::config::*;
153}
154
155/// Backup module re-export
156pub mod backup {
157 pub use crate::infrastructure::persistence::backup::*;
158}
159
160/// API v1 module re-export
161pub mod api_v1 {
162 pub use crate::infrastructure::web::api_v1::{AppState, AtomicNodeRole, NodeRole, serve_v1};
163}
164
165/// Replication module re-export
166pub mod replication {
167 pub use crate::infrastructure::replication::{
168 FollowerReplicationStatus, ReplicationMode, ReplicationStatus, WalReceiver, WalShipper,
169 };
170}
171
172// Main store facade
173pub use store::EventStore;
174
175// =============================================================================
176// Tests
177// =============================================================================
178
179#[cfg(test)]
180mod security_integration_tests;