88 lines
1.9 KiB
TypeScript
88 lines
1.9 KiB
TypeScript
import { Page } from '@playwright/test';
|
|
import { parse } from 'node-html-parser';
|
|
|
|
export class Mailbox {
|
|
constructor(private readonly page: Page) {}
|
|
|
|
async visitMailbox(
|
|
email: string,
|
|
params: {
|
|
deleteAfter: boolean;
|
|
},
|
|
) {
|
|
const mailbox = email.split('@')[0];
|
|
|
|
console.log(`Visiting mailbox ${email} ...`);
|
|
|
|
if (!mailbox) {
|
|
throw new Error('Invalid email');
|
|
}
|
|
|
|
const json = await this.getInviteEmail(mailbox, params);
|
|
|
|
if (!json?.body) {
|
|
throw new Error('Email body was not found');
|
|
}
|
|
|
|
console.log('Email found');
|
|
|
|
const html = (json.body as { html: string }).html;
|
|
const el = parse(html);
|
|
|
|
const linkHref = el.querySelector('a')?.getAttribute('href');
|
|
|
|
if (!linkHref) {
|
|
throw new Error('No link found in email');
|
|
}
|
|
|
|
console.log(`Visiting ${linkHref} from mailbox ${email}...`);
|
|
|
|
return this.page.goto(linkHref);
|
|
}
|
|
|
|
async getInviteEmail(
|
|
mailbox: string,
|
|
params: {
|
|
deleteAfter: boolean;
|
|
},
|
|
) {
|
|
const url = `http://127.0.0.1:54324/api/v1/mailbox/${mailbox}`;
|
|
|
|
const response = await fetch(url);
|
|
|
|
if (!response.ok) {
|
|
throw new Error(`Failed to fetch emails: ${response.statusText}`);
|
|
}
|
|
|
|
const json = (await response.json()) as Array<{ id: string }>;
|
|
|
|
if (!json || !json.length) {
|
|
return;
|
|
}
|
|
|
|
const messageId = json[0]?.id;
|
|
const messageUrl = `${url}/${messageId}`;
|
|
|
|
const messageResponse = await fetch(messageUrl);
|
|
|
|
if (!messageResponse.ok) {
|
|
throw new Error(`Failed to fetch email: ${messageResponse.statusText}`);
|
|
}
|
|
|
|
// delete message
|
|
if (params.deleteAfter) {
|
|
console.log(`Deleting email ${messageId} ...`);
|
|
|
|
const res = await fetch(messageUrl, {
|
|
method: 'DELETE',
|
|
});
|
|
|
|
if (!res.ok) {
|
|
console.error(`Failed to delete email: ${res.statusText}`);
|
|
}
|
|
}
|
|
|
|
return await messageResponse.json();
|
|
}
|
|
}
|