privmsgmodel.h

Go to the documentation of this file.

/*    -*-C++-*- -*-coding: utf-8-unix;-*-
    Classified Ads is Copyright (c) Antti Järvinen 2013.

    This file is part of Classified Ads.

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

    Classified Ads 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
    Lesser General Public License for more details.

    You should have received a copy of the GNU Lesser General Public
    License along with Classified Ads; if not, write to the Free Software
    Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
*/

#ifndef CLASSIFIED_PRIVMSGMODEL_H
#define CLASSIFIED_PRIVMSGMODEL_H
#include <QSqlDatabase>
#include "../mcontroller.h" // because enum from there is needed
#include "../net/protocol.h" // for SendQueueItem
#include "datamodelbase.h"

class Hash ;
class MModelProtocolInterface ;
class PrivMessage ;

class PrivMessageModel : public ModelBase {
    Q_OBJECT

public:
    PrivMessageModel(MController *aMController,
                     const MModelProtocolInterface &aModel) ;
    ~PrivMessageModel() ;

    bool publishPrivMessage(PrivMessage& aPrivMessage,
                            const Hash& aDestinationNode = KNullHash ) ;

    PrivMessage* messageByFingerPrint(const Hash& aFingerPrint) ;

    bool messageDataByFingerPrint(const Hash& aFingerPrint,
                                  QByteArray& aResultingPrivMessageData,
                                  QByteArray& aResultingSignature,
                                  Hash* aResultingDestinationNode,
                                  Hash* aResultingRecipient,
                                  quint32* aTimeOfPublish = NULL) ;
    bool publishedPrivMessageReceived(const Hash& aFingerPrint,
                                      const QByteArray& aContent,
                                      const QByteArray& aSignature,
                                      const QList<quint32>& aBangPath,
                                      const Hash& aDestinationNode,
                                      const Hash& aRecipient,
                                      const quint32 aTimeStamp,
                                      const Hash& aFromNode) ;
    bool sentPrivMessageReceived(const Hash& aFingerPrint,
                                 const QByteArray& aContent,
                                 const QByteArray& aSignature,
                                 const Hash& aDestinationNode,
                                 const Hash& aRecipient,
                                 const quint32 aTimeStamp,
                                 const Hash& fromNode ) ;

    void fillBucket(QList<SendQueueItem>& aSendQueue,
                    const Hash& aStartOfBucket,
                    const Hash& aEndOfBucket,
                    quint32 aLastMutualConnectTime,
                    const Hash& aForNode );
    QList<Hash> messagesForProfile(const Hash& aProfileHash,
                                   const quint32 aLastMutualConnectTime) ;

    void setAsRead(const Hash& aMessageHash, bool aIsRead ) ;
private: // methods
    bool doHandlepublishedOrSentPrivMessage(const Hash& aFingerPrint,
                                            const QByteArray& aContent,
                                            const QByteArray& aSignature,
                                            const QList<quint32>& aBangPath,
                                            const Hash& aDestinationNode,
                                            const Hash& aRecipient,
                                            const quint32 aTimeStamp,
                                            bool aWasPublish,
                                            const Hash& aFromNode ) ;
signals:
    void error(MController::CAErrorSituation aError,
               const QString& aExplanation) ;
    void contentReceived(const Hash& aHashOfContent,
                         const Hash& aHashOfRecipientProfile,
                         const ProtocolItemType aTypeOfReceivdContent) ;
private: // member variables:
    MController *iController  ;
    const MModelProtocolInterface& iModel ;
} ;
#endif