Rust: тонкий актор-обёртка над FFI (tokio) #7

New issue

Open

opened 2026-06-15 13:22:21 +02:00 by yorunikakeru · 0 comments

yorunikakeru commented

2026-06-15 13:22:21 +02:00

Owner

Создать Rust крейт planner-actor — тонкую tokio-обёртку над Haskell ядром.

Структура

planner-actor/
  Cargo.toml
  build.rs        -- линкует libHSplanner-core.so
  src/
    lib.rs
    ffi.rs          -- extern "C" объявления hs_plan, hs_planner_init
    actor.rs        -- PlannerActor, run loop
    messages.rs     -- PlannerMsg enum

Каналы (из spec)

pub enum PlannerMsg {
    NewConfig(Bytes),           // новый IRDocument (opaque JSON bytes)
    SystemStateUpdate(Bytes),   // новый SystemState от Watcher
}

Входящие: mpsc::Receiver<PlannerMsg>
Исходящие план: mpsc::Sender<Plan> → Executor
Store commit/rollback: mpsc::Sender<StoreMsg>

Actor loop

async fn run(mut rx: mpsc::Receiver<PlannerMsg>, ...) {
    let mut current_ir: Option<Bytes> = None;
    let mut current_state: Option<Bytes> = None;
    while let Some(msg) = rx.recv().await {
        match msg {
            NewConfig(ir) => { current_ir = Some(ir); replan(...) }
            SystemStateUpdate(s) => { current_state = Some(s); replan(...) }
        }
    }
}

Acceptance

cargo build с линкованной .so без ошибок
Актор стартует, принимает сообщения, не паникует на пустом IR

Создать Rust крейт `planner-actor` — тонкую tokio-обёртку над Haskell ядром. ## Структура ``` planner-actor/ Cargo.toml build.rs -- линкует libHSplanner-core.so src/ lib.rs ffi.rs -- extern "C" объявления hs_plan, hs_planner_init actor.rs -- PlannerActor, run loop messages.rs -- PlannerMsg enum ``` ## Каналы (из spec) ```rust pub enum PlannerMsg { NewConfig(Bytes), // новый IRDocument (opaque JSON bytes) SystemStateUpdate(Bytes), // новый SystemState от Watcher } ``` - Входящие: `mpsc::Receiver<PlannerMsg>` - Исходящие план: `mpsc::Sender<Plan>` → Executor - Store commit/rollback: `mpsc::Sender<StoreMsg>` ## Actor loop ```rust async fn run(mut rx: mpsc::Receiver<PlannerMsg>, ...) { let mut current_ir: Option<Bytes> = None; let mut current_state: Option<Bytes> = None; while let Some(msg) = rx.recv().await { match msg { NewConfig(ir) => { current_ir = Some(ir); replan(...) } SystemStateUpdate(s) => { current_state = Some(s); replan(...) } } } } ``` ## Acceptance - `cargo build` с линкованной .so без ошибок - Актор стартует, принимает сообщения, не паникует на пустом IR

yorunikakeru added the

rust

ffi

labels

2026-06-15 13:22:21 +02:00

yorunikakeru referenced this issue

2026-06-17 15:59:53 +02:00

feat(ffi): FFI boundary with Protobuf wire format (closes #6, #11) #13

yorunikakeru referenced this issue from a pull request that will close it,

2026-06-19 12:41:02 +02:00

feat(actor): add Rust FFI planner actor #15