1 files changed, 318 insertions, 0 deletions
diff --git a/qt/examples/dbus.cpp b/qt/examples/dbus.cpp
new file mode 100644
index 0000000..e011381
--- /dev/null
+++ b/qt/examples/dbus.cpp
@@ -0,0 +1,318 @@
+/* -*- C++ -*-
+ *
+ * Copyright (C) 2006 Trolltech AS. All rights reserved.
+ *    Author: Thiago Macieira <thiago.macieira@trolltech.com>
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2 of the License, or
+ * (at your option) any later version.
+ *
+ * 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 General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software Foundation,
+ * Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
+ *
+ */
+
+#include <stdio.h>
+
+#include <dbus/qdbus.h>
+#include <QtCore/QCoreApplication>
+#include <QtCore/QStringList>
+#include <QtCore/qmetaobject.h>
+#include <QtXml/QDomDocument>
+#include <QtXml/QDomElement>
+
+Q_DECLARE_METATYPE(QVariant)
+QDBusConnection *connection;
+
+void listObjects(const QString &service, const QString &path)
+{
+    QDBusInterface *iface = connection->findInterface(service, path.isEmpty() ? "/" : path,
+                                                     "org.freedesktop.DBus.Introspectable");
+    QDBusReply<QString> xml = iface->call("Introspect");
+
+    if (xml.isError())
+        return;                 // silently
+
+    QDomDocument doc;
+    doc.setContent(xml);
+    QDomElement node = doc.documentElement();
+    QDomElement child = node.firstChildElement();
+    while (!child.isNull()) {
+        if (child.tagName() == QLatin1String("node")) {
+            QString sub = path + '/' + child.attribute("name");
+            printf("%s\n", qPrintable(sub));
+            listObjects(service, sub);
+        }
+        child = child.nextSiblingElement();
+    }
+
+    delete iface;
+}
+
+void listInterface(const QString &service, const QString &path, const QString &interface)
+{
+    QDBusInterface *iface = connection->findInterface(service, path, interface);
+    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");
+    }
+    delete iface;
+}
+
+void listAllInterfaces(const QString &service, const QString &path)
+{
+    QDBusInterface *iface = connection->findInterface(service, path,
+                                                     "org.freedesktop.DBus.Introspectable");
+    QDBusReply<QString> xml = iface->call("Introspect");
+
+    if (xml.isError())
+        return;                 // silently
+
+    QDomDocument doc;
+    doc.setContent(xml);
+    QDomElement node = doc.documentElement();
+    QDomElement child = node.firstChildElement();
+    while (!child.isNull()) {
+        if (child.tagName() == QLatin1String("interface")) {
+            listInterface(service, path, child.attribute("name"));
+        }
+        child = child.nextSiblingElement();
+    }
+
+    delete iface;
+}
+
+QDBusInterface *findMember(const QString &service, const QString &path, const QString &member)
+{
+    QDBusInterface *iface = connection->findInterface(service, path,
+                                                     "org.freedesktop.DBus.Introspectable");
+    QDBusReply<QString> xml = iface->call("Introspect");
+
+    if (xml.isError())
+        return 0;
+
+    QDomDocument doc;
+    doc.setContent(xml);
+    QDomElement node = doc.documentElement();
+    QDomElement child = node.firstChildElement("interface");
+    while (!child.isNull()) {
+        QDomElement subchild = child.firstChildElement("method");
+        while (!subchild.isNull()) {
+            if (subchild.attribute("name") == member) {
+                QDBusInterface *retval;
+                retval = connection->findInterface(service, path, child.attribute("name"));
+                delete iface;
+                return retval;
+            }
+            subchild = subchild.nextSiblingElement("method");
+        }
+
+        child = child.nextSiblingElement("interface");
+    }
+
+    delete iface;
+    return 0;
+}
+
+QStringList readList(int &argc, const char *const *&argv)
+{
+    --argc;
+    ++argv;
+
+    QStringList retval;
+    while (argc && QLatin1String(argv[0]) != ")")
+        retval += QString::fromLocal8Bit(argv[0]);
+
+    return retval;
+}
+
+void placeCall(const QString &service, const QString &path, const QString &interface,
+               const QString &member, int argc, const char *const *argv)
+{
+    QDBusInterface *iface;
+    if (interface.isEmpty())
+        iface = findMember(service, path, member);
+    else
+        iface = connection->findInterface(service, path, interface);
+
+    if (!iface) {
+        fprintf(stderr, "Interface '%s' not available in object %s at %s\n",
+                qPrintable(interface), qPrintable(path), qPrintable(service));
+        exit(1);
+    }
+
+    const QMetaObject *mo = iface->metaObject();
+    QByteArray match = member.toLatin1();
+    match += '(';
+
+    int midx;
+    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 = iface->metaObject()->method(midx);
+    QList<QByteArray> types = mm.parameterTypes();
+
+    QVariantList params;
+    for (int i = 0; argc && i < types.count(); ++i) {
+        int id = QVariant::nameToType(types.at(i));
+        if (id == QVariant::UserType || id == QVariant::Map) {
+            fprintf(stderr, "Sorry, can't pass arg of type %s yet\n",
+                    types.at(i).constData());
+            exit(1);
+        }
+
+        Q_ASSERT(id);
+
+        QVariant p;
+        if ((id == QVariant::List || id == QVariant::StringList) && QLatin1String("(") == argv[0])
+            p = readList(argc, argv);
+        else
+            p = QString::fromLocal8Bit(argv[0]);
+
+        p.convert( QVariant::Type(id) );
+        params += p;
+        --argc;
+        ++argv;
+    }
+    if (params.count() != types.count()) {
+        fprintf(stderr, "Invalid number of parameters\n");
+        exit(1);
+    }
+
+    QDBusMessage reply = iface->callWithArgs(member, params);
+    if (reply.type() == QDBusMessage::ErrorMessage) {
+        QDBusError err = reply;
+        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) {
+        if (v.userType() == qMetaTypeId<QVariant>())
+            v = qvariant_cast<QVariant>(v);
+        printf("%s\n", qPrintable(v.toString()));
+    }
+
+    delete iface;
+    exit(0);
+}
+
+int main(int argc, char **argv)
+{
+    QCoreApplication app(argc, argv);
+    if (argc >= 1 && qstrcmp(argv[1], "--system") == 0) {
+        connection = &QDBus::systemBus();
+        --argc;
+        ++argv;
+    } else
+        connection = &QDBus::sessionBus();
+
+    QDBusBusService *bus = connection->busService();
+
+    if (argc == 1) {
+        QStringList names = bus->ListNames();
+        foreach (QString name, names)
+            printf("%s\n", qPrintable(name));
+        exit(0);
+    }
+    
+    QString service = QLatin1String(argv[1]);
+    if (!QDBusUtil::isValidBusName(service)) {
+        fprintf(stderr, "Service '%s' is not a valid name.\n", qPrintable(service));
+        exit(1);
+    }
+    if (!bus->NameHasOwner(service)) {
+        fprintf(stderr, "Service '%s' does not exist.\n", qPrintable(service));
+        exit(1);
+    }
+
+    if (argc == 2) {
+        printf("/\n");
+        listObjects(service, QString());
+        exit(0);
+    }
+
+    QString path = QLatin1String(argv[2]);
+    if (!QDBusUtil::isValidObjectPath(path)) {
+        fprintf(stderr, "Path '%s' is not a valid path name.\n", qPrintable(path));
+        exit(1);
+    }
+    if (argc == 3) {
+        listAllInterfaces(service, path);
+        exit(0);
+    }
+
+    QString interface = QLatin1String(argv[3]);
+    QString member;
+    int pos = interface.lastIndexOf(QLatin1Char('.'));
+    if (pos == -1) {
+        member = interface;
+        interface.clear();
+    } else {
+        member = interface.mid(pos + 1);
+        interface.truncate(pos);
+    }
+
+    placeCall(service, path, interface, member, argc - 4, argv + 4);
+}
+