1113439055

Committed 19 Dec 2023 09:01PM UTC coverage: 82.752% (-17.2%) from 99.964%

Build # 1113439055

Build Type

Pull #4258

gitlab-ci

Committed by

mender-test-bot

Commit Message

chore: Types update

Signed-off-by: Mender Test Bot <mender@northern.tech>

Pull Request Pull Request #4258: chore: Types update

Run Details

4326 of 6319 branches covered (0.0%)

8348 of 10088 relevant lines covered (82.75%)

189.39 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

86.36

/src/js/actions/organizationActions.js

// Copyright 2020 Northern.tech AS
//
//    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 { jwtDecode } from 'jwt-decode';
import hashString from 'md5';
import Cookies from 'universal-cookie';

import Api, { apiUrl, headerNames } from '../api/general-api';
import { SET_ANNOUNCEMENT, SORTING_OPTIONS, TIMEOUTS, locations } from '../constants/appConstants';
import { DEVICE_LIST_DEFAULTS } from '../constants/deviceConstants';
import {
  RECEIVE_AUDIT_LOGS,
  RECEIVE_CURRENT_CARD,
  RECEIVE_EXTERNAL_DEVICE_INTEGRATIONS,
  RECEIVE_SAML_CONFIGS,
  RECEIVE_SETUP_INTENT,
  RECEIVE_WEBHOOK_EVENTS,
  SET_AUDITLOG_STATE,
  SET_ORGANIZATION
} from '../constants/organizationConstants';
import { deepCompare } from '../helpers';
import { getCurrentSession, getTenantCapabilities } from '../selectors';
import { commonErrorFallback, commonErrorHandler, setFirstLoginAfterSignup, setSnackbar } from './appActions';
import { deviceAuthV2, iotManagerBaseURL } from './deviceActions';

const cookies = new Cookies();
export const auditLogsApiUrl = `${apiUrl.v1}/auditlogs`;
export const tenantadmApiUrlv1 = `${apiUrl.v1}/tenantadm`;
export const tenantadmApiUrlv2 = `${apiUrl.v2}/tenantadm`;
export const samlIdpApiUrlv1 = `${apiUrl.v1}/useradm/sso/idp/metadata`;

const { page: defaultPage, perPage: defaultPerPage } = DEVICE_LIST_DEFAULTS;

export const cancelRequest = (tenantId, reason) => dispatch =>
  Api.post(`${tenantadmApiUrlv2}/tenants/${tenantId}/cancel`, { reason: reason }).then(() =>
    Promise.resolve(dispatch(setSnackbar('Deactivation request was sent successfully', TIMEOUTS.fiveSeconds, '')))
  );

export const getTargetLocation = key => {
  if (devLocations.includes(window.location.hostname)) {
    return '';
  }
  let subdomainSections = window.location.hostname.substring(0, window.location.hostname.indexOf(locations.us.location)).split('.');
  subdomainSections = subdomainSections.splice(0, subdomainSections.length - 1);
  if (!subdomainSections.find(section => section === key)) {
    subdomainSections = key === locations.us.key ? subdomainSections.filter(section => !locations[section]) : [...subdomainSections, key];
    return `https://${[...subdomainSections, ...locations.us.location.split('.')].join('.')}`;
  }
  return `https://${window.location.hostname}`;
};

const devLocations = ['localhost', 'docker.mender.io'];
export const createOrganizationTrial = data => dispatch => {
  const { key } = locations[data.location];
  const targetLocation = getTargetLocation(key);
  const target = `${targetLocation}${tenantadmApiUrlv2}/tenants/trial`;
  return Api.postUnauthorized(target, data)
    .catch(err => {
      if (err.response.status >= 400 && err.response.status < 500) {
        dispatch(setSnackbar(err.response.data.error, TIMEOUTS.fiveSeconds, ''));
        return Promise.reject(err);
      }
    })
    .then(({ headers }) => {
      cookies.remove('oauth');
      cookies.remove('externalID');
      cookies.remove('email');
      dispatch(setFirstLoginAfterSignup(true));
      return new Promise(resolve =>
        setTimeout(() => {
          window.location.assign(`${targetLocation}${headers.location || ''}`);
          return resolve();
        }, TIMEOUTS.fiveSeconds)
      );
    });
};

export const startCardUpdate = () => dispatch =>
  Api.post(`${tenantadmApiUrlv2}/billing/card`)
    .then(res => {
      dispatch({
        type: RECEIVE_SETUP_INTENT,
        intentId: res.data.intent_id
      });
      return Promise.resolve(res.data.secret);
    })
    .catch(err => commonErrorHandler(err, `Updating the card failed:`, dispatch));

