Function process_batch_elements

connectd/multiplex.c:376–431

Process and eat protocol_batch_element messages, encrypt each element message * and return the encrypted messages as one long byte array. */

/* Process and eat protocol_batch_element messages, encrypt each element message
 * and return the encrypted messages as one long byte array. */
static u8 *process_batch_elements(const tal_t *ctx, struct peer *peer, const u8 *msg TAKES)
{
	u8 *ret = tal_arr(ctx, u8, 0);
	const u8 *cursor = msg;
	size_t plen = tal_count(msg);

	status_debug("Processing batch elements of %zu bytes. %s", plen,
		     tal_hex(tmpctx, msg));

	do {
		u8 *element_bytes;
		u16 element_size;
		struct channel_id channel_id;
		u8 *enc_msg;

		if (fromwire_u16(&cursor, &plen) != WIRE_PROTOCOL_BATCH_ELEMENT) {
			status_broken("process_batch_elements on msg that is"
				      " not WIRE_PROTOCOL_BATCH_ELEMENT. %s",
				      tal_hexstr(tmpctx, cursor, plen));
			return tal_free(ret);
		}

		fromwire_channel_id(&cursor, &plen, &channel_id);

	 	element_size = fromwire_u16(&cursor, &plen);
	 	if (!element_size) {
			status_broken("process_batch_elements cannot have zero"
				      " length elements. %s",
				      tal_hexstr(tmpctx, cursor, plen));
			return tal_free(ret);
	 	}

		element_bytes = fromwire_tal_arrn(NULL, &cursor, &plen,
						  element_size);
		if (!element_bytes) {
			status_broken("process_batch_elements fromwire_tal_arrn"
				      " %s",
				      tal_hexstr(tmpctx, cursor, plen));
			return tal_free(ret);
		}

		status_debug("Processing batch extracted item %s. %s",
			     peer_wire_name(fromwire_peektype(element_bytes)),
			     tal_hex(tmpctx, element_bytes));

		enc_msg = cryptomsg_encrypt_msg(tmpctx, &peer->cs,
						take(element_bytes));

		tal_arr_append(&ret, enc_msg);

	} while(plen);

	tal_free_if_taken(msg);

	return ret;
}

/* --dev-disconnect can do magic things: if this returns non-NULL,