github/socket.io
1
1
Fork 0
mirror of https://github.com/socketio/socket.io.git synced 2026-04-30 03:00:39 -04:00
Code Issues Packages Projects Releases Wiki Activity

Added missing tests for Socket#emit ACK callbacks with endpoint ''.

Browse Source
This commit is contained in:
Guillermo Rauch
2011-05-24 22:45:40 -07:00
parent a08b791cb8
commit 71ed07d458
1 changed files with 99 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

99
test/transports.xhr-polling.test.js
View File

@@ -1368,6 +1368,105 @@ module.exports = {
});
},
'test automatic ack with event sent from the client': function (done) {
var cl = client(++ports)
, io = create(cl)
, acked = false;
io.configure(function () {
io.set('polling duration', .05);
io.set('close timeout', .05);
});
io.sockets.on('connection', function (socket) {
socket.emit('woot', 1, 2, '3', function () {
acked = true;
});
socket.on('disconnect', function () {
acked.should.be.true;
cl.end();
io.server.close();
done();
});
});
cl.handshake(function (sid) {
cl.get('/socket.io/{protocol}/xhr-polling/' + sid, function (res, msgs) {
res.statusCode.should.eql(200);
msgs.should.have.length(1);
msgs[0].should.eql({
type: 'event'
, name: 'woot'
, args: [1, 2, '3']
, id: '1'
, ack: true
, endpoint: ''
});
cl.post(
'/socket.io/{protocol}/xhr-polling/' + sid
, parser.encodePacket({
type: 'ack'
, ackId: '1'
, args: []
, endpoint: ''
})
);
});
});
},
'test manual data ack with event sent from the client': function (done) {
var cl = client(++ports)
, io = create(cl)
, acked = false;
io.configure(function () {
io.set('polling duration', .05);
io.set('close timeout', .05);
});
io.sockets.on('connection', function (socket) {
socket.emit('woot', 1, 2, '3', function (a) {
a.should.eql('1');
acked = true;
});
socket.on('disconnect', function () {
acked.should.be.true;
cl.end();
io.server.close();
done();
});
});
cl.handshake(function (sid) {
cl.get('/socket.io/{protocol}/xhr-polling/' + sid, function (res, msgs) {
res.statusCode.should.eql(200);
msgs.should.have.length(1);
msgs[0].should.eql({
type: 'event'
, name: 'woot'
, args: [1, 2, '3']
, id: '1'
, ack: 'data'
, endpoint: ''
});
cl.post(
'/socket.io/{protocol}/xhr-polling/' + sid
, parser.encodePacket({
type: 'ack'
, ackId: '1'
, args: ['1']
, endpoint: ''
})
);
});
});
},
'test endpoint sending json from the server': function (done) {
var cl = client(++ports)
, io = create(cl)