export const confirmCardUpdate = () => (dispatch, getState) =>
  Api.post(`${tenantadmApiUrlv2}/billing/card/${getState().organization.intentId}/confirm`)
    .then(() =>
      Promise.all([
        dispatch(setSnackbar('Payment card was updated successfully')),
        dispatch({
          type: RECEIVE_SETUP_INTENT,
          intentId: null
        })
      ])
    )
    .catch(err => commonErrorHandler(err, `Updating the card failed:`, dispatch));

export const getCurrentCard = () => dispatch =>
  Api.get(`${tenantadmApiUrlv2}/billing`).then(res => {
    const { last4, exp_month, exp_year, brand } = res.data.card || {};
    return Promise.resolve(
      dispatch({
        type: RECEIVE_CURRENT_CARD,
        card: {
          brand,
          last4,
          expiration: { month: exp_month, year: exp_year }
        }
      })
    );
  });

export const startUpgrade = tenantId => dispatch =>
  Api.post(`${tenantadmApiUrlv2}/tenants/${tenantId}/upgrade/start`)
    .then(({ data }) => Promise.resolve(data.secret))
    .catch(err => commonErrorHandler(err, `There was an error upgrading your account:`, dispatch));

export const cancelUpgrade = tenantId => () => Api.post(`${tenantadmApiUrlv2}/tenants/${tenantId}/upgrade/cancel`);

export const completeUpgrade = (tenantId, plan) => dispatch =>
  Api.post(`${tenantadmApiUrlv2}/tenants/${tenantId}/upgrade/complete`, { plan })
    .catch(err => commonErrorHandler(err, `There was an error upgrading your account:`, dispatch))
    .then(() => Promise.resolve(dispatch(getUserOrganization())));

const prepareAuditlogQuery = ({ startDate, endDate, user: userFilter, type, detail: detailFilter, sort = {} }) => {
  const userId = userFilter?.id || userFilter;
  const detail = detailFilter?.id || detailFilter;
  const createdAfter = startDate ? `&created_after=${Math.round(Date.parse(startDate) / 1000)}` : '';
  const createdBefore = endDate ? `&created_before=${Math.round(Date.parse(endDate) / 1000)}` : '';
  const typeSearch = type ? `&object_type=${type.value}`.toLowerCase() : '';
  const userSearch = userId ? `&actor_id=${userId}` : '';
  const objectSearch = type && detail ? `&${type.queryParameter}=${encodeURIComponent(detail)}` : '';
  const { direction = SORTING_OPTIONS.desc } = sort;
  return `${createdAfter}${createdBefore}${userSearch}${typeSearch}${objectSearch}&sort=${direction}`;
};

export const getAuditLogs = selectionState => (dispatch, getState) => {
  const { page, perPage } = selectionState;
  const { hasAuditlogs } = getTenantCapabilities(getState());
  if (!hasAuditlogs) {
    return Promise.resolve();
  }
  return Api.get(`${auditLogsApiUrl}/logs?page=${page}&per_page=${perPage}${prepareAuditlogQuery(selectionState)}`)
    .then(res => {
      let total = res.headers[headerNames.total];
      total = Number(total || res.data.length);
      return Promise.resolve(dispatch({ type: RECEIVE_AUDIT_LOGS, events: res.data, total }));
    })
    .catch(err => commonErrorHandler(err, `There was an error retrieving audit logs:`, dispatch));
};

export const getAuditLogsCsvLink = () => (dispatch, getState) =>
  Promise.resolve(`${auditLogsApiUrl}/logs/export?limit=20000${prepareAuditlogQuery(getState().organization.auditlog.selectionState)}`);

export const setAuditlogsState = selectionState => (dispatch, getState) => {
  const currentState = getState().organization.auditlog.selectionState;
  let nextState = {
    ...currentState,
    ...selectionState,
    sort: { ...currentState.sort, ...selectionState.sort }
  };
  let tasks = [];
  // eslint-disable-next-line no-unused-vars
  const { isLoading: currentLoading, selectedIssue: currentIssue, ...currentRequestState } = currentState;
  // eslint-disable-next-line no-unused-vars
  const { isLoading: selectionLoading, selectedIssue: selectionIssue, ...selectionRequestState } = nextState;
  if (!deepCompare(currentRequestState, selectionRequestState)) {
    nextState.isLoading = true;
    tasks.push(dispatch(getAuditLogs(nextState)).finally(() => dispatch(setAuditlogsState({ isLoading: false }))));
  }
  tasks.push(dispatch({ type: SET_AUDITLOG_STATE, state: nextState }));
  return Promise.all(tasks);
};

