Function htlc_accepted_hook_deserialize

lightningd/peer_htlcs.c:898–1029

* 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;
	u8 *payload, *failonion;

	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));
	}

	payloadtok = json_get_member(buffer, toks, "payload");
	if (payloadtok) {
		payload = json_tok_bin_from_hex(rs, buffer, payloadtok);
		if (!payload)
			fatal("Bad payload for htlc_accepted"
			      " hook: %.*s",
			      payloadtok->end - payloadtok->start,
			      buffer + payloadtok->start);
		tal_free(request->payload);
		tal_free(rs->raw_payload);

		rs->raw_payload = prepend_length(rs, take(payload));
		request->payload = onion_decode(request, rs,
						hin->blinding, &hin->blinding_ss,
						ld->accept_extra_tlv_types,
						&request->failtlvtype,
						&request->failtlvpos);
	} else
		payload = NULL;

	fwdtok = json_get_member(buffer, toks, "forward_to");
	if (fwdtok) {
		tal_free(request->fwd_channel_id);
		request->fwd_channel_id = tal(request, struct channel_id);
		if (!json_to_channel_id(buffer, fwdtok,
					request->fwd_channel_id)) {
			fatal("Bad forward_to for htlc_accepted"
			      " hook: %.*s",
			      fwdtok->end - fwdtok->start,
			      buffer + fwdtok->start);
		}
	}

	if (json_tok_streq(buffer, resulttok, "continue")) {
		return true;