aboutsummaryrefslogtreecommitdiffstats
path: root/sdnr/wt/odlux/apps/mediatorApp/src/actions
diff options
context:
space:
mode:
Diffstat (limited to 'sdnr/wt/odlux/apps/mediatorApp/src/actions')
-rw-r--r--sdnr/wt/odlux/apps/mediatorApp/src/actions/avaliableMediatorServersActions.ts58
-rw-r--r--sdnr/wt/odlux/apps/mediatorApp/src/actions/mediatorConfigActions.ts154
-rw-r--r--sdnr/wt/odlux/apps/mediatorApp/src/actions/mediatorServerActions.ts114
3 files changed, 0 insertions, 326 deletions
diff --git a/sdnr/wt/odlux/apps/mediatorApp/src/actions/avaliableMediatorServersActions.ts b/sdnr/wt/odlux/apps/mediatorApp/src/actions/avaliableMediatorServersActions.ts
deleted file mode 100644
index 3f56b05e1..000000000
--- a/sdnr/wt/odlux/apps/mediatorApp/src/actions/avaliableMediatorServersActions.ts
+++ /dev/null
@@ -1,58 +0,0 @@
-/**
- * ============LICENSE_START========================================================================
- * ONAP : ccsdk feature sdnr wt odlux
- * =================================================================================================
- * Copyright (C) 2019 highstreet technologies GmbH Intellectual Property. All rights reserved.
- * =================================================================================================
- * 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.
- * ============LICENSE_END==========================================================================
- */
-import { Action } from '../../../../framework/src/flux/action';
-import { Dispatch } from '../../../../framework/src/flux/store';
-import { AddSnackbarNotification } from '../../../../framework/src/actions/snackbarActions';
-
-import { MediatorServer } from '../models/mediatorServer';
-import { avaliableMediatorServersReloadAction } from '../handlers/avaliableMediatorServersHandler';
-import mediatorService from '../services/mediatorService';
-
-/** Represents the base action. */
-export class BaseAction extends Action { }
-
-/** Represents an async thunk action that will add a server to the avaliable mediator servers. */
-export const addAvaliableMediatorServerAsyncActionCreator = (server: MediatorServer) => (dispatch: Dispatch) => {
- mediatorService.insertMediatorServer(server).then(_ => {
- window.setTimeout(() => {
- dispatch(avaliableMediatorServersReloadAction);
- dispatch(new AddSnackbarNotification({ message: `Successfully added [${ server.name }]`, options: { variant: 'success' } }));
- }, 900);
- });
- };
-
- /** Represents an async thunk action that will add a server to the avaliable mediator servers. */
-export const updateAvaliableMediatorServerAsyncActionCreator = (server: MediatorServer) => (dispatch: Dispatch) => {
- mediatorService.updateMediatorServer(server).then(_ => {
- window.setTimeout(() => {
- dispatch(avaliableMediatorServersReloadAction);
- dispatch(new AddSnackbarNotification({ message: `Successfully updated [${ server.name }]`, options: { variant: 'success' } }));
- }, 900);
- });
-};
-
- /** Represents an async thunk action that will delete a server from the avaliable mediator servers. */
- export const removeAvaliableMediatorServerAsyncActionCreator = (server: MediatorServer) => (dispatch: Dispatch) => {
- mediatorService.deleteMediatorServer(server).then(_ => {
- window.setTimeout(() => {
- dispatch(avaliableMediatorServersReloadAction);
- dispatch(new AddSnackbarNotification({ message: `Successfully removed [${ server.name }]`, options: { variant: 'success' } }));
- }, 900);
- });
- };
- \ No newline at end of file
diff --git a/sdnr/wt/odlux/apps/mediatorApp/src/actions/mediatorConfigActions.ts b/sdnr/wt/odlux/apps/mediatorApp/src/actions/mediatorConfigActions.ts
deleted file mode 100644
index 516515ab2..000000000
--- a/sdnr/wt/odlux/apps/mediatorApp/src/actions/mediatorConfigActions.ts
+++ /dev/null
@@ -1,154 +0,0 @@
-/**
- * ============LICENSE_START========================================================================
- * ONAP : ccsdk feature sdnr wt odlux
- * =================================================================================================
- * Copyright (C) 2019 highstreet technologies GmbH Intellectual Property. All rights reserved.
- * =================================================================================================
- * 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.
- * ============LICENSE_END==========================================================================
- */
-
-import { Action } from '../../../../framework/src/flux/action';
-import { Dispatch } from '../../../../framework/src/flux/store';
-
-import { AddSnackbarNotification } from '../../../../framework/src/actions/snackbarActions';
-import { IApplicationStoreState } from '../../../../framework/src/store/applicationStore';
-
-import mediatorService from '../services/mediatorService';
-import { MediatorConfig, MediatorConfigResponse } from '../models/mediatorServer';
-
-/** Represents the base action. */
-export class BaseAction extends Action { }
-
-export class SetMediatorBusyByName extends BaseAction {
- constructor(public name: string, public isBusy: boolean) {
- super();
- }
-}
-
-export class AddMediatorConfig extends BaseAction {
- constructor(public mediatorConfig: MediatorConfigResponse) {
- super();
- }
-}
-
-export class UpdateMediatorConfig extends BaseAction {
- constructor(public name: string, public mediatorConfig: MediatorConfigResponse) {
- super();
- }
-}
-
-export class RemoveMediatorConfig extends BaseAction {
- constructor(public name: string) {
- super();
- }
-}
-
-
-export const startMediatorByNameAsyncActionCreator = (name: string) => (dispatch: Dispatch, getState: () => IApplicationStoreState) => {
- dispatch(new SetMediatorBusyByName(name, true));
- const { mediator: { mediatorServerState: { id } } } = getState();
- if (id) {
- mediatorService.startMediatorByName(id, name).then(msg => {
- dispatch(new AddSnackbarNotification({ message: msg + ' ' + name, options: { variant: 'info' } }));
- // since there is no notification, a timeout will be need here
- window.setTimeout(() => {
- mediatorService.getMediatorServerConfigByName(id, name).then(config => {
- if (config) {
- dispatch(new UpdateMediatorConfig(name, config));
- } else {
- dispatch(new AddSnackbarNotification({ message: `Error: reading mediator config for ${name}.`, options: { variant: 'error' } }));
- }
- dispatch(new SetMediatorBusyByName(name, false));
- });
- }, 2100);
- });
- } else {
- dispatch(new AddSnackbarNotification({ message: `Error: currently no mediator server selected.`, options: { variant: 'error' } }));
- dispatch(new SetMediatorBusyByName(name, false));
- }
-};
-
-export const stopMediatorByNameAsyncActionCreator = (name: string) => (dispatch: Dispatch, getState: () => IApplicationStoreState) => {
- dispatch(new SetMediatorBusyByName(name, true));
- const { mediator: { mediatorServerState: { id } } } = getState();
- if (id) {
- mediatorService.stopMediatorByName(id, name).then(msg => {
- dispatch(new AddSnackbarNotification({ message: msg + ' ' + name, options: { variant: 'info' } }));
- // since there is no notification, a timeout will be need here
- window.setTimeout(() => {
- mediatorService.getMediatorServerConfigByName(id, name).then(config => {
- if (config) {
- dispatch(new UpdateMediatorConfig(name, config));
- } else {
- dispatch(new AddSnackbarNotification({ message: `Error: reading mediator config for ${name}.`, options: { variant: 'error' } }));
- }
- dispatch(new SetMediatorBusyByName(name, false));
- });
- }, 2100);
- });
- } else {
- dispatch(new AddSnackbarNotification({ message: `Error: currently no mediator server selected.`, options: { variant: 'error' } }));
- dispatch(new SetMediatorBusyByName(name, false));
- }
-};
-
-export const addMediatorConfigAsyncActionCreator = (config: MediatorConfig) => (dispatch: Dispatch, getState: () => IApplicationStoreState) => {
- const { Name: name } = config;
- const { mediator: { mediatorServerState: { id } } } = getState();
- if (id) {
- mediatorService.createMediatorConfig(id, config).then(msg => {
- dispatch(new AddSnackbarNotification({ message: msg + ' ' + name, options: { variant: 'info' } }));
- // since there is no notification, a timeout will be need here
- window.setTimeout(() => {
- mediatorService.getMediatorServerConfigByName(id, name).then(config => {
- if (config) {
- dispatch(new AddMediatorConfig(config));
- } else {
- dispatch(new AddSnackbarNotification({ message: `Error: reading mediator config for ${name}.`, options: { variant: 'error' } }));
- }
- });
- }, 2100);
- });
- } else {
- dispatch(new AddSnackbarNotification({ message: `Error: currently no mediator server selected.`, options: { variant: 'error' } }));
- }
-};
-
-export const updateMediatorConfigAsyncActionCreator = (config: MediatorConfig) => (dispatch: Dispatch) => {
- // currently not supported be backend
-};
-
-export const removeMediatorConfigAsyncActionCreator = (config: MediatorConfig) => (dispatch: Dispatch, getState: () => IApplicationStoreState) => {
- const { Name: name } = config;
- const { mediator: { mediatorServerState: { id } } } = getState();
- if (id) {
- mediatorService.deleteMediatorConfigByName(id, name).then(msg => {
- dispatch(new AddSnackbarNotification({ message: msg + ' ' + name, options: { variant: 'info' } }));
- // since there is no notification, a timeout will be need here
- window.setTimeout(() => {
- mediatorService.getMediatorServerConfigByName(id, config.Name).then(config => {
- if (!config) {
- dispatch(new RemoveMediatorConfig(name));
- } else {
- dispatch(new AddSnackbarNotification({ message: `Error: deleting mediator config for ${name}.`, options: { variant: 'error' } }));
- }
- });
- }, 2100);
- });
- } else {
- dispatch(new AddSnackbarNotification({ message: `Error: currently no mediator server selected.`, options: { variant: 'error' } }));
- dispatch(new SetMediatorBusyByName(name, false));
- }
-};
-
-
-
diff --git a/sdnr/wt/odlux/apps/mediatorApp/src/actions/mediatorServerActions.ts b/sdnr/wt/odlux/apps/mediatorApp/src/actions/mediatorServerActions.ts
deleted file mode 100644
index 79e46df0e..000000000
--- a/sdnr/wt/odlux/apps/mediatorApp/src/actions/mediatorServerActions.ts
+++ /dev/null
@@ -1,114 +0,0 @@
-/**
- * ============LICENSE_START========================================================================
- * ONAP : ccsdk feature sdnr wt odlux
- * =================================================================================================
- * Copyright (C) 2019 highstreet technologies GmbH Intellectual Property. All rights reserved.
- * =================================================================================================
- * 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.
- * ============LICENSE_END==========================================================================
- */
-import { Action } from '../../../../framework/src/flux/action';
-import { Dispatch } from '../../../../framework/src/flux/store';
-
-import { MediatorServerVersionInfo, MediatorConfig, MediatorConfigResponse, MediatorServerDevice } from '../models/mediatorServer';
-import mediatorService from '../services/mediatorService';
-import { AddSnackbarNotification } from '../../../../framework/src/actions/snackbarActions';
-import { NavigateToApplication } from '../../../../framework/src/actions/navigationActions';
-import { IApplicationStoreState } from '../../../../framework/src/store/applicationStore';
-
-/** Represents the base action. */
-export class BaseAction extends Action { }
-
-export class SetMediatorServerBusy extends BaseAction {
- constructor(public isBusy: boolean) {
- super();
- }
-}
-
-export class SetMediatorServerInfo extends BaseAction {
- /**
- * Initializes a new instance of this class.
- */
- constructor(public id: string | null, public name: string | null, public url: string | null) {
- super();
-
- }
-}
-
-export class SetMediatorServerVersion extends BaseAction {
- /**
- * Initializes a new instance of this class.
- */
- constructor(public versionInfo: MediatorServerVersionInfo | null) {
- super();
-
- }
-}
-
-export class SetAllMediatorServerConfigurations extends BaseAction {
- /**
- * Initializes a new instance of this class.
- */
- constructor(public allConfigurations: MediatorConfigResponse[] | null) {
- super();
-
- }
-}
-
-export class SetMediatorServerSupportedDevices extends BaseAction {
- /**
- * Initializes a new instance of this class.
- */
- constructor(public devices: MediatorServerDevice[] | null) {
- super();
-
- }
-}
-
-export class SetMediatorServerReachable extends BaseAction {
- constructor(public isReachable: boolean) {
- super();
- }
-}
-
-export const initializeMediatorServerAsyncActionCreator = (serverId: string) => (dispatch: Dispatch) => {
- dispatch(new SetMediatorServerBusy(true));
- mediatorService.getMediatorServerById(serverId).then(mediatorServer => {
- if (!mediatorServer) {
- dispatch(new SetMediatorServerBusy(false));
- dispatch(new AddSnackbarNotification({ message: `Error loading mediator server [${serverId}]`, options: { variant: 'error' } }));
- dispatch(new NavigateToApplication("mediator"));
- return;
- }
-
- dispatch(new SetMediatorServerInfo(mediatorServer.id, mediatorServer.name, mediatorServer.url));
-
- Promise.all([
- mediatorService.getMediatorServerAllConfigs(mediatorServer.id),
- mediatorService.getMediatorServerSupportedDevices(mediatorServer.id),
- mediatorService.getMediatorServerVersion(mediatorServer.id)
- ]).then(([configurations, supportedDevices, versionInfo]) => {
- if (configurations === null && supportedDevices === null && versionInfo === null) {
- dispatch(new SetMediatorServerReachable(false));
- } else {
- dispatch(new SetMediatorServerReachable(true));
- }
- dispatch(new SetAllMediatorServerConfigurations(configurations));
- dispatch(new SetMediatorServerSupportedDevices(supportedDevices));
- dispatch(new SetMediatorServerVersion(versionInfo));
- dispatch(new SetMediatorServerBusy(false));
- }).catch(error => {
- dispatch(new SetMediatorServerReachable(false));
- dispatch(new SetMediatorServerBusy(false));
- });
- });
-};
-