Function onion_message_recv

plugins/offers.c:268–331

}

static struct command_result *onion_message_recv(struct command *cmd,
						 const char *buf,
						 const jsmntok_t *params)
{
	const jsmntok_t *om, *secrettok, *replytok, *invreqtok, *invtok;
	struct blinded_path *reply_path = NULL;
 	struct secret *secret;

	om = json_get_member(buf, params, "onion_message");
	secrettok = json_get_member(buf, om, "pathsecret");
	if (secrettok) {
		secret = tal(tmpctx, struct secret);
		json_to_secret(buf, secrettok, secret);
	} else
		secret = NULL;

	/* Might be reply for fetchinvoice (which always has a secret,
	 * so we can tell it's a response). */
	if (secret) {
		struct command_result *res;
		res = handle_invoice_onion_message(cmd, buf, om, secret);
		if (res)
			return res;
	}

	/* BOLT #4:
	 * - otherwise (it is the final node):
	 *   - if `path_id` is set and corresponds to a path the reader has previously published in a `reply_path`:
	 *     - if the onion message is not a reply to that previous onion:
	 *       - MUST ignore the onion message
	 *   - otherwise (unknown or unset `path_id`):
	 *     - if the onion message is a reply to an onion message which contained a `path_id`:
	 *       - MUST respond (or not respond) exactly as if it did not send the initial onion message.
	 */
	/* FIXME: Technically, we don't meet the first half of this: we
	 * always do parsing and sanity checking before checking the
	 * secret (thus the path_id).  But we ignore it *after* that.
	 */
	replytok = json_get_member(buf, om, "reply_blindedpath");
	if (replytok) {
		reply_path = json_to_blinded_path(cmd, buf, replytok);
		if (!reply_path)
			plugin_err(cmd->plugin, "Invalid reply path %.*s?",
				   json_tok_full_len(replytok),
				   json_tok_full(buf, replytok));
	}

	invreqtok = json_get_member(buf, om, "invoice_request");
	if (invreqtok) {
		const u8 *invreqbin = json_tok_bin_from_hex(tmpctx, buf, invreqtok);
		return handle_invoice_request(cmd,
					      invreqbin,
					      reply_path, secret);
	}

	invtok = json_get_member(buf, om, "invoice");
	if (invtok) {
		const u8 *invbin = json_tok_bin_from_hex(tmpctx, buf, invtok);