CodeCow/stack
1
0
Fork 0
mirror of https://github.com/stack-auth/stack.git synced 2026-06-04 21:04:37 +08:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Add otel spans for sent emails

Browse Source
This commit is contained in:
Konstantin Wohlwend 2024-10-11 17:52:47 -07:00
parent cd4c259f0f
commit f10f03c3b3
1 changed files with 29 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

50
apps/backend/src/lib/emails.tsx
View File

@ -9,6 +9,8 @@ import { StackAssertionError } from '@stackframe/stack-shared/dist/utils/errors'
import { filterUndefined } from '@stackframe/stack-shared/dist/utils/objects';
import { typedToUppercase } from '@stackframe/stack-shared/dist/utils/strings';
import nodemailer from 'nodemailer';
import { trace } from '@opentelemetry/api';
import { wait } from '@stackframe/stack-shared/dist/utils/promises';
export async function getEmailTemplate(projectId: string, type: keyof typeof EMAIL_TEMPLATES_METADATA) {
const project = await getProject(projectId);
@ -74,28 +76,34 @@ export async function sendEmail({
html: string,
text?: string,
}) {
const transporter = nodemailer.createTransport({
host: emailConfig.host,
port: emailConfig.port,
secure: emailConfig.secure,
auth: {
user: emailConfig.username,
pass: emailConfig.password,
},
await trace.getTracer('stackframe').startActiveSpan('sendEmail', async (span) => {
try {
const transporter = nodemailer.createTransport({
logger: true,
host: emailConfig.host,
port: emailConfig.port,
secure: emailConfig.secure,
auth: {
user: emailConfig.username,
pass: emailConfig.password,
},
});
try {
return await transporter.sendMail({
from: `"${emailConfig.senderName}" <${emailConfig.senderEmail}>`,
to,
subject,
text,
html
});
} catch (error) {
throw new StackAssertionError('Failed to send email', { error, host: emailConfig.host, from: emailConfig.senderEmail, to, subject });
}
} finally {
span.end();
}
});
try {
return await transporter.sendMail({
from: `"${emailConfig.senderName}" <${emailConfig.senderEmail}>`,
to,
subject,
text,
html
});
} catch (error) {
throw new StackAssertionError('Failed to send email', { error, host: emailConfig.host, from: emailConfig.senderEmail, to, subject });
}
}
export async function sendEmailFromTemplate(options: {