monito/servers/genericserver.js

331 lines
10 KiB
JavaScript

/* -*- 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;
class GenericServer {
constructor ( _server, _extension, _serverType = 'Generic' )
{
log ( '>>> New %s server #%s'.format ( _serverType, _server ) );
this._server = _server;
this._settings = Preferences.getAccountSettings ( this._server );
this._httpSession = null;
this._url = null;
this.extension = _extension;
this.canRecheck = true;
}
getServer ( )
{
return this._server;
}
buildURL ( )
{
// if ( ! this._settings )
log ( 'monito build URL' );
this._settings = Preferences.getAccountSettings ( this._server );
if ( this.type != this._settings.get_string ( "type" ) ||
this.username != this._settings.get_string ( "username" ) ||
this.strict_ssl != this._settings.get_boolean ( "strict-ssl" ) ||
this.name != this._settings.get_string ( "name" ) ||
this.password != this._settings.get_string ( "password" ) ||
this.urlcgi != this._settings.get_string ( "urlcgi" ) )
{
this.type = this._settings.get_string ( "type" );
this.username = this._settings.get_string ( "username" );
this.strict_ssl = this._settings.get_boolean ( "strict-ssl" );
this.name = this._settings.get_string ( "name" );
this.password = this._settings.get_string ( "password" );
this.urlcgi = this._settings.get_string ( "urlcgi" );
this._httpSession = null;
log ( 'Refreshing URL parameters' );
}
// log ( 'monito server >>> ' + this._server );
// log ( 'monito name >>> ' + this.name );
// log ( 'monito type >>> ' + this.type );
// log ( 'monito username >>> ' + this.username );
// log ( 'monito urlcgi >>> ' + this.urlcgi );
}
prepareHttp ( )
{
if ( this._httpSession == null ) {
log ( 'Preparing new HTTP with strict SSL ' + this.strict_ssl );
this._httpSession = new Soup.Session();
this._httpSession.ssl_strict = this.strict_ssl;
this._httpSession.user_agent = Me.metadata.uuid;
}
}
authenticateAndSend ( message, callback = this.handleMessage )
{
let auth = new Soup.AuthBasic()
auth.authenticate ( this.username, this.password );
message.request_headers.append ( "Authorization", auth.get_authorization ( message ) );
log ( 'Sending message' );
this._httpSession.queue_message ( message, Lang.bind (this, callback ) );
}
handleMessage ( _httpSession, message )
{
this.status = { };
this.status.service_status = [ ];
this.error = null;
log ( message.status_code );
log ( message.response_body );
message.response_headers.foreach ((name, val) => {
log (name, val);
});
log ( message.response_body.data );
if ( message.status_code != Soup.Status.OK )
{
log ( '>>> Error: ' + message.reason_phrase );
//log ( '>>> Data: ' + message.data );
// TODO: add pref for that
// Main.notifyError ( 'Monito: ' + this.name,
// 'URL: ' + this.urlcgi + "\n" +
// message.status_code + ': ' + message.reason_phrase );
this.error = message.reason_phrase;
return null;
}
else
{
return message.response_body.data;
}
}
handleCMDMessage ( _httpSession, message )
{
let _data;
try {
_data = this.handleMessage ( _httpSession, message );
if ( this.error )
log ( 'Parent error ' + this.error );
else
{
// if error, grep for class='errorMessage'
// else grep for class='successBox'
log ( 'Cmd output ' + _data );
}
}
catch ( e )
{
log ( e );
log ( _data );
}
if ( message.button )
this.extension.stopChildSpin ( message.button );
}
getProcessedStatus ( )
{
let status = this.status.service_status;
this.columns = Preferences.getColumns ( this._server );
this.sortOrder = Preferences.getSortOrder ( this._server );
status = this.filterStatus ( status );
status = status.sort ( Lang.bind ( this, this.compareServices ) );
return status;
}
filterStatus ( status )
{
let filters = [ { prefKey: 'service-grep',
entryKey: 'service_display_name',
positive: true },
{ prefKey: 'service-filter-out',
entryKey: 'service_display_name',
positive: false },
{ prefKey: 'host-grep',
entryKey: 'host_name',
positive: true },
{ prefKey: 'host-filter-out',
entryKey: 'host_name',
positive: false },
{ prefKey: 'status-info-grep',
entryKey: 'status_information',
positive: true },
{ prefKey: 'status-info-filter-out',
entryKey: 'status_information',
positive: false } ];
for ( var _filter of filters )
_filter.value = this._settings.get_string ( _filter.prefKey );
entries:
for ( var i = 0 ; i < status.length ; i ++ )
{
if ( status[i]['has_been_acknowledged'] && this._settings.get_boolean ( 'acknowledged-filter-out' ) )
{
log ( '> ACKED:%s ' . format ( status[i]['service_display_name'] ) );
status.splice ( i, 1 );
i --; // This has been removed, so get back one step.
continue entries;
}
for ( var _filter of filters )
{
if ( _filter['value'] &&
( status[i][_filter['entryKey']].match ( new RegExp ( _filter['value'], 'i' ) ) <= 0 ) == _filter['positive'] )
{
status.splice ( i, 1 );
i --; // This has been removed, so get back one step.
continue entries;
}
}
}
return status;
}
compareServices ( a, b )
{
for ( let _comparison of this.sortOrder )
{
let _name = _comparison.substring ( 0, _comparison.length - 1 );
let _order = _comparison.substring ( _comparison.length - 1, _comparison.length );
if ( _name && _order && _name in a && _name in b )
{
if ( ! a [ _name ] )
return 1;
let _result = a [ _name ] . localeCompare ( b [ _name ] );
if ( _result != 0 )
{
if ( _order == '-' )
return - _result;
else
return _result;
}
}
}
return 0;
}
formatDate ( date )
{
if ( typeof date == 'string' || date instanceof String )
date = Date.parse ( date ) / 1000;
return this.timeAgo ( new Date ( date * 1000 ) );
}
getFormattedDate(date, prefomattedDate = false, hideYear = false)
{
const MONTH_NAMES = [
'Jan.', 'Feb.', 'Mar.', 'Apr.', 'May', 'Jun.',
'Jul.', 'Aug.', 'Sep.', 'Oct.', 'Nov.', 'Dec.'
];
const day = date.getDate();
const month = MONTH_NAMES[date.getMonth()];
const year = date.getFullYear();
const hours = date.getHours();
let minutes = date.getMinutes();
if (minutes < 10) {
// Adding leading zero to minutes
minutes = _(`0${ minutes }`);
}
if (prefomattedDate) {
// Today at 10:20
// Yesterday at 10:20
return _(`${ prefomattedDate } at ${ hours }:${ minutes }`);
}
if (hideYear) {
// 10. January at 10:20
return _(`${ month } ${ day } at ${ hours }:${ minutes }`);
}
// 10. January 2017. at 10:20
return _(`${ year } ${ month } ${ day }`);
}
timeAgo ( dateParam )
{
if (!dateParam) {
return null;
}
const date = typeof dateParam === 'object' ? dateParam : new Date(dateParam);
const DAY_IN_MS = 86400000; // 24 * 60 * 60 * 1000
const today = new Date();
const yesterday = new Date(today - DAY_IN_MS);
const seconds = Math.round((today - date) / 1000);
const minutes = Math.round(seconds / 60);
const isToday = today.toDateString() === date.toDateString();
const isYesterday = yesterday.toDateString() === date.toDateString();
const isThisYear = today.getFullYear() === date.getFullYear();
if (seconds < 5) {
return 'now';
} else if (seconds < 60) {
return `${ seconds } seconds ago`;
} else if (seconds < 90) {
return 'a minute ago';
} else if (minutes < 60) {
return `${ minutes } minutes ago`;
} else if (isToday) {
return this.getFormattedDate(date, 'today'); // Today at 10:20
} else if (isYesterday) {
return this.getFormattedDate(date, 'yesterday'); // Yesterday at 10:20
} else if (isThisYear) {
return this.getFormattedDate(date, false, true); // 10. January at 10:20
}
return this.getFormattedDate(date); // 10. January 2017. at 10:20
}
}