Function load_currencyrates

plugins/bkpr/bookkeeper.c:1950–2006

}

static void load_currencyrates(struct command *cmd,
			       struct bkpr *bkpr)
{
	struct json_out *params;
	const jsmntok_t *reply, *ds, *t;
	const char *buf;
	size_t i;

	params = json_out_new(NULL);
	json_out_start(params, NULL, '{');
	json_out_start(params, "key", '[');
	json_out_addstr(params, NULL, "bookkeeper");
	json_out_addstr(params, NULL, "currencyrate");
	json_out_addstr(params, NULL, bkpr->currency->name);
	json_out_end(params, ']');
	json_out_end(params, '}');
	json_out_finished(params);

	reply = jsonrpc_request_sync(tmpctx, cmd, "listdatastore",
				     take(params), &buf);
	ds = json_get_member(buf, reply, "datastore");
	json_for_each_arr(i, t, ds) {
		const jsmntok_t *data, *keytok = json_get_member(buf, t, "key");
		jsmntok_t ratetok, durationtok;
		u64 ts;
		struct currencyrate *crate;

		if (keytok->size != 4)
			goto weird;

		/* key = ["bookkeeper", "currencyrate", "USD", "timestamp"] */
		if (!json_to_u64(buf, keytok + 4, &ts))
			goto weird;

		data = json_get_member(buf, t, "string");
		if (!data)
			goto weird;

		if (!split_tok(buf, data, ':', &ratetok, &durationtok))
			goto weird;
		crate = tal(bkpr->currency_rates, struct currencyrate);
		if (!json_to_u64(buf, &ratetok, &crate->raw_rate)
		    || !json_to_u32(buf, &durationtok, &crate->duration)) {
			tal_free(crate);
			goto weird;
		}

		uintmap_add(bkpr->currency_rates, ts, crate);
		continue;

	weird:
		plugin_log(cmd->plugin, LOG_BROKEN,
			   "Unexpected datastore rate entry '%.*s'",
			   json_tok_full_len(t),
			   json_tok_full(buf, t));
	}
}