zebflow 0.8.3

Reactive web automation platform — pipelines, templates, and real-time collaboration in a single binary.
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

//! Zebflow platform module.
//!
//! Responsibility:
//!
//! - compose swappable adapters (data + file)
//! - provide service layer for auth/user/project
//! - expose Axum router for platform flow:
//!   `login -> home(project list) -> project page`

pub mod adapters;
pub mod catalog;
pub mod db;
pub mod error;
pub mod help;
pub mod interaction;
pub mod mcp;
pub mod model;
pub mod operations;
pub mod policy;
pub mod sekejap;
pub mod services;
pub mod shell;
pub mod sqlite_schema;
pub mod web;

use std::sync::Arc;

use axum::Router;

pub use error::PlatformError;
pub use model::{
    AuthSession, CreateProjectRequest, CreateUserRequest, DataAdapterKind, ExecutePipelineRequest,
    FileAdapterKind, LoginRequest, PipelineExecuteTrigger, PipelineLocateRequest, PipelineMeta,
    PipelineRegistryListing, PlatformConfig, PlatformProject, PlatformUser, ProjectAccessSubject,
    ProjectCapability, ProjectFileLayout, UpsertPipelineDefinitionRequest,
};
pub use services::{
    AssistantConfigService, AuthService, AuthorizationService, PlatformService, ProjectService,
    UserService,
};

/// Builds platform router + service graph from config.
pub async fn build_router(config: PlatformConfig) -> Result<Router, PlatformError> {
    let platform = Arc::new(PlatformService::from_config(config)?);
    Ok(web::router(platform).await)
}