// Version: $Id: 2800ac7c7d94ecb532a9165ad33f2d9f60e308bf $
//
//

// Commentary:
//
//

// Change Log:
//
//

// Code:

#pragma once

#include <dtkDistributedExport.h>

#include <QTcpSocket>

class dtkDistributedMessagePrivate;

class DTKDISTRIBUTED_EXPORT dtkDistributedMessage
{
public:
    typedef QHash<QString, QString> dtkDistributedHeaders;

    static const qint16 CONTROLLER_RANK = -1 ;
    static const qint16 SERVER_RANK     = -2 ;
    static const qint16 CONTROLLER_RUN_RANK = -5 ;
    static const qint16 SLAVE_RANK = -4 ; // identify the slave tcp connection that handle composition send/receive.

    enum Method {
        STATUS  ,
        OKSTATUS,
        NEWJOB  ,
        OKJOB   ,
        ERRORJOB,
        DELJOB  ,
        OKDEL   ,
        ERRORDEL,
        ENDJOB  ,
        DATA    ,
        SETRANK ,
        ERROR_UNKNOWN,
        STOP
    };

    dtkDistributedMessage(void);
    dtkDistributedMessage(Method method, QString jobid = "", int rank = SERVER_RANK, qint64 size = 0, QString type = "json",  const QByteArray&  content = QByteArray(), const dtkDistributedHeaders& headers = dtkDistributedHeaders());
    dtkDistributedMessage(Method method, QString jobid, int rank, const QVariant&  v, const dtkDistributedHeaders& headers = dtkDistributedHeaders());
    virtual ~dtkDistributedMessage(void);

public:
    void addHeader(QString name, QString value);
    void setHeader(const QString& headers);
    void setMethod(QString method);
    void setMethod(Method method);
    void setJobid(const QString& jobid);
    void setRank(qint16 rank);
    void setType(void);
    void setSize(void);
    void setContent(QByteArray& content);

public:
    qlonglong  send(QTcpSocket *socket);
    qlonglong parse(QTcpSocket *socket);

public:
    Method method(void);
    QString         req(void);
    QString       jobid(void);
    int            rank(void);
    QString      header(const QString& name);
    QString        type(void);
    qint64         size(void);
    QByteArray& content(void);
    QVariant&   variant(void);
    QString methodString(void);

public:
    dtkDistributedHeaders headers();

private:
    dtkDistributedMessagePrivate *d;
};

//
// dtkDistributedMessage.h ends here