blob: 50a67fda460fb0827a641e540d3e1210f0a22fc0 [file] [log] [blame]
// Copyright (C) 2018 The Android Open Source Project
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
import {Draft} from 'immer';
import {SortDirection} from '../base/comparison_utils';
import {assertExists, assertTrue} from '../base/logging';
import {duration, time} from '../base/time';
import {RecordConfig} from '../controller/record_config_types';
import {randomColor} from '../core/colorizer';
import {
GenericSliceDetailsTabConfig,
GenericSliceDetailsTabConfigBase,
} from '../frontend/generic_slice_details_tab';
import {
Aggregation,
AggregationFunction,
TableColumn,
tableColumnEquals,
toggleEnabled,
} from '../frontend/pivot_table_types';
import {
computeIntervals,
DropDirection,
performReordering,
} from './dragndrop_logic';
import {createEmptyState} from './empty_state';
import {
MetatraceTrackId,
traceEventBegin,
traceEventEnd,
TraceEventScope,
} from './metatracing';
import {
AdbRecordingTarget,
EngineMode,
LoadedConfig,
NewEngineMode,
OmniboxMode,
OmniboxState,
PendingDeeplinkState,
PivotTableResult,
PrimaryTrackSortKey,
ProfileType,
RecordingTarget,
SCROLLING_TRACK_GROUP,
State,
Status,
ThreadTrackSortKey,
TrackSortKey,
UtidToTrackSortKey,
VisibleState,
} from './state';
type StateDraft = Draft<State>;
export interface AddTrackArgs {
key?: string;
uri: string;
name: string;
labels?: string[];
trackSortKey: TrackSortKey;
trackGroup?: string;
closeable?: boolean;
}
export interface PostedTrace {
buffer: ArrayBuffer;
title: string;
fileName?: string;
url?: string;
uuid?: string;
localOnly?: boolean;
keepApiOpen?: boolean;
// Allows to pass extra arguments to plugins. This can be read by plugins
// onTraceLoad() and can be used to trigger plugin-specific-behaviours (e.g.
// allow dashboards like APC to pass extra data to materialize onto tracks).
// The format is the following:
// pluginArgs: {
// 'dev.perfetto.PluginFoo': { 'key1': 'value1', 'key2': 1234 }
// 'dev.perfetto.PluginBar': { 'key3': '...', 'key4': ... }
// }
pluginArgs?: {[pluginId: string]: {[key: string]: unknown}};
}
export interface PostedScrollToRange {
timeStart: number;
timeEnd: number;
viewPercentage?: number;
}
function clearTraceState(state: StateDraft) {
const nextId = state.nextId;
const recordConfig = state.recordConfig;
const recordingTarget = state.recordingTarget;
const fetchChromeCategories = state.fetchChromeCategories;
const extensionInstalled = state.extensionInstalled;
const availableAdbDevices = state.availableAdbDevices;
const chromeCategories = state.chromeCategories;
const newEngineMode = state.newEngineMode;
Object.assign(state, createEmptyState());
state.nextId = nextId;
state.recordConfig = recordConfig;
state.recordingTarget = recordingTarget;
state.fetchChromeCategories = fetchChromeCategories;
state.extensionInstalled = extensionInstalled;
state.availableAdbDevices = availableAdbDevices;
state.chromeCategories = chromeCategories;
state.newEngineMode = newEngineMode;
}
function generateNextId(draft: StateDraft): string {
const nextId = String(Number(draft.nextId) + 1);
draft.nextId = nextId;
return nextId;
}
// A helper to clean the state for a given removeable track.
// This is not exported as action to make it clear that not all
// tracks are removeable.
function removeTrack(state: StateDraft, trackKey: string) {
const track = state.tracks[trackKey];
if (track === undefined) {
return;
}
delete state.tracks[trackKey];
const removeTrackId = (arr: string[]) => {
const index = arr.indexOf(trackKey);
if (index !== -1) arr.splice(index, 1);
};
if (track.trackGroup === SCROLLING_TRACK_GROUP) {
removeTrackId(state.scrollingTracks);
} else if (track.trackGroup !== undefined) {
const trackGroup = state.trackGroups[track.trackGroup];
if (trackGroup !== undefined) {
removeTrackId(trackGroup.tracks);
}
}
state.pinnedTracks = state.pinnedTracks.filter((key) => key !== trackKey);
}
let statusTraceEvent: TraceEventScope | undefined;
export const StateActions = {
openTraceFromFile(state: StateDraft, args: {file: File}): void {
clearTraceState(state);
const id = generateNextId(state);
state.engine = {
id,
ready: false,
source: {type: 'FILE', file: args.file},
};
},
openTraceFromBuffer(state: StateDraft, args: PostedTrace): void {
clearTraceState(state);
const id = generateNextId(state);
state.engine = {
id,
ready: false,
source: {type: 'ARRAY_BUFFER', ...args},
};
},
openTraceFromUrl(state: StateDraft, args: {url: string}): void {
clearTraceState(state);
const id = generateNextId(state);
state.engine = {
id,
ready: false,
source: {type: 'URL', url: args.url},
};
},
openTraceFromHttpRpc(state: StateDraft, _args: {}): void {
clearTraceState(state);
const id = generateNextId(state);
state.engine = {
id,
ready: false,
source: {type: 'HTTP_RPC'},
};
},
setTraceUuid(state: StateDraft, args: {traceUuid: string}) {
state.traceUuid = args.traceUuid;
},
addTracks(state: StateDraft, args: {tracks: AddTrackArgs[]}) {
args.tracks.forEach((track) => {
const trackKey =
track.key === undefined ? generateNextId(state) : track.key;
const name = track.name;
state.tracks[trackKey] = {
key: trackKey,
name,
trackSortKey: track.trackSortKey,
trackGroup: track.trackGroup,
labels: track.labels,
uri: track.uri,
closeable: track.closeable,
};
if (track.trackGroup === SCROLLING_TRACK_GROUP) {
state.scrollingTracks.push(trackKey);
} else if (track.trackGroup !== undefined) {
const group = state.trackGroups[track.trackGroup];
if (group !== undefined) {
group.tracks.push(trackKey);
}
}
});
},
// Note: While this action has traditionally been omitted, with more and more
// dynamic tracks being added and existing ones being moved to plugins, it
// makes sense to have a generic "removeTracks" action which is un-opinionated
// about what type of tracks we are removing.
// E.g. Once debug tracks have been moved to a plugin, it makes no sense to
// keep the "removeDebugTrack()" action, as the core should have no concept of
// what debug tracks are.
removeTracks(state: StateDraft, args: {trackKeys: string[]}) {
for (const trackKey of args.trackKeys) {
removeTrack(state, trackKey);
}
},
setUtidToTrackSortKey(
state: StateDraft,
args: {threadOrderingMetadata: UtidToTrackSortKey},
) {
state.utidToThreadSortKey = args.threadOrderingMetadata;
},
addTrack(state: StateDraft, args: AddTrackArgs): void {
this.addTracks(state, {tracks: [args]});
},
addTrackGroup(
state: StateDraft,
// Define ID in action so a track group can be referred to without running
// the reducer.
args: {
name: string;
key: string;
summaryTrackKey?: string;
collapsed: boolean;
fixedOrdering?: boolean;
},
): void {
state.trackGroups[args.key] = {
name: args.name,
key: args.key,
collapsed: args.collapsed,
tracks: [],
summaryTrack: args.summaryTrackKey,
fixedOrdering: args.fixedOrdering,
};
},
maybeExpandOnlyTrackGroup(state: StateDraft, _: {}): void {
const trackGroups = Object.values(state.trackGroups);
if (trackGroups.length === 1) {
trackGroups[0].collapsed = false;
}
},
sortThreadTracks(state: StateDraft, _: {}) {
const getFullKey = (a: string) => {
const track = state.tracks[a];
const threadTrackSortKey = track.trackSortKey as ThreadTrackSortKey;
if (threadTrackSortKey.utid === undefined) {
const sortKey = track.trackSortKey as PrimaryTrackSortKey;
return [sortKey, 0, 0, 0];
}
const threadSortKey = state.utidToThreadSortKey[threadTrackSortKey.utid];
return [
/* eslint-disable @typescript-eslint/strict-boolean-expressions */
threadSortKey
? threadSortKey.sortKey
: PrimaryTrackSortKey.ORDINARY_THREAD,
threadSortKey && threadSortKey.tid !== undefined
? threadSortKey.tid
: Number.MAX_VALUE,
/* eslint-enable */
threadTrackSortKey.utid,
threadTrackSortKey.priority,
];
};
// Use a numeric collator so threads are sorted as T1, T2, ..., T10, T11,
// rather than T1, T10, T11, ..., T2, T20, T21 .
const coll = new Intl.Collator([], {sensitivity: 'base', numeric: true});
for (const group of Object.values(state.trackGroups)) {
if (group.fixedOrdering) continue;
group.tracks.sort((a: string, b: string) => {
const aRank = getFullKey(a);
const bRank = getFullKey(b);
for (let i = 0; i < aRank.length; i++) {
if (aRank[i] !== bRank[i]) return aRank[i] - bRank[i];
}
const aName = state.tracks[a].name.toLocaleLowerCase();
const bName = state.tracks[b].name.toLocaleLowerCase();
return coll.compare(aName, bName);
});
}
},
updateAggregateSorting(
state: StateDraft,
args: {id: string; column: string},
) {
let prefs = state.aggregatePreferences[args.id];
// eslint-disable-next-line @typescript-eslint/strict-boolean-expressions
if (!prefs) {
prefs = {id: args.id};
state.aggregatePreferences[args.id] = prefs;
}
if (!prefs.sorting || prefs.sorting.column !== args.column) {
// No sorting set for current column.
state.aggregatePreferences[args.id].sorting = {
column: args.column,
direction: 'DESC',
};
} else if (prefs.sorting.direction === 'DESC') {
// Toggle the direction if the column is currently sorted.
state.aggregatePreferences[args.id].sorting = {
column: args.column,
direction: 'ASC',
};
} else {
// If direction is currently 'ASC' toggle to no sorting.
state.aggregatePreferences[args.id].sorting = undefined;
}
},
moveTrack(
state: StateDraft,
args: {srcId: string; op: 'before' | 'after'; dstId: string},
): void {
const moveWithinTrackList = (trackList: string[]) => {
const newList: string[] = [];
for (let i = 0; i < trackList.length; i++) {
const curTrackId = trackList[i];
if (curTrackId === args.dstId && args.op === 'before') {
newList.push(args.srcId);
}
if (curTrackId !== args.srcId) {
newList.push(curTrackId);
}
if (curTrackId === args.dstId && args.op === 'after') {
newList.push(args.srcId);
}
}
trackList.splice(0);
newList.forEach((x) => {
trackList.push(x);
});
};
moveWithinTrackList(state.pinnedTracks);
moveWithinTrackList(state.scrollingTracks);
},
toggleTrackPinned(state: StateDraft, args: {trackKey: string}): void {
const key = args.trackKey;
const isPinned = state.pinnedTracks.includes(key);
const trackGroup = assertExists(state.tracks[key]).trackGroup;
if (isPinned) {
state.pinnedTracks.splice(state.pinnedTracks.indexOf(key), 1);
if (trackGroup === SCROLLING_TRACK_GROUP) {
state.scrollingTracks.unshift(key);
}
} else {
if (trackGroup === SCROLLING_TRACK_GROUP) {
state.scrollingTracks.splice(state.scrollingTracks.indexOf(key), 1);
}
state.pinnedTracks.push(key);
}
},
toggleTrackGroupCollapsed(state: StateDraft, args: {groupKey: string}): void {
const trackGroup = assertExists(state.trackGroups[args.groupKey]);
trackGroup.collapsed = !trackGroup.collapsed;
},
requestTrackReload(state: StateDraft, _: {}) {
// eslint-disable-next-line @typescript-eslint/strict-boolean-expressions
if (state.lastTrackReloadRequest) {
state.lastTrackReloadRequest++;
} else {
state.lastTrackReloadRequest = 1;
}
},
maybeSetPendingDeeplink(state: StateDraft, args: PendingDeeplinkState) {
state.pendingDeeplink = args;
},
clearPendingDeeplink(state: StateDraft, _: {}) {
state.pendingDeeplink = undefined;
},
// TODO(hjd): engine.ready should be a published thing. If it's part
// of the state it interacts badly with permalinks.
setEngineReady(
state: StateDraft,
args: {engineId: string; ready: boolean; mode: EngineMode},
): void {
const engine = state.engine;
if (engine === undefined || engine.id !== args.engineId) {
return;
}
engine.ready = args.ready;
engine.mode = args.mode;
},
setNewEngineMode(state: StateDraft, args: {mode: NewEngineMode}): void {
state.newEngineMode = args.mode;
},
// Marks all engines matching the given |mode| as failed.
setEngineFailed(
state: StateDraft,
args: {mode: EngineMode; failure: string},
): void {
if (state.engine !== undefined && state.engine.mode === args.mode) {
state.engine.failed = args.failure;
}
},
updateStatus(state: StateDraft, args: Status): void {
if (statusTraceEvent) {
traceEventEnd(statusTraceEvent);
}
statusTraceEvent = traceEventBegin(args.msg, {
track: MetatraceTrackId.kOmniboxStatus,
});
state.status = args;
},
// TODO(hjd): Remove setState - it causes problems due to reuse of ids.
setState(state: StateDraft, args: {newState: State}): void {
for (const key of Object.keys(state)) {
// eslint-disable-next-line @typescript-eslint/no-explicit-any
delete (state as any)[key];
}
for (const key of Object.keys(args.newState)) {
// eslint-disable-next-line @typescript-eslint/no-explicit-any
(state as any)[key] = (args.newState as any)[key];
}
// If we're loading from a permalink then none of the engines can
// possibly be ready:
if (state.engine !== undefined) {
state.engine.ready = false;
}
},
setRecordConfig(
state: StateDraft,
args: {config: RecordConfig; configType?: LoadedConfig},
): void {
state.recordConfig = args.config;
state.lastLoadedConfig = args.configType || {type: 'NONE'};
},
selectNote(state: StateDraft, args: {id: string}): void {
state.selection = {
kind: 'note',
id: args.id,
};
},
addNote(
state: StateDraft,
args: {timestamp: time; color: string; id?: string; text?: string},
): void {
const {timestamp, color, id = generateNextId(state), text = ''} = args;
state.notes[id] = {
noteType: 'DEFAULT',
id,
timestamp,
color,
text,
};
},
addSpanNote(
state: StateDraft,
args: {start: time; end: time; id?: string; color?: string},
): void {
const {
id = generateNextId(state),
color = randomColor(),
end,
start,
} = args;
state.notes[id] = {
noteType: 'SPAN',
start,
end,
color,
id,
text: '',
};
},
changeNoteColor(
state: StateDraft,
args: {id: string; newColor: string},
): void {
const note = state.notes[args.id];
if (note === undefined) return;
note.color = args.newColor;
},
changeNoteText(state: StateDraft, args: {id: string; newText: string}): void {
const note = state.notes[args.id];
if (note === undefined) return;
note.text = args.newText;
},
removeNote(state: StateDraft, args: {id: string}): void {
delete state.notes[args.id];
// Clear the selection if this note was selected
if (state.selection.kind === 'note' && state.selection.id === args.id) {
state.selection = {kind: 'empty'};
}
},
selectHeapProfile(
state: StateDraft,
args: {id: number; upid: number; ts: time; type: ProfileType},
): void {
state.selection = {
kind: 'legacy',
legacySelection: {
kind: 'HEAP_PROFILE',
id: args.id,
upid: args.upid,
ts: args.ts,
type: args.type,
},
};
},
selectPerfSamples(
state: StateDraft,
args: {
id: number;
upid: number;
leftTs: time;
rightTs: time;
type: ProfileType;
},
): void {
state.selection = {
kind: 'legacy',
legacySelection: {
kind: 'PERF_SAMPLES',
id: args.id,
upid: args.upid,
leftTs: args.leftTs,
rightTs: args.rightTs,
type: args.type,
},
};
},
selectCpuProfileSample(
state: StateDraft,
args: {id: number; utid: number; ts: time},
): void {
state.selection = {
kind: 'legacy',
legacySelection: {
kind: 'CPU_PROFILE_SAMPLE',
id: args.id,
utid: args.utid,
ts: args.ts,
},
};
},
selectSlice(
state: StateDraft,
args: {id: number; trackKey: string; table?: string; scroll?: boolean},
): void {
state.selection = {
kind: 'legacy',
legacySelection: {
kind: 'SLICE',
id: args.id,
trackKey: args.trackKey,
table: args.table,
},
};
state.pendingScrollId = args.scroll ? args.id : undefined;
},
selectGenericSlice(
state: StateDraft,
args: {
id: number;
sqlTableName: string;
start: time;
duration: duration;
trackKey: string;
detailsPanelConfig: {
kind: string;
config: GenericSliceDetailsTabConfigBase;
};
},
): void {
const detailsPanelConfig: GenericSliceDetailsTabConfig = {
id: args.id,
...args.detailsPanelConfig.config,
};
state.selection = {
kind: 'legacy',
legacySelection: {
kind: 'GENERIC_SLICE',
id: args.id,
sqlTableName: args.sqlTableName,
start: args.start,
duration: args.duration,
trackKey: args.trackKey,
detailsPanelConfig: {
kind: args.detailsPanelConfig.kind,
config: detailsPanelConfig,
},
},
};
},
setPendingScrollId(state: StateDraft, args: {pendingScrollId: number}): void {
state.pendingScrollId = args.pendingScrollId;
},
clearPendingScrollId(state: StateDraft, _: {}): void {
state.pendingScrollId = undefined;
},
selectThreadState(
state: StateDraft,
args: {id: number; trackKey: string},
): void {
state.selection = {
kind: 'legacy',
legacySelection: {
kind: 'THREAD_STATE',
id: args.id,
trackKey: args.trackKey,
},
};
},
startRecording(state: StateDraft, _: {}): void {
state.recordingInProgress = true;
state.lastRecordingError = undefined;
state.recordingCancelled = false;
},
stopRecording(state: StateDraft, _: {}): void {
state.recordingInProgress = false;
},
cancelRecording(state: StateDraft, _: {}): void {
state.recordingInProgress = false;
state.recordingCancelled = true;
},
setExtensionAvailable(state: StateDraft, args: {available: boolean}): void {
state.extensionInstalled = args.available;
},
setRecordingTarget(state: StateDraft, args: {target: RecordingTarget}): void {
state.recordingTarget = args.target;
},
setFetchChromeCategories(state: StateDraft, args: {fetch: boolean}): void {
state.fetchChromeCategories = args.fetch;
},
setAvailableAdbDevices(
state: StateDraft,
args: {devices: AdbRecordingTarget[]},
): void {
state.availableAdbDevices = args.devices;
},
setOmnibox(state: StateDraft, args: OmniboxState): void {
state.omniboxState = args;
},
setOmniboxMode(state: StateDraft, args: {mode: OmniboxMode}): void {
state.omniboxState.mode = args.mode;
},
selectArea(
state: StateDraft,
args: {start: time; end: time; tracks: string[]},
): void {
const {start, end, tracks} = args;
assertTrue(start <= end);
state.selection = {
kind: 'area',
start,
end,
tracks,
};
},
toggleTrackSelection(
state: StateDraft,
args: {key: string; isTrackGroup: boolean},
) {
const selection = state.selection;
if (selection.kind !== 'area') {
return;
}
const index = selection.tracks.indexOf(args.key);
if (index > -1) {
selection.tracks.splice(index, 1);
if (args.isTrackGroup) {
// Also remove all child tracks.
for (const childTrack of state.trackGroups[args.key].tracks) {
const childIndex = selection.tracks.indexOf(childTrack);
if (childIndex > -1) {
selection.tracks.splice(childIndex, 1);
}
}
}
} else {
selection.tracks.push(args.key);
if (args.isTrackGroup) {
// Also add all child tracks.
for (const childTrack of state.trackGroups[args.key].tracks) {
if (!selection.tracks.includes(childTrack)) {
selection.tracks.push(childTrack);
}
}
}
}
// It's super unexpected that |toggleTrackSelection| does not cause
// selection to be updated and this leads to bugs for people who do:
// if (oldSelection !== state.selection) etc.
// To solve this re-create the selection object here:
state.selection = Object.assign({}, state.selection);
},
setVisibleTraceTime(state: StateDraft, args: VisibleState): void {
state.frontendLocalState.visibleState = {...args};
},
setChromeCategories(state: StateDraft, args: {categories: string[]}): void {
state.chromeCategories = args.categories;
},
setLastRecordingError(state: StateDraft, args: {error?: string}): void {
state.lastRecordingError = args.error;
state.recordingStatus = undefined;
},
setRecordingStatus(state: StateDraft, args: {status?: string}): void {
state.recordingStatus = args.status;
state.lastRecordingError = undefined;
},
togglePerfDebug(state: StateDraft, _: {}): void {
state.perfDebug = !state.perfDebug;
},
setSidebar(state: StateDraft, args: {visible: boolean}): void {
state.sidebarVisible = args.visible;
},
setHoveredUtidAndPid(state: StateDraft, args: {utid: number; pid: number}) {
state.hoveredPid = args.pid;
state.hoveredUtid = args.utid;
},
setHighlightedSliceId(state: StateDraft, args: {sliceId: number}) {
state.highlightedSliceId = args.sliceId;
},
setHighlightedFlowLeftId(state: StateDraft, args: {flowId: number}) {
state.focusedFlowIdLeft = args.flowId;
},
setHighlightedFlowRightId(state: StateDraft, args: {flowId: number}) {
state.focusedFlowIdRight = args.flowId;
},
setSearchIndex(state: StateDraft, args: {index: number}) {
state.searchIndex = args.index;
},
setHoverCursorTimestamp(state: StateDraft, args: {ts: time}) {
state.hoverCursorTimestamp = args.ts;
},
setHoveredNoteTimestamp(state: StateDraft, args: {ts: time}) {
state.hoveredNoteTimestamp = args.ts;
},
// Add a tab with a given URI to the tab bar and show it.
// If the tab is already present in the tab bar, just show it.
showTab(state: StateDraft, args: {uri: string}) {
// Add tab, unless we're talking about the special current_selection tab
if (args.uri !== 'current_selection') {
// Add tab to tab list if not already
if (!state.tabs.openTabs.some((uri) => uri === args.uri)) {
state.tabs.openTabs.push(args.uri);
}
}
state.tabs.currentTab = args.uri;
},
// Hide a tab in the tab bar pick a new tab to show.
// Note: Attempting to hide the "current_selection" tab doesn't work. This tab
// is special and cannot be removed.
hideTab(state: StateDraft, args: {uri: string}) {
const tabs = state.tabs;
// If the removed tab is the "current" tab, we must find a new tab to focus
if (args.uri === tabs.currentTab) {
// Remember the index of the current tab
const currentTabIdx = tabs.openTabs.findIndex((uri) => uri === args.uri);
// Remove the tab
tabs.openTabs = tabs.openTabs.filter((uri) => uri !== args.uri);
if (currentTabIdx !== -1) {
if (tabs.openTabs.length === 0) {
// No more tabs, use current selection
tabs.currentTab = 'current_selection';
} else if (currentTabIdx < tabs.openTabs.length - 1) {
// Pick the tab to the right
tabs.currentTab = tabs.openTabs[currentTabIdx];
} else {
// Pick the last tab
const lastTab = tabs.openTabs[tabs.openTabs.length - 1];
tabs.currentTab = lastTab;
}
}
} else {
// Otherwise just remove the tab
tabs.openTabs = tabs.openTabs.filter((uri) => uri !== args.uri);
}
},
clearAllPinnedTracks(state: StateDraft, _: {}) {
const pinnedTracks = state.pinnedTracks.slice();
for (let index = pinnedTracks.length - 1; index >= 0; index--) {
const trackKey = pinnedTracks[index];
this.toggleTrackPinned(state, {trackKey});
}
},
togglePivotTable(
state: StateDraft,
args: {area?: {start: time; end: time; tracks: string[]}},
) {
state.nonSerializableState.pivotTable.selectionArea = args.area;
state.nonSerializableState.pivotTable.queryResult = null;
},
setPivotStateQueryResult(
state: StateDraft,
args: {queryResult: PivotTableResult | null},
) {
state.nonSerializableState.pivotTable.queryResult = args.queryResult;
},
setPivotTableConstrainToArea(state: StateDraft, args: {constrain: boolean}) {
state.nonSerializableState.pivotTable.constrainToArea = args.constrain;
},
dismissFlamegraphModal(state: StateDraft, _: {}) {
state.flamegraphModalDismissed = true;
},
addPivotTableAggregation(
state: StateDraft,
args: {aggregation: Aggregation; after: number},
) {
state.nonSerializableState.pivotTable.selectedAggregations.splice(
args.after,
0,
args.aggregation,
);
},
removePivotTableAggregation(state: StateDraft, args: {index: number}) {
state.nonSerializableState.pivotTable.selectedAggregations.splice(
args.index,
1,
);
},
setPivotTableQueryRequested(
state: StateDraft,
args: {queryRequested: boolean},
) {
state.nonSerializableState.pivotTable.queryRequested = args.queryRequested;
},
setPivotTablePivotSelected(
state: StateDraft,
args: {column: TableColumn; selected: boolean},
) {
toggleEnabled(
tableColumnEquals,
state.nonSerializableState.pivotTable.selectedPivots,
args.column,
args.selected,
);
},
setPivotTableAggregationFunction(
state: StateDraft,
args: {index: number; function: AggregationFunction},
) {
state.nonSerializableState.pivotTable.selectedAggregations[
args.index
].aggregationFunction = args.function;
},
setPivotTableSortColumn(
state: StateDraft,
args: {aggregationIndex: number; order: SortDirection},
) {
state.nonSerializableState.pivotTable.selectedAggregations =
state.nonSerializableState.pivotTable.selectedAggregations.map(
(agg, index) => ({
column: agg.column,
aggregationFunction: agg.aggregationFunction,
sortDirection:
index === args.aggregationIndex ? args.order : undefined,
}),
);
},
changePivotTablePivotOrder(
state: StateDraft,
args: {from: number; to: number; direction: DropDirection},
) {
const pivots = state.nonSerializableState.pivotTable.selectedPivots;
state.nonSerializableState.pivotTable.selectedPivots = performReordering(
computeIntervals(pivots.length, args.from, args.to, args.direction),
pivots,
);
},
changePivotTableAggregationOrder(
state: StateDraft,
args: {from: number; to: number; direction: DropDirection},
) {
const aggregations =
state.nonSerializableState.pivotTable.selectedAggregations;
state.nonSerializableState.pivotTable.selectedAggregations =
performReordering(
computeIntervals(
aggregations.length,
args.from,
args.to,
args.direction,
),
aggregations,
);
},
};
// When we are on the frontend side, we don't really want to execute the
// actions above, we just want to serialize them and marshal their
// arguments, send them over to the controller side and have them being
// executed there. The magic below takes care of turning each action into a
// function that returns the marshaled args.
// A DeferredAction is a bundle of Args and a method name. This is the marshaled
// version of a StateActions method call.
export interface DeferredAction<Args = {}> {
type: string;
args: Args;
}
// This type magic creates a type function DeferredActions<T> which takes a type
// T and 'maps' its attributes. For each attribute on T matching the signature:
// (state: StateDraft, args: Args) => void
// DeferredActions<T> has an attribute:
// (args: Args) => DeferredAction<Args>
type ActionFunction<Args> = (state: StateDraft, args: Args) => void;
type DeferredActionFunc<T> = T extends ActionFunction<infer Args>
? (args: Args) => DeferredAction<Args>
: never;
type DeferredActions<C> = {
[P in keyof C]: DeferredActionFunc<C[P]>;
};
// Actions is an implementation of DeferredActions<typeof StateActions>.
// (since StateActions is a variable not a type we have to do
// 'typeof StateActions' to access the (unnamed) type of StateActions).
// It's a Proxy such that any attribute access returns a function:
// (args) => {return {type: ATTRIBUTE_NAME, args};}
export const Actions =
// eslint-disable-next-line @typescript-eslint/no-explicit-any
new Proxy<DeferredActions<typeof StateActions>>({} as any, {
// eslint-disable-next-line @typescript-eslint/no-explicit-any
get(_: any, prop: string, _2: any) {
return (args: {}): DeferredAction<{}> => {
return {
type: prop,
args,
};
};
},
});