aboutsummaryrefslogtreecommitdiff
path: root/src/server/ActionUtilities.ts
diff options
context:
space:
mode:
authorSam Wilkins <samwilkins333@gmail.com>2020-01-06 15:54:05 -0800
committerSam Wilkins <samwilkins333@gmail.com>2020-01-06 15:54:05 -0800
commit45f3eba54ffdb2e4571712a13fcf72a359ec5857 (patch)
treedad8ab26fede40a372a52946239512a7b0fcb7d0 /src/server/ActionUtilities.ts
parente4d9fd09f6ede20e79d58119d239bb7a3a7dae25 (diff)
configurable tolerance, change polling interval from repl
Diffstat (limited to 'src/server/ActionUtilities.ts')
-rw-r--r--src/server/ActionUtilities.ts23
1 files changed, 16 insertions, 7 deletions
diff --git a/src/server/ActionUtilities.ts b/src/server/ActionUtilities.ts
index 30aed32e6..a93566fb1 100644
--- a/src/server/ActionUtilities.ts
+++ b/src/server/ActionUtilities.ts
@@ -118,25 +118,34 @@ export namespace Email {
}
});
+ export interface DispatchFailure {
+ recipient: string;
+ error: Error;
+ }
+
export async function dispatchAll(recipients: string[], subject: string, content: string) {
- const failures: string[] = [];
+ const failures: DispatchFailure[] = [];
await Promise.all(recipients.map(async (recipient: string) => {
- if (!await Email.dispatch(recipient, subject, content)) {
- failures.push(recipient);
+ let error: Error | null;
+ if ((error = await Email.dispatch(recipient, subject, content)) !== null) {
+ failures.push({
+ recipient,
+ error
+ });
}
}));
- return failures;
+ return failures.length ? failures : undefined;
}
- export async function dispatch(recipient: string, subject: string, content: string): Promise<boolean> {
+ export async function dispatch(recipient: string, subject: string, content: string): Promise<Error | null> {
const mailOptions = {
to: recipient,
from: 'brownptcdash@gmail.com',
subject,
text: `Hello ${recipient.split("@")[0]},\n\n${content}`
} as MailOptions;
- return new Promise<boolean>(resolve => {
- smtpTransport.sendMail(mailOptions, (dispatchError: Error | null) => resolve(dispatchError === null));
+ return new Promise<Error | null>(resolve => {
+ smtpTransport.sendMail(mailOptions, resolve);
});
}