Skip to content
Merged
Show file tree
Hide file tree
Changes from 6 commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
66 changes: 44 additions & 22 deletions packages/dashboard/src/DashboardLayout.tsx
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@ import type {
ReactComponentConfig,
} from '@deephaven/golden-layout';
import Log from '@deephaven/log';
import { usePrevious } from '@deephaven/react-hooks';
import { usePrevious, useThrottledCallback } from '@deephaven/react-hooks';
import { RootState } from '@deephaven/redux';
import { useDispatch, useSelector } from 'react-redux';
import PanelManager, { ClosedPanels } from './PanelManager';
Expand Down Expand Up @@ -46,6 +46,8 @@ const DEFAULT_LAYOUT_CONFIG: DashboardLayoutConfig = [];

const DEFAULT_CALLBACK = (): void => undefined;

const STATE_CHANGE_DEBOUNCE_MS = 1000;
Comment thread
mofojed marked this conversation as resolved.
Outdated

// If a component isn't registered, just pass through the props so they are saved if a plugin is loaded later
const FALLBACK_CALLBACK = (props: unknown): unknown => props;

Expand Down Expand Up @@ -195,6 +197,40 @@ export function DashboardLayout({
]
);

// eslint-disable-next-line react-hooks/exhaustive-deps
Comment thread
mofojed marked this conversation as resolved.
Outdated
const processDehydratedLayoutConfig = useCallback(
dehydratedLayoutConfig => {
const hasChanged =
lastConfig == null ||
!LayoutUtils.isEqual(lastConfig, dehydratedLayoutConfig);

log.debug('handleLayoutStateChanged', hasChanged, dehydratedLayoutConfig);

if (hasChanged) {
setIsDashboardEmpty(layout.root.contentItems.length === 0);

setLastConfig(dehydratedLayoutConfig);

onLayoutChange(dehydratedLayoutConfig);

setLayoutChildren(layout.getReactChildren());
}
},
[lastConfig, layout, onLayoutChange]
);

// Throttle the calls so that we don't flood comparing these layouts
const throttledProcessDehydratedLayoutConfig = useThrottledCallback(
processDehydratedLayoutConfig,
STATE_CHANGE_DEBOUNCE_MS,
{ flushOnUnmount: true }
);

useEffect(
() => () => throttledProcessDehydratedLayoutConfig.flush(),
[throttledProcessDehydratedLayoutConfig]
);
Comment on lines +223 to +226
Copy link
Copy Markdown
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Should this be part of the hook instead?

Copy link
Copy Markdown
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Moved it to the hook.


const handleLayoutStateChanged = useCallback(() => {
// we don't want to emit stateChanges that happen during item drags or else
// we risk the last saved state being one without that panel in the layout entirely
Expand All @@ -206,27 +242,13 @@ export function DashboardLayout({
contentConfig,
dehydrateComponent
);
const hasChanged =
lastConfig == null ||
!LayoutUtils.isEqual(lastConfig, dehydratedLayoutConfig);

log.debug(
'handleLayoutStateChanged',
hasChanged,
contentConfig,
dehydratedLayoutConfig
);

if (hasChanged) {
setIsDashboardEmpty(layout.root.contentItems.length === 0);

setLastConfig(dehydratedLayoutConfig);

onLayoutChange(dehydratedLayoutConfig);

setLayoutChildren(layout.getReactChildren());
}
}, [dehydrateComponent, isItemDragging, lastConfig, layout, onLayoutChange]);
throttledProcessDehydratedLayoutConfig(dehydratedLayoutConfig);
}, [
dehydrateComponent,
isItemDragging,
layout,
throttledProcessDehydratedLayoutConfig,
]);

