Function on_invoice_payment

plugins/lsps-plugin/src/client.rs:510–541

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

}

async fn on_invoice_payment(
    p: cln_plugin::Plugin<State>,
    v: serde_json::Value,
) -> Result<serde_json::Value, anyhow::Error> {
    let req: InvoicePaymentRequest = ok_or_continue!(
        serde_json::from_value(v).context("failed to deserialize htlc_accepted request JSON")
    );
    let preimage = ok_or_continue!(
        <[u8; 32]>::from_hex(&req.payment.preimage).context("invalid preimage hex")
    );
    let hash = payment_hash(&preimage);

    // Delete DS-entries.
    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")
    );
    ok_or_continue!(
        cln_client
            .call_typed(&DeldatastoreRequest {
                key: vec!["lsps".to_string(), "invoice".to_string(), hash.to_string()],
                generation: None,
            })
            .await
            .context("failed to delete datastore record")
    );

    Ok(serde_json::json!({"result": "continue"}))
}

async fn on_htlc_accepted(
    p: cln_plugin::Plugin<State>,