framework/notifications/notificationhandler.cpp


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73

/*
    Copyright (c) 2016 Christian Mollekopf <mollekopf@kolabsys.com>

    This library is free software; you can redistribute it and/or modify it
    under the terms of the GNU Library General Public License as published by
    the Free Software Foundation; either version 2 of the License, or (at your
    option) any later version.

    This library 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 Library General Public
    License for more details.

    You should have received a copy of the GNU Library General Public License
    along with this library; see the file COPYING.LIB.  If not, write to the
    Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
    02110-1301, USA.
*/

#include "notificationhandler.h"

#include <QDebug>

#include <sink/notifier.h>
#include <sink/notification.h>
#include <sink/query.h>

using namespace Kube;

NotificationHandler::NotificationHandler(QObject *parent)
    : QObject(parent)
{
    Sink::Query query{Sink::Query::LiveQuery};
    mNotifier.reset(new Sink::Notifier{query});
    mNotifier->registerHandler([this] (const Sink::Notification &notification) {
        notify(notification);
    });

}

void NotificationHandler::notify(const Sink::Notification &notification)
{
    Notification n;
    qWarning() << "Received notification: " << notification;
    if (notification.type == Sink::Notification::Warning) {
        n.mType = Notification::Warning;
        if (notification.code == Sink::ApplicationDomain::TransmissionError) {
            n.mMessage = "Failed to send message.";
        } else {
            return;
        }
    } else if (notification.type == Sink::Notification::Status) {
        if (notification.code == Sink::ApplicationDomain::ErrorStatus) {
            //A resource entered error status
            n.mType = Notification::Warning;
            n.mMessage = "A resource experienced an error.";
        } else {
            return;
        }
    } else if (notification.type == Sink::Notification::Info) {
        n.mType = Notification::Info;
        if (notification.code == Sink::ApplicationDomain::TransmissionSuccess) {
            n.mMessage = "A message has been sent.";
        } else {
            return;
        }
    } else {
        return;
    }
    //The base implementation to call the handler in QML
    QMetaObject::invokeMethod(this, "handler", Q_ARG(QVariant, QVariant::fromValue(&n)));
}