/*
* Copyright (c) 2009 Nokia Corporation and/or its subsidiary(-ies).
* All rights reserved.
*
* This program 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, version 2.1 of the License.
* 
* This program 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 this program.  If not, 
* see "http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html/".
*
* Description:                                                         
*
*/                                                                    

#ifndef XQSERVICEADAPTOR_H
#define XQSERVICEADAPTOR_H

#include <xqserviceglobal.h>

#include <QObject>
#include <QString>
#include <QByteArray>
#include <QVariant>
#include <QStringList>

#include <xqrequestinfo.h>

class XQServiceAdaptorPrivate;
class XQServiceRequestCompletedAsync;
class XQSharableFile;

class XQSERVICE_EXPORT XQServiceAdaptor : public QObject
{
    Q_OBJECT
    friend class XQServiceAdaptorPrivate;
    friend class XQServiceAdaptorChannel;
    friend class XQServiceProvider;
    
public:
    explicit XQServiceAdaptor(const QString& channel, QObject *parent = 0);
    virtual ~XQServiceAdaptor();

    QString channel() const;

    static bool connect(QObject *sender, const QByteArray& signal,
                        QObject *receiver, const QByteArray& member);

    bool send(const QByteArray& member, const QVariant &arg1, QVariant &retData);
    bool send(const QByteArray& member, const QVariant &arg1,
              const QVariant &arg2, QVariant &retData);
    bool send(const QByteArray& member, const QVariant &arg1,
              const QVariant &arg2, const QVariant &arg3, QVariant &retData);
    bool send(const QByteArray& member, const QList<QVariant>& args, QVariant &retData);

    bool isConnected(const QByteArray& signal);

    //todo: proposed to change in channel in 2 separate api sendSync sendAsync
    static bool send(const QString& channel,
                     const QString& msg, 
                     const QList<QVariant>& args, 
                     QVariant& retValue, 
                     bool sync = true,
                     XQServiceRequestCompletedAsync* rc = NULL);

    static bool send(const QString& channel,
                     const QString& msg, 
                     const QList<QVariant>& args, 
                     QVariant& retValue, 
                     bool sync,
                     XQServiceRequestCompletedAsync* rc,
                     const void *userData);
    
    static bool cancelPendingSend(const QString& channel);

    static int latestError();

    int setCurrentRequestAsync();

    bool completeRequest(int index, const QVariant& retValue);

    XQRequestInfo requestInfo() const;
    
 Q_SIGNALS:
    void returnValueDelivered() ;
    void clientDisconnected() ;
        
protected:
    enum PublishType
    {
        Signals,
        Slots,
        SignalsAndSlots
    };

    bool publish(const QByteArray& member);
    void publishAll(XQServiceAdaptor::PublishType type);
    virtual QString memberToMessage(const QByteArray& member);

private slots:
    void receiverDestroyed();

private:
    QVariant received(const QString& msg, const QByteArray& data,const XQSharableFile &sf);

    bool connectLocalToRemote(QObject *sender, const QByteArray& signal,
                              const QByteArray& member);
    bool connectRemoteToLocal(const QByteArray& signal, QObject *receiver,
                              const QByteArray& member);
    bool sendMessage(const QString& msg, const QList<QVariant>& args, QVariant &retData);
    
    void publishAll(QObject* object, int metCount, XQServiceAdaptor::PublishType type);

private:
    XQServiceAdaptorPrivate *d;
};

// Useful alias to make it clearer when connecting to messages on a channel.
#define MESSAGE(x)      "3"#x
#define QMESSAGE_CODE   3

#endif