init

Author: Ghospel

.gitignore

@@ -0,0 +1,80 @@
+# Logs
+logs
+*.log
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*
+
+# Runtime data
+pids
+*.pid
+*.seed
+*.pid.lock
+
+# Directory for instrumented libs generated by jscoverage/JSCover
+lib-cov
+
+# Coverage directory used by tools like istanbul
+coverage
+
+# nyc test coverage
+.nyc_output
+
+# Grunt intermediate storage (https://gruntjs.com/creating-plugins#storing-task-files)
+.grunt
+
+# Bower dependency directory (https://bower.io/)
+bower_components
+
+# node-waf configuration
+.lock-wscript
+
+# Compiled binary addons (https://nodejs.org/api/addons.html)
+build/Release
+
+# Dependency directories
+node_modules/
+jspm_packages/
+
+# TypeScript v1 declaration files
+typings/
+
+# Optional npm cache directory
+.npm
+
+# Optional eslint cache
+.eslintcache
+
+# Optional REPL history
+.node_repl_history
+
+# Output of 'npm pack'
+*.tgz
+
+# Yarn Integrity file
+.yarn-integrity
+
+# dotenv environment variables file
+.env
+.env.test
+
+# parcel-bundler cache (https://parceljs.org/)
+.cache
+
+# next.js build output
+.next
+
+# nuxt.js build output
+.nuxt
+
+# vuepress build output
+.vuepress/dist
+
+# Serverless directories
+.serverless/
+
+# FuseBox cache
+.fusebox/
+
+# DynamoDB Local files
+.dynamodb/

api.js

@@ -0,0 +1,102 @@
+const express = require("express");
+const bodyParser = require("body-parser");
+const app = express();
+const http = require("http").Server(app);
+const io = require("socket.io")(http);
+const models = require('./models');
+const dbConnection = require('./dbconnection');
+
+var server = require('./server')
+
+app.use(bodyParser.json());
+app.use(bodyParser.urlencoded({ extended: false }));
+app.use(express.static(__dirname));
+
+let Chats = models.ChatsModel;
+
+// Connect to the database
+dbConnection.Connect();
+server.init();
+
+app.post("/chats", async (req, res) => {
+    try {
+        let chat = new Chats(req.body);
+        await chat.save();
+        res.sendStatus(202).send(chat._id);
+        io.emit("chat", req.body);
+    } catch (error) {
+        res.sendStatus(500);
+        console.error(error);
+    }
+});
+
+// Post request on chats endpoind with ID parameter
+app.post("/chats/:id", async (req, res) => {
+    try {
+        let chatsFound;
+        let chat = Chats.find({_id: req.params.id}, (error, chats) => {
+            chatsFound = chats;
+        });
+        if(chat){
+            // We found a chat with the supplied ID
+            let user1 = search(chatsFound.user1ID, connections);
+            let user2 = search(chatsFound.user2ID, connections);
+            // Are both users currently online?
+            if( user1 && user2 ){
+                // Then broadcast the message over sockets
+                socket.broadcast.to(user1.socketID).emit('chat', req.body);
+                socket.broadcast.to(user2.socketID).emit('chat', req.body);
+            }
+        }
+        await Chats.findByIdAndUpdate(
+            req.params.id,
+            req.body,
+            (err, chat) => {
+                if(err) return res.status(500).send(err);
+                return res.send(chat);
+            }
+        )
+    } catch (error) {
+        res.sendStatus(500)
+        console.error(error)
+    }
+});
+
+app.get("/chats", (req, res) => {
+    Chats.find({}, (error, chats) => {
+        res.send(chats)
+    });
+});
+
+app.get("/chats/:id", (req, res) => {
+    Chats.find({ _id: req.params.id}, (error, chats) => {
+        console.log(req.params.id);
+        console.log(chats);
+        res.sendStatus(202).send(chats);
+        res.send(chats)
+    });
+});
+
+app.delete("/chats/:id", (req, res) => {
+    Chats.deleteOne({ _id: req.params.id}, (error, chats) => {
+        if(error){
+            return res.status(error.statusCode).send({
+                message: res.statusCode
+            }); 
+        }
+        return res.status(202);
+    });
+});
+
+process.on('exit', () => {
+    dbConnection.Disconnect();
+});
+
+function search(nameKey, myArray){
+    for (var i=0; i < myArray.length; i++) {
+        if (myArray[i].name === nameKey) {
+            return myArray[i];
+        }
+    }
+}
+

dbconnection.js

@@ -0,0 +1,18 @@
+const mongoose = require("mongoose");
+const conString = "mongodb://test:[email protected]:45923/huizingdb";
+
+function Connect(){
+    mongoose.connect(conString, {useNewUrlParser: true}, (err) => {
+    if(err){
+            throw(err);
+        }
+        console.log("Database connection established")
+    });
+}
+
+function Disconnect(){
+    mongoose.disconnect();
+}
+
+module.exports.Connect = Connect;
+module.exports.Disconnect = Disconnect;

index.html

@@ -0,0 +1,51 @@
+<!DOCTYPE html>
+<title>Epic, epic ftw.</title>
+<link rel="stylesheet" href="https://maxcdn.bootstrapcdn.com/bootstrap/4.0.0-beta.2/css/bootstrap.min.css" crossorigin="anonymous">
+<script src="https://code.jquery.com/jquery-3.2.1.min.js" crossorigin="anonymous"></script>
+<script src="https://cdnjs.cloudflare.com/ajax/libs/popper.js/1.12.3/umd/popper.min.js" crossorigin="anonymous"></script>
+<script src="https://maxcdn.bootstrapcdn.com/bootstrap/4.0.0-beta.2/js/bootstrap.min.js" crossorigin="anonymous"></script>
+<script src="/socket.io/socket.io.js"></script>
+
+<script>
+    var socket = io()
+    socket.on("chat", addChat)
+
+    $(() => {
+        console.log('getting chats');
+        getChats();
+
+        $("#send").click(() => {
+            var chatMessage = {
+                name: $("#txtName").val(), chat: $("#txtMessage").val()
+            }
+            postChat(chatMessage)
+        })
+    })
+    function postChat(chat) {
+        $.post("http://localhost:4001/chats", chat)
+}
+
+function getChats() {
+     $.get("/chats", (chats) => {
+         chats.forEach(addChat)
+     })
+}
+function addChat(chatObj){
+    $("#messages").append(`<h5>${chatObj.name} </h5><p>${chatObj.chat}</p>`);
+}
+
+</script>
+
+<div class="container">
+    <br>
+    <div class="jumbotron">
+        <h1 class="dispaly-4">Chat</h1>
+        <br>
+        <input id="txtName" class="form-control" placeholder="Name" type="text">
+        <br>
+        <textarea id="txtMessage" class="form-control" placeholder="Message"></textarea>
+        <br>
+        <button id="send" class="btn btn-success">Send</button>
+    </div>
+    <div id="messages"></div>
+</div>

models.js

@@ -0,0 +1,18 @@
+const mongoose = require("mongoose");
+
+const Message = new mongoose.Schema({
+    message: String,
+    from: String,
+});
+
+const ChatSchema = new mongoose.Schema({
+    user1ID: String,
+    user2ID: String, 
+    messages: [Message]
+});
+
+var Chats = mongoose.model("Chats", ChatSchema);
+
+exports.ChatsModel = Chats;
+exports.Message = Message;
+exports.ChatSchema = ChatSchema;