/*
  Tenant management + Hosted Mender
*/
export const tenantDataDivergedMessage = 'The system detected there is a change in your plan or purchased add-ons. Please log out and log in again';
export const getUserOrganization = () => (dispatch, getState) =>
  Api.get(`${tenantadmApiUrlv1}/user/tenant`).then(res => {
    let tasks = [dispatch({ type: SET_ORGANIZATION, organization: res.data })];
    const { addons, plan, trial } = res.data;
    const { token } = getCurrentSession(getState());
    const jwt = jwtDecode(token);
    const jwtData = { addons: jwt['mender.addons'], plan: jwt['mender.plan'], trial: jwt['mender.trial'] };
    if (!deepCompare({ addons, plan, trial }, jwtData)) {
      const hash = hashString(tenantDataDivergedMessage);
      cookies.remove(`${jwt.sub}${hash}`);
      tasks.push(dispatch({ type: SET_ANNOUNCEMENT, announcement: tenantDataDivergedMessage }));
    }
    return Promise.all(tasks);
  });

export const sendSupportMessage = content => dispatch =>
  Api.post(`${tenantadmApiUrlv2}/contact/support`, content)
    .catch(err => commonErrorHandler(err, 'There was an error sending your request', dispatch, commonErrorFallback))
    .then(() => Promise.resolve(dispatch(setSnackbar('Your request was sent successfully', TIMEOUTS.fiveSeconds, ''))));

export const requestPlanChange = (tenantId, content) => dispatch =>
  Api.post(`${tenantadmApiUrlv2}/tenants/${tenantId}/plan`, content)
    .catch(err => commonErrorHandler(err, 'There was an error sending your request', dispatch, commonErrorFallback))
    .then(() => Promise.resolve(dispatch(setSnackbar('Your request was sent successfully', TIMEOUTS.fiveSeconds, ''))));

export const downloadLicenseReport = () => dispatch =>
  Api.get(`${deviceAuthV2}/reports/devices`)
    .catch(err => commonErrorHandler(err, 'There was an error downloading the report', dispatch, commonErrorFallback))
    .then(res => res.data);

export const createIntegration = integration => dispatch => {
  // eslint-disable-next-line no-unused-vars
  const { credentials, id, provider, ...remainder } = integration;
  return Api.post(`${iotManagerBaseURL}/integrations`, { provider, credentials, ...remainder })
    .catch(err => commonErrorHandler(err, 'There was an error creating the integration', dispatch, commonErrorFallback))
    .then(() => Promise.all([dispatch(setSnackbar('The integration was set up successfully')), dispatch(getIntegrations())]));
};

export const changeIntegration = integration => dispatch =>
  Api.put(`${iotManagerBaseURL}/integrations/${integration.id}/credentials`, integration.credentials)
    .catch(err => commonErrorHandler(err, 'There was an error updating the integration', dispatch, commonErrorFallback))
    .then(() => Promise.all([dispatch(setSnackbar('The integration was updated successfully')), dispatch(getIntegrations())]));

export const deleteIntegration = integration => (dispatch, getState) =>
  Api.delete(`${iotManagerBaseURL}/integrations/${integration.id}`, {})
    .catch(err => commonErrorHandler(err, 'There was an error removing the integration', dispatch, commonErrorFallback))
    .then(() => {
      const integrations = getState().organization.externalDeviceIntegrations.filter(item => integration.provider !== item.provider);
      return Promise.all([
        dispatch(setSnackbar('The integration was removed successfully')),
        dispatch({ type: RECEIVE_EXTERNAL_DEVICE_INTEGRATIONS, value: integrations })
      ]);
    });

export const getIntegrations = () => (dispatch, getState) =>
  Api.get(`${iotManagerBaseURL}/integrations`)
    .catch(err => commonErrorHandler(err, 'There was an error retrieving the integration', dispatch, commonErrorFallback))
    .then(({ data }) => {
      const existingIntegrations = getState().organization.externalDeviceIntegrations;
      const integrations = data.reduce((accu, item) => {
        const existingIntegration = existingIntegrations.find(integration => item.id === integration.id) ?? {};
        const integration = { ...existingIntegration, ...item };
        accu.push(integration);
        return accu;
      }, []);
      return Promise.resolve(dispatch({ type: RECEIVE_EXTERNAL_DEVICE_INTEGRATIONS, value: integrations }));
    });

