Added create message endpoint

Author: nora-soderlund

database.sql

@@ -106,3 +106,10 @@ CREATE TABLE IF NOT EXISTS "activities" (
 	"status"	TEXT DEFAULT NULL,
 	"timestamp"	double NOT NULL
 );
+DROP TABLE IF EXISTS "messages";
+CREATE TABLE IF NOT EXISTS "messages" (
+	"id"	varchar(255) NOT NULL,
+	"user"	varchar(255) NOT NULL,
+	"message"	TEXT DEFAULT NULL,
+	"timestamp"	double NOT NULL
+);

src/controllers/messages/createMessage.ts

@@ -0,0 +1,6 @@
+export async function createMessage(database: D1Database, user: string, message: string): Promise<void> {
+    const id = crypto.randomUUID();
+    const timestamp = Date.now();
+
+    await database.prepare("INSERT INTO messages (id, user, message, timestamp) VALUES (?, ?, ?, ?)").bind(id, user, message, timestamp).run();
+};

src/controllers/messages/sendMessageEmail.ts

@@ -0,0 +1,33 @@
+import { User } from "../../models/user";
+
+export async function sendMessageEmail(user: User, message: string): Promise<any> {
+    return await fetch("https://api.mailchannels.net/tx/v1/send", {
+        "method": "POST",
+        "headers": {
+            "content-type": "application/json",
+        },
+        "body": JSON.stringify({
+            "personalizations": [
+                {
+                    "to": [
+                        {
+                            "email": "contact@ridetracker.app",
+                            "name": "Ride Tracker",
+                        }
+                    ]
+                }
+            ],
+            "from": {
+                "email": "noreply@ridetracker.app",
+                "name": user.firstname + " " + user.lastname
+            },
+            "subject": "Message from the app",
+            "content": [
+                {
+                    "type": "text/plain",
+                    "value": `${message}\n\nThis was sent from ${user.firstname} ${user.lastname} from ${user.email}.`,
+                }
+            ]
+        })
+    });
+};

src/domains/router.ts

@@ -33,6 +33,7 @@ import { handleMapsGeocodeRequest, mapsGeocodeSchema } from "../routes/maps/geoc
 import { handleMapsRouteRequest, mapsRouteSchema } from "../routes/maps/route";
 import { handleStatusRequest, statusRequestSchema } from "../routes/status";
 import { Token } from "../models/token";
+import { createMessageRequestSchema, handleCreateMessageRequest } from "../routes/message";
 
 export default function createRouter() {
     const router = ThrowableRouter();
@@ -75,6 +76,8 @@ export default function createRouter() {
     router.post("/api/profiles/:userId/bikes", withAuth, withParams, withContent, withSchema(profileBikesRequestSchema), handleProfileBikesRequest);
 
     router.post("/api/user/avatar", withAuth, withContent, withSchema(uploadUserImageRequestSchema), handleUploadUserAvatarRequest);
+
+    router.post("/api/message", withAuth, withContent, withSchema(createMessageRequestSchema), handleCreateMessageRequest);
 
     router.get("/api/ping", withContent, async (request: RequestWithKey, env: Env) => {
         return Response.json({

src/models/Message.ts

@@ -0,0 +1,6 @@
+export type Message = {
+    id: string;
+    user: string;
+    message: string;
+    timestamp: number;
+};

src/routes/message.ts

@@ -0,0 +1,30 @@
+import { createMessage } from "../controllers/messages/createMessage";
+import { sendMessageEmail } from "../controllers/messages/sendMessageEmail";
+import { getUserById } from "../controllers/users/getUserById";
+import { VersionFeatureFlags } from "../models/FeatureFlags";
+
+export const createMessageRequestSchema = {
+    content: {
+        message: {
+            type: "string",
+            required: true
+        }
+    }  
+};
+
+export async function handleCreateMessageRequest(request: RequestWithKey, env: Env, context: EventContext<Env, string, null>, featureFlags: VersionFeatureFlags) {
+    const { message } = request.content;
+
+    if(!message?.length)
+        return Response.json({ success: false, message: "You must enter a message." });
+
+    await createMessage(env.DATABASE, request.key.user, message);
+
+    const user = await getUserById(env.DATABASE, request.key.user);
+
+    context.waitUntil(sendMessageEmail(user, message));
+
+    return Response.json({
+        success: true
+    });
+};