Function read_sync_rpc_reply

plugins/libplugin.c:735–770

Reads rpc reply and returns result tokens */

/* Reads rpc reply and returns result tokens */
static const jsmntok_t *read_sync_rpc_reply(const tal_t *ctx,
					    struct plugin *plugin,
					    const char *method,
					    const char **final_buffer)
{
	const jsmntok_t *errtok, *resulttok, *toks;
	const char *buffer;

	for (;;) {
		buffer = read_one_json_sync(plugin, &toks);
		/* FIXME: Don't simply ignore notifications here! */
		if (json_get_member(buffer, toks, "id"))
			break;
		jsonrpc_io_parse_done(plugin->sync_io);
	}

	errtok = json_get_member(buffer, toks, "error");
	if (errtok) {
		plugin_err(plugin, "Got error result to %s: '%.*s'",
			   method,
			   json_tok_full_len(toks),
			   json_tok_full(buffer, toks));
	}
	resulttok = json_get_member(buffer, toks, "result");
	if (!resulttok) {
		plugin_err(plugin, "JSON reply with no 'result' nor 'error'? '%.*s'",
			   json_tok_full_len(toks),
			   json_tok_full(buffer, toks));
	}

	/* Make the returned pointers valid tal object */
	json_dup_contents(ctx, buffer, resulttok, final_buffer, &toks);
	jsonrpc_io_parse_done(plugin->sync_io);

	return toks;
}

/* Send request, return response, set resp/len to reponse */
static const jsmntok_t *sync_req(const tal_t *ctx,