apb2006/app-basex.js

## app-basex.js
// Andy bunce jan 2013 based on http://book.mixu.net/ch13.html
var fs = require('fs'),
    http = require('http'),
    sio = require('socket.io');
var port=8001;
var server = http.createServer(function(req, res) {
  res.writeHead(200, { 'Content-type': 'text/html'});
  res.end(fs.readFileSync('./index.html'));
});
server.listen(port, function() {
  console.log('Server listening at http://localhost:',port);
});
// Attach the socket.io server
io = sio.listen(server);
// store messages
var messages = [];
var userId=0;
// Define a message handler
io.sockets.on('connection', function (socket) {
  socket.username="user"+userId++;
  socket.on('message', function (msg) {
    var lmsg=socket.username+ ": "+msg;
    messages.push(lmsg);
    socket.broadcast.emit('message', lmsg);
    //---- if starts "xquery" execute on basex server -----------
    if(msg.indexOf("xquery ") == 0){
    bx.execute(msg,function(err,reply){
        io.sockets.emit('message', "basex: " +reply.result);
        })
    }
  });
  // send messages to new clients
  messages.forEach(function(msg) {
    socket.send(msg);
  })
});

var basex=require('basex');
var bx = new basex.Session("localhost", 1984, "admin", "admin");
bx.execute("create event chat", afterCreate);
// watch for it
function afterCreate(err, reply) {
  console.log("running afterCreate...");
	if (err)
		console.log("Error: " + err);
	bx.watch("chat", watchCallback);
};
// echo events as chat
function watchCallback(name,msg){
 io.sockets.emit('message', "basex: " +msg);
};

## index.html
<html>
<head>
  <title>Xquery chat</title>
  <style type="text/css">

    #messages li { padding: 2px 0px; border-bottom: 1px solid #ccc; }
  </style>
  <script src="http://code.jquery.com/jquery-1.7.1.min.js"></script>
  <script src="/socket.io/socket.io.js"></script>
  <script>
  $(function(){
    var socket = io.connect();
    socket.on('connect', function () {
      socket.on('message', function(message) {
        $('#messages').append($('<li></li>').text(message));
      });
      socket.on('disconnect', function() {
        $('#messages').append('<li>Disconnected</li>');
      });
    });

    var el = $('#chatmsg');
    $('#chatmsg').keypress(function(e) {
      if(e.which == 13) {
        e.preventDefault();
        socket.send(el.val());
        $('#messages').append($('<li></li>').text(el.val()));
        el.val('');
      }
    });
  });
  </script>
</head>
<body>
 <ol id="messages"></ol>
 <hr>
 <input type="text" id="chatmsg">
</body>
</html>
	// Andy bunce jan 2013 based on http://book.mixu.net/ch13.html
	var fs = require('fs'),
	http = require('http'),
	sio = require('socket.io');
	var port=8001;
	var server = http.createServer(function(req, res) {
	res.writeHead(200, { 'Content-type': 'text/html'});
	res.end(fs.readFileSync('./index.html'));
	});
	server.listen(port, function() {
	console.log('Server listening at http://localhost:',port);
	});
	// Attach the socket.io server
	io = sio.listen(server);
	// store messages
	var messages = [];
	var userId=0;
	// Define a message handler
	io.sockets.on('connection', function (socket) {
	socket.username="user"+userId++;
	socket.on('message', function (msg) {
	var lmsg=socket.username+ ": "+msg;
	messages.push(lmsg);
	socket.broadcast.emit('message', lmsg);
	//---- if starts "xquery" execute on basex server -----------
	if(msg.indexOf("xquery ") == 0){
	bx.execute(msg,function(err,reply){
	io.sockets.emit('message', "basex: " +reply.result);
	})
	}
	});
	// send messages to new clients
	messages.forEach(function(msg) {
	socket.send(msg);
	})
	});

	var basex=require('basex');
	var bx = new basex.Session("localhost", 1984, "admin", "admin");
	bx.execute("create event chat", afterCreate);
	// watch for it
	function afterCreate(err, reply) {
	console.log("running afterCreate...");
	if (err)
	console.log("Error: " + err);
	bx.watch("chat", watchCallback);
	};
	// echo events as chat
	function watchCallback(name,msg){
	io.sockets.emit('message', "basex: " +msg);
	};
	<html>
	<head>
	<title>Xquery chat</title>
	<style type="text/css">

	#messages li { padding: 2px 0px; border-bottom: 1px solid #ccc; }
	</style>
	<script src="http://code.jquery.com/jquery-1.7.1.min.js"></script>
	<script src="/socket.io/socket.io.js"></script>
	<script>
	$(function(){
	var socket = io.connect();
	socket.on('connect', function () {
	socket.on('message', function(message) {
	$('#messages').append($('<li></li>').text(message));
	});
	socket.on('disconnect', function() {
	$('#messages').append('<li>Disconnected</li>');
	});
	});

	var el = $('#chatmsg');
	$('#chatmsg').keypress(function(e) {
	if(e.which == 13) {
	e.preventDefault();
	socket.send(el.val());
	$('#messages').append($('<li></li>').text(el.val()));
	el.val('');
	}
	});
	});
	</script>
	</head>
	<body>
	<ol id="messages"></ol>
	<hr>
	<input type="text" id="chatmsg">
	</body>
	</html>