cadbrecordmodel.h

Go to the documentation of this file.

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

  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_CADBRECORDMODEL_H
#define CLASSIFIED_CADBRECORDMODEL_H
#include <QPair>
#include "../mcontroller.h" // because enum from there is needed
#include "../net/protocol.h" // for SendQueueItem
#include "datamodelbase.h"
#include <limits>

class Hash ;
class MModelProtocolInterface ;
class CaDbRecord ;

class CaDbRecordModel : public ModelBase {
    Q_OBJECT

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

    QString publishDbRecord(CaDbRecord& aRecord,
                            const QList<Hash>* aRecordReaders = NULL ) ;

    QList<CaDbRecord *> searchRecords(const Hash& aFromCollection,
                                      const Hash& aById = KNullHash,
                                      const quint32 aModifiedAfter = 0 ,
                                      const quint32 aModifiedBefore = std::numeric_limits<quint32>::max(),
                                      const qint64 aByHavingNumberMoreThan = std::numeric_limits<qint64>::min(),
                                      const qint64 aByHavingNumberLessThan = std::numeric_limits<qint64>::max(),
                                      const QString& aBySearchPhrase = QString::null,
                                      const Hash& aBySender = KNullHash,
                                      const bool aForPublish = false ) ; 
                                     

    bool publishedCaDbRecordReceived(CaDbRecord& aRecord,
                                     const QByteArray& aSignature,
                                     const QList<quint32>& aBangPath,
                                     const Hash& aFromNode) ;
    bool sentCaDbRecordReceived(CaDbRecord& aRecord,
                                const QByteArray& aSignature,
                                const Hash& aFromNode ) ;

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

private: // methods
    bool doHandlepublishedOrSentRecord(CaDbRecord& aRecord,
                                       const QByteArray& aSignature,
                                       const QList<quint32>& aBangPath,
                                       const Hash& aFromNode,
                                       bool aWasPublish);
    
    QString persistDbRecordIntoDb(const CaDbRecord &aRecord,
                                  bool aIsNew,
                                  const QByteArray& aSignature,
                                  quint32 aReceivedFrom ) ; 

    QString isRecordNew(const CaDbRecord &aRecord,
                        bool* aResult,
                        quint32* aTimestampOfOldRecord = NULL ) ; 

    bool tryVerifyRecord(CaDbRecord& aRecord,
                         const QByteArray& aSignature,
                         QList<QPair<Hash,Hash> >& aListOfGoodSignatures ) ;  

    void deleteRecord(const Hash& aRecordId,
                      const Hash& aSenderId) ; 
    void updateRecordVerification(const Hash& aRecordId,
                                  const Hash& aSenderId,
                                  bool aNewVerificationStatus) ; 
    void updateFTS(const CaDbRecord& aRecord,
                   bool aIsNewRecord ) ; 

signals:
    void error(MController::CAErrorSituation aError,
               const QString& aExplanation) ;
    void contentReceived(const Hash& aHashOfContent,
                         const Hash& aHashOfCollection,
                         const ProtocolItemType aTypeOfReceivedContent) ;
private: // member variables:
    MController *iController  ;
    const MModelProtocolInterface& iModel ;
} ;
#endif