129 lines
3.5 KiB
JavaScript
129 lines
3.5 KiB
JavaScript
import fs from 'fs'
|
|
import path from 'path'
|
|
import axios from 'axios'
|
|
import { unified } from 'unified'
|
|
import remarkParse from 'remark-parse'
|
|
import remarkRehype from 'remark-rehype'
|
|
import rehypeFormat from 'rehype-format'
|
|
import rehypeStringify from 'rehype-stringify'
|
|
import remarkGfm from 'remark-gfm'
|
|
import mustache from 'mustache'
|
|
import { testers } from '../config/newsletter-testers.mjs'
|
|
import { fileURLToPath } from 'url'
|
|
import { SESv2Client, SendEmailCommand } from '@aws-sdk/client-sesv2'
|
|
|
|
// Current working directory
|
|
const cwd = path.dirname(fileURLToPath(import.meta.url))
|
|
|
|
const backend = 'https://backend.freesewing.org/'
|
|
|
|
const asHtml = async (text) => {
|
|
const content = await unified()
|
|
.use(remarkParse)
|
|
.use(remarkGfm)
|
|
.use(remarkRehype)
|
|
.use(rehypeFormat)
|
|
.use(rehypeStringify)
|
|
.process(text)
|
|
|
|
return content.value
|
|
}
|
|
|
|
const getToken = async () => {
|
|
let res = await axios.post(`${backend}login`, {
|
|
username: process.env.FS_USER,
|
|
password: process.env.FS_PASSWORD,
|
|
})
|
|
if (res.data) return res.data.token
|
|
else if (res.err) return console.log(err)
|
|
}
|
|
|
|
const getSubscribers = async (test = true) => {
|
|
if (test) return testers
|
|
let token = await getToken()
|
|
let res = await axios.get(`${backend}admin/subscribers`, {
|
|
headers: { Authorization: 'Bearer ' + token },
|
|
})
|
|
if (res.data) return res.data
|
|
else return false
|
|
}
|
|
|
|
const send = async (test = true) => {
|
|
const us = 'FreeSewing <info@freesewing.org>'
|
|
const template = fs.readFileSync(`${cwd}/../config/templates/newsletter.html`, 'utf8')
|
|
let edition
|
|
try {
|
|
edition = await axios.get(
|
|
`https://posts.freesewing.org/newsletters?slug_eq=${process.env.NL_EDITION}`,
|
|
'utf8'
|
|
)
|
|
} catch (err) {
|
|
console.log(err)
|
|
process.exit()
|
|
}
|
|
const text = edition.data[0].body
|
|
|
|
const subscribers = await getSubscribers(test)
|
|
const content = await asHtml(text)
|
|
const inject = { content }
|
|
|
|
// Oh AWS your APIs are such a clusterfuck
|
|
const client = new SESv2Client({ region: 'us-east-1' })
|
|
|
|
let i = 1
|
|
subscribers.sort()
|
|
let subs = subscribers.length
|
|
for (let sub of subscribers) {
|
|
// If your SMTP relay start rate-limiting midway through
|
|
// you can use this if loop to start just after the last
|
|
// successful delivery
|
|
if (i > 0) {
|
|
let unsub = `${backend}newsletter/unsubscribe/${sub.ehash}`
|
|
inject.unsubscribe = unsub
|
|
let body = mustache.render(template, inject)
|
|
console.log(`${i}/${subs} Sending to ${sub.email}`)
|
|
|
|
// Via API
|
|
const command = new SendEmailCommand({
|
|
ConfigurationSetName: 'Newsletter',
|
|
Content: {
|
|
Simple: {
|
|
Body: {
|
|
Text: {
|
|
Charset: 'utf-8',
|
|
Data: text,
|
|
},
|
|
Html: {
|
|
Charset: 'utf-8',
|
|
Data: body,
|
|
},
|
|
},
|
|
Subject: {
|
|
Charset: 'utf-8',
|
|
Data: 'FreeSewing newsletter: Autumn 2023',
|
|
},
|
|
},
|
|
},
|
|
Destination: {
|
|
ToAddresses: [sub.email],
|
|
},
|
|
//FeedbackForwardingEmailAddress: us,
|
|
FromEmailAddress: us,
|
|
//FromEmailAddressIdentityArn: "arn:aws:ses:us-east-1:550348293871:identity/freesewing.org",
|
|
//ReplyToAddresses: us,
|
|
})
|
|
try {
|
|
await client.send(command)
|
|
} catch (err) {
|
|
console.log(err)
|
|
return false
|
|
}
|
|
}
|
|
i++
|
|
}
|
|
}
|
|
|
|
const sendTest = () => send(true)
|
|
const sendReal = () => send(false)
|
|
|
|
export { sendTest, sendReal }
|