Function wait_done

plugins/sql.c:1281–1319

		      u64 next_index);

static struct command_result *wait_done(struct command *auxcmd,
					const char *method,
					const char *buf,
					const jsmntok_t *result,
					struct table_desc *td)
{
	const jsmntok_t *valtok;
	const char *indexname;
	u64 val;

	if ((valtok = json_get_member(buf, result, "created")) != NULL) {
		indexname = "created";
		td->refresh_needs |= REFRESH_CREATED;
	} else if ((valtok = json_get_member(buf, result, "updated")) != NULL) {
		indexname = "updated";
		td->refresh_needs |= REFRESH_UPDATED;
	} else if ((valtok = json_get_member(buf, result, "deleted")) != NULL) {
		indexname = "deleted";
		td->refresh_needs |= REFRESH_DELETED;
	} else {
		plugin_err(auxcmd->plugin,
			   "Invalid wait_done for %s: '%.*s'",
			   td->name,
			   json_tok_full_len(result),
			   json_tok_full(buf, result));
	}

	if (!json_to_u64(buf, valtok, &val)) {
		plugin_err(auxcmd->plugin,
			   "Invalid wait_done index for %s: '%.*s'",
			   td->name,
			   json_tok_full_len(result),
			   json_tok_full(buf, result));
	}

	/* Keep watching for next one */
	watch_for(sql_of(auxcmd->plugin), td, indexname, val + 1);
	return command_still_pending(auxcmd);
}

static void watch_for(struct sql *sql,
		      struct table_desc *td,