const handleLayoutItemPickedUp = useCallback(
(component: Container) => {
Expand Down
1 change: 1 addition & 0 deletions packages/react-hooks/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,7 @@
"@deephaven/log": "file:../log",
"@deephaven/utils": "file:../utils",
"lodash.debounce": "^4.0.8",
"lodash.throttle": "^4.1.1",
"shortid": "^2.2.16"
},
"peerDependencies": {
Expand Down
1 change: 1 addition & 0 deletions packages/react-hooks/src/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@ export * from './useCheckOverflow';
export * from './useContentRect';
export { default as useContextOrThrow } from './useContextOrThrow';
export * from './useDebouncedCallback';
export * from './useThrottledCallback';
export * from './useDelay';
export * from './useDependentState';
export * from './useEffectNTimesWhen';
Expand Down
115 changes: 115 additions & 0 deletions packages/react-hooks/src/useThrottledCallback.test.ts
Original file line number Diff line number Diff line change
@@ -0,0 +1,115 @@
import { renderHook } from '@testing-library/react-hooks';
import useThrottledCallback from './useThrottledCallback';

const callback = jest.fn((text: string) => undefined);
const arg = 'mock.arg';
const arg2 = 'mock.arg2';
const throttleMs = 400;

beforeEach(() => {
jest.clearAllMocks();
jest.useFakeTimers();
});
Comment thread
mofojed marked this conversation as resolved.

it('should throttle a given callback', () => {
const { result } = renderHook(() =>
useThrottledCallback(callback, throttleMs)
);

result.current(arg);
result.current(arg);

jest.advanceTimersByTime(5);

result.current(arg);

result.current(arg2);

expect(callback).toHaveBeenCalledTimes(1);
expect(callback).toHaveBeenCalledWith(arg);

jest.clearAllMocks();

jest.advanceTimersByTime(throttleMs);
expect(callback).toHaveBeenCalledTimes(1);
expect(callback).toHaveBeenCalledWith(arg2);
});

it('should cancel throttle if component unmounts', () => {
const { result, unmount } = renderHook(() =>
useThrottledCallback(callback, throttleMs)
);

result.current(arg);
result.current(arg2);

jest.advanceTimersByTime(throttleMs - 1);

expect(callback).toHaveBeenCalledTimes(1);
expect(callback).toHaveBeenCalledWith(arg);
callback.mockClear();

jest.spyOn(result.current, 'cancel');

unmount();

expect(result.current.cancel).toHaveBeenCalled();

jest.advanceTimersByTime(5);

expect(callback).not.toHaveBeenCalled();
});

it('should call the updated callback if the ref changes', () => {
const { rerender, result } = renderHook(
fn => useThrottledCallback(fn, throttleMs),
{
initialProps: callback,
}
);

result.current(arg);
result.current(arg2);

// Leading is always called
expect(callback).toHaveBeenCalledTimes(1);
expect(callback).toHaveBeenCalledWith(arg);
callback.mockClear();

jest.advanceTimersByTime(throttleMs - 1);

const newCallback = jest.fn();
rerender(newCallback);

jest.advanceTimersByTime(1);

expect(callback).not.toHaveBeenCalled();
expect(newCallback).toHaveBeenCalledTimes(1);
expect(newCallback).toHaveBeenCalledWith(arg2);
});

it('should flush on unmount if that option is set', () => {
const { result, unmount } = renderHook(() =>
useThrottledCallback(callback, throttleMs, { flushOnUnmount: true })
);

result.current(arg);
result.current(arg2);

jest.advanceTimersByTime(throttleMs - 1);

expect(callback).toHaveBeenCalledTimes(1);
expect(callback).toHaveBeenCalledWith(arg);
callback.mockClear();

jest.spyOn(result.current, 'flush');

unmount();

expect(result.current.flush).toHaveBeenCalled();

jest.advanceTimersByTime(1);

expect(callback).toHaveBeenCalledTimes(1);
expect(callback).toHaveBeenCalledWith(arg2);
});
51 changes: 51 additions & 0 deletions packages/react-hooks/src/useThrottledCallback.ts
Original file line number Diff line number Diff line change
@@ -0,0 +1,51 @@
import { useEffect, useMemo, useRef } from 'react';
import type { DebouncedFunc, ThrottleSettings } from 'lodash';
import throttle from 'lodash.throttle';

/**
* Wraps a given callback in a cancelable, throttled function. The throttled
* callback is automatically cancelled if the callback reference changes or the
Copy link
Copy Markdown
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Something like this? Since flushOnUnmount also triggers with the callback changing

Suggested change
* callback is automatically cancelled if the callback reference changes or the
* callback is automatically cancelled or flushed if flushOnUnmount is set if the callback reference changes or the

Copy link
Copy Markdown
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

So I don't think we want to actually flush or cancel when the callback reference changes, we only want to cancel or flush on unmount, and we want the throttled callback to always call the latest callback reference.
I've changed it to always return a stable callback... as I think the behaviour is too ambiguous/confusing if you try to introduce cancel/flush whenever the callback reference changes (do you want to cancel or flush? Should the throttle timer reset? etc).

Copy link
Copy Markdown
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Also of note the useDebouncedCallback should probably be structured similarly, as right now it could continually cancel if the callback passed in changes and then never gets called.

* component unmounts.
* @param callback callback function to throttle
* @param throttleMs throttle milliseconds
* @param options lodash throttle options. Will not react to changes to this param
Comment thread
mofojed marked this conversation as resolved.
Outdated
* @returns a cancelable, throttled function
*/
export function useThrottledCallback<TArgs extends unknown[], TResult>(
callback: (...args: TArgs) => TResult,
throttleMs: number,
initialOptions?: ThrottleSettings & { flushOnUnmount?: boolean }
): DebouncedFunc<(...args: TArgs) => TResult> {
const options = useRef(initialOptions);

// Use a ref for the callback
// We want to keep a stable callback so the flush/cancel works as expected
// So we keep a ref to the current callback, then we have a throttled callback that will just call this
const callbackRef = useRef(callback);
callbackRef.current = callback;

const throttledCallback = useMemo(
() =>
throttle(
(...args: TArgs) => callbackRef.current(...args),
throttleMs,
options.current
),
[throttleMs]
);

useEffect(
() => () => {
if (options.current?.flushOnUnmount ?? false) {
Comment thread
mofojed marked this conversation as resolved.
throttledCallback.flush();
} else {
throttledCallback.cancel();
}
},
[throttledCallback]
);

return throttledCallback;
}

export default useThrottledCallback;