Gabriel Kaszewski
f652785acb
All checks were successful
CI / ci (push) Successful in 7m16s
Restructure the monolithic 252-line main.rs into a 10-crate workspace with clean hexagonal architecture, swappable adapters, and a production- ready deployment pipeline. Backend architecture: - domain: Canvas, Color/Position/PixelUpdate value objects, port traits (CanvasStore, CanvasPersistence, EventBroadcaster), BroadcastEvent - application: use cases (place_pixel, get_state, save/restore snapshot, connect/disconnect), AppState with Arc snapshot cache - config: AppConfig structs + ConfigSource trait - api-types: shared DTOs, event name constants - adapters: config-env, canvas-file, http-axum (rust-embed), socketio, websocket — all behind port traits, swappable via feature flags - server: composition root with graceful shutdown (SIGTERM/SIGINT) Frontend: - Transport abstraction: Socket.IO and native WebSocket via VITE_TRANSPORT - Canvas zoom/pan with mouse wheel, pinch-to-zoom, and +/- buttons - ImageData rendering (~50x faster than fillRect loop) - Touch support, responsive CSS scaling, mobile-friendly layout - OG/Twitter Card meta tags for rich link previews Production: - Docker: musl static build on scratch — 2.73MB image - CI workflows for Gitea and GitHub Actions (fmt, clippy, test, Docker push) - deploy.sh for private registry - 39 unit tests across domain and application - Zero unwraps, zero unsafe, graceful error handling with tracing - Periodic canvas snapshots with rotation, restored on startup - All config via environment variables with typed defaults
110 lines
2.7 KiB
Rust
110 lines
2.7 KiB
Rust
use std::future::Future;
|
|
use std::pin::Pin;
|
|
use std::sync::{Arc, Mutex};
|
|
use std::time::Duration;
|
|
|
|
use application::{AppState, InMemoryCanvasStore};
|
|
use domain::ports::{
|
|
BroadcastReceiverInner, BroadcastSubscription, CanvasPersistence, EventBroadcaster,
|
|
};
|
|
use domain::{BroadcastEvent, Color, DomainError};
|
|
|
|
#[derive(Clone)]
|
|
pub struct SpyBroadcaster {
|
|
events: Arc<Mutex<Vec<BroadcastEvent>>>,
|
|
}
|
|
|
|
impl SpyBroadcaster {
|
|
pub fn new() -> Self {
|
|
Self {
|
|
events: Arc::new(Mutex::new(Vec::new())),
|
|
}
|
|
}
|
|
|
|
pub fn events(&self) -> Vec<BroadcastEvent> {
|
|
self.events.lock().unwrap().clone()
|
|
}
|
|
|
|
pub fn event_count(&self) -> usize {
|
|
self.events.lock().unwrap().len()
|
|
}
|
|
}
|
|
|
|
impl EventBroadcaster for SpyBroadcaster {
|
|
fn publish(&self, event: BroadcastEvent) {
|
|
self.events.lock().unwrap().push(event);
|
|
}
|
|
|
|
fn subscribe(&self) -> BroadcastSubscription {
|
|
BroadcastSubscription::new(Box::new(NoopReceiver))
|
|
}
|
|
}
|
|
|
|
struct NoopReceiver;
|
|
|
|
impl BroadcastReceiverInner for NoopReceiver {
|
|
fn recv_boxed(&mut self) -> Pin<Box<dyn Future<Output = Option<BroadcastEvent>> + Send + '_>> {
|
|
Box::pin(async { None })
|
|
}
|
|
}
|
|
|
|
pub struct FakePersistence {
|
|
saved: Arc<Mutex<Vec<Vec<Color>>>>,
|
|
to_load: Mutex<Option<Vec<Color>>>,
|
|
}
|
|
|
|
impl FakePersistence {
|
|
pub fn empty() -> Self {
|
|
Self {
|
|
saved: Arc::new(Mutex::new(Vec::new())),
|
|
to_load: Mutex::new(None),
|
|
}
|
|
}
|
|
|
|
pub fn with_snapshot(pixels: Vec<Color>) -> Self {
|
|
Self {
|
|
saved: Arc::new(Mutex::new(Vec::new())),
|
|
to_load: Mutex::new(Some(pixels)),
|
|
}
|
|
}
|
|
|
|
pub fn saved_ref(&self) -> Arc<Mutex<Vec<Vec<Color>>>> {
|
|
self.saved.clone()
|
|
}
|
|
}
|
|
|
|
impl CanvasPersistence for FakePersistence {
|
|
fn save(&self, pixels: &[Color]) -> Result<(), DomainError> {
|
|
self.saved.lock().unwrap().push(pixels.to_vec());
|
|
Ok(())
|
|
}
|
|
|
|
fn load_latest(&self) -> Result<Option<Vec<Color>>, DomainError> {
|
|
Ok(self.to_load.lock().unwrap().clone())
|
|
}
|
|
}
|
|
|
|
pub fn test_state() -> (Arc<AppState>, SpyBroadcaster) {
|
|
test_state_sized(10, 10)
|
|
}
|
|
|
|
pub fn test_state_sized(width: u32, height: u32) -> (Arc<AppState>, SpyBroadcaster) {
|
|
let spy = SpyBroadcaster::new();
|
|
let state = AppState::new(
|
|
Box::new(InMemoryCanvasStore::new(width, height)),
|
|
Box::new(spy.clone()),
|
|
Duration::from_secs(10),
|
|
);
|
|
(Arc::new(state), spy)
|
|
}
|
|
|
|
pub fn test_state_no_cooldown() -> (Arc<AppState>, SpyBroadcaster) {
|
|
let spy = SpyBroadcaster::new();
|
|
let state = AppState::new(
|
|
Box::new(InMemoryCanvasStore::new(10, 10)),
|
|
Box::new(spy.clone()),
|
|
Duration::ZERO,
|
|
);
|
|
(Arc::new(state), spy)
|
|
}
|