export const getWebhookEvents =
  (config = {}) =>
  (dispatch, getState) => {
    const { isFollowUp, page = defaultPage, perPage = defaultPerPage } = config;
    return Api.get(`${iotManagerBaseURL}/events?page=${page}&per_page=${perPage}`)
      .catch(err => commonErrorHandler(err, 'There was an error retrieving activity for this integration', dispatch, commonErrorFallback))
      .then(({ data }) => {
        let tasks = [
          dispatch({
            type: RECEIVE_WEBHOOK_EVENTS,
            value: isFollowUp ? getState().organization.webhooks.events : data,
            total: (page - 1) * perPage + data.length
          })
        ];
        if (data.length >= perPage && !isFollowUp) {
          tasks.push(dispatch(getWebhookEvents({ isFollowUp: true, page: page + 1, perPage: 1 })));
        }
        return Promise.all(tasks);
      });
  };

const samlConfigActions = {
  create: { success: 'stored', error: 'storing' },
  edit: { success: 'updated', error: 'updating' },
  read: { success: '', error: 'retrieving' },
  remove: { success: 'removed', error: 'removing' }
};

const samlConfigActionErrorHandler = (err, type) => dispatch =>
  commonErrorHandler(err, `There was an error ${samlConfigActions[type].error} the SAML configuration.`, dispatch, commonErrorFallback);

const samlConfigActionSuccessHandler = type => dispatch => dispatch(setSnackbar(`The SAML configuration was ${samlConfigActions[type].success} successfully`));

export const storeSamlConfig = config => dispatch =>
  Api.post(samlIdpApiUrlv1, config, { headers: { 'Content-Type': 'application/samlmetadata+xml', Accept: 'application/json' } })
    .catch(err => dispatch(samlConfigActionErrorHandler(err, 'create')))
    .then(() => Promise.all([dispatch(samlConfigActionSuccessHandler('create')), dispatch(getSamlConfigs())]));

export const changeSamlConfig =
  ({ id, config }) =>
  dispatch =>
    Api.put(`${samlIdpApiUrlv1}/${id}`, config, { headers: { 'Content-Type': 'application/samlmetadata+xml', Accept: 'application/json' } })
      .catch(err => dispatch(samlConfigActionErrorHandler(err, 'edit')))
      .then(() => Promise.all([dispatch(samlConfigActionSuccessHandler('edit')), dispatch(getSamlConfigs())]));

export const deleteSamlConfig =
  ({ id }) =>
  (dispatch, getState) =>
    Api.delete(`${samlIdpApiUrlv1}/${id}`)
      .catch(err => dispatch(samlConfigActionErrorHandler(err, 'remove')))
      .then(() => {
        const configs = getState().organization.samlConfigs.filter(item => id !== item.id);
        return Promise.all([dispatch(samlConfigActionSuccessHandler('remove')), dispatch({ type: RECEIVE_SAML_CONFIGS, value: configs })]);
      });

const getSamlConfigById = config => dispatch =>
  Api.get(`${samlIdpApiUrlv1}/${config.id}`)
    .catch(err => dispatch(samlConfigActionErrorHandler(err, 'read')))
    .then(({ data }) => Promise.resolve({ ...config, config: data }));

export const getSamlConfigs = () => dispatch =>
  Api.get(samlIdpApiUrlv1)
    .catch(err => commonErrorHandler(err, 'There was an error retrieving SAML configurations', dispatch, commonErrorFallback))
    .then(({ data }) =>
      Promise.all(data.map(config => Promise.resolve(dispatch(getSamlConfigById(config))))).then(configs => {
        return dispatch({ type: RECEIVE_SAML_CONFIGS, value: configs });
      })
    );

