org.nuxeo.elasticsearch.audit.pageprovider

Class ESAuditPageProvider

java.lang.Object

org.nuxeo.ecm.platform.query.api.AbstractPageProvider<LogEntry>

org.nuxeo.elasticsearch.audit.pageprovider.ESAuditPageProvider

All Implemented Interfaces:

Serializable, PageProvider<LogEntry>

Direct Known Subclasses:

ESDocumentHistoryPageProvider

public class ESAuditPageProvider
extends AbstractPageProvider<LogEntry>
implements PageProvider<LogEntry>

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	CORE_SESSION_PROPERTY
protected static String	emptyQuery
protected Long	maxResultWindow
protected org.elasticsearch.action.search.SearchRequest	searchRequest
static String	UICOMMENTS_PROPERTY

Fields inherited from class org.nuxeo.ecm.platform.query.api.AbstractPageProvider

currentEntryIndex, currentHigherNonEmptyPageIndex, currentSelectPage, definition, error, errorMessage, highlights, log, maxPageSize, name, offset, PAGEPROVIDER_TRACK_PROPERTY_NAME, pageProviderChangedListener, pageSize, pageSizeOptions, parameters, properties, quickFilters, resultsCount, searchDocumentModel, selectedEntries, SKIPPED_SCHEMAS_FOR_SEARCHFIELD, sortable, sortInfos, tracking

Fields inherited from interface org.nuxeo.ecm.platform.query.api.PageProvider

DEFAULT_MAX_PAGE_SIZE, DEFAULT_MAX_PAGE_SIZE_RUNTIME_PROP, HIGHLIGHT_CTX_DATA, PAGE_LIMIT_UNKNOWN, SKIP_AGGREGATES_PROP, UNKNOWN_SIZE, UNKNOWN_SIZE_AFTER_QUERY

Constructor Summary

Constructors

Constructor and Description
ESAuditPageProvider()

Method Summary

Modifier and Type	Method and Description
protected boolean	allowSimplePattern()
protected void	buildAuditQuery(boolean includeSort)
protected CoreSession	getCoreSession()
List<LogEntry>	getCurrentPage() Returns the list of current page items.
protected ESAuditBackend	getESBackend()
protected String	getFixedPart()
long	getMaxResultWindow() Returns the max result window where the PP can navigate without raising Elasticsearch QueryPhaseExecutionException.
long	getPageLimit() Returns the page limit.
long	getResultsCount() Returns the number of result elements if available or a negative value if it is unknown: UNKNOWN_SIZE if it is unknown as query was not done, and since 5.5, UNKNOWN_SIZE_AFTER_QUERY if it is still unknown after query was done.
List<SortInfo>	getSortInfos() Returns the complete list of sorting info for this provider
boolean	isLastPageAvailable() Returns a boolean expressing if the last page can be displayed.
boolean	isNextPageAvailable() Returns a boolean expressing if there are further pages.
protected boolean	isNonNullParam(Object[] val)
protected void	preprocessCommentsIfNeeded(List<LogEntry> entries)
void	refresh() Refresh hook, to override for custom behavior
void	setMaxResultWindow(long maxResultWindow) Set the max result window where the PP can navigate, for testing purpose.
String	toString()

Methods inherited from class org.nuxeo.ecm.platform.query.api.AbstractPageProvider

addQuickFilter, addSortInfo, fireSearchEvent, firstPage, getAggregateDefinitions, getAggregates, getAvailableQuickFilters, getBooleanProperty, getCurrentEntry, getCurrentHigherNonEmptyPageIndex, getCurrentPageIndex, getCurrentPageOffset, getCurrentPageSize, getCurrentPageStatus, getCurrentSelectPage, getDefaultMaxPageSize, getDefinition, getError, getErrorMessage, getHighlights, getMaxNumberOfEmptyPages, getMaxPageSize, getMinMaxPageSize, getName, getNumberOfPages, getPageSize, getPageSizeOptions, getParameters, getParametersChanged, getProperties, getQuickFilters, getResultsCountLimit, getSearchDocumentModel, getSortInfo, getSortInfoIndex, hasAggregateSupport, hasChangedParameters, hasError, incorporateAggregates, isNextEntryAvailable, isPreviousEntryAvailable, isPreviousPageAvailable, isSkipAggregates, isSortable, isTrackingEnabled, lastPage, nextEntry, nextPage, notifyPageChanged, notifyRefresh, pageChanged, previousEntry, previousPage, searchDocumentModelChanged, setCurrentEntry, setCurrentEntryIndex, setCurrentHigherNonEmptyPageIndex, setCurrentPage, setCurrentPageIndex, setCurrentPageOffset, setDefinition, setHighlights, setMaxPageSize, setName, setPageProviderChangedListener, setPageSize, setPageSizeOptions, setParameters, setProperties, setQuickFilters, setResultsCount, setSearchDocumentModel, setSelectedEntries, setSortable, setSortInfo, setSortInfo, setSortInfos, sortInfoChanged

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.nuxeo.ecm.platform.query.api.PageProvider

addQuickFilter, addSortInfo, firstPage, getAggregateDefinitions, getAggregates, getAvailableQuickFilters, getCurrentEntry, getCurrentPageIndex, getCurrentPageOffset, getCurrentPageSize, getCurrentPageStatus, getCurrentSelectPage, getDefinition, getError, getErrorMessage, getHighlights, getMaxPageSize, getName, getNumberOfPages, getPageSize, getPageSizeOptions, getParameters, getProperties, getQuickFilters, getResultsCountLimit, getSearchDocumentModel, getSortInfo, getSortInfoIndex, hasAggregateSupport, hasChangedParameters, hasError, isNextEntryAvailable, isPreviousEntryAvailable, isPreviousPageAvailable, isSkipAggregates, isSortable, lastPage, nextEntry, nextPage, previousEntry, previousPage, setCurrentEntry, setCurrentEntryIndex, setCurrentPage, setCurrentPageIndex, setCurrentPageOffset, setDefinition, setHighlights, setMaxPageSize, setName, setPageProviderChangedListener, setPageSize, setPageSizeOptions, setParameters, setProperties, setQuickFilters, setResultsCount, setSearchDocumentModel, setSelectedEntries, setSortable, setSortInfo, setSortInfo, setSortInfos

Field Detail

searchRequest

protected org.elasticsearch.action.search.SearchRequest searchRequest

CORE_SESSION_PROPERTY

public static final String CORE_SESSION_PROPERTY

See Also:

Constant Field Values

UICOMMENTS_PROPERTY

public static final String UICOMMENTS_PROPERTY

See Also:

Constant Field Values

emptyQuery

protected static String emptyQuery

maxResultWindow

protected Long maxResultWindow

Constructor Detail

ESAuditPageProvider

public ESAuditPageProvider()

Method Detail

toString

public String toString()

Overrides:

toString in class Object

getCoreSession

protected CoreSession getCoreSession()

preprocessCommentsIfNeeded

protected void preprocessCommentsIfNeeded(List<LogEntry> entries)

getCurrentPage

public List<LogEntry> getCurrentPage()

Description copied from class: AbstractPageProvider

Returns the list of current page items.

Custom implementation can be added here, based on the page provider properties, parameters and WhereClauseDefinition on the PageProviderDefinition, as well as search document, sort information, etc...

Implementation of this method usually consists in setting a non-null value to a field caching current items, and nullifying this field by overriding AbstractPageProvider.pageChanged() and AbstractPageProvider.refresh().

Fields AbstractPageProvider.errorMessage and AbstractPageProvider.error can also be filled to provide accurate feedback in case an error occurs during the search.

When items are retrieved, a call to AbstractPageProvider.setResultsCount(long) should be made to ensure proper pagination as implemented in this abstract class. The implementation in CoreQueryAndFetchPageProvider is a good example when the total results count is known.

If for performance reasons, for instance, the number of results cannot be known, a fall-back strategy can be applied to provide the "next" button but not the "last" one, by calling AbstractPageProvider.getCurrentHigherNonEmptyPageIndex() and AbstractPageProvider.setCurrentHigherNonEmptyPageIndex(int). In this case, CoreQueryDocumentPageProvider is a good example.

Specified by:

getCurrentPage in interface PageProvider<LogEntry>

Specified by:

getCurrentPage in class AbstractPageProvider<LogEntry>

Returns:

the current page

isNonNullParam

protected boolean isNonNullParam(Object[] val)

getFixedPart

protected String getFixedPart()

allowSimplePattern

protected boolean allowSimplePattern()

getESBackend

protected ESAuditBackend getESBackend()

buildAuditQuery

protected void buildAuditQuery(boolean includeSort)

refresh

public void refresh()

Description copied from class: AbstractPageProvider

Refresh hook, to override for custom behavior

When overriding it, call super.refresh() as last statement to make sure that the PageProviderChangedListener is called with the up-to-date @{code PageProvider} state.

Specified by:

refresh in interface PageProvider<LogEntry>

Overrides:

refresh in class AbstractPageProvider<LogEntry>

getResultsCount

public long getResultsCount()

Description copied from interface: PageProvider

Returns the number of result elements if available or a negative value if it is unknown: UNKNOWN_SIZE if it is unknown as query was not done, and since 5.5, UNKNOWN_SIZE_AFTER_QUERY if it is still unknown after query was done.

Specified by:

getResultsCount in interface PageProvider<LogEntry>

Overrides:

getResultsCount in class AbstractPageProvider<LogEntry>

getSortInfos

public List<SortInfo> getSortInfos()

Description copied from interface: PageProvider

Returns the complete list of sorting info for this provider

Specified by:

getSortInfos in interface PageProvider<LogEntry>

Overrides:

getSortInfos in class AbstractPageProvider<LogEntry>

isLastPageAvailable

public boolean isLastPageAvailable()

Description copied from interface: PageProvider

Returns a boolean expressing if the last page can be displayed.

Specified by:

isLastPageAvailable in interface PageProvider<LogEntry>

Overrides:

isLastPageAvailable in class AbstractPageProvider<LogEntry>

isNextPageAvailable

public boolean isNextPageAvailable()

Description copied from interface: PageProvider

Returns a boolean expressing if there are further pages.

Specified by:

isNextPageAvailable in interface PageProvider<LogEntry>

Overrides:

isNextPageAvailable in class AbstractPageProvider<LogEntry>

getPageLimit

public long getPageLimit()

Description copied from class: AbstractPageProvider

Returns the page limit. The n first page we know they exist.

Specified by:

getPageLimit in interface PageProvider<LogEntry>

Overrides:

getPageLimit in class AbstractPageProvider<LogEntry>

getMaxResultWindow

public long getMaxResultWindow()

Returns the max result window where the PP can navigate without raising Elasticsearch QueryPhaseExecutionException. from + size must be less than or equal to this value.

Since:

9.2

setMaxResultWindow

public void setMaxResultWindow(long maxResultWindow)

Set the max result window where the PP can navigate, for testing purpose.

Since:

9.2