// Version: $Id: 858fd6001f86e89c622cb0a9017df8385dcde791 $
//
//

// Commentary:
//
//

// Change Log:
//
//

// Code:

#include "dtkComposerNodeProcess.h"
#include "dtkComposerMetatype.h"

#include "dtkComposerTransmitterEmitter.h"
#include "dtkComposerTransmitterReceiver.h"

#include <dtkLog/dtkLog>

#include <dtkCoreSupport/dtkAbstractData.h>
#include <dtkCoreSupport/dtkAbstractProcess.h>

// /////////////////////////////////////////////////////////////////
// dtkComposerNodeProcessPrivate interface
// /////////////////////////////////////////////////////////////////

class dtkComposerNodeProcessPrivate
{
public:
    dtkComposerTransmitterReceiver<qlonglong> receiver_integer_0;
    dtkComposerTransmitterReceiver<qlonglong> receiver_integer_1;
    dtkComposerTransmitterReceiver<double> receiver_real;
    dtkComposerTransmitterReceiver<dtkAbstractData> receiver_data;
    dtkComposerTransmitterReceiver<QString> receiver_string;
    dtkComposerTransmitterReceiver<dtkAbstractData> receiver_lhs;
    dtkComposerTransmitterReceiver<dtkAbstractData> receiver_rhs;

public:
    dtkComposerTransmitterEmitter<qlonglong> emitter_integer;
    dtkComposerTransmitterEmitter<double> emitter_real;
    dtkComposerTransmitterEmitter<dtkAbstractData> emitter_data;

public:
    dtkAbstractProcess *process;

public:
    qlonglong index;
    qreal value;

public:
    QString implementation;
};

// /////////////////////////////////////////////////////////////////
// dtkComposerNodeProcess implementation
// /////////////////////////////////////////////////////////////////

dtkComposerNodeProcess::dtkComposerNodeProcess(void) : dtkComposerNodeLeafProcess(), d(new dtkComposerNodeProcessPrivate)
{
    this->appendReceiver(&(d->receiver_string));
    this->appendReceiver(&(d->receiver_integer_0));
    this->appendReceiver(&(d->receiver_integer_1));
    this->appendReceiver(&(d->receiver_real));
    this->appendReceiver(&(d->receiver_data));
    this->appendReceiver(&(d->receiver_lhs));
    this->appendReceiver(&(d->receiver_rhs));

    d->index = -1;
    this->appendEmitter(&(d->emitter_integer));

    d->value = 0.;
    this->appendEmitter(&(d->emitter_real));

    this->appendEmitter(&(d->emitter_data));

    d->process = NULL;
}

dtkComposerNodeProcess::~dtkComposerNodeProcess(void)
{
    if (d->process)
        delete d->process;

    delete d;

    d = NULL;
}

bool dtkComposerNodeProcess::isAbstractProcess(void) const
{
    return true;
}

QString dtkComposerNodeProcess::abstractProcessType(void) const
{
    return "dtkAbstractProcess";
}

void dtkComposerNodeProcess::setProcess(dtkAbstractProcess *process)
{
    d->process = process;
}

dtkAbstractProcess *dtkComposerNodeProcess::process(void) const
{
    return d->process;
}

void dtkComposerNodeProcess::run(void)
{
    if (!d->process) {
        dtkWarn() << Q_FUNC_INFO << "No process instantiated, abort:" << this->currentImplementation();
        return;
    }

    if (!d->receiver_string.isEmpty())
        d->process->read(*d->receiver_string.data());

    if (!d->receiver_integer_0.isEmpty())
        d->process->setParameter(static_cast<int>(*d->receiver_integer_0.data()), 0);

    if (!d->receiver_integer_1.isEmpty())
        d->process->setParameter(static_cast<int>(*d->receiver_integer_1.data()), 1);

    if (!d->receiver_real.isEmpty())
        d->process->setParameter(*d->receiver_real.data());

    if (!d->receiver_data.isEmpty()) {
        dtkAbstractData *data = d->receiver_data.data();
        d->process->setInput(data);
    }

    if (!d->receiver_lhs.isEmpty())
        d->process->setInput(d->receiver_lhs.data(), 0);

    if (!d->receiver_rhs.isEmpty())
        d->process->setInput(d->receiver_rhs.data(), 1);

    d->index = d->process->run();

    d->emitter_integer.setData(&d->index);

    if (d->process->data(0))
        d->value = *(static_cast<qreal *>(d->process->data(0)));

    d->emitter_real.setData(&d->value);

    if (d->process->output())
        d->emitter_data.setData(d->process->output());
}

QString dtkComposerNodeProcess::type(void)
{
    return "process";
}

QString dtkComposerNodeProcess::titleHint(void)
{
    return "Process";
}

QString dtkComposerNodeProcess::inputLabelHint(int port)
{
    if (port == 0)
        return "string";

    if (port == 1)
        return "integer";

    if (port == 2)
        return "integer";

    if (port == 3)
        return "real";

    if (port == 4)
        return "data";

    if (port == 5)
        return "lhs";

    if (port == 6)
        return "rhs";

    return dtkComposerNodeLeaf::inputLabelHint(port);
}

QString dtkComposerNodeProcess::outputLabelHint(int port)
{
    if (port == 0)
        return "integer";

    if (port == 1)
        return "real";

    if (port == 2)
        return "data";

    return dtkComposerNodeLeaf::outputLabelHint(port);
}

//
// dtkComposerNodeProcess.cpp ends here