diff options
author | Frederik Gladhorn <frederik.gladhorn@digia.com> | 2014-09-02 17:47:32 +0200 |
---|---|---|
committer | Frederik Gladhorn <frederik.gladhorn@digia.com> | 2014-09-02 17:47:32 +0200 |
commit | bcbaa596815caf53c80f4a5220fb008000b3d897 (patch) | |
tree | bf639fe99579d951e85618f3bd0ff71b6b1e974c /examples/webchannel/nodejs/chatclient.js | |
parent | 6bea7fb2dc597817fde7e16216220d2eacc48509 (diff) | |
parent | a79f70e2dfa1fa3d3a418310c7b8c8bb89c2d3c8 (diff) | |
download | qtwebchannel-bcbaa596815caf53c80f4a5220fb008000b3d897.tar.gz |
Merge remote-tracking branch 'origin/5.4' into dev
Change-Id: Ibbab64e34150e1131fadf37f2e84a0a3f618974f
Diffstat (limited to 'examples/webchannel/nodejs/chatclient.js')
-rw-r--r-- | examples/webchannel/nodejs/chatclient.js | 125 |
1 files changed, 125 insertions, 0 deletions
diff --git a/examples/webchannel/nodejs/chatclient.js b/examples/webchannel/nodejs/chatclient.js new file mode 100644 index 0000000..ac28d84 --- /dev/null +++ b/examples/webchannel/nodejs/chatclient.js @@ -0,0 +1,125 @@ +/**************************************************************************** +** +** 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:LGPL21$ +** 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 or version 3 as published by the Free +** Software Foundation and appearing in the file LICENSE.LGPLv21 and +** LICENSE.LGPLv3 included in the packaging of this file. Please review the +** following information to ensure the GNU Lesser General Public License +** requirements will be met: https://www.gnu.org/licenses/lgpl.html and +** 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. +** +** $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); +}); |