Method new

chirpstack/src/adr/plugin.rs:17–58

(file_path: &str)

impl Plugin {
    pub fn new(file_path: &str) -> Result<Self> {
        let rt = rquickjs::Runtime::new()?;
        let ctx = rquickjs::Context::full(&rt)?;
        let script = fs::read_to_string(file_path).context("Read ADR plugin")?;

        let (id, name) = ctx.with::<_, Result<(String, String)>>(|ctx| {
            let m = rquickjs::Module::declare(ctx.clone(), "script", script.clone())
                .catch(&ctx)
                .map_err(|e| anyhow!("Declare script: JS error: {}", e))?;
            let (m, m_promise) = m
                .eval()
                .catch(&ctx)
                .map_err(|e| anyhow!("Evaluate script: JS error: {}", e))?;
            () = m_promise
                .finish()
                .catch(&ctx)
                .map_err(|e| anyhow!("Evaluate script: JS error: {}", e))?;
            let id_func: rquickjs::Function = m
                .get("id")
                .catch(&ctx)
                .map_err(|e| anyhow!("Get id function: JS error: {}", e))?;
            let name_func: rquickjs::Function = m
                .get("name")
                .catch(&ctx)
                .map_err(|e| anyhow!("Get name function: JS error: {}", e))?;

            let id: String = id_func
                .call(())
                .catch(&ctx)
                .map_err(|e| anyhow!("Call id function: JS error: {}", e))?;
            let name: String = name_func
                .call(())
                .catch(&ctx)
                .map_err(|e| anyhow!("Call name function: JS error: {}", e))?;

            Ok((id, name))
        })?;

        let p = Plugin { script, id, name };

        Ok(p)
    }
}

#[async_trait]