/****************************************************************************

**

** Copyright (C) 2009 Nokia Corporation and/or its subsidiary(-ies).

** All rights reserved.

** Contact: Nokia Corporation (qt-info@nokia.com)

**

** This file is part of the tools applications of the Qt Toolkit.

**

** $QT_BEGIN_LICENSE:LGPL$

** No Commercial Usage

** This file contains pre-release code and may not be distributed.

** You may use this file in accordance with the terms and conditions

** contained in the Technology Preview License Agreement accompanying

** this package.

**

** GNU Lesser General Public License Usage

** Alternatively, this file may be used under the terms of the GNU Lesser

** General Public License version 2.1 as published by the Free Software

** Foundation and appearing in the file LICENSE.LGPL included in the

** packaging of this file.  Please review the following information to

** ensure the GNU Lesser General Public License version 2.1 requirements

** will be met: http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html.

**

** In addition, as a special exception, Nokia gives you certain additional

** rights.  These rights are described in the Nokia Qt LGPL Exception

** version 1.1, included in the file LGPL_EXCEPTION.txt in this package.

**

** If you have questions regarding the use of this file, please contact

** Nokia at qt-info@nokia.com.

**

**

**

**

**

**

**

**

** $QT_END_LICENSE$

**

****************************************************************************/

#include <stdio.h>

#include <stdlib.h>

#include <QtCore/QCoreApplication>

#include <QtCore/QStringList>

#include <QtCore/qmetaobject.h>

#include <QtXml/QDomDocument>

#include <QtXml/QDomElement>

#include <QtDBus/QtDBus>

#include <private/qdbusutil_p.h>

static QDBusConnection connection(QLatin1String(""));

static bool printArgumentsLiterally = false;

static void showUsage()

{

    printf("Usage: qdbus [--system] [--literal] [servicename] [path] [method] [args]\n"

           "\n"

           "  servicename       the service to connect to (e.g., org.freedesktop.DBus)\n"

           "  path              the path to the object (e.g., /)\n"

           "  method            the method to call, with or without the interface\n"

           "  args              arguments to pass to the call\n"

           "With 0 arguments, qdbus will list the services available on the bus\n"

           "With just the servicename, qdbus will list the object paths available on the service\n"

           "With service name and object path, qdbus will list the methods, signals and properties available on the object\n"

           "\n"

           "Options:\n"

           "  --system          connect to the system bus\n"

           "  --literal         print replies literally\n");

}

static void printArg(const QVariant &v)

{

    if (printArgumentsLiterally) {

        printf("%s\n", qPrintable(QDBusUtil::argumentToString(v)));

        return;

    }

    if (v.userType() == QVariant::StringList) {

        foreach (QString s, v.toStringList())

            printf("%s\n", qPrintable(s));

    } else if (v.userType() == QVariant::List) {

        foreach (const QVariant &var, v.toList())

            printArg(var);

    } else if (v.userType() == QVariant::Map) {

        const QVariantMap map = v.toMap();

        QVariantMap::ConstIterator it = map.constBegin();

        for ( ; it != map.constEnd(); ++it) {

            printf("%s: ", qPrintable(it.key()));

            printArg(it.value());

        }

    } else if (v.userType() == qMetaTypeId<QDBusVariant>()) {

        printArg(qvariant_cast<QDBusVariant>(v).variant());

    } else if (v.userType() == qMetaTypeId<QDBusArgument>()) {

        QDBusArgument arg = qvariant_cast<QDBusArgument>(v);

        if (arg.currentSignature() == QLatin1String("av"))

            printArg(qdbus_cast<QVariantList>(arg));

        else if (arg.currentSignature() == QLatin1String("a{sv}"))

            printArg(qdbus_cast<QVariantMap>(arg));

        else

            printf("qdbus: I don't know how to display an argument of type '%s'\n",

                   qPrintable(arg.currentSignature()));

    } else {

        printf("%s\n", qPrintable(v.toString()));

    }

}

static void listObjects(const QString &service, const QString &path)