1	// Copyright 2020 Northern.tech AS
2	//
3	// Licensed under the Apache License, Version 2.0 (the "License");
4	// you may not use this file except in compliance with the License.
5	// You may obtain a copy of the License at
6	//
7	// http://www.apache.org/licenses/LICENSE-2.0
8	//
9	// Unless required by applicable law or agreed to in writing, software
10	// distributed under the License is distributed on an "AS IS" BASIS,
11	// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12	// See the License for the specific language governing permissions and
13	// limitations under the License.
14	import { jwtDecode } from 'jwt-decode';
15	import hashString from 'md5';
16	import Cookies from 'universal-cookie';
17
18	import Api, { apiUrl, headerNames } from '../api/general-api';
19	import { SET_ANNOUNCEMENT, SORTING_OPTIONS, TIMEOUTS, locations } from '../constants/appConstants';
20	import { DEVICE_LIST_DEFAULTS } from '../constants/deviceConstants';
21	import {
22	RECEIVE_AUDIT_LOGS,
23	RECEIVE_CURRENT_CARD,
24	RECEIVE_EXTERNAL_DEVICE_INTEGRATIONS,
25	RECEIVE_SAML_CONFIGS,
26	RECEIVE_SETUP_INTENT,
27	RECEIVE_WEBHOOK_EVENTS,
28	SET_AUDITLOG_STATE,
29	SET_ORGANIZATION
30	} from '../constants/organizationConstants';
31	import { deepCompare } from '../helpers';
32	import { getCurrentSession, getTenantCapabilities } from '../selectors';
33	import { commonErrorFallback, commonErrorHandler, setFirstLoginAfterSignup, setSnackbar } from './appActions';
34	import { deviceAuthV2, iotManagerBaseURL } from './deviceActions';
35
36	const cookies = new Cookies();	183✔
37	export const auditLogsApiUrl = `${apiUrl.v1}/auditlogs`;	183✔
38	export const tenantadmApiUrlv1 = `${apiUrl.v1}/tenantadm`;	183✔
39	export const tenantadmApiUrlv2 = `${apiUrl.v2}/tenantadm`;	183✔
40	export const samlIdpApiUrlv1 = `${apiUrl.v1}/useradm/sso/idp/metadata`;	183✔
41
42	const { page: defaultPage, perPage: defaultPerPage } = DEVICE_LIST_DEFAULTS;	183✔
43
44	export const cancelRequest = (tenantId, reason) => dispatch =>	183✔
45	Api.post(`${tenantadmApiUrlv2}/tenants/${tenantId}/cancel`, { reason: reason }).then(() =>	1✔
46	Promise.resolve(dispatch(setSnackbar('Deactivation request was sent successfully', TIMEOUTS.fiveSeconds, '')))	1✔
47	);
48
49	export const getTargetLocation = key => {	183✔
50	if (devLocations.includes(window.location.hostname)) {	14✔
51	return '';	6✔
52	}
53	let subdomainSections = window.location.hostname.substring(0, window.location.hostname.indexOf(locations.us.location)).split('.');	8✔
54	subdomainSections = subdomainSections.splice(0, subdomainSections.length - 1);	8✔
55	if (!subdomainSections.find(section => section === key)) {	8✔
56	subdomainSections = key === locations.us.key ? subdomainSections.filter(section => !locations[section]) : [...subdomainSections, key];	7✔
57	return `https://${[...subdomainSections, ...locations.us.location.split('.')].join('.')}`;	7✔
58	}
59	return `https://${window.location.hostname}`;	1✔
60	};
61
62	const devLocations = ['localhost', 'docker.mender.io'];	183✔
63	export const createOrganizationTrial = data => dispatch => {	183✔
64	const { key } = locations[data.location];	2✔
65	const targetLocation = getTargetLocation(key);	2✔
66	const target = `${targetLocation}${tenantadmApiUrlv2}/tenants/trial`;	2✔
67	return Api.postUnauthorized(target, data)	2✔
68	.catch(err => {
69	if (err.response.status >= 400 && err.response.status < 500) {	×
70	dispatch(setSnackbar(err.response.data.error, TIMEOUTS.fiveSeconds, ''));	×
71	return Promise.reject(err);	×
72	}
73	})
74	.then(({ headers }) => {
75	cookies.remove('oauth');	2✔
76	cookies.remove('externalID');	2✔
77	cookies.remove('email');	2✔
78	dispatch(setFirstLoginAfterSignup(true));	2✔
79	return new Promise(resolve =>	2✔
80	setTimeout(() => {	2✔
81	window.location.assign(`${targetLocation}${headers.location \|\| ''}`);	×
82	return resolve();	×
83	}, TIMEOUTS.fiveSeconds)
84	);
85	});
86	};
87
88	export const startCardUpdate = () => dispatch =>	183✔
89	Api.post(`${tenantadmApiUrlv2}/billing/card`)	1✔
90	.then(res => {
91	dispatch({	1✔
92	type: RECEIVE_SETUP_INTENT,
93	intentId: res.data.intent_id
94	});
95	return Promise.resolve(res.data.secret);	1✔
96	})
97	.catch(err => commonErrorHandler(err, `Updating the card failed:`, dispatch));	×
98
99	export const confirmCardUpdate = () => (dispatch, getState) =>	183✔
100	Api.post(`${tenantadmApiUrlv2}/billing/card/${getState().organization.intentId}/confirm`)	1✔
101	.then(() =>
102	Promise.all([	1✔
103	dispatch(setSnackbar('Payment card was updated successfully')),
104	dispatch({
105	type: RECEIVE_SETUP_INTENT,
106	intentId: null
107	})
108	])
109	)
110	.catch(err => commonErrorHandler(err, `Updating the card failed:`, dispatch));	×
111
112	export const getCurrentCard = () => dispatch =>	183✔
113	Api.get(`${tenantadmApiUrlv2}/billing`).then(res => {	2✔
114	const { last4, exp_month, exp_year, brand } = res.data.card \|\| {};	1!
115	return Promise.resolve(	1✔
116	dispatch({
117	type: RECEIVE_CURRENT_CARD,
118	card: {
119	brand,
120	last4,
121	expiration: { month: exp_month, year: exp_year }
122	}
123	})
124	);
125	});
126
127	export const startUpgrade = tenantId => dispatch =>	183✔
128	Api.post(`${tenantadmApiUrlv2}/tenants/${tenantId}/upgrade/start`)	1✔
129	.then(({ data }) => Promise.resolve(data.secret))	1✔
130	.catch(err => commonErrorHandler(err, `There was an error upgrading your account:`, dispatch));	×
131
132	export const cancelUpgrade = tenantId => () => Api.post(`${tenantadmApiUrlv2}/tenants/${tenantId}/upgrade/cancel`);	183✔
133
134	export const completeUpgrade = (tenantId, plan) => dispatch =>	183✔
135	Api.post(`${tenantadmApiUrlv2}/tenants/${tenantId}/upgrade/complete`, { plan })	1✔
136	.catch(err => commonErrorHandler(err, `There was an error upgrading your account:`, dispatch))	×
137	.then(() => Promise.resolve(dispatch(getUserOrganization())));	1✔
138
139	const prepareAuditlogQuery = ({ startDate, endDate, user: userFilter, type, detail: detailFilter, sort = {} }) => {	183✔
140	const userId = userFilter?.id \|\| userFilter;	13✔
141	const detail = detailFilter?.id \|\| detailFilter;	13✔
142	const createdAfter = startDate ? `&created_after=${Math.round(Date.parse(startDate) / 1000)}` : '';	13✔
143	const createdBefore = endDate ? `&created_before=${Math.round(Date.parse(endDate) / 1000)}` : '';	13✔
144	const typeSearch = type ? `&object_type=${type.value}`.toLowerCase() : '';	13!
145	const userSearch = userId ? `&actor_id=${userId}` : '';	13!
146	const objectSearch = type && detail ? `&${type.queryParameter}=${encodeURIComponent(detail)}` : '';	13!
147	const { direction = SORTING_OPTIONS.desc } = sort;	13✔
148	return `${createdAfter}${createdBefore}${userSearch}${typeSearch}${objectSearch}&sort=${direction}`;	13✔
149	};
150
151	export const getAuditLogs = selectionState => (dispatch, getState) => {	183✔
152	const { page, perPage } = selectionState;	12✔
153	const { hasAuditlogs } = getTenantCapabilities(getState());	12✔
154	if (!hasAuditlogs) {	12✔
155	return Promise.resolve();	1✔
156	}
157	return Api.get(`${auditLogsApiUrl}/logs?page=${page}&per_page=${perPage}${prepareAuditlogQuery(selectionState)}`)	11✔
158	.then(res => {
159	let total = res.headers[headerNames.total];	11✔
160	total = Number(total \|\| res.data.length);	11!
161	return Promise.resolve(dispatch({ type: RECEIVE_AUDIT_LOGS, events: res.data, total }));	11✔
162	})
163	.catch(err => commonErrorHandler(err, `There was an error retrieving audit logs:`, dispatch));	×
164	};
165
166	export const getAuditLogsCsvLink = () => (dispatch, getState) =>	183✔
167	Promise.resolve(`${auditLogsApiUrl}/logs/export?limit=20000${prepareAuditlogQuery(getState().organization.auditlog.selectionState)}`);	2✔
168
169	export const setAuditlogsState = selectionState => (dispatch, getState) => {	183✔
170	const currentState = getState().organization.auditlog.selectionState;	16✔
171	let nextState = {	16✔
172	...currentState,
173	...selectionState,
174	sort: { ...currentState.sort, ...selectionState.sort }
175	};
176	let tasks = [];	16✔
177	// eslint-disable-next-line no-unused-vars
178	const { isLoading: currentLoading, selectedIssue: currentIssue, ...currentRequestState } = currentState;	16✔
179	// eslint-disable-next-line no-unused-vars
180	const { isLoading: selectionLoading, selectedIssue: selectionIssue, ...selectionRequestState } = nextState;	16✔
181	if (!deepCompare(currentRequestState, selectionRequestState)) {	16✔
182	nextState.isLoading = true;	8✔
183	tasks.push(dispatch(getAuditLogs(nextState)).finally(() => dispatch(setAuditlogsState({ isLoading: false }))));	8✔
184	}
185	tasks.push(dispatch({ type: SET_AUDITLOG_STATE, state: nextState }));	16✔
186	return Promise.all(tasks);	16✔
187	};
188
189	/*
190	Tenant management + Hosted Mender
191	*/
192	export const tenantDataDivergedMessage = 'The system detected there is a change in your plan or purchased add-ons. Please log out and log in again';	183✔
193	export const getUserOrganization = () => (dispatch, getState) =>	183✔
194	Api.get(`${tenantadmApiUrlv1}/user/tenant`).then(res => {	8✔
195	let tasks = [dispatch({ type: SET_ORGANIZATION, organization: res.data })];	7✔
196	const { addons, plan, trial } = res.data;	7✔
197	const { token } = getCurrentSession(getState());	7✔
198	const jwt = jwtDecode(token);	7✔
199	const jwtData = { addons: jwt['mender.addons'], plan: jwt['mender.plan'], trial: jwt['mender.trial'] };	7✔
200	if (!deepCompare({ addons, plan, trial }, jwtData)) {	7!
201	const hash = hashString(tenantDataDivergedMessage);	7✔
202	cookies.remove(`${jwt.sub}${hash}`);	7✔
203	tasks.push(dispatch({ type: SET_ANNOUNCEMENT, announcement: tenantDataDivergedMessage }));	7✔
204	}
205	return Promise.all(tasks);	7✔
206	});
207
208	export const sendSupportMessage = content => dispatch =>	183✔
209	Api.post(`${tenantadmApiUrlv2}/contact/support`, content)	1✔
210	.catch(err => commonErrorHandler(err, 'There was an error sending your request', dispatch, commonErrorFallback))	×
211	.then(() => Promise.resolve(dispatch(setSnackbar('Your request was sent successfully', TIMEOUTS.fiveSeconds, ''))));	1✔
212
213	export const requestPlanChange = (tenantId, content) => dispatch =>	183✔
214	Api.post(`${tenantadmApiUrlv2}/tenants/${tenantId}/plan`, content)	1✔
215	.catch(err => commonErrorHandler(err, 'There was an error sending your request', dispatch, commonErrorFallback))	×
216	.then(() => Promise.resolve(dispatch(setSnackbar('Your request was sent successfully', TIMEOUTS.fiveSeconds, ''))));	1✔
217
218	export const downloadLicenseReport = () => dispatch =>	183✔
219	Api.get(`${deviceAuthV2}/reports/devices`)	1✔
220	.catch(err => commonErrorHandler(err, 'There was an error downloading the report', dispatch, commonErrorFallback))	×
221	.then(res => res.data);	1✔
222
223	export const createIntegration = integration => dispatch => {	183✔
224	// eslint-disable-next-line no-unused-vars
225	const { credentials, id, provider, ...remainder } = integration;	1✔
226	return Api.post(`${iotManagerBaseURL}/integrations`, { provider, credentials, ...remainder })	1✔
227	.catch(err => commonErrorHandler(err, 'There was an error creating the integration', dispatch, commonErrorFallback))	×
228	.then(() => Promise.all([dispatch(setSnackbar('The integration was set up successfully')), dispatch(getIntegrations())]));	1✔
229	};
230
231	export const changeIntegration = integration => dispatch =>	183✔
232	Api.put(`${iotManagerBaseURL}/integrations/${integration.id}/credentials`, integration.credentials)	1✔
233	.catch(err => commonErrorHandler(err, 'There was an error updating the integration', dispatch, commonErrorFallback))	×
234	.then(() => Promise.all([dispatch(setSnackbar('The integration was updated successfully')), dispatch(getIntegrations())]));	1✔
235
236	export const deleteIntegration = integration => (dispatch, getState) =>	183✔
237	Api.delete(`${iotManagerBaseURL}/integrations/${integration.id}`, {})	1✔
238	.catch(err => commonErrorHandler(err, 'There was an error removing the integration', dispatch, commonErrorFallback))	×
239	.then(() => {
240	const integrations = getState().organization.externalDeviceIntegrations.filter(item => integration.provider !== item.provider);	1✔
241	return Promise.all([	1✔
242	dispatch(setSnackbar('The integration was removed successfully')),
243	dispatch({ type: RECEIVE_EXTERNAL_DEVICE_INTEGRATIONS, value: integrations })
244	]);
245	});
246
247	export const getIntegrations = () => (dispatch, getState) =>	183✔
248	Api.get(`${iotManagerBaseURL}/integrations`)	9✔
249	.catch(err => commonErrorHandler(err, 'There was an error retrieving the integration', dispatch, commonErrorFallback))	×
250	.then(({ data }) => {
251	const existingIntegrations = getState().organization.externalDeviceIntegrations;	6✔
252	const integrations = data.reduce((accu, item) => {	6✔
253	const existingIntegration = existingIntegrations.find(integration => item.id === integration.id) ?? {};	12✔
254	const integration = { ...existingIntegration, ...item };	12✔
255	accu.push(integration);	12✔
256	return accu;	12✔
257	}, []);
258	return Promise.resolve(dispatch({ type: RECEIVE_EXTERNAL_DEVICE_INTEGRATIONS, value: integrations }));	6✔
259	});
260
261	export const getWebhookEvents =
262	(config = {}) =>	183✔
263	(dispatch, getState) => {	3✔
264	const { isFollowUp, page = defaultPage, perPage = defaultPerPage } = config;	3✔
265	return Api.get(`${iotManagerBaseURL}/events?page=${page}&per_page=${perPage}`)	3✔
266	.catch(err => commonErrorHandler(err, 'There was an error retrieving activity for this integration', dispatch, commonErrorFallback))	×
267	.then(({ data }) => {
268	let tasks = [	3✔
269	dispatch({
270	type: RECEIVE_WEBHOOK_EVENTS,
271	value: isFollowUp ? getState().organization.webhooks.events : data,	3✔
272	total: (page - 1) * perPage + data.length
273	})
274	];
275	if (data.length >= perPage && !isFollowUp) {	3✔
276	tasks.push(dispatch(getWebhookEvents({ isFollowUp: true, page: page + 1, perPage: 1 })));	1✔
277	}
278	return Promise.all(tasks);	3✔
279	});
280	};
281
282	const samlConfigActions = {	183✔
283	create: { success: 'stored', error: 'storing' },
284	edit: { success: 'updated', error: 'updating' },
285	read: { success: '', error: 'retrieving' },
286	remove: { success: 'removed', error: 'removing' }
287	};
288
289	const samlConfigActionErrorHandler = (err, type) => dispatch =>	183✔
290	commonErrorHandler(err, `There was an error ${samlConfigActions[type].error} the SAML configuration.`, dispatch, commonErrorFallback);	×
291
292	const samlConfigActionSuccessHandler = type => dispatch => dispatch(setSnackbar(`The SAML configuration was ${samlConfigActions[type].success} successfully`));	183✔
293
294	export const storeSamlConfig = config => dispatch =>	183✔
295	Api.post(samlIdpApiUrlv1, config, { headers: { 'Content-Type': 'application/samlmetadata+xml', Accept: 'application/json' } })	1✔
296	.catch(err => dispatch(samlConfigActionErrorHandler(err, 'create')))	×
297	.then(() => Promise.all([dispatch(samlConfigActionSuccessHandler('create')), dispatch(getSamlConfigs())]));	1✔
298
299	export const changeSamlConfig =
300	({ id, config }) =>	183✔
301	dispatch =>	1✔
302	Api.put(`${samlIdpApiUrlv1}/${id}`, config, { headers: { 'Content-Type': 'application/samlmetadata+xml', Accept: 'application/json' } })	1✔
303	.catch(err => dispatch(samlConfigActionErrorHandler(err, 'edit')))	×
304	.then(() => Promise.all([dispatch(samlConfigActionSuccessHandler('edit')), dispatch(getSamlConfigs())]));	1✔
305
306	export const deleteSamlConfig =
307	({ id }) =>	183✔
308	(dispatch, getState) =>	4✔
309	Api.delete(`${samlIdpApiUrlv1}/${id}`)	4✔
310	.catch(err => dispatch(samlConfigActionErrorHandler(err, 'remove')))	×
311	.then(() => {
312	const configs = getState().organization.samlConfigs.filter(item => id !== item.id);	6✔
313	return Promise.all([dispatch(samlConfigActionSuccessHandler('remove')), dispatch({ type: RECEIVE_SAML_CONFIGS, value: configs })]);	4✔
314	});
315
316	const getSamlConfigById = config => dispatch =>	183✔
317	Api.get(`${samlIdpApiUrlv1}/${config.id}`)	12✔
318	.catch(err => dispatch(samlConfigActionErrorHandler(err, 'read')))	×
319	.then(({ data }) => Promise.resolve({ ...config, config: data }));	12✔
320
321	export const getSamlConfigs = () => dispatch =>	183✔
322	Api.get(samlIdpApiUrlv1)	6✔
323	.catch(err => commonErrorHandler(err, 'There was an error retrieving SAML configurations', dispatch, commonErrorFallback))	×
324	.then(({ data }) =>
325	Promise.all(data.map(config => Promise.resolve(dispatch(getSamlConfigById(config))))).then(configs => {	12✔
326	return dispatch({ type: RECEIVE_SAML_CONFIGS, value: configs });	6✔
327	})
328	);

mendersoftware / gui / 1113439055

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous