cloud-mail/mail-worker/src/email/email.js

import PostalMime from 'postal-mime';
import emailService from '../service/email-service';
import accountService from '../service/account-service';
import settingService from '../service/setting-service';
import attService from '../service/att-service';
import constant from '../const/constant';
import fileUtils from '../utils/file-utils';
import {attConst, emailConst, isDel} from '../const/entity-const';

export async function email(message, env, ctx) {

	try {

		if (!await settingService.isReceive({ env })) {
			return;
		}

		const account = await accountService.selectByEmailIncludeDel({ env: env }, message.to);

		const reader = message.raw.getReader();
		let content = '';

		while (true) {
			const { done, value } = await reader.read();
			if (done) break;
			content += new TextDecoder().decode(value);
		}

		const email = await PostalMime.parse(content);

		const params = {
			sendEmail: email.from.address,
			name: email.from.name,
			receiveEmail: message.to,
			subject: email.subject,
			content: email.html,
			text: email.text,
			userId: account.userId,
			accountId: account.accountId,
			isDel: isDel.DELETE,
			status: emailConst.status.SAVING
		};

		const attachments = [];
		const cidAttachments = [];

		for(let item of email.attachments) {
			let attachment = { ...item };
			attachment.key = constant.ATTACHMENT_PREFIX + await fileUtils.getBuffHash(attachment.content) + fileUtils.getExtFileName(item.filename);
			attachment.size = item.content.length ?? item.content.byteLength;
			attachments.push(attachment);
			if (attachment.contentId) {
				cidAttachments.push(attachment)
			}
		}

		const emailRow = await emailService.receive({ env }, params, cidAttachments);

		attachments.forEach(attachment => {
			attachment.emailId = emailRow.emailId;
			attachment.userId = emailRow.userId;
			attachment.accountId = emailRow.accountId;
			attachment.type = attachment.contentId ? attConst.type.EMBED : attConst.type.ATT
		})

		if (attachments.length > 0) {
			await attService.addAtt({ env }, attachments);
		}

		await emailService.completeReceive({ env }, emailRow.emailId);

	} catch (e) {
		console.error('邮件接收异常: ', e);
	}
}