{

    // make a low-level call, to avoid introspecting the Introspectable interface

    QDBusMessage call = QDBusMessage::createMethodCall(service, path.isEmpty() ? QLatin1String("/") : path,

                                                       QLatin1String("org.freedesktop.DBus.Introspectable"),

                                                       QLatin1String("Introspect"));

    QDBusReply<QString> xml = connection.call(call);

    if (path.isEmpty()) {

        // top-level

        if (xml.isValid()) {

            printf("/\n");

        } else {

            QDBusError err = xml.error();

            if (err.type() == QDBusError::ServiceUnknown)

                fprintf(stderr, "Service '%s' does not exist.\n", qPrintable(service));

            else

                printf("Error: %s\n%s\n", qPrintable(err.name()), qPrintable(err.message()));

            exit(2);

        }

    } else if (!xml.isValid()) {

        // this is not the first object, just fail silently

        return;

    }

    QDomDocument doc;

    doc.setContent(xml);

    QDomElement node = doc.documentElement();

    QDomElement child = node.firstChildElement();

    while (!child.isNull()) {

        if (child.tagName() == QLatin1String("node")) {

            QString sub = path + QLatin1Char('/') + child.attribute(QLatin1String("name"));

            printf("%s\n", qPrintable(sub));

            listObjects(service, sub);

        }

        child = child.nextSiblingElement();

    }

}

static void listInterface(const QString &service, const QString &path, const QString &interface)

{

    QDBusInterface iface(service, path, interface, connection);

    if (!iface.isValid()) {

        QDBusError err(iface.lastError());

        fprintf(stderr, "Interface '%s' not available in object %s at %s:\n%s (%s)\n",

                qPrintable(interface), qPrintable(path), qPrintable(service),

                qPrintable(err.name()), qPrintable(err.message()));

        exit(1);

    }

    const QMetaObject *mo = iface.metaObject();

    // properties

    for (int i = mo->propertyOffset(); i < mo->propertyCount(); ++i) {

        QMetaProperty mp = mo->property(i);

        printf("property ");

        if (mp.isReadable() && mp.isWritable())

            printf("readwrite");

        else if (mp.isReadable())

            printf("read");

        else

            printf("write");

        printf(" %s %s.%s\n", mp.typeName(), qPrintable(interface), mp.name());

    }

    // methods (signals and slots)

    for (int i = mo->methodOffset(); i < mo->methodCount(); ++i) {

        QMetaMethod mm = mo->method(i);

        QByteArray signature = mm.signature();

        signature.truncate(signature.indexOf('('));

        printf("%s %s%s%s %s.%s(",

               mm.methodType() == QMetaMethod::Signal ? "signal" : "method",

               mm.tag(), *mm.tag() ? " " : "",

               *mm.typeName() ? mm.typeName() : "void",

               qPrintable(interface), signature.constData());

        QList<QByteArray> types = mm.parameterTypes();

        QList<QByteArray> names = mm.parameterNames();

        bool first = true;

        for (int i = 0; i < types.count(); ++i) {

            printf("%s%s",

                   first ? "" : ", ",

                   types.at(i).constData());

            if (!names.at(i).isEmpty())

                printf(" %s", names.at(i).constData());

            first = false;

        }

        printf(")\n");

    }

}

static void listAllInterfaces(const QString &service, const QString &path)

{

    // make a low-level call, to avoid introspecting the Introspectable interface

    QDBusMessage call = QDBusMessage::createMethodCall(service, path.isEmpty() ? QLatin1String("/") : path,

                                                       QLatin1String("org.freedesktop.DBus.Introspectable"),

                                                       QLatin1String("Introspect"));

    QDBusReply<QString> xml = connection.call(call);

    if (!xml.isValid()) {

        QDBusError err = xml.error();

        if (err.type() == QDBusError::ServiceUnknown)

            fprintf(stderr, "Service '%s' does not exist.\n", qPrintable(service));

        else

            printf("Error: %s\n%s\n", qPrintable(err.name()), qPrintable(err.message()));

        exit(2);

    }

    QDomDocument doc;

    doc.setContent(xml);

    QDomElement node = doc.documentElement();

    QDomElement child = node.firstChildElement();

    while (!child.isNull()) {

        if (child.tagName() == QLatin1String("interface")) {

            QString ifaceName = child.attribute(QLatin1String("name"));

            if (QDBusUtil::isValidInterfaceName(ifaceName))

                listInterface(service, path, ifaceName);

            else {

                qWarning("Invalid D-BUS interface name '%s' found while parsing introspection",

                         qPrintable(ifaceName));

            }

        }

        child = child.nextSiblingElement();

    }

}

