Function setup_backup_map

plugins/chanbackup.c:1064–1113

}

static void setup_backup_map(struct command *init_cmd,
			     struct chanbackup *cb)
{
	struct json_out *params = json_out_new(init_cmd);
	const jsmntok_t *result;
	const char *buf;
	const jsmntok_t *datastore, *t;
	size_t i, total = 0;

	cb->backups = new_htable(cb, backup_map);
	cb->peers = new_htable(cb, peer_map);

	json_out_start(params, NULL, '{');
	json_out_start(params, "key", '[');
	json_out_addstr(params, NULL, "chanbackup");
	json_out_addstr(params, NULL, "peers");
	json_out_end(params, ']');
	json_out_end(params, '}');

	result = jsonrpc_request_sync(tmpctx, init_cmd,
				      "listdatastore",
				      take(params), &buf);

	datastore = json_get_member(buf, result, "datastore");
	json_for_each_arr(i, t, datastore) {
		const jsmntok_t *keytok, *hextok;
		struct node_id peer;
		u8 *data;

		/* Key is an array, first two elements are chanbackup, peers */
		keytok = json_get_member(buf, t, "key") + 3;
		hextok = json_get_member(buf, t, "hex");
		/* In case someone creates a subdir? */
		if (!hextok)
			continue;
		if (!json_to_node_id(buf, keytok, &peer))
			plugin_err(init_cmd->plugin,
				   "Could not parse datastore id '%.*s'",
				   json_tok_full_len(keytok),
				   json_tok_full(buf, keytok));
		data = json_tok_bin_from_hex(NULL, buf, hextok);
		/* Only count non-empty ones. */
		if (tal_bytelen(data) != 0)
			total++;
		add_to_backup_map(cb, &peer, take(data));
	}
	if (total)
		plugin_log(init_cmd->plugin, LOG_INFORM,
			   "Loaded %zu stored backups for peers", total);
}

static const char *init(struct command *init_cmd,
			const char *buf UNUSED,