diff --git a/back/abl/Room-abl.ts b/back/abl/Room-abl.ts index b139fe6..8ba2136 100644 --- a/back/abl/Room-abl.ts +++ b/back/abl/Room-abl.ts @@ -6,6 +6,8 @@ import { getLastMsgData, getRoomOwner } from "../db/Room-db"; import emailManager from "../mails/EmailManager"; import MailBuilder from "../mails/utils/mailBuilder"; import { getAddresses } from "../db/utils/mail"; +import { getMembers, getMessages, getRooms } from "../db/api-db"; +import logger from "../system/Logger"; function rmUserFromAddrs(addresses: { email: string }[], user: string) { let index = addresses.findIndex((a) => a.email == user); @@ -58,4 +60,39 @@ export default class Room { res.status(statusCode.FORBIDDEN).send({ error: "Cannot add a new message in a room or a channel." }); } } + + static async getAll(body, res: Response) { + const { mailboxId, offset, limit } = body; + getRooms(mailboxId) + .then((rooms) => { + res.status(statusCode.OK).json(rooms); + }) + .catch((err) => { + logger.err(err); + res.status(statusCode.INTERNAL_SERVER_ERROR); + }); + } + + static async getMessages(body, res: Response) { + const { roomId } = body; + getMessages(roomId) + .then((messages) => { + res.status(statusCode.OK).json(messages); + }) + .catch((err) => { + logger.err(err); + res.status(statusCode.INTERNAL_SERVER_ERROR); + }); + } + + static async getMembers(body, res) { + const { roomId } = body; + getMembers(roomId).then((addresses) => { + res.status(statusCode.OK).json(addresses); + }).catch((err) => { + logger.err(err) + res.status(statusCode.INTERNAL_SERVER_ERROR); + }); + } + } diff --git a/back/abl/members.ts b/back/abl/members.ts deleted file mode 100644 index b3a1c05..0000000 --- a/back/abl/members.ts +++ /dev/null @@ -1,13 +0,0 @@ -import statusCode from "../utils/statusCodes"; -import { getMembers } from "../db/api-db"; -import logger from "../system/Logger"; - -export async function members(body, res) { - const { roomId } = body; - getMembers(roomId).then((addresses) => { - res.status(statusCode.OK).json(addresses); - }).catch((err) => { - logger.err(err) - res.status(statusCode.INTERNAL_SERVER_ERROR); - }); -} diff --git a/back/abl/messages.ts b/back/abl/messages.ts deleted file mode 100644 index 9a92d87..0000000 --- a/back/abl/messages.ts +++ /dev/null @@ -1,16 +0,0 @@ -import statusCode from "../utils/statusCodes"; -import { getMessages } from "../db/api-db"; -import logger from "../system/Logger"; -import { Response } from "express"; - -export async function messages(body, res: Response) { - const { roomId } = body; - getMessages(roomId) - .then((messages) => { - res.status(statusCode.OK).json(messages); - }) - .catch((err) => { - logger.err(err); - res.status(statusCode.INTERNAL_SERVER_ERROR); - }); -} diff --git a/back/abl/rooms.ts b/back/abl/rooms.ts deleted file mode 100644 index 911f342..0000000 --- a/back/abl/rooms.ts +++ /dev/null @@ -1,14 +0,0 @@ -import statusCode from "../utils/statusCodes"; -import { getRooms } from "../db/api-db"; -import logger from "../system/Logger"; -import { Response } from "express"; - -export async function rooms(body, res: Response) { - const { mailboxId, offset, limit } = body; - getRooms(mailboxId).then((rooms) => { - res.status(statusCode.OK).json(rooms); - }).catch((err) => { - logger.err(err) - res.status(statusCode.INTERNAL_SERVER_ERROR); - }); -} diff --git a/back/mails/imap/Mailbox.ts b/back/mails/imap/Mailbox.ts index 22e9ba6..7fd944e 100644 --- a/back/mails/imap/Mailbox.ts +++ b/back/mails/imap/Mailbox.ts @@ -35,7 +35,6 @@ export default class Mailbox { this.box = (await getMailbox(this.id))[0]; const isReadOnly = false; this.imap.openBox(this.boxName, isReadOnly, (err, box) => { - console.log(typeof(box.highestmodseq)) if (err) logger.err(err); // sync messages and flags diff --git a/back/routes/mail.ts b/back/routes/mail.ts index 151ae59..4e1c228 100644 --- a/back/routes/mail.ts +++ b/back/routes/mail.ts @@ -1,10 +1,7 @@ import express from "express"; const router = express.Router(); -import { rooms } from "../abl/rooms"; import Message from "../abl/Message-abl"; -import { messages } from "../abl/messages"; -import { members } from "../abl/members"; import Account from "../abl/Account-abl"; import validator from "../validator/validator"; import Room from "../abl/Room-abl"; @@ -21,21 +18,21 @@ router.get("/accounts", async (req, res) => { */ router.get("/:mailboxId/rooms", async (req, res) => { // todo offet limit - await validator.validate("getRooms", req.params, res, rooms); + await validator.validate("getRooms", req.params, res, Room.getAll); }); /** * Return all messages from a room */ router.get("/:roomId/messages", async (req, res) => { - await validator.validate("getMessages", req.params, res, messages); + await validator.validate("getMessages", req.params, res, Room.getMessages); }); /** * Return all members from a room */ router.get("/:roomId/members", async (req, res) => { - await validator.validate("getMembers", req.params, res, members); + await validator.validate("getMembers", req.params, res, Room.getMembers); }); /**