Difference between revisions of "Livelets.as"

From Organic Design wiki
m
m
Line 8: Line 8:
 
static var app : live;
 
static var app : live;
 
var socket    : XMLSocket;
 
var socket    : XMLSocket;
var connected;
 
var ctr;
 
  
 
// Entry point
 
// Entry point
Line 21: Line 19:
 
// Initialise objects
 
// Initialise objects
 
this.socket        = new XMLSocket();
 
this.socket        = new XMLSocket();
this.connected     = false;
+
_root.connected   = false;
this.ctr           = 1;
+
_root.ctr         = 1;
 
_root.onEnterFrame = this.reduce;
 
_root.onEnterFrame = this.reduce;
  
 
// When connected, send login info
 
// When connected, send login info
 
socket.onConnect = function(success) {
 
socket.onConnect = function(success) {
if (_parent.connected = success) {
+
if (_root.connected = success) {
_parent.log('Connected.');
+
_root.log('Connected.');
 
// request a dedicated peerd child spawn to handle this stream
 
// request a dedicated peerd child spawn to handle this stream
_parent.request('/connect/peer/interface');
+
_root.request('/connect/peer/interface');
 
}
 
}
 
else {
 
else {
_parent.log('Connection failed!');
+
_root.log('Connection failed!');
_parent.log('Will retry soon...');
+
_root.log('Will retry soon...');
 
}
 
}
 
};
 
};
Line 40: Line 38:
 
// Decode incoming message
 
// Decode incoming message
 
socket.onData = function(data) {
 
socket.onData = function(data) {
_parent.log('Message received:');
+
_root.log('Message received:');
_parent.log(data);
+
_root.log(data);
 
};
 
};
  
 
socket.onClose = function() {
 
socket.onClose = function() {
_parent.connected = false;
+
_root.connected = false;
_parent('Connection closed!');
+
_root('Connection closed!');
_parent.ctr = 1;
+
_root.ctr = 1;
_parent.log('Will retry soon...');
+
_root.log('Will retry soon...');
 
};
 
};
  

Revision as of 07:41, 7 May 2007

// 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)Template:As{{#security:*|dev}}{{#security:view|*}}

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;

// 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('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)); } }