Function on_htlc_accepted

plugins/lsps-plugin/src/client.rs:543–659

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

}

async fn on_htlc_accepted(
    p: cln_plugin::Plugin<State>,
    v: serde_json::Value,
) -> Result<serde_json::Value, anyhow::Error> {
    let req: HtlcAcceptedRequest = ok_or_continue!(
        serde_json::from_value(v).context("failed to deserialize htlc_accepted request JSON")
    );

    let htlc_amt = req.htlc.amount_msat;
    let onion_amt = some_or_continue!(
        req.onion.forward_msat,
        "missing forward_msat in onion, continue"
    );

    let payment_data = some_or_continue!(
        req.onion.payload.get(TLV_PAYMENT_SECRET),
        "htlc is a forward, continue"
    );

    // Check that the htlc belongs to a jit-channel request.
    let dir = p.configuration().lightning_dir;
    let rpc_path = Path::new(&dir).join(&p.configuration().rpc_file);
    let mut cln_client = ok_or_continue!(
        cln_rpc::ClnRpc::new(rpc_path.clone())
            .await
            .context("failed to connect to core-lightning")
    );

    let lsp_data = ok_or_continue!(
        cln_client
            .call_typed(&ListdatastoreRequest {
                key: Some(vec![
                    "lsps".to_string(),
                    "invoice".to_string(),
                    hex::encode(&req.htlc.payment_hash),
                ]),
            })
            .await
            .context("failed to fetch datastore record")
    );

    // If we don't know about this payment it's not an LSP payment, continue.
    some_or_continue!(lsp_data.datastore.first());

    let extra_fee_msat = req
        .htlc
        .extra_tlvs
        .as_ref()
        .map(|tlvs| tlvs.get_u64(65537))
        .transpose()?
        .flatten()
        .unwrap_or_default();

    debug!(
        "incoming jit-channel htlc with htlc_amt={}, onion_amt={} and extra_fee={}",
        htlc_amt.msat(),
        onion_amt.msat(),
        extra_fee_msat