/* dtkDistributedMessage.h ---
 *
 * Author: Nicolas Niclausse
 * Copyright (C) 2011 - Nicolas Niclausse, Inria.
 * Created: mar. oct. 11 10:46:57 2011 (+0200)
 * Version: $Id: 993176ff83a2854db46d509da0bd263e64a847ca $
 * Last-Updated: mar. févr.  4 15:18:12 2014 (+0100)
 *           By: Nicolas Niclausse
 *     Update #: 376
 */

/* Commentary:
 *
 */

/* Change log:
 *
 */

#include "dtkDistributedMessage.h"

#include <dtkCoreSupport/dtkGlobal.h>

#include <dtkLog>

class dtkDistributedMessagePrivate
{
public:
    dtkDistributedMessage::Method method;
    QString jobid;
    int rank ;
    dtkDistributedMessage::dtkDistributedHeaders headers;
    qint64 size ;
    QString type;
    QByteArray content;
};

dtkDistributedMessage::dtkDistributedMessage(void) :  d(new dtkDistributedMessagePrivate)
{
}

dtkDistributedMessage::~dtkDistributedMessage(void)
{
    delete d;
}


dtkDistributedMessage::dtkDistributedMessage(Method method, QString jobid, int rank, qint64 size, QString type, const QByteArray&  content,  const QHash<QString, QString>&  headers ) :  d(new dtkDistributedMessagePrivate)
{
    d->method = method;
    d->size = size;
    d->type = type;
    d->jobid = jobid;
    d->rank = rank;
    d->headers = headers;
    d->content = content;

}

// set method, and also, if necessary, jobid and rank
void dtkDistributedMessage::setMethod(QString method)
{
    QStringList tokens = QString(method).split(QRegExp("/"));

    if (method.startsWith("GET /status")) {
        d->method = STATUS;
    } else if (method.startsWith("OK /status")) {
        d->method = OKSTATUS;
    } else if (method.startsWith("PUT /job")) {
        d->method = NEWJOB;
    } else if (method.startsWith("OK /job")) {
        d->method = OKJOB;
        d->jobid  = tokens[2].trimmed();
    } else if (method.startsWith("DELETE /job")) {
        d->method = DELJOB;
        d->jobid  = tokens[2].trimmed();
    } else if (method.startsWith("OK /deleted")) {
        d->method = OKDEL;
        d->jobid  = tokens[2].trimmed();
    } else if (method.startsWith("ERROR /deleted")) {
        d->method = ERRORDEL;
        d->jobid  = tokens[2].trimmed();
    } else if (method.startsWith("STARTED /job")) {
        d->method = STARTJOB;
        d->jobid  = tokens[2].trimmed();
    } else if (method.startsWith("ENDED /job")) {
        d->method = ENDJOB;
        d->jobid  = tokens[2].trimmed();
    } else if (method.startsWith("DELETE /")) {
        d->method = STOP;
    } else if (method.startsWith("POST /data")) {
        d->method = DATA;
        d->jobid  = tokens[2];

        if (tokens.size() > 2)
            d->rank  = tokens[3].toInt();
    } else if (method.startsWith("PUT /rank")) {
        d->method = SETRANK;
        d->jobid  = tokens[2];
        d->rank   = tokens[3].toInt();
    } else
        dtkWarn() << DTK_PRETTY_FUNCTION << "Unsupported method " << method;

}

void dtkDistributedMessage::setSize(const QString& header)
{
    QStringList tokens = header.split(QRegExp(":\\s*"));

    if (tokens[0].toLower() != "content-size") {
        dtkWarn() << "Error: Not a size header ! " << header;
        d->size = -1;
    } else
        d->size = tokens[1].toInt();
}

void dtkDistributedMessage::setType(const QString& header)
{
    QStringList tokens = header.split(QRegExp(":\\s*"));

    if (tokens[0].toLower() != "content-type") {
        dtkWarn() << "Error: Not a content type header ! " << header;
        d->type = "unknown";
    } else
        d->type = tokens[1].trimmed();
}

void dtkDistributedMessage::setContent(QByteArray& content)
{
    d->size    = content.size();
    d->content = content;
}

void dtkDistributedMessage::setHeader(const QString& headerString)
{
    QStringList tokens = headerString.split(QRegExp(":\\s*"));
    d->headers.insert(tokens[0], tokens[1].trimmed());
}

void dtkDistributedMessage::addHeader(QString name, QString value)
{
    d->headers.insert(name, value);
}

dtkDistributedMessage::Method dtkDistributedMessage::method(void)
{
    return d->method;
}

QString dtkDistributedMessage::req(void)
{
    QString req;

    switch (d->method) {
    case STATUS:
        req = "GET /status";
        break;

    case OKSTATUS:
        req = "OK /status/" + d->jobid;
        break;

    case NEWJOB:
        req = "PUT /job";
        break;

    case OKJOB:
        req = "OK /job/" + d->jobid;
        break;

    case DELJOB:
        req = "DELETE /job/" + d->jobid;
        break;

    case OKDEL:
        req = "OK /deleted/" + d->jobid;
        break;

    case ERRORDEL:
        req = "ERROR /deleted/" + d->jobid;
        break;

    case STARTJOB:
        req = "STARTED /job/" + d->jobid;
        break;

    case ENDJOB:
        req = "ENDED /job/" + d->jobid;
        break;

    case DATA:
        req = "POST /data/" + d->jobid + "/" + QString::number(d->rank) ;
        break;

    case SETRANK:
        req = "PUT /rank/" + d->jobid + "/" + QString::number(d->rank) ;
        break;

    case STOP:
        req = "DELETE /";
        break;

    default:
        dtkWarn() << "Unsupported method";
    };

    return req + "\n";
}

QString dtkDistributedMessage::jobid(void)
{
    return d->jobid;
}

int  dtkDistributedMessage::rank(void)
{
    return d->rank;
}

dtkDistributedMessage::dtkDistributedHeaders dtkDistributedMessage::headers()
{
    return d->headers;
}

QString dtkDistributedMessage::header(const QString& name)
{
    return d->headers[name];
}

QString dtkDistributedMessage::type(void)
{
    return d->type;
}

qint64  dtkDistributedMessage::size(void)
{
    return d->size;
}

QByteArray& dtkDistributedMessage::content(void)
{
    return d->content;
}