122 lines
4.1 KiB
JavaScript
122 lines
4.1 KiB
JavaScript
const { db, execQueryAsync, execQueryAsyncWithId } = require("./db.js");
|
|
const DEBUG = require("../utils/debug").DEBUG;
|
|
|
|
async function registerMailbox(userId, pwd, xoauth, xoauth2, host, port, tls) {
|
|
const query = `
|
|
INSERT INTO app_account
|
|
(user_id, account_pwd, xoauth, xoauth2, host, port, tls) VALUES (?, ?, ?, ?, ?, ?, ?)
|
|
`;
|
|
const values = [userId, pwd, xoauth, xoauth2, host, port, tls];
|
|
return await execQueryAsyncWithId(query, values);
|
|
}
|
|
|
|
async function getMailboxes() {
|
|
const query = `
|
|
SELECT
|
|
app_account.account_id AS id,
|
|
address.email
|
|
FROM app_account INNER JOIN address
|
|
WHERE address.address_id = app_account.user_id
|
|
`;
|
|
const values = [];
|
|
return await execQueryAsync(query, values);
|
|
}
|
|
|
|
async function getRooms(mailboxId) {
|
|
const query = `
|
|
SELECT
|
|
app_room.room_id AS id,
|
|
app_room.room_name AS roomName,
|
|
address.email AS user,
|
|
app_room.owner_id AS userId,
|
|
app_room.notSeen,
|
|
mailbox_message.mailbox_id AS mailboxId
|
|
FROM app_room
|
|
INNER JOIN message
|
|
INNER JOIN mailbox_message
|
|
INNER JOIN address
|
|
WHERE
|
|
message.message_id = app_room.message_id AND
|
|
mailbox_message.mailbox_id = 1 AND
|
|
mailbox_message.message_id = message.message_id AND
|
|
address.address_id = app_room.owner_id
|
|
`;
|
|
// todo mailboxId
|
|
const values = [];
|
|
return await execQueryAsync(query, values);
|
|
}
|
|
|
|
async function getMessages(roomId) {
|
|
// todo attachements name
|
|
// todo html, text, textAsHtml
|
|
// todo datetime
|
|
const query = `
|
|
SELECT
|
|
msg.message_id AS id,
|
|
GROUP_CONCAT(fromT.address_id) AS fromA,
|
|
GROUP_CONCAT(toT.address_id) AS toA,
|
|
GROUP_CONCAT(ccT.address_id) AS ccA,
|
|
subjectT.value AS subject,
|
|
content.text AS content,
|
|
message.idate AS date
|
|
FROM app_room_message msg
|
|
|
|
LEFT JOIN (
|
|
SELECT address_field.address_id, address_field.message_id
|
|
FROM address_field
|
|
INNER JOIN field_name
|
|
WHERE
|
|
field_name.field_id = address_field.field_id AND
|
|
field_name.field_name = 'from'
|
|
) fromT ON msg.message_id = fromT.message_id
|
|
LEFT JOIN (
|
|
SELECT address_field.address_id, address_field.message_id
|
|
FROM address_field
|
|
INNER JOIN field_name
|
|
WHERE
|
|
field_name.field_id = address_field.field_id AND
|
|
field_name.field_name = 'to'
|
|
) toT ON msg.message_id = toT.message_id
|
|
LEFT JOIN (
|
|
SELECT address_field.address_id, address_field.message_id
|
|
FROM address_field
|
|
INNER JOIN field_name
|
|
WHERE
|
|
field_name.field_id = address_field.field_id AND
|
|
field_name.field_name = 'cc'
|
|
) ccT ON msg.message_id = ccT.message_id
|
|
|
|
LEFT JOIN (
|
|
SELECT header_field.message_id, header_field.value
|
|
FROM header_field
|
|
INNER JOIN field_name
|
|
WHERE
|
|
field_name.field_id = header_field.field_id AND
|
|
field_name.field_name = 'subject'
|
|
) subjectT ON msg.message_id = subjectT.message_id
|
|
|
|
LEFT JOIN (
|
|
SELECT bodypart.text, header_field.message_id FROM bodypart
|
|
INNER JOIN header_field
|
|
INNER JOIN field_name
|
|
WHERE
|
|
field_name.field_id = header_field.field_id AND
|
|
field_name.field_name = 'html' AND
|
|
bodypart.bodypart_id = header_field.bodypart_id
|
|
) content ON msg.message_id = content.message_id
|
|
|
|
INNER JOIN message ON message.message_id = msg.message_id
|
|
WHERE msg.room_id = ?
|
|
GROUP BY msg.message_id;
|
|
`;
|
|
const values = [roomId];
|
|
return await execQueryAsync(query, values);
|
|
}
|
|
|
|
module.exports = {
|
|
registerMailbox,
|
|
getMailboxes,
|
|
getRooms,
|
|
getMessages
|
|
};
|