Function jsonrpc_request_sync

plugins/bkpr/test/run-recorder.c:467–545

}

const jsmntok_t *jsonrpc_request_sync(const tal_t *ctx,
				      struct command *cmd,
				      const char *method,
				      const struct json_out *params TAKES,
				      const char **resp)
{
	sqlite3_stmt *s;
	jsmntok_t *toks;
	jsmn_parser parser;
	size_t len;
	char *buf;
	const char *p, *querystr;
	bool complete;
	int rc;

	if (streq(method, "listdatastore")) {
		buf = tal_fmt(ctx, "{\"datastore\": []}");
		goto done;
	}

	assert(streq(method, "sql"));

	/* Grab select query */
	jsmn_init(&parser);
	p = json_out_contents(params, &len);
	toks = toks_alloc(tmpctx);
	assert(json_parse_input(&parser, &toks, p, len, &complete));
	assert(complete);
	/* { "query": <querystr> } */
	querystr = json_strdup(tmpctx, p, toks + 2);

	sqlite3_prepare_v2(bkpr_db, querystr,
			   -1, &s, NULL);

	/* Make JSON-style result */
	buf = tal_fmt(ctx, "{\"rows\": [");
	while ((rc = sqlite3_step(s)) == SQLITE_ROW) {
		size_t num_cols = sqlite3_column_count(s);

		tal_append_fmt(&buf, "[");
		for (size_t i = 0; i < num_cols; i++) {
			switch (sqlite3_column_type(s, i)) {
			case SQLITE_NULL:
				tal_append_fmt(&buf, "null");
				break;
			case SQLITE_INTEGER:
				tal_append_fmt(&buf, "%"PRIu64, (u64)sqlite3_column_int64(s, i));
				break;
			case SQLITE_TEXT:
				tal_append_fmt(&buf, "\"%s\"", sqlite3_column_text(s, i));
				break;
			case SQLITE_BLOB: {
				const void *blob = sqlite3_column_blob(s, i);
				int bloblen = sqlite3_column_bytes(s, i);
				tal_append_fmt(&buf, "\"%s\"", tal_hexstr(tmpctx, blob, bloblen));
				break;
			}
			default: