[Discover] Added context aware logic for logs view in discover to show Load More…

src/platform/packages/shared/kbn-react-hooks/index.ts

@@ -9,6 +9,8 @@
 
 export { useBoolean } from './src/use_boolean';
 export { useErrorTextStyle } from './src/use_error_text_style';
+export { useDebounceFn } from './src/use_debounce_fn';
+export { useThrottleFn } from './src/use_throttle_fn';
 export { useAbortController } from './src/use_abort_controller';
 export { useAbortableAsync } from './src/use_abortable_async';
 export type { UseAbortableAsync, AbortableAsyncState } from './src/use_abortable_async';

src/platform/packages/shared/kbn-react-hooks/src/use_debounce_fn/index.ts

@@ -0,0 +1,10 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the "Elastic License
+ * 2.0", the "GNU Affero General Public License v3.0 only", and the "Server Side
+ * Public License v 1"; you may not use this file except in compliance with, at
+ * your election, the "Elastic License 2.0", the "GNU Affero General Public
+ * License v3.0 only", or the "Server Side Public License, v 1".
+ */
+
+export * from './use_debounce_fn';

src/platform/packages/shared/kbn-react-hooks/src/use_debounce_fn/use_debounce_fn.test.ts

@@ -0,0 +1,100 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the "Elastic License
+ * 2.0", the "GNU Affero General Public License v3.0 only", and the "Server Side
+ * Public License v 1"; you may not use this file except in compliance with, at
+ * your election, the "Elastic License 2.0", the "GNU Affero General Public
+ * License v3.0 only", or the "Server Side Public License, v 1".
+ */
+
+import { renderHook, act } from '@testing-library/react';
+import { useDebounceFn } from '../..';
+
+describe('useDebounceFn hook', () => {
+  jest.useFakeTimers();
+
+  it('should debounce the function call', () => {
+    const fn = jest.fn();
+    const { result } = renderHook(() => useDebounceFn(fn, { wait: 200 }));
+
+    act(() => {
+      result.current.run();
+      result.current.run();
+    });
+
+    expect(fn).not.toBeCalled();
+
+    act(() => {
+      jest.advanceTimersByTime(200);
+    });
+
+    expect(fn).toBeCalledTimes(1);
+  });
+
+  it('should cancel the debounced function call', () => {
+    const fn = jest.fn();
+    const { result } = renderHook(() => useDebounceFn(fn, { wait: 200 }));
+
+    act(() => {
+      result.current.run();
+      result.current.cancel();
+    });
+
+    act(() => {
+      jest.advanceTimersByTime(200);
+    });
+
+    expect(fn).not.toBeCalled();
+  });
+
+  it('should flush the debounced function call', () => {
+    const fn = jest.fn();
+    const { result } = renderHook(() => useDebounceFn(fn, { wait: 200 }));
+
+    act(() => {
+      result.current.run();
+      result.current.flush();
+    });
+
+    expect(fn).toBeCalledTimes(1);
+  });
+
+  it('should handle leading option correctly', () => {
+    const fn = jest.fn();
+    const { result } = renderHook(() => useDebounceFn(fn, { wait: 200, leading: true }));
+
+    act(() => {
+      result.current.run();
+    });
+
+    expect(fn).toBeCalledTimes(1);
+
+    act(() => {
+      jest.advanceTimersByTime(200);
+    });
+
+    act(() => {
+      result.current.run();
+    });
+
+    expect(fn).toBeCalledTimes(2);
+  });
+
+  it('should handle trailing option correctly', () => {
+    const fn = jest.fn();
+    const { result } = renderHook(() => useDebounceFn(fn, { wait: 200, trailing: true }));
+
+    act(() => {
+      result.current.run();
+      result.current.run();
+    });
+
+    expect(fn).not.toBeCalled();
+
+    act(() => {
+      jest.advanceTimersByTime(200);
+    });
+
+    expect(fn).toBeCalledTimes(1);
+  });
+});

src/platform/packages/shared/kbn-react-hooks/src/use_debounce_fn/use_debounce_fn.ts

@@ -0,0 +1,54 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the "Elastic License
+ * 2.0", the "GNU Affero General Public License v3.0 only", and the "Server Side
+ * Public License v 1"; you may not use this file except in compliance with, at
+ * your election, the "Elastic License 2.0", the "GNU Affero General Public
+ * License v3.0 only", or the "Server Side Public License, v 1".
+ */
+
+import { debounce, isFunction } from 'lodash';
+import { useMemo } from 'react';
+import useLatest from 'react-use/lib/useLatest';
+import useUnmount from 'react-use/lib/useUnmount';
+
+type Noop = (...args: any[]) => any;
+
+export interface DebounceOptions {
+  wait?: number;
+  leading?: boolean;
+  trailing?: boolean;
+  maxWait?: number;
+}
+
+export function useDebounceFn<T extends Noop>(fn: T, options?: DebounceOptions) {
+  if (!isFunction(fn)) {
+    throw Error(`useDebounceFn expected parameter is a function, got ${typeof fn}`);
+  }
+
+  const fnRef = useLatest(fn);
+
+  const wait = options?.wait ?? 1000;
+
+  const debounced = useMemo(
+    () =>
+      debounce(
+        (...args: Parameters<T>): ReturnType<T> => {
+          return fnRef.current(...args);
+        },
+        wait,
+        options
+      ),
+    [fnRef, options, wait]
+  );
+
+  useUnmount(() => {
+    debounced.cancel();
+  });
+
+  return {
+    run: debounced,
+    cancel: debounced.cancel,
+    flush: debounced.flush,
+  };
+}

src/platform/packages/shared/kbn-react-hooks/src/use_throttle_fn/index.ts

@@ -0,0 +1,10 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the "Elastic License
+ * 2.0", the "GNU Affero General Public License v3.0 only", and the "Server Side
+ * Public License v 1"; you may not use this file except in compliance with, at
+ * your election, the "Elastic License 2.0", the "GNU Affero General Public
+ * License v3.0 only", or the "Server Side Public License, v 1".
+ */
+
+export * from './use_throttle_fn';

src/platform/packages/shared/kbn-react-hooks/src/use_throttle_fn/use_throttle_fn.test.ts

@@ -0,0 +1,109 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the "Elastic License
+ * 2.0", the "GNU Affero General Public License v3.0 only", and the "Server Side
+ * Public License v 1"; you may not use this file except in compliance with, at
+ * your election, the "Elastic License 2.0", the "GNU Affero General Public
+ * License v3.0 only", or the "Server Side Public License, v 1".
+ */
+
+import { renderHook, act } from '@testing-library/react';
+import { useThrottleFn } from '../..';
+
+describe('useThrottleFn hook', () => {
+  jest.useFakeTimers();
+
+  it('should throttle the function call', () => {
+    const fn = jest.fn();
+    const { result } = renderHook(() => useThrottleFn(fn, { wait: 200, leading: false }));
+
+    act(() => {
+      result.current.run();
+      result.current.run();
+      result.current.run();
+    });
+
+    // Because leading is false, the fn won't be called immediately.
+    expect(fn).toBeCalledTimes(0);
+
+    act(() => {
+      jest.advanceTimersByTime(200);
+    });
+
+    expect(fn).toBeCalledTimes(1);
+
+    act(() => {
+      result.current.run();
+      jest.advanceTimersByTime(200);
+    });
+
+    expect(fn).toBeCalledTimes(2);
+  });
+
+  it('should cancel the throttled function call', () => {
+    const fn = jest.fn();
+    const { result } = renderHook(() => useThrottleFn(fn, { wait: 200, leading: false }));
+
+    act(() => {
+      result.current.run();
+      result.current.cancel();
+    });
+
+    act(() => {
+      jest.advanceTimersByTime(200);
+    });
+
+    expect(fn).not.toBeCalled();
+  });
+
+  it('should flush the throttled function call', () => {
+    const fn = jest.fn();
+    const { result } = renderHook(() => useThrottleFn(fn, { wait: 200 }));
+
+    act(() => {
+      result.current.run();
+      result.current.flush();
+    });
+
+    expect(fn).toBeCalledTimes(1);
+  });
+
+  it('should handle leading option correctly', () => {
+    const fn = jest.fn();
+    const { result } = renderHook(() => useThrottleFn(fn, { wait: 200, leading: true }));
+
+    act(() => {
+      result.current.run();
+    });
+
+    expect(fn).toBeCalledTimes(1);
+
+    act(() => {
+      jest.advanceTimersByTime(200);
+    });
+
+    act(() => {
+      result.current.run();
+    });
+
+    expect(fn).toBeCalledTimes(2);
+  });
+
+  it('should handle trailing option correctly', () => {
+    const fn = jest.fn();
+    const { result } = renderHook(() => useThrottleFn(fn, { wait: 200, trailing: true }));
+
+    act(() => {
+      result.current.run();
+      result.current.run();
+    });
+
+    expect(fn).toBeCalledTimes(1);
+
+    act(() => {
+      jest.advanceTimersByTime(200);
+    });
+
+    expect(fn).toBeCalledTimes(2);
+  });
+});

src/platform/packages/shared/kbn-react-hooks/src/use_throttle_fn/use_throttle_fn.ts

@@ -0,0 +1,53 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the "Elastic License
+ * 2.0", the "GNU Affero General Public License v3.0 only", and the "Server Side
+ * Public License v 1"; you may not use this file except in compliance with, at
+ * your election, the "Elastic License 2.0", the "GNU Affero General Public
+ * License v3.0 only", or the "Server Side Public License, v 1".
+ */
+
+import { throttle, isFunction } from 'lodash';
+import { useMemo } from 'react';
+import useLatest from 'react-use/lib/useLatest';
+import useUnmount from 'react-use/lib/useUnmount';
+
+type Noop = (...args: any[]) => any;
+
+export interface ThrottleOptions {
+  wait?: number;
+  leading?: boolean;
+  trailing?: boolean;
+}
+
+export function useThrottleFn<T extends Noop>(fn: T, options?: ThrottleOptions) {
+  if (!isFunction(fn)) {
+    throw Error(`useThrottleFn expected parameter is a function, got ${typeof fn}`);
+  }
+
+  const fnRef = useLatest(fn);
+
+  const wait = options?.wait ?? 1000;
+
+  const throttled = useMemo(
+    () =>
+      throttle(
+        (...args: Parameters<T>): ReturnType<T> => {
+          return fnRef.current(...args);
+        },
+        wait,
+        options
+      ),
+    [fnRef, options, wait]
+  );
+
+  useUnmount(() => {
+    throttled.cancel();
+  });
+
+  return {
+    run: throttled,
+    cancel: throttled.cancel,
+    flush: throttled.flush,
+  };
+}

src/platform/packages/shared/kbn-unified-data-table/index.ts

@@ -15,7 +15,7 @@ export {
 } from './src/components/row_height_settings';
 export { getDisplayedColumns, SOURCE_COLUMN } from './src/utils/columns';
 export { getTextBasedColumnsMeta } from './src/utils/get_columns_meta';
-export { ROWS_HEIGHT_OPTIONS, DataGridDensity } from './src/constants';
+export { ROWS_HEIGHT_OPTIONS, DataGridDensity, DEFAULT_PAGINATION_MODE } from './src/constants';
 
 export { JSONCodeEditorCommonMemoized } from './src/components/json_code_editor/json_code_editor_common';
 export { SourceDocument } from './src/components/source_document';