Skip to content

Commit

Permalink
chore: refactor remind endpoint to just provide db data
Browse files Browse the repository at this point in the history
  • Loading branch information
@kcoderhtml
kcoderhtml committed Apr 29, 2024
1 parent fe96f4e commit dfdb74c
Showing 1 changed file with 1 addition and 105 deletions.
106 changes: 1 addition & 105 deletions src/pages/api/remind.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,10 +2,6 @@ import type { APIRoute } from "astro"
import { db, User, Organization, Event } from "astro:db";

export const POST: APIRoute = async ({ request }) => {
const endpointStart = new Date()
const continuePoint: [{ org: string, users: string[], completed: boolean }] = await request.json().catch(() => null);
let processed: [{ org: string, users: string[], completed: boolean }] = continuePoint || [];

// get authorization header
const auth = request.headers.get("Authorization")

Expand All @@ -24,108 +20,8 @@ export const POST: APIRoute = async ({ request }) => {
return diffHours < 24 && diffHours > 0
})

console.log(`Found ${eventsHappeningToday.length} events happening in the next 24 hours`)

for (const org of organizations) {
if (processed && processed.find((p) => p.org === org.team && p.completed)) {
console.log(`Skipping ${org.name} because it was already processed`)
continue
} else {
processed.push({ org: org.team, users: [], completed: false })
}

const teamMembers = users.filter((u) => u.team === org.team)
console.log(`Organization: ${org.name} has ${teamMembers.length} team members`)

for (const member of teamMembers) {
if (processed && processed.find((p) => p.org === org.team && p.users.includes(member.userId))) {
console.log(`Skipping ${member.name} because they were already processed`)
continue
} else if (new Date().getTime() - endpointStart.getTime() > 10000) {
console.log(`Stopping at ${member.name} because it's been 10 seconds`)
await fetch("https://worker-long-pine-89a7-callback.kieran-fdb.workers.dev/", {
method: "POST",
headers: {
"Content-Type": "application/json",
Authorization: process.env.API_SECRET || "",
},
body: JSON.stringify(processed),
});
return new Response(JSON.stringify({
ok: false, error: "Timeout", processed: processed
}), { status: 408 })
} else {
processed.find((p) => p.org === org.team)?.users.push(member.userId)
}

console.log(`Sending Email to ${member.role}: ${member.name} (${member.email})`)

// get all events that the user is going to
const eventsGoing = eventsHappeningToday.filter((e) => e.statusGoing.includes(member.userId))

// get all events that the user is maybe going to
const eventsMaybe = eventsHappeningToday.filter((e) => e.statusMaybe.includes(member.userId))

// get all events that the user is not going to
const eventsNotGoing = eventsHappeningToday.filter((e) => e.statusNotGoing.includes(member.userId))

// send email to user
const message = `Hey ${member.name},\nJust a friendly reminder about your schedule for tomorrow, ${new Date().toLocaleDateString('en-US', { weekday: 'long', month: 'long', day: 'numeric' })}:`;
let emailMessage = message;

if (eventsGoing.length > 0) {
const going = eventsGoing.map((e) => `* **${e.name}** at ${new Date(e.date).toLocaleString('en-US', { weekday: 'long', month: 'long', day: 'numeric', hour: 'numeric', minute: 'numeric' })} in ${e.location}`).join("\n");
emailMessage += "\n\n**Events you're attending:**\n" + going;
}

if (eventsMaybe.length > 0) {
const maybe = eventsMaybe.map((e) => `* **${e.name}** at ${e.date.toLocaleString('en-US', { weekday: 'long', month: 'long', day: 'numeric', hour: 'numeric', minute: 'numeric' })} in ${e.location}`).join("\n");
emailMessage += "\n\n**Events you might be attending:**\n" + maybe;
}

if (eventsNotGoing.length > 0) {
const notGoing = eventsNotGoing.map((e) => `* **${e.name}** at ${e.date.toLocaleString('en-US', { weekday: 'long', month: 'long', day: 'numeric', hour: 'numeric', minute: 'numeric' })} in ${e.location}`).join("\n");
emailMessage += "\n\n**Events you declined:**\n" + notGoing;
}

if (eventsGoing.length === 0 && eventsMaybe.length === 0 && eventsNotGoing.length === 0) {
emailMessage += "\n\nLooks like you have a free day tomorrow! Enjoy!";
}

emailMessage += "\n\nDon't forget to stay organized and have a productive day!";

emailMessage += "\n\nAll the Best, \nYour friendly neighborhood event reminder bot";

emailMessage += "\n\n-----\n\n";
emailMessage += `*This email was sent by MagicSnap because you are a member of ${org.name}. If you have any questions or need assistance, please contact us at [email protected].*`;

// console.log(emailMessage)
console.log(new Date().getTime() - endpointStart.getTime() + "ms")
const response = await fetch("https://email.magicsnap.org/api/email", {
method: "POST",
headers: {
"Content-Type": "application/json",
Authorization: process.env.EMAIL_API_KEY || "",
},
body: JSON.stringify({
to: member.email,
from: "[email protected]",
subject: "Event Reminder for " + new Date().toDateString(),
markdown: emailMessage,
}),
});
}

const processedOrg = processed.find((p) => p.org === org.team);
if (processedOrg) {
processedOrg.completed = true;
}

console.log(`Processed ${org.name} ${new Date().getTime() - endpointStart.getTime() + "ms"}`)
}

return new Response(JSON.stringify({
ok: true, message: "Reminders sent"
ok: true, eventsHappeningToday: eventsHappeningToday, users: users, organizations: organizations
}), { status: 200 })
} else {
return new Response(JSON.stringify({
Expand Down

0 comments on commit dfdb74c

Please sign in to comment.