From b4fce004a40753e396f100ac9abdbe876de5865e Mon Sep 17 00:00:00 2001 From: Michael Dürre Date: Fri, 2 Aug 2019 06:45:49 +0200 Subject: fixed mediator app MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit route requests through apigateway Issue-ID: SDNC-824 Signed-off-by: Michael Dürre Change-Id: Ief159a71888f271a7751884260f85be01efdd6b4 --- .../src/actions/avaliableMediatorServersActions.ts | 17 +++++++ .../src/actions/mediatorConfigActions.ts | 57 ++++++++++++++-------- .../src/actions/mediatorServerActions.ts | 37 ++++++++++---- 3 files changed, 81 insertions(+), 30 deletions(-) (limited to 'sdnr/wt/odlux/apps/mediatorApp/src/actions') diff --git a/sdnr/wt/odlux/apps/mediatorApp/src/actions/avaliableMediatorServersActions.ts b/sdnr/wt/odlux/apps/mediatorApp/src/actions/avaliableMediatorServersActions.ts index 4cbad42dd..3f56b05e1 100644 --- a/sdnr/wt/odlux/apps/mediatorApp/src/actions/avaliableMediatorServersActions.ts +++ b/sdnr/wt/odlux/apps/mediatorApp/src/actions/avaliableMediatorServersActions.ts @@ -1,3 +1,20 @@ +/** + * ============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'; diff --git a/sdnr/wt/odlux/apps/mediatorApp/src/actions/mediatorConfigActions.ts b/sdnr/wt/odlux/apps/mediatorApp/src/actions/mediatorConfigActions.ts index 058110614..516515ab2 100644 --- a/sdnr/wt/odlux/apps/mediatorApp/src/actions/mediatorConfigActions.ts +++ b/sdnr/wt/odlux/apps/mediatorApp/src/actions/mediatorConfigActions.ts @@ -1,3 +1,20 @@ +/** + * ============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'; @@ -12,25 +29,25 @@ import { MediatorConfig, MediatorConfigResponse } from '../models/mediatorServer export class BaseAction extends Action { } export class SetMediatorBusyByName extends BaseAction { - constructor (public name: string, public isBusy: boolean) { + constructor(public name: string, public isBusy: boolean) { super(); } } export class AddMediatorConfig extends BaseAction { - constructor (public mediatorConfig: MediatorConfigResponse) { + constructor(public mediatorConfig: MediatorConfigResponse) { super(); } } export class UpdateMediatorConfig extends BaseAction { - constructor (public name: string, public mediatorConfig: MediatorConfigResponse) { + constructor(public name: string, public mediatorConfig: MediatorConfigResponse) { super(); } } export class RemoveMediatorConfig extends BaseAction { - constructor (public name: string) { + constructor(public name: string) { super(); } } @@ -38,13 +55,13 @@ export class RemoveMediatorConfig extends BaseAction { export const startMediatorByNameAsyncActionCreator = (name: string) => (dispatch: Dispatch, getState: () => IApplicationStoreState) => { dispatch(new SetMediatorBusyByName(name, true)); - const { mediator: { mediatorServerState: { url } } } = getState(); - if (url) { - mediatorService.startMediatorByName(url, name).then(msg => { + 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(url, name).then(config => { + mediatorService.getMediatorServerConfigByName(id, name).then(config => { if (config) { dispatch(new UpdateMediatorConfig(name, config)); } else { @@ -62,13 +79,13 @@ export const startMediatorByNameAsyncActionCreator = (name: string) => (dispatch export const stopMediatorByNameAsyncActionCreator = (name: string) => (dispatch: Dispatch, getState: () => IApplicationStoreState) => { dispatch(new SetMediatorBusyByName(name, true)); - const { mediator: { mediatorServerState: { url } } } = getState(); - if (url) { - mediatorService.stopMediatorByName(url, name).then(msg => { + 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(url, name).then(config => { + mediatorService.getMediatorServerConfigByName(id, name).then(config => { if (config) { dispatch(new UpdateMediatorConfig(name, config)); } else { @@ -86,13 +103,13 @@ export const stopMediatorByNameAsyncActionCreator = (name: string) => (dispatch: export const addMediatorConfigAsyncActionCreator = (config: MediatorConfig) => (dispatch: Dispatch, getState: () => IApplicationStoreState) => { const { Name: name } = config; - const { mediator: { mediatorServerState: { url } } } = getState(); - if (url) { - mediatorService.createMediatorConfig(url, config).then(msg => { + 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(url, name).then(config => { + mediatorService.getMediatorServerConfigByName(id, name).then(config => { if (config) { dispatch(new AddMediatorConfig(config)); } else { @@ -112,13 +129,13 @@ export const updateMediatorConfigAsyncActionCreator = (config: MediatorConfig) = export const removeMediatorConfigAsyncActionCreator = (config: MediatorConfig) => (dispatch: Dispatch, getState: () => IApplicationStoreState) => { const { Name: name } = config; - const { mediator: { mediatorServerState: { url } } } = getState(); - if (url) { - mediatorService.deleteMediatorConfigByName(url, name).then(msg => { + 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(url, config.Name).then(config => { + mediatorService.getMediatorServerConfigByName(id, config.Name).then(config => { if (!config) { dispatch(new RemoveMediatorConfig(name)); } else { diff --git a/sdnr/wt/odlux/apps/mediatorApp/src/actions/mediatorServerActions.ts b/sdnr/wt/odlux/apps/mediatorApp/src/actions/mediatorServerActions.ts index e7719aac5..143dd7d4a 100644 --- a/sdnr/wt/odlux/apps/mediatorApp/src/actions/mediatorServerActions.ts +++ b/sdnr/wt/odlux/apps/mediatorApp/src/actions/mediatorServerActions.ts @@ -1,3 +1,20 @@ +/** + * ============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'; @@ -11,7 +28,7 @@ import { IApplicationStoreState } from '../../../../framework/src/store/applicat export class BaseAction extends Action { } export class SetMediatorServerBusy extends BaseAction { - constructor (public isBusy: boolean) { + constructor(public isBusy: boolean) { super(); } } @@ -20,7 +37,7 @@ export class SetMediatorServerInfo extends BaseAction { /** * Initializes a new instance of this class. */ - constructor (public name: string | null, public url: string | null) { + constructor(public id: string | null, public name: string | null, public url: string | null) { super(); } @@ -30,7 +47,7 @@ export class SetMediatorServerVersion extends BaseAction { /** * Initializes a new instance of this class. */ - constructor (public versionInfo: MediatorServerVersionInfo | null) { + constructor(public versionInfo: MediatorServerVersionInfo | null) { super(); } @@ -40,7 +57,7 @@ export class SetAllMediatorServerConfigurations extends BaseAction { /** * Initializes a new instance of this class. */ - constructor (public allConfigurations: MediatorConfigResponse[] | null) { + constructor(public allConfigurations: MediatorConfigResponse[] | null) { super(); } @@ -50,7 +67,7 @@ export class SetMediatorServerSupportedDevices extends BaseAction { /** * Initializes a new instance of this class. */ - constructor (public devices: MediatorServerDevice[] | null) { + constructor(public devices: MediatorServerDevice[] | null) { super(); } @@ -65,16 +82,16 @@ export const initializeMediatorServerAsyncActionCreator = (serverId: string) => dispatch(new NavigateToApplication("mediator")); return; } - dispatch(new SetMediatorServerInfo(mediatorServer.name, mediatorServer.url)); + dispatch(new SetMediatorServerInfo(mediatorServer._id, mediatorServer.name, mediatorServer.url)); - mediatorService.getMediatorServerVersion(mediatorServer.url).then(versionInfo => { + mediatorService.getMediatorServerVersion(mediatorServer._id).then(versionInfo => { dispatch(new SetMediatorServerVersion(versionInfo)); }); Promise.all([ - mediatorService.getMediatorServerAllConfigs(mediatorServer.url), - mediatorService.getMediatorServerSupportedDevices(mediatorServer.url) - ]).then(([configurations,supportedDevices]) => { + mediatorService.getMediatorServerAllConfigs(mediatorServer._id), + mediatorService.getMediatorServerSupportedDevices(mediatorServer._id) + ]).then(([configurations, supportedDevices]) => { dispatch(new SetAllMediatorServerConfigurations(configurations)); dispatch(new SetMediatorServerSupportedDevices(supportedDevices)); dispatch(new SetMediatorServerBusy(false)); -- cgit 1.2.3-korg