Function handle_htlc_inner

plugins/lsps-plugin/src/service.rs:154–201

(
    p: &Plugin<State>,
    v: serde_json::Value,
)

}

async fn handle_htlc_inner(
    p: &Plugin<State>,
    v: serde_json::Value,
) -> Result<serde_json::Value, anyhow::Error> {
    if !p.state().lsps2_enabled {
        return Ok(json_continue());
    }

    let req: HtlcAcceptedRequest = serde_json::from_value(v)?;

    let short_channel_id = match req.onion.short_channel_id {
        Some(scid) => scid,
        None => {
            trace!("We are the destination of the HTLC, continue.");
            return Ok(json_continue());
        }
    };

    let rpc_path = Path::new(&p.configuration().lightning_dir).join(&p.configuration().rpc_file);
    let api = ClnApiRpc::new(rpc_path);
    // Fixme: Use real htlc_minimum_amount.
    let handler = HtlcAcceptedHookHandler::new(api, 1000);

    let onion = Onion {
        short_channel_id,
        payload: req.onion.payload,
    };

    let htlc = Htlc {
        amount_msat: Msat::from_msat(req.htlc.amount_msat.msat()),
        extra_tlvs: req.htlc.extra_tlvs.unwrap_or_default(),
    };

    debug!("Handle potential jit-session HTLC.");
    let response = match handler.handle(&htlc, &onion).await {
        Ok(dec) => {
            log_decision(&dec);
            decision_to_response(dec)?
        }
        Err(e) => {
            // Fixme: Should we log **BROKEN** here?
            debug!("Htlc handler failed (continuing): {:#}", e);
            return Ok(json_continue());
        }
    };

    Ok(serde_json::to_value(&response)?)
}

fn decision_to_response(decision: HtlcDecision) -> Result<serde_json::Value, anyhow::Error> {
    Ok(match decision {