mirror of
https://github.com/eleith/emailjs.git
synced 2024-07-02 19:18:52 +00:00
test: don't destructure cjs modules
This commit is contained in:
parent
1727412b98
commit
5d34773455
|
@ -1,6 +1,6 @@
|
||||||
import test from 'ava';
|
import test from 'ava';
|
||||||
import { simpleParser } from 'mailparser';
|
import mailparser from 'mailparser';
|
||||||
import { SMTPServer } from 'smtp-server';
|
import smtp from 'smtp-server';
|
||||||
|
|
||||||
import { client as c, message as m } from '../email';
|
import { client as c, message as m } from '../email';
|
||||||
|
|
||||||
|
@ -13,20 +13,22 @@ const client = new c.Client({
|
||||||
password: 'honey',
|
password: 'honey',
|
||||||
ssl: true,
|
ssl: true,
|
||||||
});
|
});
|
||||||
const smtp = new SMTPServer({ secure: true, authMethods: ['LOGIN'] });
|
const server = new smtp.SMTPServer({ secure: true, authMethods: ['LOGIN'] });
|
||||||
|
|
||||||
const send = (
|
const send = (
|
||||||
message: m.Message,
|
message: m.Message,
|
||||||
verify: (mail: UnPromisify<ReturnType<typeof simpleParser>>) => void
|
verify: (
|
||||||
|
mail: UnPromisify<ReturnType<typeof mailparser.simpleParser>>
|
||||||
|
) => void
|
||||||
) => {
|
) => {
|
||||||
process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0'; // prevent CERT_HAS_EXPIRED errors
|
process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0'; // prevent CERT_HAS_EXPIRED errors
|
||||||
|
|
||||||
smtp.onData = (
|
server.onData = (
|
||||||
stream: import('stream').Readable,
|
stream: import('stream').Readable,
|
||||||
_session,
|
_session,
|
||||||
callback: () => void
|
callback: () => void
|
||||||
) => {
|
) => {
|
||||||
simpleParser(stream).then(verify);
|
mailparser.simpleParser(stream).then(verify);
|
||||||
stream.on('end', callback);
|
stream.on('end', callback);
|
||||||
};
|
};
|
||||||
client.send(message, (err) => {
|
client.send(message, (err) => {
|
||||||
|
@ -37,8 +39,8 @@ const send = (
|
||||||
};
|
};
|
||||||
|
|
||||||
test.before(() => {
|
test.before(() => {
|
||||||
smtp.listen(port, function () {
|
server.listen(port, function () {
|
||||||
smtp.onAuth = function (auth, _session, callback) {
|
server.onAuth = function (auth, _session, callback) {
|
||||||
if (auth.username == 'pooh' && auth.password == 'honey') {
|
if (auth.username == 'pooh' && auth.password == 'honey') {
|
||||||
callback(null, { user: 'pooh' });
|
callback(null, { user: 'pooh' });
|
||||||
} else {
|
} else {
|
||||||
|
@ -48,7 +50,7 @@ test.before(() => {
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
test.after(() => smtp.close());
|
test.after(() => server.close());
|
||||||
|
|
||||||
test.cb('authorize plain', (t) => {
|
test.cb('authorize plain', (t) => {
|
||||||
const msg = {
|
const msg = {
|
||||||
|
|
|
@ -1,6 +1,6 @@
|
||||||
import test from 'ava';
|
import test from 'ava';
|
||||||
import { simpleParser } from 'mailparser';
|
import mailparser from 'mailparser';
|
||||||
import { SMTPServer } from 'smtp-server';
|
import smtp from 'smtp-server';
|
||||||
|
|
||||||
import { client as c, message as m } from '../email';
|
import { client as c, message as m } from '../email';
|
||||||
|
|
||||||
|
@ -12,19 +12,21 @@ const client = new c.Client({
|
||||||
password: 'honey',
|
password: 'honey',
|
||||||
ssl: true,
|
ssl: true,
|
||||||
});
|
});
|
||||||
const smtp = new SMTPServer({ secure: true, authMethods: ['LOGIN'] });
|
const server = new smtp.SMTPServer({ secure: true, authMethods: ['LOGIN'] });
|
||||||
|
|
||||||
type UnPromisify<T> = T extends Promise<infer U> ? U : T;
|
type UnPromisify<T> = T extends Promise<infer U> ? U : T;
|
||||||
const send = (
|
const send = (
|
||||||
message: m.Message,
|
message: m.Message,
|
||||||
verify: (mail: UnPromisify<ReturnType<typeof simpleParser>>) => void
|
verify: (
|
||||||
|
mail: UnPromisify<ReturnType<typeof mailparser.simpleParser>>
|
||||||
|
) => void
|
||||||
) => {
|
) => {
|
||||||
smtp.onData = (
|
server.onData = (
|
||||||
stream: import('stream').Readable,
|
stream: import('stream').Readable,
|
||||||
_session,
|
_session,
|
||||||
callback: () => void
|
callback: () => void
|
||||||
) => {
|
) => {
|
||||||
simpleParser(stream).then(verify);
|
mailparser.simpleParser(stream).then(verify);
|
||||||
stream.on('end', callback);
|
stream.on('end', callback);
|
||||||
};
|
};
|
||||||
client.send(message, (err) => {
|
client.send(message, (err) => {
|
||||||
|
@ -37,8 +39,8 @@ const send = (
|
||||||
test.before(() => {
|
test.before(() => {
|
||||||
process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0'; // prevent CERT_HAS_EXPIRED errors
|
process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0'; // prevent CERT_HAS_EXPIRED errors
|
||||||
|
|
||||||
smtp.listen(port, function () {
|
server.listen(port, function () {
|
||||||
smtp.onAuth = function (auth, _session, callback) {
|
server.onAuth = function (auth, _session, callback) {
|
||||||
if (auth.username == 'pooh' && auth.password == 'honey') {
|
if (auth.username == 'pooh' && auth.password == 'honey') {
|
||||||
callback(null, { user: 'pooh' });
|
callback(null, { user: 'pooh' });
|
||||||
} else {
|
} else {
|
||||||
|
@ -48,7 +50,7 @@ test.before(() => {
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
test.after(() => smtp.close());
|
test.after(() => server.close());
|
||||||
|
|
||||||
test.cb('authorize ssl', (t) => {
|
test.cb('authorize ssl', (t) => {
|
||||||
const msg = {
|
const msg = {
|
||||||
|
|
|
@ -2,8 +2,8 @@ import { readFileSync, createReadStream } from 'fs';
|
||||||
import { join } from 'path';
|
import { join } from 'path';
|
||||||
|
|
||||||
import test from 'ava';
|
import test from 'ava';
|
||||||
import { simpleParser } from 'mailparser';
|
import mailparser from 'mailparser';
|
||||||
import { SMTPServer } from 'smtp-server';
|
import smtp from 'smtp-server';
|
||||||
|
|
||||||
import { client as c, message as m } from '../email';
|
import { client as c, message as m } from '../email';
|
||||||
|
|
||||||
|
@ -14,21 +14,23 @@ const client = new c.Client({
|
||||||
password: 'honey',
|
password: 'honey',
|
||||||
ssl: true,
|
ssl: true,
|
||||||
});
|
});
|
||||||
const smtp = new SMTPServer({ secure: true, authMethods: ['LOGIN'] });
|
const server = new smtp.SMTPServer({ secure: true, authMethods: ['LOGIN'] });
|
||||||
|
|
||||||
type UnPromisify<T> = T extends Promise<infer U> ? U : T;
|
type UnPromisify<T> = T extends Promise<infer U> ? U : T;
|
||||||
const send = (
|
const send = (
|
||||||
message: m.Message,
|
message: m.Message,
|
||||||
verify: (mail: UnPromisify<ReturnType<typeof simpleParser>>) => void
|
verify: (
|
||||||
|
mail: UnPromisify<ReturnType<typeof mailparser.simpleParser>>
|
||||||
|
) => void
|
||||||
) => {
|
) => {
|
||||||
process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0'; // prevent CERT_HAS_EXPIRED errors
|
process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0'; // prevent CERT_HAS_EXPIRED errors
|
||||||
|
|
||||||
smtp.onData = (
|
server.onData = (
|
||||||
stream: import('stream').Readable,
|
stream: import('stream').Readable,
|
||||||
_session,
|
_session,
|
||||||
callback: () => void
|
callback: () => void
|
||||||
) => {
|
) => {
|
||||||
simpleParser(stream).then(verify);
|
mailparser.simpleParser(stream).then(verify);
|
||||||
stream.on('end', callback);
|
stream.on('end', callback);
|
||||||
};
|
};
|
||||||
client.send(message, (err) => {
|
client.send(message, (err) => {
|
||||||
|
@ -40,8 +42,8 @@ const send = (
|
||||||
|
|
||||||
test.before(() => {
|
test.before(() => {
|
||||||
process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0'; // prevent CERT_HAS_EXPIRED errors
|
process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0'; // prevent CERT_HAS_EXPIRED errors
|
||||||
smtp.listen(port, function () {
|
server.listen(port, function () {
|
||||||
smtp.onAuth = function (auth, _session, callback) {
|
server.onAuth = function (auth, _session, callback) {
|
||||||
if (auth.username == 'pooh' && auth.password == 'honey') {
|
if (auth.username == 'pooh' && auth.password == 'honey') {
|
||||||
callback(null, { user: 'pooh' });
|
callback(null, { user: 'pooh' });
|
||||||
} else {
|
} else {
|
||||||
|
@ -51,7 +53,7 @@ test.before(() => {
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
test.after(() => smtp.close());
|
test.after(() => server.close());
|
||||||
|
|
||||||
test.cb('simple text message', (t) => {
|
test.cb('simple text message', (t) => {
|
||||||
const msg = {
|
const msg = {
|
||||||
|
|
Loading…
Reference in New Issue
Block a user