Implement email notifications for new accounts #2

+2

settings.toml.example

··· 12 12 backfillAccounts = true 13 13 # Listens for new accounts 14 14 listenForNewAccounts = true 15 15 + # Send notification for new accounts 16 16 + notifyOnNewAccounts = false 15 17 16 18 # Another PDS you want to watch 17 19 # [pds.your-pds-two]

+13

src/handlers/pdsSubscriber.ts

··· 6 6 import { FirehoseSubscription } from "@atcute/firehose"; 7 7 import { ComAtprotoSyncSubscribeRepos } from "@atcute/atproto"; 8 8 import { handleNewIdentityEvent } from "./handleNewIdentityEvent.js"; 9 9 + import { sendNewAccountNotification } from "../mailer.js"; 9 10 10 11 export const pdsSubscriber = ( 11 12 config: PDSConfig, ··· 39 40 }, 40 41 "Identity event", 41 42 ); 43 43 + if (config.notifyOnNewAccounts) { 44 44 + if (message.active == true) { 45 45 + await queue.add(() => 46 46 + sendNewAccountNotification(config.notifyEmails, { 47 47 + did: message.did, 48 48 + pds: config.host 49 49 + }).catch((err) => { 50 50 + logger.error({ err }, "Error sending new account notification email") 51 51 + }) 52 52 + ); 53 53 + } 54 54 + } 42 55 await queue.add(() => 43 56 handleNewIdentityEvent( 44 57 db,

+49

src/mailer.ts

··· 73 73 return info.join("\n"); 74 74 } 75 75 76 76 + export const sendNewAccountNotification = async ( 77 77 + emails: string[], 78 78 + params: { 79 79 + did: string; 80 80 + pds: string; 81 81 + } 82 82 + ) => { 83 83 + const { 84 84 + did, 85 85 + pds 86 86 + } = params; 87 87 + 88 88 + logger.info(`Sending new account notification for ${did} on ${pds}...`) 89 89 + 90 90 + const subject = `New account created on ${pds} - ${did}`; 91 91 + let infoText = [ 92 92 + `A new account has been detected on ${pds}.`, 93 93 + ``, 94 94 + `DID: ${did}`, 95 95 + `PDS: ${pds}` 96 96 + ]; 97 97 + const text = infoText.join("\n"); 98 98 + 99 99 + if (resend) { 100 100 + await resend.emails.send({ 101 101 + from: senderEmail, 102 102 + to: emails, 103 103 + subject, 104 104 + text, 105 105 + }); 106 106 + } else { 107 107 + if (transporter) { 108 108 + await transporter.sendMail({ 109 109 + from: senderEmail, 110 110 + to: emails.join(", "), 111 111 + subject, 112 112 + text, 113 113 + }); 114 114 + } else { 115 115 + logger.error( 116 116 + { 117 117 + error: "No transporter available", 118 118 + }, 119 119 + "Error sending email", 120 120 + ); 121 121 + } 122 122 + } 123 123 + } 124 124 + 76 125 export const sendLabelNotification = async ( 77 126 emails: string[], 78 127 params: {

+1

src/types/settings.ts

··· 7 7 pdsAdminPassword?: string; 8 8 backfillAccounts: boolean; 9 9 listenForNewAccounts: boolean; 10 10 + notifyOnNewAccounts: boolean; 10 11 } 11 12 12 13 export type LabelAction = "notify" | "takedown";