static QStringList readList(QStringList &args)

{

    args.takeFirst();

    QStringList retval;

    while (!args.isEmpty() && args.at(0) != QLatin1String(")"))

        retval += args.takeFirst();

    if (args.value(0) == QLatin1String(")"))

        args.takeFirst();

    return retval;

}

static void placeCall(const QString &service, const QString &path, const QString &interface,

               const QString &member, QStringList args)

{

    QDBusInterface iface(service, path, interface, connection);

    // Don't check whether the interface is valid to allow DBus try to

    // activate the service if possible.

    QVariantList params;

    if (!args.isEmpty()) {

        const QMetaObject *mo = iface.metaObject();

        QByteArray match = member.toLatin1();

        match += '(';

        int midx = -1;

        for (int i = mo->methodOffset(); i < mo->methodCount(); ++i) {

            QMetaMethod mm = mo->method(i);

            QByteArray signature = mm.signature();

            if (signature.startsWith(match)) {

                midx = i;

                break;

            }

         }

        if (midx == -1) {

            fprintf(stderr, "Cannot find '%s.%s' in object %s at %s\n",

                    qPrintable(interface), qPrintable(member), qPrintable(path),

                    qPrintable(service));

            exit(1);

        }

        QMetaMethod mm = mo->method(midx);

        QList<QByteArray> types = mm.parameterTypes();

        for (int i = 0; i < types.count(); ++i) {

            if (types.at(i).endsWith('&')) {

                // reference (and not a reference to const): output argument

                // we're done with the inputs

                while (types.count() > i)

                    types.removeLast();

                break;

            }

        }

        for (int i = 0; !args.isEmpty() && i < types.count(); ++i) {

            int id = QVariant::nameToType(types.at(i));

            if (id == QVariant::UserType)

                id = QMetaType::type(types.at(i));

            Q_ASSERT(id);

            QVariant p;

            QString argument;

            if ((id == QVariant::List || id == QVariant::StringList)

                 && args.at(0) == QLatin1String("("))

                p = readList(args);

            else

                p = argument = args.takeFirst();

            if (id == int(QMetaType::UChar)) {

                // special case: QVariant::convert doesn't convert to/from

                // UChar because it can't decide if it's a character or a number

                p = qVariantFromValue<uchar>(p.toUInt());

            } else if (id < int(QMetaType::User) && id != int(QVariant::Map)) {

                p.convert(QVariant::Type(id));

                if (p.type() == QVariant::Invalid) {

                    fprintf(stderr, "Could not convert '%s' to type '%s'.\n",

                            qPrintable(argument), types.at(i).constData());

                    exit(1);

                }

            } else if (id == qMetaTypeId<QDBusVariant>()) {

                QDBusVariant tmp(p);

                p = qVariantFromValue(tmp);

            } else if (id == qMetaTypeId<QDBusObjectPath>()) {

                QDBusObjectPath path(argument);

                if (path.path().isNull()) {

                    fprintf(stderr, "Cannot pass argument '%s' because it is not a valid object path.\n",

                            qPrintable(argument));

                    exit(1);

                }

                p = qVariantFromValue(path);

            } else if (id == qMetaTypeId<QDBusSignature>()) {

                QDBusSignature sig(argument);

                if (sig.signature().isNull()) {

                    fprintf(stderr, "Cannot pass argument '%s' because it is not a valid signature.\n",

                            qPrintable(argument));

                    exit(1);

                }

                p = qVariantFromValue(sig);

            } else {

                fprintf(stderr, "Sorry, can't pass arg of type '%s'.\n",

                        types.at(i).constData());

                exit(1);

            }

            params += p;

        }

        if (params.count() != types.count() || !args.isEmpty()) {

            fprintf(stderr, "Invalid number of parameters\n");

            exit(1);

        }

    }

    QDBusMessage reply = iface.callWithArgumentList(QDBus::Block, member, params);

    if (reply.type() == QDBusMessage::ErrorMessage) {

        QDBusError err = reply;

        if (err.type() == QDBusError::ServiceUnknown)

            fprintf(stderr, "Service '%s' does not exist.\n", qPrintable(service));

        else

            printf("Error: %s\n%s\n", qPrintable(err.name()), qPrintable(err.message()));

        exit(2);

    } else if (reply.type() != QDBusMessage::ReplyMessage) {

        fprintf(stderr, "Invalid reply type %d\n", int(reply.type()));

        exit(1);

    }

    foreach (QVariant v, reply.arguments())

        printArg(v);

    exit(0);

}

