add smtpInstance in emailManager

This commit is contained in:
grimhilt 2023-04-09 23:46:33 +02:00
parent 160bb0c605
commit 4b21168547
5 changed files with 51 additions and 43 deletions

View File

@ -0,0 +1,44 @@
import { ImapInstance } from "./imap/ImapInstance";
import { SmtpInstance } from "./smtp/SmtpInstance";
import logger from "../system/Logger";
import { getAllAccounts } from "../db/imap/imap-db";
export interface Account {
id: number;
user: string
password?: string
}
class EmailManager {
imapInstances: ImapInstance[]
smtpInstances: SmtpInstance[]
constructor() {
this.imapInstances = [];
this.smtpInstances = [];
}
init() {
getAllAccounts().then((accounts: Account[]) => {
for (let i = 0; i < accounts.length; i++) {
accounts[i].password = accounts[i]?.password?.toString().replace(/[\u{0080}-\u{FFFF}]/gu,"");
if (accounts[i].id == 2) continue; //debug_todo
this.addImapInstance(accounts[i]);
this.addSmtpInstance(accounts[i]);
}
}).catch((err) => {
logger.err(err);
});
}
addImapInstance(config) {
this.imapInstances.push(new ImapInstance(config));
}
addSmtpInstance(config) {
this.smtpInstances.push(new SmtpInstance(config));
}
}
const emailManager = new EmailManager();
export default emailManager;

View File

@ -1,4 +1,4 @@
import { Account } from "./ImapSync"; import { Account } from "../EmailManager";
import Imap from "imap"; import Imap from "imap";
import { getAllMailboxes, registerMailbox } from "../../db/imap/imap-db"; import { getAllMailboxes, registerMailbox } from "../../db/imap/imap-db";

View File

@ -1,33 +0,0 @@
import { getAllAccounts } from "../../db/imap/imap-db";
import logger from "../../system/Logger";
import { ImapInstance } from "./ImapInstance";
export interface Account {
id: number;
user: string
password?: string
}
export default class ImapSync {
instances: ImapInstance[]
constructor() {
this.instances = [];
}
init() {
getAllAccounts().then((accounts: Account[]) => {
for (let i = 0; i < accounts.length; i++) {
accounts[i].password = accounts[i]?.password?.toString().replace(/[\u{0080}-\u{FFFF}]/gu,"");
if (accounts[i].id == 2) continue; //debug_todo
this.addInstance(accounts[i]);
}
}).catch((err) => {
logger.err(err);
});
}
addInstance(config) {
this.instances.push(new ImapInstance(config));
}
}

View File

@ -1,12 +1,10 @@
import { Account } from "../imap/ImapSync";
import logger from "../../system/Logger"; import logger from "../../system/Logger";
import nodemailer, { Transporter } from "nodemailer"; import nodemailer, { Transporter } from "nodemailer";
export class SmapInstance { export class SmtpInstance {
transporter: Transporter; transporter: Transporter;
account: Account;
constructor(account) { constructor(account: {user: string, password: string}) {
// todo store other data // todo store other data
this.transporter = nodemailer.createTransport({ this.transporter = nodemailer.createTransport({
host: "smtp.gmail.com", host: "smtp.gmail.com",
@ -17,7 +15,6 @@ export class SmapInstance {
pass: account.password, pass: account.password,
}, },
}); });
this.account = account;
} }
sendMail() { sendMail() {

View File

@ -1,7 +1,7 @@
import express from "express"; import express from "express";
import cors from "cors"; import cors from "cors";
const app = express(); const app = express();
import ImapSync from "./mails/imap/ImapSync"; import ImapSync from "./mails/EmailManager";
import { execQueryAsync, execQuery } from "./db/db"; import { execQueryAsync, execQuery } from "./db/db";
app.use(express.json()); app.use(express.json());
@ -14,12 +14,12 @@ app.use(cors());
app.listen(process.env.PORT || 5500); app.listen(process.env.PORT || 5500);
import mailRouter from "./routes/mail"; import mailRouter from "./routes/mail";
import logger from "./system/Logger"; import emailManager from "./mails/EmailManager";
app.use("/api/mail", mailRouter); app.use("/api/mail", mailRouter);
const imapSync = new ImapSync(); emailManager.init();
imapSync.init();
// debug reset all tables
const shouldReset = false; const shouldReset = false;
if (shouldReset) { if (shouldReset) {
const query = "SELECT table_name FROM INFORMATION_SCHEMA.tables WHERE table_schema = 'mail'"; const query = "SELECT table_name FROM INFORMATION_SCHEMA.tables WHERE table_schema = 'mail'";