Difference between revisions of "Livelets.as"
m |
m (_parent) |
||
| Line 27: | Line 27: | ||
// When connected, send login info | // When connected, send login info | ||
socket.onConnect = function(success) { | socket.onConnect = function(success) { | ||
| − | if ( | + | if (_parent.connected = success) { |
| − | + | _parent.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'); | |
} | } | ||
else { | else { | ||
| − | + | _parent.log('Connection failed!'); | |
| − | + | _parent.log('Will retry soon...'); | |
} | } | ||
}; | }; | ||
| Line 40: | Line 40: | ||
// Decode incoming message | // Decode incoming message | ||
socket.onData = function(data) { | socket.onData = function(data) { | ||
| − | + | _parent.log('Message received:'); | |
| − | + | _parent.log(data); | |
}; | }; | ||
socket.onClose = function() { | socket.onClose = function() { | ||
| − | + | _parent.connected = false; | |
| − | + | _parent('Connection closed!'); | |
| − | + | _parent.ctr = 1; | |
| − | + | _parent.log('Will retry soon...'); | |
}; | }; | ||
| Line 66: | Line 66: | ||
// Send a message to the associated peer | // Send a message to the associated peer | ||
function request(request) { | function request(request) { | ||
| − | + | _parent.log('Sending message: "'+request+'"'); | |
this.send('GET '+request+' HTTP/1.1'+String.fromCharCode(13,10,13,10)); | this.send('GET '+request+' HTTP/1.1'+String.fromCharCode(13,10,13,10)); | ||
} | } | ||
} | } | ||
Revision as of 03:23, 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; var connected; var ctr;
// Entry point static function main(mc) { app = new live(); }
// Constructor function live() {
// Initialise objects this.socket = new XMLSocket(); this.connected = false; this.ctr = 1; _root.onEnterFrame = this.reduce;
// When connected, send login info socket.onConnect = function(success) { if (_parent.connected = success) { _parent.log('Connected.'); // request a dedicated peerd child spawn to handle this stream _parent.request('/connect/peer/interface'); } else { _parent.log('Connection failed!'); _parent.log('Will retry soon...'); } };
// Decode incoming message socket.onData = function(data) { _parent.log('Message received:'); _parent.log(data); };
socket.onClose = function() { _parent.connected = false; _parent('Connection closed!'); _parent.ctr = 1; _parent.log('Will retry soon...'); };
}
// 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 log('Could not initialise connection!'); }
// Send a message to the associated peer function request(request) { _parent.log('Sending message: "'+request+'"'); this.send('GET '+request+' HTTP/1.1'+String.fromCharCode(13,10,13,10)); } }
