/* -*- mode: js; js-basic-offset: 4; indent-tabs-mode: nil -*- */ /* Monito Gnome-Shell extension Copyright (C) 2021 Benjamin Drieu This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; either version 2 of the License, or (at your option) any later version. This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. You should have received a copy of the GNU General Public License along with this program; if not, write to the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. SPDX-License-Identifier: GPL-2.0-or-later */ const { Soup } = imports.gi; const ExtensionUtils = imports.misc.extensionUtils; const Lang = imports.lang; const Main = imports.ui.main; const Me = ExtensionUtils.getCurrentExtension(); const Preferences = Me.imports.prefs; const GenericServer = Me.imports.servers.genericserver.GenericServer; class Icinga2 extends GenericServer { constructor ( _server, extension ) { super(_server, extension, 'Icinga2'); this.canRecheck = false; } refresh ( ) { this.buildURL ( ); this.prepareHttp ( ); } prepareHttp ( ) { super.prepareHttp ( ); let message = Soup.form_request_new_from_hash ( 'GET', this.urlcgi, { 'format': 'json' } ); message.request_headers.append ( 'Accept', 'application/json' ); this.authenticateAndSend ( message ); } handleMessage ( _httpSession, message ) { let _data = super.handleMessage ( _httpSession, message ); if ( this.error ) log ( 'Parent error ' + this.error ); else { let json = JSON.parse ( _data ); let _statuses = [ 'OK', 'WARNING', 'CRITICAL', 'UNKNOWN' ]; for ( var entry of json ) { this.status.service_status.push ( { status: _statuses [ entry.service_state ], host_name: entry.host_name, service_display_name: entry.service_display_name, attempts: entry.service_attempt, has_been_acknowledged: parseInt(entry.service_acknowledged), status_information: entry.service_output, last_check: this.formatDate(parseInt(entry.service_last_state_change)), } ); } } this.extension.refreshUI ( this ); return ! this.error; } getUrlForService ( service ) { log ( service ); return '%s/monitoring/service/show?host=%s&service=%s'.format ( this._settings.get_string ( 'url' ), service.host_name, service.service_display_name ); } }