Function encode

chirpstack/src/codec/js/mod.rs:99–179

(
    f_port: u8,
    variables: &HashMap<String, String>,
    encode_config: &str,
    s: &prost_types::Struct,
)

}

pub async fn encode(
    f_port: u8,
    variables: &HashMap<String, String>,
    encode_config: &str,
    s: &prost_types::Struct,
) -> Result<(u8, Vec<u8>)> {
    let conf = config::get();
    let max_run_ts = SystemTime::now() + conf.codec.js.max_execution_time;

    let resolver = rquickjs::loader::BuiltinResolver::default()
        .with_module("base64-js")
        .with_module("ieee754")
        .with_module("buffer");
    let loader = rquickjs::loader::BuiltinLoader::default()
        .with_module("base64-js", vendor_base64_js::SCRIPT)
        .with_module("ieee754", vendor_ieee754::SCRIPT)
        .with_module("buffer", vendor_buffer::SCRIPT);

    let rt = rquickjs::Runtime::new()?;
    rt.set_interrupt_handler(Some(Box::new(move || SystemTime::now() > max_run_ts)));
    rt.set_loader(resolver, loader);

    let ctx = rquickjs::Context::full(&rt)?;

    let script = format!(
        r#"
        import {{ Buffer }} from "buffer";

        {}

        export default encodeDownlink(chirpstack_input);
        "#,
        encode_config,
    );

    ctx.with(|ctx| {
        let input = rquickjs::Object::new(ctx.clone())?;
        input.set("variables", variables.into_js(&ctx)?)?;
        input.set("data", convert::struct_to_rquickjs(&ctx, s))?;
        ctx.globals().set("chirpstack_input", input)?;

        let module = rquickjs::Module::declare(ctx.clone(), "main", script)
            .catch(&ctx)
            .map_err(|e| anyhow!("JS error: {}", e))?;

        let (module, promise) = module
            .eval()
            .catch(&ctx)
            .map_err(|e| anyhow!("JS error: {}", e))?;
        () = promise
            .finish()
            .catch(&ctx)
            .map_err(|e| anyhow!("JS error: {}", e))?;

        let res: rquickjs::Object = module
            .get("default")
            .catch(&ctx)
            .map_err(|e| anyhow!("JS error: {}", e))?;