test: add Connection tests for split fetch responses
mscdex
12 years ago
parent
cd3358c814
commit
f176494188
@ -0,0 +1,81 @@
|
||||
var assert = require('assert'),
|
||||
net = require('net'),
|
||||
Imap = require('../lib/Connection'),
|
||||
result;
|
||||
|
||||
var CRLF = '\r\n';
|
||||
|
||||
var RESPONSES = [
|
||||
['* CAPABILITY IMAP4rev1 UNSELECT IDLE NAMESPACE QUOTA CHILDREN',
|
||||
'A0 OK Thats all she wrote!', ''
|
||||
].join(CRLF),
|
||||
['* CAPABILITY IMAP4rev1 UNSELECT IDLE NAMESPACE QUOTA CHILDREN UIDPLUS MOVE',
|
||||
'A1 OK authenticated (Success)', ''
|
||||
].join(CRLF),
|
||||
['* NAMESPACE (("" "/")) NIL NIL',
|
||||
'A2 OK Success', ''
|
||||
].join(CRLF),
|
||||
['* LIST (\\Noselect) "/" "/"',
|
||||
'A3 OK Success', ''
|
||||
].join(CRLF),
|
||||
['* FLAGS (\\Answered \\Flagged \\Draft \\Deleted \\Seen)',
|
||||
'* OK [PERMANENTFLAGS ()] Flags permitted.',
|
||||
'* OK [UIDVALIDITY 2] UIDs valid.',
|
||||
'* 685 EXISTS',
|
||||
'* 0 RECENT',
|
||||
'* OK [UIDNEXT 4422] Predicted next UID.',
|
||||
'A4 OK [READ-ONLY] INBOX selected. (Success)', ''
|
||||
].join(CRLF),
|
||||
['* 1 FETCH (UID 1)',
|
||||
'* 1 FETCH (INTERNALDATE "05-Sep-2004 00:38:03 +0000" UID 1000)',
|
||||
'* 1 FETCH (FLAGS (\\Seen))',
|
||||
'A5 OK Success', ''
|
||||
].join(CRLF)
|
||||
];
|
||||
|
||||
var srv = net.createServer(function(sock) {
|
||||
sock.write('* OK asdf\r\n');
|
||||
var buf = '', lines;
|
||||
sock.on('data', function(data) {
|
||||
buf += data.toString('utf8');
|
||||
if (buf.indexOf(CRLF) > -1) {
|
||||
lines = buf.split(CRLF);
|
||||
buf = lines.pop();
|
||||
lines.forEach(function(l) {
|
||||
sock.write(RESPONSES.shift());
|
||||
});
|
||||
}
|
||||
});
|
||||
});
|
||||
srv.listen(0, '127.0.0.1', function() {
|
||||
var port = srv.address().port;
|
||||
var imap = new Imap({
|
||||
user: 'foo',
|
||||
password: 'bar',
|
||||
host: '127.0.0.1',
|
||||
port: port
|
||||
});
|
||||
imap.on('ready', function() {
|
||||
imap.openBox('INBOX', true, function(err, box) {
|
||||
var f = imap.seq.fetch(1);
|
||||
f.on('message', function(m) {
|
||||
m.once('attributes', function(attrs) {
|
||||
result = attrs;
|
||||
});
|
||||
});
|
||||
f.on('end', function() {
|
||||
srv.close();
|
||||
imap.end();
|
||||
});
|
||||
});
|
||||
});
|
||||
imap.connect();
|
||||
});
|
||||
|
||||
process.once('exit', function() {
|
||||
assert.deepEqual(result, {
|
||||
uid: 1,
|
||||
date: new Date('05-Sep-2004 00:38:03 +0000'),
|
||||
flags: [ '\\Seen' ]
|
||||
});
|
||||
});
|
||||
@ -0,0 +1,81 @@
|
||||
var assert = require('assert'),
|
||||
net = require('net'),
|
||||
Imap = require('../lib/Connection'),
|
||||
result;
|
||||
|
||||
var CRLF = '\r\n';
|
||||
|
||||
var RESPONSES = [
|
||||
['* CAPABILITY IMAP4rev1 UNSELECT IDLE NAMESPACE QUOTA CHILDREN',
|
||||
'A0 OK Thats all she wrote!', ''
|
||||
].join(CRLF),
|
||||
['* CAPABILITY IMAP4rev1 UNSELECT IDLE NAMESPACE QUOTA CHILDREN UIDPLUS MOVE',
|
||||
'A1 OK authenticated (Success)', ''
|
||||
].join(CRLF),
|
||||
['* NAMESPACE (("" "/")) NIL NIL',
|
||||
'A2 OK Success', ''
|
||||
].join(CRLF),
|
||||
['* LIST (\\Noselect) "/" "/"',
|
||||
'A3 OK Success', ''
|
||||
].join(CRLF),
|
||||
['* FLAGS (\\Answered \\Flagged \\Draft \\Deleted \\Seen)',
|
||||
'* OK [PERMANENTFLAGS ()] Flags permitted.',
|
||||
'* OK [UIDVALIDITY 2] UIDs valid.',
|
||||
'* 685 EXISTS',
|
||||
'* 0 RECENT',
|
||||
'* OK [UIDNEXT 4422] Predicted next UID.',
|
||||
'A4 OK [READ-ONLY] INBOX selected. (Success)', ''
|
||||
].join(CRLF),
|
||||
['* 1 FETCH (UID 1)',
|
||||
'* 1 FETCH (INTERNALDATE "05-Sep-2004 00:38:03 +0000")',
|
||||
'* 1 FETCH (FLAGS (\\Seen))',
|
||||
'A5 OK Success', ''
|
||||
].join(CRLF)
|
||||
];
|
||||
|
||||
var srv = net.createServer(function(sock) {
|
||||
sock.write('* OK asdf\r\n');
|
||||
var buf = '', lines;
|
||||
sock.on('data', function(data) {
|
||||
buf += data.toString('utf8');
|
||||
if (buf.indexOf(CRLF) > -1) {
|
||||
lines = buf.split(CRLF);
|
||||
buf = lines.pop();
|
||||
lines.forEach(function(l) {
|
||||
sock.write(RESPONSES.shift());
|
||||
});
|
||||
}
|
||||
});
|
||||
});
|
||||
srv.listen(0, '127.0.0.1', function() {
|
||||
var port = srv.address().port;
|
||||
var imap = new Imap({
|
||||
user: 'foo',
|
||||
password: 'bar',
|
||||
host: '127.0.0.1',
|
||||
port: port
|
||||
});
|
||||
imap.on('ready', function() {
|
||||
imap.openBox('INBOX', true, function(err, box) {
|
||||
var f = imap.seq.fetch(1);
|
||||
f.on('message', function(m) {
|
||||
m.once('attributes', function(attrs) {
|
||||
result = attrs;
|
||||
});
|
||||
});
|
||||
f.on('end', function() {
|
||||
srv.close();
|
||||
imap.end();
|
||||
});
|
||||
});
|
||||
});
|
||||
imap.connect();
|
||||
});
|
||||
|
||||
process.once('exit', function() {
|
||||
assert.deepEqual(result, {
|
||||
uid: 1,
|
||||
date: new Date('05-Sep-2004 00:38:03 +0000'),
|
||||
flags: [ '\\Seen' ]
|
||||
});
|
||||
});
|
||||
Loading…
Reference in New Issue