Livelets.as

From OrganicDesign Wiki

Legacy: This article describes a concept that has been superseded in the course of ongoing development on the Organic Design wiki. Please do not develop this any further or base work on this concept, this is only useful for a historic record of work done. You may find a link to the currently used concept or function in this article, if not you can contact the author to find out what has taken the place of this legacy item.

// Extension:Livelets
// - See http://www.mediawiki.org/wiki/Extension:Livelets for installation and usage details
// - Licenced under LGPL (http://www.gnu.org/copyleft/lesser.html)
 
// All this needs to do is unintelligently route incoming update messages to the recipient livelets by id
// - each message can just be update:id1,id2,id3,id4... which executes the $wgLiveletsUpdate code for each id
// - remember that the SWF binary needs to be served from livelets.pl
 
class live {
 
	// Properties
	static var app : live;
	var socket     : XMLSocket;
 
	// Entry point
	static function main(mc) {
		app = new live();
		}
 
	// Constructor
	function live() {
 
		// Initialise objects
		this.socket        = new XMLSocket();
		_root.connected    = false;
		_root.ctr          = 1;
		_root.onEnterFrame = this.reduce;
		_root.log          = this.log;
 
		// When connected, send login info
		socket.onConnect = function(success) {
			if (_root.connected = success) {
				_root.log('Connected.');
				// request a dedicated peerd child spawn to handle this stream
				_root.request('/connect/peer/interface');
				}
			else {
				_root.log('Connection failed!');
				_root.log('Will retry soon...');
				}
			};
 
		// Decode incoming message
		socket.onData = function(data) {
			_root.log('Message received:');
			_root.log(data);
			};
 
		socket.onClose = function() {
			_root.connected = false;
			_root.log('Connection closed!');
			_root.ctr = 1;
			_root.log('Will retry soon...');
			};
 
		}
 
	function log(entry) {
		return entry;
		}
 
	// Called periodically (per frame)
	function reduce() {
//		if (!this.socket.connected && ++this.ctr%250 == 1) this.peerConnect('organicdesign.co.nz',1729);
		}
 
	// Connect to our host to establish stream
	function peerConnect(domain,port) {
		if (this.socket.connect(domain,port)) log('Connecting to '+domain+':'+port);
		else this.log('Could not initialise connection!');
		}
 
	// Send a message to the associated peer
	function request(request) {
		this.log('Sending message: "'+request+'"');
		this.socket.send('GET '+request+' HTTP/1.1'+String.fromCharCode(13,10,13,10));
		}
	}