import type { Readable } from 'stream'; import { readFileSync, createReadStream } from 'fs'; import { join } from 'path'; import test from 'ava'; import mailparser from 'mailparser'; import smtp from 'smtp-server'; import { client as c, message as m } from '../email'; const port = 2526; const client = new c.Client({ port, user: 'pooh', password: 'honey', ssl: true, }); const server = new smtp.SMTPServer({ secure: true, authMethods: ['LOGIN'] }); type UnPromisify = T extends Promise ? U : T; const send = ( message: m.Message, verify: ( mail: UnPromisify> ) => void, done: () => void ) => { server.onData = (stream: Readable, _session, callback: () => void) => { mailparser .simpleParser(stream, { skipTextLinks: true } as Record) .then(verify) .then(done) .catch(done); stream.on('end', callback); }; client.send(message, (err) => { if (err) { throw err; } }); }; test.before.cb((t) => { server.listen(port, function () { server.onAuth = function (auth, _session, callback) { if (auth.username == 'pooh' && auth.password == 'honey') { callback(null, { user: 'pooh' }); } else { return callback(new Error('invalid user / pass')); } }; t.end(); }); }); test.after.cb((t) => server.close(t.end)); test.cb('simple text message', (t) => { const msg = { subject: 'this is a test TEXT message from emailjs', from: 'zelda@gmail.com', to: 'gannon@gmail.com', text: 'hello friend, i hope this message finds you well.', 'message-id': 'this is a special id', }; send( new m.Message(msg), (mail) => { t.is(mail.text, msg.text + '\n\n\n'); t.is(mail.subject, msg.subject); t.is(mail.from?.text, msg.from); t.is(mail.to?.text, msg.to); t.is(mail.messageId, '<' + msg['message-id'] + '>'); }, t.end ); }); test.cb('null text message', (t) => { const msg = { subject: 'this is a test TEXT message from emailjs', from: 'zelda@gmail.com', to: 'gannon@gmail.com', text: null, 'message-id': 'this is a special id', }; send( new m.Message(msg), (mail) => { t.is(mail.text, '\n\n\n'); }, t.end ); }); test.cb('empty text message', (t) => { const msg = { subject: 'this is a test TEXT message from emailjs', from: 'zelda@gmail.com', to: 'gannon@gmail.com', text: '', 'message-id': 'this is a special id', }; send( new m.Message(msg), (mail) => { t.is(mail.text, '\n\n\n'); }, t.end ); }); test.cb('simple unicode text message', (t) => { const msg = { subject: 'this ✓ is a test ✓ TEXT message from emailjs', from: 'zelda✓ ', to: 'gannon✓ ', text: 'hello ✓ friend, i hope this message finds you well.', }; send( new m.Message(msg), (mail) => { t.is(mail.text, msg.text + '\n\n\n'); t.is(mail.subject, msg.subject); t.is(mail.from?.text, msg.from); t.is(mail.to?.text, msg.to); }, t.end ); }); test.cb('very large text message', (t) => { // thanks to jart+loberstech for this one! const msg = { subject: 'this is a test TEXT message from emailjs', from: 'ninjas@gmail.com', to: 'pirates@gmail.com', text: readFileSync(join(__dirname, 'attachments/smtp.txt'), 'utf-8'), }; send( new m.Message(msg), (mail) => { t.is(mail.text, msg.text.replace(/\r/g, '') + '\n\n\n'); t.is(mail.subject, msg.subject); t.is(mail.from?.text, msg.from); t.is(mail.to?.text, msg.to); }, t.end ); }); test.cb('very large text data message', (t) => { const text = '

' +
		readFileSync(join(__dirname, 'attachments/smtp.txt'), 'utf-8') +
		'

'; const msg = { subject: 'this is a test TEXT+DATA message from emailjs', from: 'lobsters@gmail.com', to: 'lizards@gmail.com', text: 'hello friend if you are seeing this, you can not view html emails. it is attached inline.', attachment: ({ data: text, alternative: true, } as unknown) as m.MessageAttachment, }; send( new m.Message(msg), (mail) => { t.is(mail.html, text.replace(/\r/g, '')); t.is(mail.text, msg.text + '\n'); t.is(mail.subject, msg.subject); t.is(mail.from?.text, msg.from); t.is(mail.to?.text, msg.to); }, t.end ); }); test.cb('html data message', (t) => { const html = readFileSync(join(__dirname, 'attachments/smtp.html'), 'utf-8'); const msg = { subject: 'this is a test TEXT+HTML+DATA message from emailjs', from: 'obama@gmail.com', to: 'mitt@gmail.com', attachment: ({ data: html, alternative: true, } as unknown) as m.MessageAttachment, }; send( new m.Message(msg), (mail) => { t.is(mail.html, html.replace(/\r/g, '')); t.is(mail.text, '\n'); t.is(mail.subject, msg.subject); t.is(mail.from?.text, msg.from); t.is(mail.to?.text, msg.to); }, t.end ); }); test.cb('html file message', (t) => { const html = readFileSync(join(__dirname, 'attachments/smtp.html'), 'utf-8'); const msg = { subject: 'this is a test TEXT+HTML+FILE message from emailjs', from: 'thomas@gmail.com', to: 'nikolas@gmail.com', attachment: ({ path: join(__dirname, 'attachments/smtp.html'), alternative: true, } as unknown) as m.MessageAttachment, }; send( new m.Message(msg), (mail) => { t.is(mail.html, html.replace(/\r/g, '')); t.is(mail.text, '\n'); t.is(mail.subject, msg.subject); t.is(mail.from?.text, msg.from); t.is(mail.to?.text, msg.to); }, t.end ); }); test.cb('html with image embed message', (t) => { const html = readFileSync(join(__dirname, 'attachments/smtp2.html'), 'utf-8'); const image = readFileSync(join(__dirname, 'attachments/smtp.gif')); const msg = { subject: 'this is a test TEXT+HTML+IMAGE message from emailjs', from: 'ninja@gmail.com', to: 'pirate@gmail.com', attachment: ({ path: join(__dirname, 'attachments/smtp2.html'), alternative: true, related: [ { path: join(__dirname, 'attachments/smtp.gif'), type: 'image/gif', name: 'smtp-diagram.gif', headers: { 'Content-ID': '' }, }, ], } as unknown) as m.MessageAttachment, }; send( new m.Message(msg), (mail) => { t.is( mail.attachments[0].content.toString('base64'), image.toString('base64') ); t.is(mail.html, html.replace(/\r/g, '')); t.is(mail.text, '\n'); t.is(mail.subject, msg.subject); t.is(mail.from?.text, msg.from); t.is(mail.to?.text, msg.to); }, t.end ); }); test.cb('html data and attachment message', (t) => { const html = readFileSync(join(__dirname, 'attachments/smtp.html'), 'utf-8'); const msg = { subject: 'this is a test TEXT+HTML+FILE message from emailjs', from: 'thomas@gmail.com', to: 'nikolas@gmail.com', attachment: [ { path: join(__dirname, 'attachments/smtp.html'), alternative: true }, { path: join(__dirname, 'attachments/smtp.gif') }, ] as m.MessageAttachment[], }; send( new m.Message(msg), (mail) => { t.is(mail.html, html.replace(/\r/g, '')); t.is(mail.text, '\n'); t.is(mail.subject, msg.subject); t.is(mail.from?.text, msg.from); t.is(mail.to?.text, msg.to); }, t.end ); }); test.cb('attachment message', (t) => { const pdf = readFileSync(join(__dirname, 'attachments/smtp.pdf')); const msg = { subject: 'this is a test TEXT+ATTACHMENT message from emailjs', from: 'washing@gmail.com', to: 'lincoln@gmail.com', text: 'hello friend, i hope this message and pdf finds you well.', attachment: { path: join(__dirname, 'attachments/smtp.pdf'), type: 'application/pdf', name: 'smtp-info.pdf', } as m.MessageAttachment, }; send( new m.Message(msg), (mail) => { t.is( mail.attachments[0].content.toString('base64'), pdf.toString('base64') ); t.is(mail.text, msg.text + '\n'); t.is(mail.subject, msg.subject); t.is(mail.from?.text, msg.from); t.is(mail.to?.text, msg.to); }, t.end ); }); test.cb('attachment sent with unicode filename message', (t) => { const pdf = readFileSync(join(__dirname, 'attachments/smtp.pdf')); const msg = { subject: 'this is a test TEXT+ATTACHMENT message from emailjs', from: 'washing@gmail.com', to: 'lincoln@gmail.com', text: 'hello friend, i hope this message and pdf finds you well.', attachment: { path: join(__dirname, 'attachments/smtp.pdf'), type: 'application/pdf', name: 'smtp-✓-info.pdf', } as m.MessageAttachment, }; send( new m.Message(msg), (mail) => { t.is( mail.attachments[0].content.toString('base64'), pdf.toString('base64') ); t.is(mail.attachments[0].filename, 'smtp-✓-info.pdf'); t.is(mail.text, msg.text + '\n'); t.is(mail.subject, msg.subject); t.is(mail.from?.text, msg.from); t.is(mail.to?.text, msg.to); }, t.end ); }); test.cb('attachments message', (t) => { const pdf = readFileSync(join(__dirname, 'attachments/smtp.pdf')); const tar = readFileSync(join(__dirname, 'attachments/postfix-2.8.7.tar.gz')); const msg = { subject: 'this is a test TEXT+2+ATTACHMENTS message from emailjs', from: 'sergey@gmail.com', to: 'jobs@gmail.com', text: 'hello friend, i hope this message and attachments finds you well.', attachment: [ { path: join(__dirname, 'attachments/smtp.pdf'), type: 'application/pdf', name: 'smtp-info.pdf', }, { path: join(__dirname, 'attachments/postfix-2.8.7.tar.gz'), type: 'application/tar-gz', name: 'postfix.source.2.8.7.tar.gz', }, ] as m.MessageAttachment[], }; send( new m.Message(msg), (mail) => { t.is( mail.attachments[0].content.toString('base64'), pdf.toString('base64') ); t.is( mail.attachments[1].content.toString('base64'), tar.toString('base64') ); t.is(mail.text, msg.text + '\n'); t.is(mail.subject, msg.subject); t.is(mail.from?.text, msg.from); t.is(mail.to?.text, msg.to); }, t.end ); }); test.cb('streams message', (t) => { const pdf = readFileSync(join(__dirname, 'attachments/smtp.pdf')); const tar = readFileSync(join(__dirname, 'attachments/postfix-2.8.7.tar.gz')); const stream = createReadStream(join(__dirname, 'attachments/smtp.pdf')); const stream2 = createReadStream( join(__dirname, 'attachments/postfix-2.8.7.tar.gz') ); const msg = { subject: 'this is a test TEXT+2+STREAMED+ATTACHMENTS message from emailjs', from: 'stanford@gmail.com', to: 'mit@gmail.com', text: 'hello friend, i hope this message and streamed attachments finds you well.', attachment: ([ { stream, type: 'application/pdf', name: 'smtp-info.pdf' }, { stream: stream2, type: 'application/x-gzip', name: 'postfix.source.2.8.7.tar.gz', }, ] as unknown) as m.MessageAttachment[], }; stream.pause(); stream2.pause(); send( new m.Message(msg), (mail) => { t.is( mail.attachments[0].content.toString('base64'), pdf.toString('base64') ); t.is( mail.attachments[1].content.toString('base64'), tar.toString('base64') ); t.is(mail.text, msg.text + '\n'); t.is(mail.subject, msg.subject); t.is(mail.from?.text, msg.from); t.is(mail.to?.text, msg.to); }, t.end ); });