mirror of
https://github.com/grafana/grafana.git
synced 2025-02-20 11:48:34 -06:00
* Refactor: initial commit * Tests: updates tests * Tests: updates snapshots * Chore: updates after PR comments * Chore: renamed initVariablesBatch * Tests: adds transactionReducer tests * Chore: updates after PR comments * Refactor: renames cancelAllDataSourceRequests * Refactor: reduces cancellation complexity * Tests: adds tests for cancelAllInFlightRequests * Tests: adds initVariablesTransaction tests * Tests: adds tests for cleanUpVariables and cancelVariables * Always cleanup dashboard on unmount, even if init is in progress. Check if init phase has changed after services init is completed * fixed failing tests and added some more to test new scenario. Co-authored-by: Torkel Ödegaard <torkel@grafana.com> Co-authored-by: Marcus Andersson <marcus.andersson@grafana.com>
167 lines
5.0 KiB
TypeScript
167 lines
5.0 KiB
TypeScript
// Services & Utils
|
|
import { getBackendSrv } from '@grafana/runtime';
|
|
import { createSuccessNotification } from 'app/core/copy/appNotification';
|
|
// Actions
|
|
import { loadPluginDashboards } from '../../plugins/state/actions';
|
|
import {
|
|
cleanUpDashboard,
|
|
loadDashboardPermissions,
|
|
panelModelAndPluginReady,
|
|
setPanelAngularComponent,
|
|
} from './reducers';
|
|
import { notifyApp } from 'app/core/actions';
|
|
import { loadPanelPlugin } from 'app/features/plugins/state/actions';
|
|
// Types
|
|
import { DashboardAcl, DashboardAclUpdateDTO, NewDashboardAclItem, PermissionLevel, ThunkResult } from 'app/types';
|
|
import { PanelModel } from './PanelModel';
|
|
import { cancelVariables } from '../../variables/state/actions';
|
|
|
|
export function getDashboardPermissions(id: number): ThunkResult<void> {
|
|
return async dispatch => {
|
|
const permissions = await getBackendSrv().get(`/api/dashboards/id/${id}/permissions`);
|
|
dispatch(loadDashboardPermissions(permissions));
|
|
};
|
|
}
|
|
|
|
function toUpdateItem(item: DashboardAcl): DashboardAclUpdateDTO {
|
|
return {
|
|
userId: item.userId,
|
|
teamId: item.teamId,
|
|
role: item.role,
|
|
permission: item.permission,
|
|
};
|
|
}
|
|
|
|
export function updateDashboardPermission(
|
|
dashboardId: number,
|
|
itemToUpdate: DashboardAcl,
|
|
level: PermissionLevel
|
|
): ThunkResult<void> {
|
|
return async (dispatch, getStore) => {
|
|
const { dashboard } = getStore();
|
|
const itemsToUpdate = [];
|
|
|
|
for (const item of dashboard.permissions) {
|
|
if (item.inherited) {
|
|
continue;
|
|
}
|
|
|
|
const updated = toUpdateItem(item);
|
|
|
|
// if this is the item we want to update, update it's permission
|
|
if (itemToUpdate === item) {
|
|
updated.permission = level;
|
|
}
|
|
|
|
itemsToUpdate.push(updated);
|
|
}
|
|
|
|
await getBackendSrv().post(`/api/dashboards/id/${dashboardId}/permissions`, { items: itemsToUpdate });
|
|
await dispatch(getDashboardPermissions(dashboardId));
|
|
};
|
|
}
|
|
|
|
export function removeDashboardPermission(dashboardId: number, itemToDelete: DashboardAcl): ThunkResult<void> {
|
|
return async (dispatch, getStore) => {
|
|
const dashboard = getStore().dashboard;
|
|
const itemsToUpdate = [];
|
|
|
|
for (const item of dashboard.permissions) {
|
|
if (item.inherited || item === itemToDelete) {
|
|
continue;
|
|
}
|
|
itemsToUpdate.push(toUpdateItem(item));
|
|
}
|
|
|
|
await getBackendSrv().post(`/api/dashboards/id/${dashboardId}/permissions`, { items: itemsToUpdate });
|
|
await dispatch(getDashboardPermissions(dashboardId));
|
|
};
|
|
}
|
|
|
|
export function addDashboardPermission(dashboardId: number, newItem: NewDashboardAclItem): ThunkResult<void> {
|
|
return async (dispatch, getStore) => {
|
|
const { dashboard } = getStore();
|
|
const itemsToUpdate = [];
|
|
|
|
for (const item of dashboard.permissions) {
|
|
if (item.inherited) {
|
|
continue;
|
|
}
|
|
itemsToUpdate.push(toUpdateItem(item));
|
|
}
|
|
|
|
itemsToUpdate.push({
|
|
userId: newItem.userId,
|
|
teamId: newItem.teamId,
|
|
role: newItem.role,
|
|
permission: newItem.permission,
|
|
});
|
|
|
|
await getBackendSrv().post(`/api/dashboards/id/${dashboardId}/permissions`, { items: itemsToUpdate });
|
|
await dispatch(getDashboardPermissions(dashboardId));
|
|
};
|
|
}
|
|
|
|
export function importDashboard(data: any, dashboardTitle: string): ThunkResult<void> {
|
|
return async dispatch => {
|
|
await getBackendSrv().post('/api/dashboards/import', data);
|
|
dispatch(notifyApp(createSuccessNotification('Dashboard Imported', dashboardTitle)));
|
|
dispatch(loadPluginDashboards());
|
|
};
|
|
}
|
|
|
|
export function removeDashboard(uri: string): ThunkResult<void> {
|
|
return async dispatch => {
|
|
await getBackendSrv().delete(`/api/dashboards/${uri}`);
|
|
dispatch(loadPluginDashboards());
|
|
};
|
|
}
|
|
|
|
export function initDashboardPanel(panel: PanelModel): ThunkResult<void> {
|
|
return async (dispatch, getStore) => {
|
|
let plugin = getStore().plugins.panels[panel.type];
|
|
|
|
if (!plugin) {
|
|
plugin = await dispatch(loadPanelPlugin(panel.type));
|
|
}
|
|
|
|
if (!panel.plugin) {
|
|
panel.pluginLoaded(plugin);
|
|
}
|
|
|
|
dispatch(panelModelAndPluginReady({ panelId: panel.id, plugin }));
|
|
};
|
|
}
|
|
|
|
export function changePanelPlugin(panel: PanelModel, pluginId: string): ThunkResult<void> {
|
|
return async (dispatch, getStore) => {
|
|
// ignore action is no change
|
|
if (panel.type === pluginId) {
|
|
return;
|
|
}
|
|
|
|
const store = getStore();
|
|
let plugin = store.plugins.panels[pluginId];
|
|
|
|
if (!plugin) {
|
|
plugin = await dispatch(loadPanelPlugin(pluginId));
|
|
}
|
|
|
|
// clean up angular component (scope / ctrl state)
|
|
const angularComponent = store.dashboard.panels[panel.id].angularComponent;
|
|
if (angularComponent) {
|
|
angularComponent.destroy();
|
|
dispatch(setPanelAngularComponent({ panelId: panel.id, angularComponent: null }));
|
|
}
|
|
|
|
panel.changePlugin(plugin);
|
|
|
|
dispatch(panelModelAndPluginReady({ panelId: panel.id, plugin }));
|
|
};
|
|
}
|
|
|
|
export const cleanUpDashboardAndVariables = (): ThunkResult<void> => dispatch => {
|
|
dispatch(cleanUpDashboard());
|
|
dispatch(cancelVariables());
|
|
};
|