Function paginated_refresh

plugins/sql.c:1787–1817

}

static struct command_result *paginated_refresh(struct command *cmd,
						struct table_desc *td,
						struct db_query *dbq)
{
	/* In case something was deleted (rare!) we just reload the
	 * entire thing */
	if (td->refresh_needs & REFRESH_DELETED) {
		plugin_log(cmd->plugin, LOG_DBG, "%s: total reload due to delete", td->name);
		/* Since this reloads everything, covers all: updates and creates */
		td->refresh_needs = REFRESH_UNNECESSARY;
		return default_refresh(cmd, td, dbq);
	}

	if (td->refresh_needs & REFRESH_UPDATED) {
		struct out_req *req;
		plugin_log(cmd->plugin, LOG_DBG,
			   "%s: records updated, updating from %"PRIu64, td->name, td->last_updated_index + 1);
		td->refresh_needs &= ~REFRESH_UPDATED;
		req = jsonrpc_request_start(cmd, td->cmdname,
					    updated_list_done, forward_error,
					    dbq);
		json_add_string(req->js, "index", "updated");
		json_add_u64(req->js, "start", td->last_updated_index + 1);
		return send_outreq(req);
	}

	/* No updates, no deletes: the simple case! */
	plugin_log(cmd->plugin, LOG_DBG,
		   "%s: records created, inserting from %"PRIu64, td->name, td->last_created_index + 1);
	return refresh_by_created_index(cmd, td, dbq);
}

struct refresh_funcs {
	const char *cmdname;