Permalink
Please sign in to comment.
Browse files
Add basic script
- Loading branch information...
1 parent
1602967
commit 95d8f8e243881787c56d4de817c63143fc51a0c2
BerkeleyTrue
committed
BerkeleyTrue
committed
Showing
with
54 additions
and 2 deletions.
- +3 −0 .gitignore
- +5 −2 package.json
- +46 −0 src/index.js
3
.gitignore
| @@ -1 +1,4 @@ | ||
| node_modules | ||
| +.env | ||
| +data.json | ||
| +emails.json |
7
package.json
46
src/index.js
| @@ -0,0 +1,46 @@ | ||
| +import { Observable, Schedular } from 'rx'; | ||
| +import nodemailer from 'nodemailer'; | ||
| +import ses from 'nodemailer-ses-transporter'; | ||
| +import dotenv from 'dotenv'; | ||
| +import emails from 'emails.json'; | ||
| +import data from 'data.json'; | ||
| + | ||
| +dotenv.load(); | ||
| + | ||
| +const options = { | ||
| + accessKeyId: process.env.access_key, | ||
| + secretAccessKey: process.env.priv_key, | ||
| + rateLimit: 10000 | ||
| +}; | ||
| + | ||
| +const mailOptions = { | ||
| + from: "You <you@example.com>", | ||
| + subject: data.subject, | ||
| + text: data.text | ||
| +}; | ||
| + | ||
| +const transporter = nodemailer.createTransport(ses(options)); | ||
| +const send$ = Observable.fromNodeback(transporter.sendMail, transporter); | ||
| + | ||
| +Observable.from(emails) | ||
| + // batch every 10000 | ||
| + .bufferWithCount(10000) | ||
| + // wait 1 sec between batches | ||
| + .delay(1000) | ||
| + .flatMap(emails => { | ||
| + const filledOptions = Object.assign( | ||
| + {}, | ||
| + mailOptions, | ||
| + { emails: emails.join(', ').replace(/,$/, '') } | ||
| + ); | ||
| + return send$(filledOptions); | ||
| + }) | ||
| + .count() | ||
| + .subscribe( | ||
| + count => console.log('sent %d so far', count), | ||
| + err => throw err, | ||
| + () => { | ||
| + console.log('process complete'); | ||
| + process.exit(0); | ||
| + } | ||
| + ); |
0 comments on commit
95d8f8e