Turned the e-mails to be dependent on the environment
This commit is contained in:
Tiago Ribeiro
@@ -1,109 +1,104 @@
|
||||
// Next.js API route support: https://nextjs.org/docs/api-routes/introduction
|
||||
import type { NextApiRequest, NextApiResponse } from "next";
|
||||
import { app } from "@/firebase";
|
||||
import {
|
||||
getFirestore,
|
||||
getDoc,
|
||||
doc,
|
||||
deleteDoc,
|
||||
setDoc,
|
||||
} from "firebase/firestore";
|
||||
import { withIronSessionApiRoute } from "iron-session/next";
|
||||
import { sessionOptions } from "@/lib/session";
|
||||
import { Ticket, TicketTypeLabel, TicketStatusLabel } from "@/interfaces/ticket";
|
||||
import type {NextApiRequest, NextApiResponse} from "next";
|
||||
import {app} from "@/firebase";
|
||||
import {getFirestore, getDoc, doc, deleteDoc, setDoc} from "firebase/firestore";
|
||||
import {withIronSessionApiRoute} from "iron-session/next";
|
||||
import {sessionOptions} from "@/lib/session";
|
||||
import {Ticket, TicketTypeLabel, TicketStatusLabel} from "@/interfaces/ticket";
|
||||
import moment from "moment";
|
||||
import { sendEmail } from "@/email";
|
||||
import {sendEmail} from "@/email";
|
||||
|
||||
const db = getFirestore(app);
|
||||
|
||||
export default withIronSessionApiRoute(handler, sessionOptions);
|
||||
|
||||
async function handler(req: NextApiRequest, res: NextApiResponse) {
|
||||
if (req.method === "GET") return await get(req, res);
|
||||
if (req.method === "DELETE") return await del(req, res);
|
||||
if (req.method === "PATCH") return await patch(req, res);
|
||||
if (req.method === "GET") return await get(req, res);
|
||||
if (req.method === "DELETE") return await del(req, res);
|
||||
if (req.method === "PATCH") return await patch(req, res);
|
||||
|
||||
res.status(404).json(undefined);
|
||||
res.status(404).json(undefined);
|
||||
}
|
||||
|
||||
async function get(req: NextApiRequest, res: NextApiResponse) {
|
||||
if (!req.session.user) {
|
||||
res.status(401).json({ ok: false });
|
||||
return;
|
||||
}
|
||||
if (!req.session.user) {
|
||||
res.status(401).json({ok: false});
|
||||
return;
|
||||
}
|
||||
|
||||
const { id } = req.query as { id: string };
|
||||
const {id} = req.query as {id: string};
|
||||
|
||||
const snapshot = await getDoc(doc(db, "tickets", id));
|
||||
const snapshot = await getDoc(doc(db, "tickets", id));
|
||||
|
||||
if (snapshot.exists()) {
|
||||
res.status(200).json({ ...snapshot.data(), id: snapshot.id });
|
||||
} else {
|
||||
res.status(404).json(undefined);
|
||||
}
|
||||
if (snapshot.exists()) {
|
||||
res.status(200).json({...snapshot.data(), id: snapshot.id});
|
||||
} else {
|
||||
res.status(404).json(undefined);
|
||||
}
|
||||
}
|
||||
|
||||
async function del(req: NextApiRequest, res: NextApiResponse) {
|
||||
if (!req.session.user) {
|
||||
res.status(401).json({ ok: false });
|
||||
return;
|
||||
}
|
||||
if (!req.session.user) {
|
||||
res.status(401).json({ok: false});
|
||||
return;
|
||||
}
|
||||
|
||||
const { id } = req.query as { id: string };
|
||||
const {id} = req.query as {id: string};
|
||||
|
||||
const snapshot = await getDoc(doc(db, "tickets", id));
|
||||
const data = snapshot.data() as Ticket;
|
||||
const snapshot = await getDoc(doc(db, "tickets", id));
|
||||
const data = snapshot.data() as Ticket;
|
||||
|
||||
const user = req.session.user;
|
||||
if (user.type === "admin" || user.type === "developer") {
|
||||
await deleteDoc(snapshot.ref);
|
||||
res.status(200).json({ ok: true });
|
||||
return;
|
||||
}
|
||||
const user = req.session.user;
|
||||
if (user.type === "admin" || user.type === "developer") {
|
||||
await deleteDoc(snapshot.ref);
|
||||
res.status(200).json({ok: true});
|
||||
return;
|
||||
}
|
||||
|
||||
res.status(403).json({ ok: false });
|
||||
res.status(403).json({ok: false});
|
||||
}
|
||||
|
||||
async function patch(req: NextApiRequest, res: NextApiResponse) {
|
||||
if (!req.session.user) {
|
||||
res.status(401).json({ ok: false });
|
||||
return;
|
||||
}
|
||||
if (!req.session.user) {
|
||||
res.status(401).json({ok: false});
|
||||
return;
|
||||
}
|
||||
|
||||
const { id } = req.query as { id: string };
|
||||
const body = req.body as Ticket;
|
||||
const {id} = req.query as {id: string};
|
||||
const body = req.body as Ticket;
|
||||
|
||||
const snapshot = await getDoc(doc(db, "tickets", id));
|
||||
const snapshot = await getDoc(doc(db, "tickets", id));
|
||||
|
||||
const user = req.session.user;
|
||||
if (user.type === "admin" || user.type === "developer") {
|
||||
const data = snapshot.data() as Ticket;
|
||||
await setDoc(snapshot.ref, body, { merge: true });
|
||||
try {
|
||||
// send email if the status actually changed to completed
|
||||
if(data.status !== req.body.status && req.body.status === 'completed') {
|
||||
await sendEmail(
|
||||
"ticketStatusCompleted",
|
||||
{
|
||||
id,
|
||||
subject: body.subject,
|
||||
reporter: body.reporter,
|
||||
date: moment(body.date).format("DD/MM/YYYY - HH:mm"),
|
||||
type: TicketTypeLabel[body.type],
|
||||
reportedFrom: body.reportedFrom,
|
||||
description: body.description,
|
||||
},
|
||||
[data.reporter.email],
|
||||
`Ticket ${id}: ${data.subject}`,
|
||||
);
|
||||
}
|
||||
} catch(err) {
|
||||
console.error(err);
|
||||
// doesnt matter if the email fails
|
||||
}
|
||||
res.status(200).json({ ok: true });
|
||||
return;
|
||||
}
|
||||
const user = req.session.user;
|
||||
if (user.type === "admin" || user.type === "developer") {
|
||||
const data = snapshot.data() as Ticket;
|
||||
await setDoc(snapshot.ref, body, {merge: true});
|
||||
try {
|
||||
// send email if the status actually changed to completed
|
||||
if (data.status !== req.body.status && req.body.status === "completed") {
|
||||
await sendEmail(
|
||||
"ticketStatusCompleted",
|
||||
{
|
||||
id,
|
||||
subject: body.subject,
|
||||
reporter: body.reporter,
|
||||
date: moment(body.date).format("DD/MM/YYYY - HH:mm"),
|
||||
type: TicketTypeLabel[body.type],
|
||||
reportedFrom: body.reportedFrom,
|
||||
description: body.description,
|
||||
environment: process.env.ENVIRONMENT,
|
||||
},
|
||||
[data.reporter.email],
|
||||
`Ticket ${id}: ${data.subject}`,
|
||||
);
|
||||
}
|
||||
} catch (err) {
|
||||
console.error(err);
|
||||
// doesnt matter if the email fails
|
||||
}
|
||||
res.status(200).json({ok: true});
|
||||
return;
|
||||
}
|
||||
|
||||
res.status(403).json({ ok: false });
|
||||
res.status(403).json({ok: false});
|
||||
}
|
||||
|
||||
@@ -1,110 +1,103 @@
|
||||
// Next.js API route support: https://nextjs.org/docs/api-routes/introduction
|
||||
import { sendEmail } from "@/email";
|
||||
import { app } from "@/firebase";
|
||||
import { Ticket, TicketTypeLabel, TicketWithCorporate } from "@/interfaces/ticket";
|
||||
import { sessionOptions } from "@/lib/session";
|
||||
import {
|
||||
collection,
|
||||
doc,
|
||||
getDocs,
|
||||
getFirestore,
|
||||
setDoc,
|
||||
where,
|
||||
query,
|
||||
} from "firebase/firestore";
|
||||
import { withIronSessionApiRoute } from "iron-session/next";
|
||||
import {sendEmail} from "@/email";
|
||||
import {app} from "@/firebase";
|
||||
import {Ticket, TicketTypeLabel, TicketWithCorporate} from "@/interfaces/ticket";
|
||||
import {sessionOptions} from "@/lib/session";
|
||||
import {collection, doc, getDocs, getFirestore, setDoc, where, query} from "firebase/firestore";
|
||||
import {withIronSessionApiRoute} from "iron-session/next";
|
||||
import moment from "moment";
|
||||
import type { NextApiRequest, NextApiResponse } from "next";
|
||||
import type {NextApiRequest, NextApiResponse} from "next";
|
||||
import ShortUniqueId from "short-unique-id";
|
||||
import { Group, CorporateUser } from "@/interfaces/user";
|
||||
import {Group, CorporateUser} from "@/interfaces/user";
|
||||
|
||||
const db = getFirestore(app);
|
||||
|
||||
export default withIronSessionApiRoute(handler, sessionOptions);
|
||||
|
||||
async function handler(req: NextApiRequest, res: NextApiResponse) {
|
||||
// due to integration with the homepage the POST request should be public
|
||||
if (req.method === "POST") {
|
||||
await post(req, res);
|
||||
return;
|
||||
}
|
||||
// due to integration with the homepage the POST request should be public
|
||||
if (req.method === "POST") {
|
||||
await post(req, res);
|
||||
return;
|
||||
}
|
||||
|
||||
// specific logic for the preflight request
|
||||
if (req.method === "OPTIONS") {
|
||||
res.status(200).end();
|
||||
return;
|
||||
}
|
||||
if (!req.session.user) {
|
||||
res.status(401).json({ ok: false });
|
||||
return;
|
||||
}
|
||||
// specific logic for the preflight request
|
||||
if (req.method === "OPTIONS") {
|
||||
res.status(200).end();
|
||||
return;
|
||||
}
|
||||
if (!req.session.user) {
|
||||
res.status(401).json({ok: false});
|
||||
return;
|
||||
}
|
||||
|
||||
if (req.method === "GET") {
|
||||
await get(req, res);
|
||||
}
|
||||
if (req.method === "GET") {
|
||||
await get(req, res);
|
||||
}
|
||||
}
|
||||
|
||||
async function get(req: NextApiRequest, res: NextApiResponse) {
|
||||
const snapshot = await getDocs(collection(db, "tickets"));
|
||||
const snapshot = await getDocs(collection(db, "tickets"));
|
||||
|
||||
const docs = snapshot.docs.map((doc) => ({
|
||||
id: doc.id,
|
||||
...doc.data(),
|
||||
})) as Ticket[];
|
||||
const docs = snapshot.docs.map((doc) => ({
|
||||
id: doc.id,
|
||||
...doc.data(),
|
||||
})) as Ticket[];
|
||||
|
||||
// fetch all groups for these users
|
||||
// fetch all groups for these users
|
||||
|
||||
const reporters = [...new Set(docs.map((d) => d.reporter.id).filter((id) => id))];
|
||||
const reporters = [...new Set(docs.map((d) => d.reporter.id).filter((id) => id))];
|
||||
|
||||
const groupsSnapshot = await getDocs(query(collection(db, "groups"), where("participants", "array-contains-any", reporters)));
|
||||
const groups = groupsSnapshot.docs.map((doc) => doc.data()) as Group[];
|
||||
const groupsSnapshot = await getDocs(query(collection(db, "groups"), where("participants", "array-contains-any", reporters)));
|
||||
const groups = groupsSnapshot.docs.map((doc) => doc.data()) as Group[];
|
||||
|
||||
// based on the admin of each group, verify if it exists and it's of type corporate
|
||||
const groupsAdmins = [...new Set(groups.map((g) => g.admin).filter((id) => id))];
|
||||
const adminsSnapshot = await getDocs(query(collection(db, "users"), where("id", "in", groupsAdmins), where("type", "==", "corporate")));
|
||||
const admins = adminsSnapshot.docs.map((doc) => doc.data());
|
||||
// based on the admin of each group, verify if it exists and it's of type corporate
|
||||
const groupsAdmins = [...new Set(groups.map((g) => g.admin).filter((id) => id))];
|
||||
const adminsSnapshot = await getDocs(query(collection(db, "users"), where("id", "in", groupsAdmins), where("type", "==", "corporate")));
|
||||
const admins = adminsSnapshot.docs.map((doc) => doc.data());
|
||||
|
||||
const docsWithAdmins = docs.map((d) => {
|
||||
const group = groups.find((g) => g.participants.includes(d.reporter.id));
|
||||
const admin = admins.find((a) => a.id === group?.admin) as CorporateUser;
|
||||
const docsWithAdmins = docs.map((d) => {
|
||||
const group = groups.find((g) => g.participants.includes(d.reporter.id));
|
||||
const admin = admins.find((a) => a.id === group?.admin) as CorporateUser;
|
||||
|
||||
if(admin) {
|
||||
return {
|
||||
...d,
|
||||
corporate: admin.corporateInformation?.companyInformation?.name,
|
||||
};
|
||||
}
|
||||
if (admin) {
|
||||
return {
|
||||
...d,
|
||||
corporate: admin.corporateInformation?.companyInformation?.name,
|
||||
};
|
||||
}
|
||||
|
||||
return d;
|
||||
}) as TicketWithCorporate[];
|
||||
return d;
|
||||
}) as TicketWithCorporate[];
|
||||
|
||||
res.status(200).json(docsWithAdmins);
|
||||
res.status(200).json(docsWithAdmins);
|
||||
}
|
||||
|
||||
async function post(req: NextApiRequest, res: NextApiResponse) {
|
||||
const body = req.body as Ticket;
|
||||
const body = req.body as Ticket;
|
||||
|
||||
const shortUID = new ShortUniqueId();
|
||||
const id = body.id || shortUID.randomUUID(8);
|
||||
await setDoc(doc(db, "tickets", id), body);
|
||||
res.status(200).json({ ok: true });
|
||||
const shortUID = new ShortUniqueId();
|
||||
const id = body.id || shortUID.randomUUID(8);
|
||||
await setDoc(doc(db, "tickets", id), body);
|
||||
res.status(200).json({ok: true});
|
||||
|
||||
try {
|
||||
await sendEmail(
|
||||
"submittedFeedback",
|
||||
{
|
||||
id,
|
||||
subject: body.subject,
|
||||
reporter: body.reporter,
|
||||
date: moment(body.date).format("DD/MM/YYYY - HH:mm"),
|
||||
type: TicketTypeLabel[body.type],
|
||||
reportedFrom: body.reportedFrom,
|
||||
description: body.description,
|
||||
},
|
||||
[body.reporter.email],
|
||||
`Ticket ${id}: ${body.subject}`
|
||||
);
|
||||
} catch (e) {
|
||||
console.log(e);
|
||||
}
|
||||
try {
|
||||
await sendEmail(
|
||||
"submittedFeedback",
|
||||
{
|
||||
id,
|
||||
subject: body.subject,
|
||||
reporter: body.reporter,
|
||||
date: moment(body.date).format("DD/MM/YYYY - HH:mm"),
|
||||
type: TicketTypeLabel[body.type],
|
||||
reportedFrom: body.reportedFrom,
|
||||
description: body.description,
|
||||
environment: process.env.ENVIRONMENT,
|
||||
},
|
||||
[body.reporter.email],
|
||||
`Ticket ${id}: ${body.subject}`,
|
||||
);
|
||||
} catch (e) {
|
||||
console.log(e);
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user