textchannel.hpp

/*
    This file is part of the telepathy-morse connection manager.
    Copyright (C) 2016 Alexandr Akulich <akulichalexander@gmail.com>

    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.
*/

#ifndef MORSE_TEXTCHANNEL_HPP
#define MORSE_TEXTCHANNEL_HPP

#include <QPointer>

#include <TelegramQt/TelegramNamespace>

#include <TelepathyQt/BaseChannel>

class QTimer;

class CTelegramCore;

class MorseTextChannel;
class MorseConnection;

namespace Telegram {

namespace Client {

class Client;
class MessagingApi;

} // Client namespace

} // Telegram namespace

typedef Tp::SharedPtr<MorseTextChannel> MorseTextChannelPtr;

class MorseTextChannel : public Tp::BaseChannelTextType
{
    Q_OBJECT
public:
    static MorseTextChannelPtr create(MorseConnection *morseConnection, Tp::BaseChannel *baseChannel);
    virtual ~MorseTextChannel();

    QString sendMessageCallback(const Tp::MessagePartList &messageParts, uint flags, Tp::DBusError *error);

    void messageAcknowledgedCallback(const QString &messageToken);

    QString getMessageToken(quint32 messageId) const;
    quint32 getMessageId(const QString &token) const;

public slots:
    void onMessageActionChanged(const Telegram::Peer &peer, quint32 userId, const Telegram::MessageAction &action);
    void setMessageAction(quint32 userId, const Telegram::MessageAction &action);
    void onMessageReceived(const Telegram::Message &message);
    void onMessageSent(quint64 messageRandomId, quint32 messageId);
    void updateChatParticipants(const Tp::UIntList &handles);

    void onChatDetailsChanged(const Telegram::Peer &peer, const Tp::UIntList &handles);

signals:
    void messageAcknowledged(const Telegram::Peer &peer, quint32 messageId);

protected slots:
    void setMessageInboxRead(Telegram::Peer peer, quint32 messageId);
    void setMessageOutboxRead(Telegram::Peer peer, quint32 messageId);
    void updateDialogInfo();
    void reactivateLocalTyping();

protected:
    void setChatState(uint state, Tp::DBusError *error);

private:
    MorseTextChannel(MorseConnection *morseConnection, Tp::BaseChannel *baseChannel);

    MorseConnection *m_connection;
    Telegram::Client::Client *m_client;
    Telegram::Client::MessagingApi *m_api = nullptr;

    uint m_targetHandle;
    uint m_targetHandleType;
    Telegram::Peer m_targetPeer;
    Telegram::DialogInfo m_dialogInfo;
    bool m_broadcast = false;

    Tp::BaseChannelTextTypePtr m_channelTextType;
    Tp::BaseChannelMessagesInterfacePtr m_messagesIface;
    Tp::BaseChannelChatStateInterfacePtr m_chatStateIface;
    Tp::BaseChannelGroupInterfacePtr m_groupIface;
    Tp::BaseChannelRoomInterfacePtr m_roomIface;
    Tp::BaseChannelRoomConfigInterfacePtr m_roomConfigIface;

    QTimer *m_localTypingTimer;

};

#endif // MORSE_TEXTCHANNEL_HPP