channel.h

/*

Hanghish
Copyright (C) 2015 Daniele Rogora

This file is part of Hangish.

Hangish 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 3 of the License, or
(at your option) any later version.

Hangish 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 Nome-Programma.  If not, see <http://www.gnu.org/licenses/>

*/


#ifndef CHANNEL_H
#define CHANNEL_H

#include "utils.h"
#include "notification.h"
#include "conversationmodel.h"
#include "rostermodel.h"


struct ChannelEvent {
    QString conversationId;
    bool isTyping;
    QString userId;
    int typingStatus;
};

class Channel : public QObject
{
    Q_OBJECT
    //Used to know wether the network has problems, so that the app doesn't spawn lots of unuseful connections
    bool channelError, fetchingSid;
    QNetworkReply *LPrep;
    User myself;
    ConversationModel *conversationModel;
    RosterModel *rosterModel;
    QNetworkAccessManager *nam;
    QNetworkCookieJar cJar;
    QList<QNetworkCookie> session_cookies;
    QString sid, clid, ec, path, prop, header_client, email, gsessionid;
    QString lastIncompleteParcel;
    QDateTime lastPushReceived;
    int lastAs;

private:
    QByteArray getAuthHeader();
    QTimer *checkChannelTimer;
    bool channelEstablishmentOccurring;
    bool isOnline;
    int lastValidParcelId;    
    QDateTime lastLongPollReq;
    QDateTime lastValidParcelIdTS;
    bool appPaused;
    QString lastIncomingConvId;
    void fetchNewSid();
    void checkChannelAndReconnect();
    void processCookies(QNetworkReply *reply);
    void addChannelService();

public:
    Channel(QList<QNetworkCookie> cookies, QString ppath, QString pclid, QString pec, QString pprop, User pms, ConversationModel *cModel, RosterModel *rModel);
    void listen();
    void parseChannelData(QString sreply);
    QDateTime getLastPushTs();
    void fastReconnect();
    void setAppPaused();
    void setAppOpened();
    QString getLastIncomingConversation();
    void setStatus(bool online);

public slots:
    void checkChannel();
    void nr();
    void nrf();
    void parseSid();
    void slotError(QNetworkReply::NetworkError err);

private slots:
    void longPollRequest();

signals:
    void cookieUpdateNeeded(QList<QNetworkCookie> cookies);
    void updateClientId(QString newID);
    void activeClientUpdate(int state);
    void updateWM(QString convId);
    void channelLost();
    void channelRestored(QDateTime lastRecv);
    void isTyping(QString convId, QString chatId, int type);
    void showNotification(QString preview, QString summary, QString body, QString sender, int num, QString convId);
    void renameConversation(QString cid, QString newname);
    void cancelAllActiveRequests();

};

#endif // CHANNEL_H