1 files changed, 133 insertions, 0 deletions
diff --git a/examples/qwebchannel/nodejs/chatclient.js b/examples/qwebchannel/nodejs/chatclient.js
new file mode 100644
index 0000000..03ce214
--- /dev/null
+++ b/examples/qwebchannel/nodejs/chatclient.js
@@ -0,0 +1,133 @@
+/****************************************************************************
+**
+** Copyright (C) 2014 Digia Plc and/or its subsidiary(-ies).
+** Copyright (C) 2014 basysKom GmbH, author Bernd Lamecker <bernd.lamecker@basyskom.com>
+** Contact: http://www.qt-project.org/legal
+**
+** This file is part of the QtWebChannel module of the Qt Toolkit.
+**
+** $QT_BEGIN_LICENSE:LGPL$
+** Commercial License Usage
+** Licensees holding valid commercial Qt licenses may use this file in
+** accordance with the commercial license agreement provided with the
+** Software or, alternatively, in accordance with the terms contained in
+** a written agreement between you and Digia.  For licensing terms and
+** conditions see http://qt.digia.com/licensing.  For further information
+** use the contact form at http://qt.digia.com/contact-us.
+**
+** 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, Digia gives you certain additional
+** rights.  These rights are described in the Digia Qt LGPL Exception
+** version 1.1, included in the file LGPL_EXCEPTION.txt in this package.
+**
+** GNU General Public License Usage
+** Alternatively, this file may be used under the terms of the GNU
+** General Public License version 3.0 as published by the Free Software
+** Foundation and appearing in the file LICENSE.GPL included in the
+** packaging of this file.  Please review the following information to
+** ensure the GNU General Public License version 3.0 requirements will be
+** met: http://www.gnu.org/copyleft/gpl.html.
+**
+**
+** $QT_END_LICENSE$
+**
+****************************************************************************/
+'use strict';
+
+var readline = require('readline');
+var QWebChannel = require('./qwebchannel.js').QWebChannel;
+var websocket = require('faye-websocket');
+
+var address = 'ws://127.0.0.1:12345';
+var socket = new websocket.Client(address);
+
+console.log('Chat client connecting to ' + address + ' (Ctrl-D to quit)');
+
+var createReadlineInterface = function() {
+    var bye = function() {
+        console.log('Bye...');
+        process.exit(0);
+    }
+
+    var rlif = readline.createInterface({
+        input: process.stdin,
+        output: process.stdout
+    });
+    rlif.setPrompt('chat: ');
+
+    // Handle Ctrl-D and Ctrl-C
+    rlif.on('close', bye);
+    rlif.on('SIGINT', bye);
+
+    return rlif;
+}
+
+var createWebChannel = function(transport, rlif) {
+    return new QWebChannel(transport, function(channel) {
+        // We connect to the 'sendText' signal of the remote QObject
+        // Be aware, that the signal is named for the remote side,
+        // i.e. the server wants to 'send text'.
+        // This can be confusing, as we connect to the signal
+        // to receive incoming messages on our side
+        channel.objects.dialog.sendText.connect(function(message) {
+            process.stdout.cursorTo(0);
+            process.stdout.clearLine(0);
+            console.log(' <<   ' + message);
+            rlif.prompt();
+            // Go to end of existing input if any
+            rlif.write(null, {ctrl: true, name: 'e'})
+        });
+
+        rlif.on('line', function(line) {
+            var l = line.trim();
+            if (l !== '') {
+                process.stdout.moveCursor(0, -1);
+                process.stdout.cursorTo(0);
+                process.stdout.clearLine(0);
+                // The 'receiveText' slot of the remote QObject
+                // is called with our message.
+                // Again the naming is for the server side,
+                // i.e. the slot is used _by the server_ to receive text.
+                channel.objects.dialog.receiveText(l);
+                console.log('   >> ' + l);
+            }
+            rlif.prompt();
+        });
+        rlif.prompt();
+    });
+}
+
+socket.on('open', function(event) {
+    console.log("info: Client connected");
+    var transport = {
+        // We cant't do 'send: socket.send' here
+        // because 'send' wouldn't be bound to 'socket'
+        send: function(data) {socket.send(data)}
+    };
+
+    createWebChannel(transport, createReadlineInterface());
+
+    // QWebChannel has set up its onmessage handler
+    // on the transport in the constructor.
+    // Now we connect it to the websocket event.
+    socket.on('message', function(event) {
+        transport.onmessage(event);
+    });
+});
+
+socket.on('error', function (error) {
+    console.log('Connection error: ' + error.message);
+    process.exit(1);
+});
+
+socket.on('close', function () {
+    console.log('Connection closed.');
+    process.exit(1);
+});