Function htlc_accepted_hook_deserialize

lightningd/peer_htlcs.c:1016–1192

* Callback when a plugin answers to the htlc_accepted hook */

 * Callback when a plugin answers to the htlc_accepted hook
 */
static bool htlc_accepted_hook_deserialize(struct htlc_accepted_hook_payload *request,
					   const char *buffer,
					   const jsmntok_t *toks)
{
	struct route_step *rs = request->route_step;
	struct htlc_in *hin = request->hin;
	struct lightningd *ld = request->ld;
	struct preimage payment_preimage;
	const jsmntok_t *resulttok, *paykeytok, *payloadtok, *fwdtok, *extra_tlvs_tok,
		*invmsattok;
	u8 *failonion, *raw_tlvs;

	if (!toks || !buffer)
		return true;

	resulttok = json_get_member(buffer, toks, "result");

	/* If the result is "continue" we can just return NULL since
	 * this is the default behavior for this hook anyway */
	if (!resulttok) {
		fatal("Plugin return value does not contain 'result' key %s",
		      json_strdup(tmpctx, buffer, toks));
	}

	invmsattok = json_get_member(buffer, toks, "invoice_msat");
	if (invmsattok) {
		tal_free(request->invoice_msat);
		request->invoice_msat = tal(request, struct amount_msat);
		if (!json_to_msat(buffer, invmsattok, request->invoice_msat)) {
			fatal("Bad invoice_msat for htlc_accepted hook: %.*s",
				invmsattok->end - invmsattok->start,
				buffer + invmsattok->start);
		}
	}

	extra_tlvs_tok = json_get_member(buffer, toks, "extra_tlvs");
	if (extra_tlvs_tok) {
		size_t max;
		struct tlv_update_add_htlc_tlvs *check_extra_tlvs;

		raw_tlvs = json_tok_bin_from_hex(tmpctx, buffer,
						 extra_tlvs_tok);
		if (!raw_tlvs)
			fatal("Bad custom tlvs for htlc_accepted"
			      " hook: %.*s",
			      extra_tlvs_tok->end - extra_tlvs_tok->start,
			      buffer + extra_tlvs_tok->start);

		max = tal_bytelen(raw_tlvs);

         	/* We check if the custom tlvs are still valid BOLT#1 tlvs.
          	 * As these are appended to forwarded htlcs we check for valid
            	 * update_add_htlc_tlvs (restricts to known even types).
              	 * NOTE: We may be less strict and allow unknown evens .*/
                const u8 *cursor = raw_tlvs;
		check_extra_tlvs = fromwire_tlv_update_add_htlc_tlvs(tmpctx,
								     &cursor,
								     &max);