static bool globServices(QDBusConnectionInterface *bus, const QString &glob)

{

    QRegExp pattern(glob, Qt::CaseSensitive, QRegExp::Wildcard);

    if (!pattern.isValid())

        return false;

    QStringList names = bus->registeredServiceNames();

    names.sort();

    foreach (const QString &name, names)

        if (pattern.exactMatch(name))

            printf("%s\n", qPrintable(name));

    return true;

}

static void printAllServices(QDBusConnectionInterface *bus)

{

    const QStringList services = bus->registeredServiceNames();

    QMap<QString, QStringList> servicesWithAliases;

    foreach (QString serviceName, services) {

        QDBusReply<QString> reply = bus->serviceOwner(serviceName);

        QString owner = reply;

        if (owner.isEmpty())

            owner = serviceName;

        servicesWithAliases[owner].append(serviceName);

    }

    for (QMap<QString,QStringList>::const_iterator it = servicesWithAliases.constBegin();

         it != servicesWithAliases.constEnd(); ++it) {

        QStringList names = it.value();

        names.sort();

        printf("%s\n", qPrintable(names.join(QLatin1String("\n "))));

    }

}

int main(int argc, char **argv)

{

    QCoreApplication app(argc, argv);

    QStringList args = app.arguments();

    args.takeFirst();

    bool connectionOpened = false;

    while (!args.isEmpty() && args.at(0).startsWith(QLatin1Char('-'))) {

        QString arg = args.takeFirst();

        if (arg == QLatin1String("--system")) {

            connection = QDBusConnection::systemBus();

            connectionOpened = true;

        } else if (arg == QLatin1String("--literal")) {

            printArgumentsLiterally = true;

        } else if (arg == QLatin1String("--help")) {

            showUsage();

            return 0;

        }

    }

    if (!connectionOpened)

        connection = QDBusConnection::sessionBus();

    if (!connection.isConnected()) {

        fprintf(stderr, "Could not connect to D-Bus server: %s: %s\n",

                qPrintable(connection.lastError().name()),

                qPrintable(connection.lastError().message()));

        return 1;

    }

    QDBusConnectionInterface *bus = connection.interface();

    if (args.isEmpty()) {

        printAllServices(bus);

        exit(0);

    }

    QString service = args.takeFirst();

    if (!QDBusUtil::isValidBusName(service)) {

        if (service.contains(QLatin1Char('*'))) {

            if (globServices(bus, service))

                return 0;

        }

        fprintf(stderr, "Service '%s' is not a valid name.\n", qPrintable(service));

        exit(1);

    }

    if (args.isEmpty()) {

        listObjects(service, QString());

        exit(0);

    }

    QString path = args.takeFirst();

    if (!QDBusUtil::isValidObjectPath(path)) {

        fprintf(stderr, "Path '%s' is not a valid path name.\n", qPrintable(path));

        exit(1);

    }

    if (args.isEmpty()) {

        listAllInterfaces(service, path);

        exit(0);

    }

    QString interface = args.takeFirst();

    QString member;

    int pos = interface.lastIndexOf(QLatin1Char('.'));

    if (pos == -1) {

        member = interface;

        interface.clear();

    } else {

        member = interface.mid(pos + 1);

        interface.truncate(pos);

    }

    if (!interface.isEmpty() && !QDBusUtil::isValidInterfaceName(interface)) {

        fprintf(stderr, "Interface '%s' is not a valid interface name.\n", qPrintable(interface));

        exit(1);

    }

    if (!QDBusUtil::isValidMemberName(member)) {

        fprintf(stderr, "Method name '%s' is not a valid member name.\n", qPrintable(member));

        exit(1);

    }

    placeCall(service, path, interface, member, args);

}