Class MailPit

e2e/helpers/services/email/mail-pit.ts:47–161

}

export class MailPit implements EmailClient{
    private readonly apiUrl: string;

    constructor(baseUrl: string = 'http://localhost:8026') {
        this.apiUrl = `${baseUrl}/api/v1`;
    }

    async getMessages(limit: number = 50): Promise<EmailMessage[]> {
        const response = await this.executeApiCall(
            `messages?limit=${limit}`,
            'fetch messages'
        );

        return this.parseMessagesFromResponse(response);
    }

    async getMessageDetailed(message: EmailMessage): Promise<EmailMessageDetailed> {
        const response = await this.executeApiCall(
            `message/${message.ID}`,
            'fetch message'
        );

        return await response.json() as EmailMessageDetailed;
    }

    async searchByRecipient(recipient: string, options?: EmailSearchOptions): Promise<EmailMessage[]> {
        return this.search({to: recipient}, options);
    }

    async searchByContent(content: string, options?: EmailSearchOptions): Promise<EmailMessage[]> {
        return this.search({subject: content}, options);
    }

    async search(queryOptions:Partial<EmailSearchQuery>, options?: EmailSearchOptions): Promise<EmailMessage[]> {
        const defaultOptions = {limit: 50, timeoutMs: 10000, numberOfMessages: null};
        const searchOptions = {...defaultOptions, ...options};

        if (searchOptions.timeoutMs !== null) {
            return await this.searchWithWait(
                () => this.searchByQuery(queryOptions, searchOptions.limit),
                searchOptions.timeoutMs,
                searchOptions.numberOfMessages
            );
        }
        return await this.searchByQuery(queryOptions, searchOptions.limit);
    }

    async searchByQuery(options: Partial<EmailSearchQuery>, limit: number = 50): Promise<EmailMessage[]> {
        const queryString = Object.entries(options)
            .filter((entry): entry is [string, string] => {
                const [, value] = entry;
                return value !== null && value !== undefined && value !== '';
            })
            .map(([key, value]) => `${encodeURIComponent(key)}:${encodeURIComponent(value)}`)
            .join('+');

        const response = await this.executeApiCall(
            `search?query=${queryString}&limit=${limit}`,