//! Dialogica: AI legal assistant for law firms
//! Role:     AI Engineer · Santa Monica, CA
//! Dates:    Mar 2026 – Sep 2026
//! Stack:    Rust (Axum) · Python (LangGraph) · SolidJS · MCP · SSE · OAuth 2.0
//!
//! Shipped to production with pilot users at real law firms.
//! Tip: open `architecture/dialogica.flow` to watch this system run.

use crate::{agent::LangGraphRuntime, sse::EventStream, tools::McpTool};

/// Human-in-the-loop approval system (Rust + SolidJS).
/// Every AI action that touches the outside world stops here first.
pub struct ApprovalGate {
    pub gated: [ActionKind; 3], // Email, Document, Calendar
}

pub enum Decision {
    Approved { edited_args: Option<serde_json::Value> },
    Rejected { reason: String },
}

impl ApprovalGate {
    /// The agent pauses, the attorney sees exactly what will happen,
    /// and nothing is sent, filed, or booked without a human "yes".
    pub async fn review(&self, call: &ToolCall, ui: &EventStream) -> Decision {
        ui.emit(Event::ApprovalRequired(call.preview())).await;
        ui.wait_for_decision(call.id).await
    }
}

/// Tool-provider registry: one interface over 150+ MCP tools,
/// shared by the Rust backend and the Python LangGraph runtime.
pub struct ToolRegistry {
    providers: Vec<Box<dyn ToolProvider>>, // iManage, SharePoint, Email, Calendar, ...
}

impl ToolRegistry {
    pub fn tool_count(&self) -> usize { 150 /* and growing */ }

    /// As integrations grew, every provider kept the same schema
    /// and the same error shape, so the agent never had to guess.
    pub fn register<P: ToolProvider + 'static>(&mut self, provider: P) {
        provider.schemas().iter().for_each(validate_schema);
        self.providers.push(Box::new(provider));
    }
}

/// Reconnect-safe SSE streaming with pause/resume.
/// Approvals and tool results survive dropped connections:
/// the client reconnects with `Last-Event-ID` and the server replays.
pub async fn stream(run: RunId, last_event_id: Option<u64>) -> EventStream {
    let buffered = replay_since(run, last_event_id).await;
    EventStream::resume(run, buffered)
}

/// Document management integrations over OAuth 2.0.
pub mod integrations {
    pub const IMANAGE_DMS: &str = "iManage DMS";
    pub const SHAREPOINT: &str = "SharePoint (Microsoft 365)";
    /// Cleared a 71-finding security audit against a Microsoft 365 tenant.
    pub const AUDIT_FINDINGS_CLEARED: u32 = 71;
}

/// Hardening the LangGraph runtime for pilot use.
pub struct RuntimeGuards {
    pub argument_validation: bool,  // reject malformed tool args before execution
    pub tool_result_truncation: bool, // keep huge results from blowing the context window
    pub error_recovery: bool,       // retry or explain instead of crashing the run
}

/// Observability: LangGraph runs traced in LangSmith.
/// Tool-call and token traces surfaced failures before pilot users hit them.
pub fn observe(run: &LangGraphRuntime) {
    run.trace_to("langsmith").with_tool_calls().with_token_usage();
}
Darshan Vaghasiya

Start

Experience

Highlights

On GitHub
