Los servidores Comet – APE III – Objetos

pe.start(); //Send CONNECT command to APE.

ape.start('myNickname'); //Send CONNECT command with a nickname to APE.

ape.join(['channel1', 'channel2']); //Join channels "channel1" and "channel2"

Ape.getUserByPubid(pubid)

Ape.getChannelByName('foochannel')

Ape.getChannelByPubid(pubid)

var channel = Ape.mkChan('foo');

ape.fireEvent('myEvent', ['argument1', 'argument2'], 1000);

var mypipe = new Ape.pipe()

var mypipe = Ape.pipe()

//Get a pipe
var myPipe = ape.getPipe('a852c20b3e5c9889c16fe4ac88abe98f');
//Send a message on the pipe
myPipe.send('Hello world');

ape.join('testChannel');
//This sample is just here to show you how to intercept pipe pubid in pipeCreate event
ape.addEvent('multiPipeCreate', function(type, pipe, options) {
      //Get the pipe object
      var myPubid = ape.getPipe(pipe.getPubid());
      //Send a message on the pipe
      myPipe.send('Hello world');
});

ape.request.send(comando, parametros);

//This example sends a "JOIN" command,
// and "anotherCommand" with 2 arguments without adding sessid
ape.request.send([
      {
        "cmd":"JOIN",
        "params": {
              "channels": "test1"
               }
       },
      {
        "cmd": "anotherCommand",
        "params": {
              "param1": "value",
              "param2": "value"
           },
        "sessid": false
     }
]);

//Add two request to the stack
  ape.request.stack.add('testCommand', {"param1":"value"});
  ape.request.stack.add('anotherCommand', {"param1":"value"});
//Send the stack to APE server
  ape.request.stack.send();

ape.request.cycledStack.add(comando,parametros)

ape.request.cycledStack.add('mouseMotion', {"x":ev.x, "y":ev.y})

ape.request.cycledStack.send();

ape.request.cycledStack.send();

//Set cycle stack time to 100 ms
ape.request.cycledStack.setTime(100);

Si el booleano se activa a true, se envia inmediatamente, y se activa el contador de tiempoo a cero

Ape.addEvent('beforeJoin', function(user, channel)

Ape.registerCmd("helloworld",true, function(params, infos)

Ape.registerHookCmd("foocmd", function(params, infos)

Ape.registerHookBadCmd(function(params, info, raw){
  	Ape.log("Bad RAW received ("+raw+").");
  	//We return nothing so client will receive a BAD_CMD error
});

Ape.sockServer(port, «0.0.0.0», {flushlf: true})

var socket = new Ape.sockClient(port, host, {flushlf: true});

var socket = new Ape.sockServer(port, "0.0.0.0", {flushlf: true});

ape.onError('004', function() {
      ape.clearSession();
      ape.initialize(ape.options); //Reinitialize APE class
});

Ape.setSession({'myKey1':'myValue','myKey2':'myValue2'});

Ape.getSession('myKey', function() {
      console.log(resp.datas.sessions.myKey1);  });

new APE.Client()

new Ape.MySQL("ip:port", "user", "password", "database");

Ape.MySQL.escape(mylogin)

sql.query("SELECT nick FROM user WHERE login = '"
               +Ape.MySQL.escape(mylogin)+"'");

var xxx = Ape.base64.encode('foo')

var xxx = Ape.base64.decode('foo')

var result = Ape.sha1.str(«hello world», «mysecretkey»);

var result = Ape.sha1.bin(«hello world»);

var result = Ape.xorize("key1", "key2");

var timeoutID = Ape.setTimeout(func, delayms, [param1, param2, ...]);

var timeoutID = Ape.setInterval(func, delay[, param1, param2, ...]);

Ape.clearTimeout(timeoutID)

var timeoutID = Ape.setInterval(function(a, b) {
  	Ape.log("Foo : " + a + " Bar : " + b);
  }, 3000, "foo", "bar");
Ape.clearTimeout(timeoutID);

include('./scripts/foo.js');

Ape.registerCmd('foo', true, function(params, info) {
  	info.subuser.sendRaw('bar', {'ok':'true'});
});

Ape.registerCmd('foo', true, function(params, info) {
  	info.subuser.sendRaw('bar', {'ok':'true'});
});

setProperty(datos)

getProperty('pubid')

function(user, params)

//Add an event when a new pipe is created
ape.addEvent('pipeCreate', function(type, pipe, options) {
      //Test if the pipe is a "multi pipe" with name test1
      if (type == 'multi' && pipe.name == 'test1') {
          //Add an event when a message is received on the pipe test1
          pipe.onRaw('data', function(data, pipe) {
              console.log('data received on pipe', pipe.name, ' message : ', data.msg);
          });
      }
 //When a new pipe is created, send hello world
      pipe.send('Hello world');
 });
//Join channel test1 and test2
  ape.join(['test1', 'test2']);
---------------------------------------------------

//Server side code

var chan = Ape.getChannelByName('demoChannel');
chan.pipe.sendRaw('testRaw', {'foo': 'bar', 'pipe': chan.pipe.toObject()});

//Client side code (pipe is a pipe object)
pipe.onRaw('testRaw', function(data, pipe) {
      console.log('testRaw received on pipe');
});

//Add an event when a new pipe is created
ape.addEvent('pipeCreate', function(type, pipe, options) {
      //Test if the pipe is a "multi pipe" with name test1
      if (type == 'multi' && pipe.name == 'test1') {
          //Add an event when a message is received on the pipe test1
          pipe.onCmd('send', function(data, pipe) {
              console.log('Sending data on pipe pipe', pipe.name, ' message : ', data.msg);
          });
      }
      //When a new pipe is created, send hello world
      pipe.send('Hello world');
  });
//Join channel test1 and test2
ape.join(['test1', 'test2']);

setProperty(datos)

var chan = Ape.getChannelByName('test');
chan.userslist.each(function(user) {
      Ape.log(user.getProperty('pubid'));
});

sendResponse('custom_raw', {'foo':'bar'})

var socket = new Ape.sockClient('21', 'example.com', {flushlf: true} );

onConnect

function()

function(data)

var socket = new Ape.sockServer("80", "0.0.0.0", {flushlf: true});

onConnect

function()

function(data)

socket.onAccept = function(client) {
  	Ape.log("New client !");
  	client.write("Hello world\n");
}

sql.query("SELECT * FROM table", function(res, errorNo) {
      if (errorNo)
          Ape.log('Request error : ' + errorNo + ' : '+ this.errorString());
      else {
          Ape.log('Fetching ' + res.length);
          res.each(function(data) {
              Ape.log(data.content);//data.<column name> or data[column_name]
          });
      }
});

La funcion, es obligatoria.

En la funcion, si se ha hecho un insert, de dispone de la clave insertado por medio de

this.getInsertId()

sql.onConnect = function() {
     Ape.log('Connected to mysql server');  }

sql.onError = function(errorNo) {
     Ape.log('Connection Error : ' + errorNo + ' : '+ this.errorString());