Method handle

chirpstack/src/adr/plugin.rs:71–146

(&self, req: &Request)

    }

    async fn handle(&self, req: &Request) -> Result<Response> {
        let rt = rquickjs::Runtime::new()?;
        let ctx = rquickjs::Context::full(&rt)?;

        ctx.with::<_, Result<Response>>(|ctx| {
            let m = rquickjs::Module::declare(ctx.clone(), "script", self.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!("Eval script: JS error: {}", e))?;
            () = m_promise.finish()?;
            let func: rquickjs::Function = m
                .get("handle")
                .catch(&ctx)
                .map_err(|e| anyhow!("Get handle function: JS error: {}", e))?;

            let device_variables = rquickjs::Object::new(ctx.clone())?;
            for (k, v) in &req.device_variables {
                device_variables.set(k, v)?;
            }

            let input = rquickjs::Object::new(ctx.clone())?;
            input.set("regionConfigId", req.region_config_id.clone())?;
            input.set("regionCommonName", req.region_common_name.to_string())?;
            input.set("devEui", req.dev_eui.to_string())?;
            input.set("macVersion", req.mac_version.to_string())?;
            input.set("regParamsRevision", req.reg_params_revision.to_string())?;
            input.set("adr", req.adr)?;
            input.set("dr", req.dr)?;
            input.set("txPowerIndex", req.tx_power_index)?;
            input.set("nbTrans", req.nb_trans)?;
            input.set("maxTxPowerIndex", req.max_tx_power_index)?;
            input.set("requiredSnrForDr", req.required_snr_for_dr)?;
            input.set("installationMargin", req.installation_margin)?;
            input.set("minDr", req.min_dr)?;
            input.set("maxDr", req.max_dr)?;
            input.set("skipFCntCheck", req.skip_f_cnt_check)?;
            input.set("deviceVariables", device_variables)?;

            let mut uplink_history: Vec<rquickjs::Object> = Vec::new();

            for uh in &req.uplink_history {
                let obj = rquickjs::Object::new(ctx.clone())?;
                obj.set("fCnt", uh.f_cnt)?;
                obj.set("maxSnr", uh.max_snr)?;
                obj.set("maxRssi", uh.max_rssi)?;
                obj.set("txPowerIndex", uh.tx_power_index)?;
                obj.set("gatewayCount", uh.gateway_count)?;
                uplink_history.push(obj);
            }

            input.set("uplinkHistory", uplink_history)?;

            let res: rquickjs::Object = func
                .call((input,))
                .catch(&ctx)