eleith/emailjs
1
0
Fork 0
mirror of https://github.com/eleith/emailjs.git synced 2024-06-30 18:30:58 +00:00
Code Issues Projects Releases Wiki Activity

smtp/message: remove eslint-disable comments

Browse Source
This commit is contained in:
Zack Schuster 2020-07-27 02:19:10 -07:00
parent 10cfc1a2b9
commit ce7094ec08
1 changed files with 11 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
smtp/message.ts
View File

@ -236,7 +236,6 @@ export class Message {
* @returns {*} a stream of the current message
*/
public stream() {
// eslint-disable-next-line @typescript-eslint/no-use-before-define
return new MessageStream(this);
}
@ -441,22 +440,20 @@ class MessageStream extends Stream {
attachment: MessageAttachment,
callback: () => void
) => {
if (attachment.stream != null && attachment.stream.readable) {
const { stream } = attachment;
if (stream?.readable) {
let previous = Buffer.alloc(0);
attachment.stream.resume();
stream.resume();
attachment.stream.on('end', () => {
stream.on('end', () => {
output_base64(previous.toString('base64'), callback);
// eslint-disable-next-line @typescript-eslint/no-non-null-assertion
this.removeListener('pause', attachment.stream!.pause);
// eslint-disable-next-line @typescript-eslint/no-non-null-assertion
this.removeListener('resume', attachment.stream!.resume);
// eslint-disable-next-line @typescript-eslint/no-non-null-assertion
this.removeListener('error', attachment.stream!.resume);
this.removeListener('pause', stream.pause);
this.removeListener('resume', stream.resume);
this.removeListener('error', stream.resume);
});
attachment.stream.on('data', (buff) => {
stream.on('data', (buff) => {
// do we have bytes from a previous stream data event?
let buffer = Buffer.isBuffer(buff) ? buff : Buffer.from(buff);
@ -475,9 +472,9 @@ class MessageStream extends Stream {
output_base64(buffer.toString('base64', 0, buffer.length - padded));
});
this.on('pause', attachment.stream.pause);
this.on('resume', attachment.stream.resume);
this.on('error', attachment.stream.resume);
this.on('pause', stream.pause);
this.on('resume', stream.resume);
this.on('error', stream.resume);
} else {
this.emit('error', { message: 'stream not readable' });
}