Function handle_your_peer_storage

plugins/chanbackup.c:860–952

}

static struct command_result *handle_your_peer_storage(struct command *cmd,
						       const char *buf,
						       const jsmntok_t *params)
{
        struct node_id node_id;
        u8 *payload, *payload_deserialise;
	const char *err;
	struct chanbackup *cb = chanbackup(cmd->plugin);

	err = json_scan(cmd, buf, params,
			"{payload:%,peer_id:%}",
			JSON_SCAN_TAL(cmd, json_tok_bin_from_hex, &payload),
			JSON_SCAN(json_to_node_id, &node_id));
	if (err) {
		plugin_err(cmd->plugin,
			   "`your_peer_storage` response did not scan %s: %.*s",
			   err, json_tok_full_len(params),
			   json_tok_full(buf, params));
	}

	if (fromwire_peer_storage(cmd, payload, &payload_deserialise)) {
		struct peer_backup *pb;

		if (!cb->handle_their_peer_backup)
			return command_hook_success(cmd);

		/* BOLT #1:
		 * The receiver of `peer_storage`:
		 *   - If it offered `option_provide_storage`:
		 *    - if it has an open channel with the sender:
		 *      - MUST store the message.
		 *    - MAY store the message anyway.
		 */
		/* We store if we have a datastore slot for it
		 * (otherwise, this fails).  We create those once it
		 * has a channel, though the user could also create an
		 * empty one if they wanted to */

		/* BOLT #1:
		 * - If it does store the message:
		 *   - MAY delay storage to ratelimit peer to no more than one
		 *     update per minute.
		 *   - MUST replace the old `blob` with the latest received.
		 */
		pb = backup_map_get(cb->backups, &node_id);
		if (!pb)
			return command_hook_success(cmd);

		tal_free(pb->data);
		pb->data = tal_steal(pb, payload_deserialise);
		return commit_peer_backup(cmd, pb);
	} else if (fromwire_peer_storage_retrieval(cmd, payload, &payload_deserialise)) {
		crypto_secretstream_xchacha20poly1305_state crypto_state;

		plugin_log(cmd->plugin, LOG_DBG,
                           "Received peer_storage from peer.");

		if (!cb->send_our_peer_backup)