import {ToasterService} from './toaster.service'; import {OgSweetAlertService} from './og-sweet-alert.service'; import {CommandService} from '../api/command.service'; import {OgCommonService} from './og-common.service'; import {TranslateService} from '@ngx-translate/core'; import {Router} from '@angular/router'; import {Injectable} from '@angular/core'; import * as _ from 'lodash'; import {environment} from '../../environments/environment'; @Injectable({ providedIn: 'root' }) export class OGCommandsService { public ogInstructions = ''; public execution: any; private commands: any; constructor(private router: Router, private ogCommonService: OgCommonService, private toaster: ToasterService, private ogSweetAlert: OgSweetAlertService, private commandService: CommandService, private translate: TranslateService) { this.execution = {}; this.commands = environment.commands; } sendCommand() { let result = true; // TODO - Comprobar parametros if (!this.execution.script) { result = false; this.toaster.pop({type: 'error', title: 'error', body: this.translate.instant('command_not_valid')}); } else if (!this.execution.clients) { result = false; this.toaster.pop({type: 'error', title: 'error', body: this.translate.instant('not_clients_selected')}); } // Si no hubo ningun error if (result === true) { this.execution.script = this.execution.script.replace(/\"/g, '\\"').replace(/\$/g, '\\\$'); // Resetar las instrucciones del script opengnsys almacenadas. this.ogInstructions = ''; this.commandService.execute(this.execution).subscribe( (response: any[]) => { // Buscar en la respuesta si hay algún statuscode diferente de 200 const errors = []; const keys = Object.keys(response); keys.forEach((index) => { const elemKeys = Object.keys(response[index]); elemKeys.forEach((elemKey) => { if (elemKey === 'statusCode' && response[index][elemKey] !== 200) { errors.push(response[index]); } }); }); let errorStr = ''; let toasterOpts = {type: 'success', title: 'success', body: this.translate.instant('successfully_executed')}; if (errors.length > 0) { for (let e = 0; e < errors.length; e++) { errorStr += this.translate.instant('execution_failed_in') + ' ' + errors[e].name + '\n'; } toasterOpts = {type: 'error', title: 'error', body: errorStr}; } this.toaster.pop(toasterOpts); this.router.navigate(['/app/ous']); }, (error) => { this.toaster.pop({type: 'error', title: 'error', body: error}); } ); } } execute(command, params?) { this.execution.type = command; if (command === 'HISTORY_LOG') { let clientIp = null; // Abrir ventana de log if (typeof params === 'undefined' || typeof params.clientIp === 'undefined') { const client = this.ogCommonService.selectedClients[Object.keys(this.ogCommonService.selectedClients)[0]]; if (client) { clientIp = client.ip; } } else { clientIp = params.clientIp; } if (clientIp) { const url = 'http://' + clientIp + environment.commands.HISTORY_LOG; window.open(url, '', 'resizable=yes,toolbar=no,status=no,location=no,menubar=no,scrollbars=yes'); } } else if (command === 'REALTIME_LOG') { let clientIp = null; // Abrir ventana de log if (typeof params === 'undefined' || typeof params.clientIp === 'undefined') { const client = this.ogCommonService.selectedClients[Object.keys(this.ogCommonService.selectedClients)[0]]; if (client) { clientIp = client.ip; } } else { clientIp = params.clientIp; } if (clientIp) { const url = 'http://' + clientIp + environment.commands.REALTIME_LOG; window.open(url, '', 'resizable=yes,toolbar=no,status=no,location=no,menubar=no,scrollbars=yes'); } } else if (command === 'SOFTWARE_INVENTORY') { const client = this.ogCommonService.selectedClients[Object.keys(this.ogCommonService.selectedClients)[0]]; // Preparar el scope para el sweet alert const options = { scope: { partitions: [], selectedPart: null } }; // Comprobar tipo de cada particion para ver si es clonable // var parttable = $rootScope.constants.partitiontable[client.partitions[0].partitionCode-1]; // buscar las particiones que sean clonables const clonablePartitions = []; for (let index = 1; index < client.partitions.length; index++) { if (client.partitions[index].osName !== 'DATA' && client.partitions[index].osName !== '') { // Crear como nombre para mostrar, el disco y partición del sistema const obj = Object.assign({}, client.partitions[index]); const str = 'disco: ' + obj.numDisk + ', part: ' + obj.numPartition + ', SO: ' + client.partitions[index].osName; clonablePartitions.push(obj.numDisk + ' ' + obj.numPartition); options.scope.partitions.push(str); } } const self = this; this.ogSweetAlert.swal({ title: this.translate.instant('select_partition_to_inventary'), // text: $filter("translate")("action_cannot_be_undone"), type: 'info', input: 'select', inputOptions: options.scope.partitions, showCancelButton: true, confirmButtonColor: '#3c8dbc', confirmButtonText: this.translate.instant('done'), closeOnConfirm: true }).then( function(result) { if (result.value) { // Montar el script con el disco y partición elegida self.execution.script = self.commands.SOFTWARE_INVENTORY + ' ' + clonablePartitions[result.value]; self.loadClients(); self.sendCommand(); } }, null); } else { if (command === 'REBOOT') { this.execution.script = environment.commands.REBOOT; } else if (command === 'POWER_OFF') { this.execution.script = environment.commands.POWER_OFF; } else if (command === 'POWER_ON') { this.execution.script = 'wakeonlan'; } else if (command === 'HARDWARE_INVENTORY') { this.execution.script = environment.commands.HARDWARE_INVENTORY; } else if (command === 'RUN_SCRIPT') { this.execution.script = params ? (params.script || this.ogInstructions) : this.ogInstructions; } else if (command === 'REFRESH_INFO') { this.execution.script = environment.commands.REFRESH_INFO; } // Comprobar si en los parametros viene la opcion de guardar if (typeof params !== 'undefined' && params.save === true) { const self = this; // Mostrar cuadro de dialogo para guardar procedimiento this.ogSweetAlert.swal({ title: this.translate.instant('new_command_name'), type: 'info', html: '
', showCancelButton: true, confirmButtonColor: '#3c8dbc', confirmButtonText: this.translate.instant('done'), closeOnConfirm: true, preConfirm: () => { return { execute: (