From cc1fa351f91f88e5fc7c57238f674e890d09311b Mon Sep 17 00:00:00 2001 From: Sarthak0702 Date: Fri, 11 Feb 2022 01:20:42 +0530 Subject: [PATCH] mgr/dashboard: dashboard turns telemetry off when configuring report Signed-off-by: Sarthak0702 (cherry picked from commit 97c57adf8565756dbf24f3c46ed3916303903fb7) --- .../telemetry/telemetry.component.spec.ts | 30 ++++--- .../cluster/telemetry/telemetry.component.ts | 84 ++++++++++++------- 2 files changed, 70 insertions(+), 44 deletions(-) diff --git a/src/pybind/mgr/dashboard/frontend/src/app/ceph/cluster/telemetry/telemetry.component.spec.ts b/src/pybind/mgr/dashboard/frontend/src/app/ceph/cluster/telemetry/telemetry.component.spec.ts index 72215f6176f9a..baf43e3ffc90d 100644 --- a/src/pybind/mgr/dashboard/frontend/src/app/ceph/cluster/telemetry/telemetry.component.spec.ts +++ b/src/pybind/mgr/dashboard/frontend/src/app/ceph/cluster/telemetry/telemetry.component.spec.ts @@ -120,16 +120,6 @@ describe('TelemetryComponent', () => { }); }); - it('should update the Telemetry configuration', () => { - component.updateConfig(); - const req = httpTesting.expectOne('api/mgr/module/telemetry'); - expect(req.request.method).toBe('PUT'); - expect(req.request.body).toEqual({ - config: {} - }); - req.flush({}); - }); - it('should disable the Telemetry module', () => { const message = 'Module disabled message.'; const followUpFunc = function () { @@ -303,16 +293,24 @@ describe('TelemetryComponent', () => { }); }); - it('should submit', () => { + it('should submit ', () => { component.onSubmit(); - const req = httpTesting.expectOne('api/telemetry'); - expect(req.request.method).toBe('PUT'); - expect(req.request.body).toEqual({ + const req1 = httpTesting.expectOne('api/telemetry'); + expect(req1.request.method).toBe('PUT'); + expect(req1.request.body).toEqual({ enable: true, license_name: 'sharing-1-0' }); - req.flush({}); - expect(router.navigate).toHaveBeenCalledWith(['']); + req1.flush({}); + const req2 = httpTesting.expectOne({ + url: 'api/mgr/module/telemetry', + method: 'PUT' + }); + expect(req2.request.body).toEqual({ + config: {} + }); + req2.flush({}); + expect(router.url).toBe('/'); }); }); }); diff --git a/src/pybind/mgr/dashboard/frontend/src/app/ceph/cluster/telemetry/telemetry.component.ts b/src/pybind/mgr/dashboard/frontend/src/app/ceph/cluster/telemetry/telemetry.component.ts index 41d9f677553e5..47ebae3be199d 100644 --- a/src/pybind/mgr/dashboard/frontend/src/app/ceph/cluster/telemetry/telemetry.component.ts +++ b/src/pybind/mgr/dashboard/frontend/src/app/ceph/cluster/telemetry/telemetry.component.ts @@ -25,6 +25,7 @@ export class TelemetryComponent extends CdForm implements OnInit { licenseAgrmt = false; moduleEnabled: boolean; options: Object = {}; + updatedConfig: Object = {}; previewForm: CdFormGroup; requiredFields = [ 'channel_basic', @@ -176,6 +177,23 @@ export class TelemetryComponent extends CdForm implements OnInit { return result; } + private updateChannelsInReport(updatedConfig: Object = {}) { + const channels: string[] = this.report['report']['channels']; + const availableChannels: string[] = this.report['report']['channels_available']; + const updatedChannels = []; + for (const channel of availableChannels) { + const key = `channel_${channel}`; + // channel unchanged or toggled on + if ( + (!updatedConfig.hasOwnProperty(key) && channels.includes(channel)) || + updatedConfig[key] + ) { + updatedChannels.push(channel); + } + } + this.report['report']['channels'] = updatedChannels; + } + private getReport() { this.loadingStart(); @@ -183,6 +201,7 @@ export class TelemetryComponent extends CdForm implements OnInit { (resp: object) => { this.report = resp; this.reportId = resp['report']['report_id']; + this.updateChannelsInReport(this.updatedConfig); this.createPreviewForm(); this.loadingReady(); this.step++; @@ -198,30 +217,19 @@ export class TelemetryComponent extends CdForm implements OnInit { } updateConfig() { - const config = {}; - _.forEach(Object.values(this.options), (option) => { + this.updatedConfig = {}; + for (const option of Object.values(this.options)) { const control = this.configForm.get(option.name); + if (!control.valid) { + this.configForm.setErrors({ cdSubmitButton: true }); + return; + } // Append the option only if the value has been modified. if (control.dirty && control.valid) { - config[option.name] = control.value; - } - }); - this.mgrModuleService.updateConfig('telemetry', config).subscribe( - () => { - this.disableModule( - $localize`Your settings have been applied successfully. \ - Due to privacy/legal reasons the Telemetry module is now disabled until you \ - complete the next step and accept the license.`, - () => { - this.getReport(); - } - ); - }, - () => { - // Reset the 'Submit' button. - this.configForm.setErrors({ cdSubmitButton: true }); + this.updatedConfig[option.name] = control.value; } - ); + } + this.getReport(); } disableModule(message: string = null, followUpFunc: Function = null) { @@ -251,13 +259,33 @@ export class TelemetryComponent extends CdForm implements OnInit { } onSubmit() { - this.telemetryService.enable().subscribe(() => { - this.telemetryNotificationService.setVisibility(false); - this.notificationService.show( - NotificationType.success, - $localize`The Telemetry module has been configured and activated successfully.` - ); - this.router.navigate(['']); - }); + const observables = [ + this.telemetryService.enable(), + this.mgrModuleService.updateConfig('telemetry', this.updatedConfig) + ]; + + observableForkJoin(observables).subscribe( + () => { + this.telemetryNotificationService.setVisibility(false); + this.notificationService.show( + NotificationType.success, + $localize`The Telemetry module has been configured and activated successfully.` + ); + }, + () => { + this.telemetryNotificationService.setVisibility(false); + this.notificationService.show( + NotificationType.error, + $localize`An Error occurred while updating the Telemetry module configuration.\ + Please Try again` + ); + // Reset the 'Update' button. + this.previewForm.setErrors({ cdSubmitButton: true }); + }, + () => { + this.updatedConfig = {}; + this.router.navigate(['']); + } + ); } } -- 2.39.5