Merge pull request BloomTech-Labs#144 from Lambda-School-Labs/messageEndpoints

Commit for push

Author: Serrowxd

ReadMe.md

@@ -107,6 +107,7 @@ Deployed [here](https://intense-stream-29923.herokuapp.com/api/database/seekers)
     - [auth](#auth)
     - [companies](#companies)
     - [constants](#constants)
+    - [conversations](#conversations)
     - [firebase](#firebase)
       - [functions](#functions)
     - [markers](#markers)
@@ -260,6 +261,11 @@ Contains the server/backend of the project.
 
    **Files:** frontend.js, stripe.js
 
+- ### conversations
+   The endpoints used to retrieve and manipulate data associated with conversations in the database.
+
+   **Files:** conversationsRouters.js
+
 - ### firebase
    The configuration files for the client-side firebase integration.
 

server/conversations/conversationsRouters.js

@@ -0,0 +1,76 @@
+const express = require('express');
+const firebase = require('../firebase/firebase.js');
+const rootRef = firebase.database().ref();
+const router = express.Router();
+
+
+//--------------------------------------------------------POSTS
+
+router.post(
+  '/addMessage',
+  (req, res) => {
+
+    const messageKey = rootRef.push(null).key;
+
+    // Deconstruct Request Body
+    const {
+      uid, // User ID (Sender)
+      pid, // Participant ID (Receiver)
+      message,
+      name,
+      participant,
+      date
+    } = req.body;
+
+    cid = [uid, pid].sort().join('_'); // Conversation ID - Combination of Sender's and Receiver's UIDs.
+
+    // Check for Missing Required Information
+    if (!pid || !uid || !message || !name || !participant || !date) {
+     return res.status(400).json({"errorMessage":"Please send a message, date, and the names and ids of both participants."})
+    }
+
+    // Construct New Message Object
+    let newMessage = {
+      date,
+      message,
+      name,
+    }
+
+    // Construct Object to Add to User's Conversation Lookup (Sender)
+    let newUserLookup = {
+      lastMessage: newMessage,
+      participant: {
+        name: participant,
+        uid: pid
+      }
+    }
+
+    // Construct Object to Add to Participant's Conversation Lookup (Receiver)
+    let newParticipantLookup = {
+      lastMessage: newMessage,
+      participant: {
+        name,
+        uid
+      }
+    }
+    
+    // Create Object to Update Firebase
+    let updateObject = {};
+
+    // Set Up New Message to be Added to Conversations and Conversation Lookup
+    updateObject[`conversations/${cid}/${messageKey}`] = newMessage;
+    updateObject[`conversationLookup/${uid}/${cid}`] = newUserLookup; // Lookup for Sender
+    updateObject[`conversationLookup/${pid}/${cid}`] = newParticipantLookup; // Lookup for Receiver
+    
+
+    // Update database with the new object
+    rootRef.update(updateObject).catch(error => console.log(error));
+
+    // Success Message
+    res.status(201).json({
+      success: `Message has been sent.`,
+    });
+  }
+);
+
+module.exports = router;

server/server.js

@@ -14,8 +14,8 @@ const corsOptions = {
 const seekersRouters = require('./seekers/seekersRouters.js');
 const companiesRouters = require('./companies/companiesRouters.js');
 const markersRouters = require('./markers/markersRouters.js');
-
 const favoritesRouters = require('./seekers/favoritesRoutes.js');
+const conversationsRouters = require('./conversations/conversationsRouters.js');
 
 // const configureServer = require('./serverConfig');
 const configureRoutes = require('./stripe-routes');
@@ -27,9 +27,8 @@ server.use(express.json(), helmet());
 server.use('/api/database/seekers', seekersRouters);
 server.use('/api/database/companies', companiesRouters);
 server.use('/api/markers', markersRouters);
-
-
 server.use('/api/database/favorites', favoritesRouters);
+server.use('/api/database/conversations', conversationsRouters)
 
 server.get('/', (req, res) => {
  res.status(200).send('Developer Map API. Currently In Development.');