fdev 0.3.211

Freenet development tool
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

use freenet_stdlib::client_api::ClientRequest;

use crate::CommandReceiver;

use super::{ExecutorConfig, state::AppState};

pub(super) async fn wasm_runtime(
    _config: ExecutorConfig,
    mut command_receiver: CommandReceiver,
    mut app: AppState,
) -> anyhow::Result<()> {
    loop {
        let req = command_receiver.recv().await;
        let dc = execute_command(
            req.ok_or_else(|| anyhow::anyhow!("channel closed"))?,
            &mut app,
        )
        .await?;
        if dc {
            break;
        }
    }
    Ok(())
}

async fn execute_command(req: ClientRequest<'static>, app: &mut AppState) -> anyhow::Result<bool> {
    let node = &mut *app.local_node.lock().await;
    match req {
        ClientRequest::ContractOp(_) => {
            node.send(req).await?;
            Ok(false)
        }
        _ => {
            tracing::error!("op not supported");
            anyhow::bail!("op not support");
        }
    }
}