+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 | + + + + +2x + + +2x +2x +3x +3x +3x + +3x +3x + + + +3x +3x +3x +1x + + +2x + +2x + + + + +2x + +2x + + +2x + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + | import uuid from 'uuid';
+import md5 from 'md5';
+import { connectDB } from './connect-db'
+import { assembleUserState } from './utility';
+
+const authenticationTokens = [];
+
+
+export const authenticationRoute = app => {
+ app.post('/authenticate',async (req,res)=>{
+ let { username, password } = req.body;
+ let db = await connectDB();
+ let collection = db.collection(`users`);
+
+ let user = await collection.findOne({name:username});
+ Iif (!user) {
+ return res.status(500).send(`User not found`);
+ }
+
+ let hash = md5(password);
+ let passwordCorrect = hash === user.passwordHash;
+ if (!passwordCorrect) {
+ return res.status(500).send('Password incorrect');
+ }
+
+ let token = uuid();
+
+ authenticationTokens.push({
+ token,
+ userID: user.id
+ });
+
+ let state = await assembleUserState(user);
+
+ res.send({token,state});
+ });
+
+ app.post('/user/create',async(req,res)=>{
+ let {username,password} = req.body;
+ console.log(username,password);
+ let db = await connectDB();
+ let collection = db.collection(`users`);
+ let user = await collection.findOne({name:username});
+ if (user) {
+ res.status(500).send({message:"A user with that account name already exists."});
+ return;
+ };
+
+ let userID = uuid();
+ let groupID = uuid();
+
+ await collection.insertOne({
+ name:username,
+ id:userID,
+ passwordHash:md5(password)
+ });
+
+ await db.collection(`groups`).insertOne({
+ id:groupID,
+ owner:userID,
+ name: `To Do`
+ });
+
+ let state = await assembleUserState({id:userID,name:username});
+
+ res.status(200).send({userID,state});
+ });
+}; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 | + +2x +2x +2x +2x + + +2x +2x +1x +1x +1x + + +1x +1x + +1x +1x + + | import { connectDB } from './connect-db'
+
+export const addNewTask = async task=>{
+ let db = await connectDB();
+ let collection = db.collection(`tasks`);
+ await collection.insertOne(task);
+};
+
+export const updateTask = async task=>{
+ let {id,group,isComplete,name} = task;
+ let db = await connectDB();
+ let collection = db.collection(`tasks`);
+ Iif (group) {
+ await collection.updateOne({id},{$set:{group}});
+ }
+ Eif (name) {
+ await collection.updateOne({id},{$set:{name}});
+ }
+ Eif (isComplete !== undefined) {
+ await collection.updateOne({id},{$set:{isComplete}});
+ }
+}; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 | +2x +2x +2x + + +14x +4x + + + +4x +4x + + + +1x +1x +1x +1x + + | import { MongoClient } from 'mongodb';
+const url = process.env.MONGODB_URI || `mongodb://localhost:27017/organizer`;
+let db = null;
+let client = null;
+
+export async function connectDB(){
+ if (db) return db;
+ client = await MongoClient.connect(url, {
+ useNewUrlParser: true,
+ useUnifiedTopology: true
+ });
+ db = client.db();
+ return db;
+}
+
+export async function closeDB() {
+ Eif (client) {
+ await client.close();
+ db = null;
+ client = null;
+ }
+} |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 | +2x + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + | import md5 from 'md5';
+export const defaultState = {
+ users:[{
+ id:"U1",
+ name:"Dev",
+ passwordHash:md5("TUPLES"),
+ friends:[`U2`]
+ },{
+ id:"U2",
+ name:"C. Eeyo",
+ passwordHash:md5("PROFITING"),
+ friends:[]
+ }],
+ groups:[{
+ name:"To Do",
+ id:"G1",
+ owner:"U1"
+ },{
+ name:"Doing",
+ id:"G2",
+ owner:"U1"
+ },{
+ name:"Done",
+ id:"G3",
+ owner:"U1"
+ }
+ ],
+ tasks:[{
+ name:"Refactor tests",
+ id:"T1",
+ group:"G1",
+ owner:"U1",
+ isComplete:false,
+ },{
+ name:"Meet with CTO",
+ id:"T2",
+ group:"G1",
+ owner:"U1",
+ isComplete:true,
+ },{
+ name:"Compile ES6",
+ id:"T3",
+ group:"G2",
+ owner:"U2",
+ isComplete:false,
+ },{
+ name:"Update component snapshots",
+ id:"T4",
+ group:"G2",
+ owner:"U1",
+ isComplete:true,
+ },{
+ name:"Production optimizations",
+ id:"T5",
+ group:"G3",
+ owner:"U1",
+ isComplete:false,
+ }],
+ comments:[{
+ owner:"U1",
+ id:"C1",
+ task:"T1",
+ content:"Great work!"
+ }]
+}; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| File | ++ | Statements | ++ | Branches | ++ | Functions | ++ | Lines | ++ |
|---|---|---|---|---|---|---|---|---|---|
| authenticate.js | +
+
+ |
+ 53.12% | +17/32 | +50% | +3/6 | +66.66% | +2/3 | +53.12% | +17/32 | +
| communicate-db.js | +
+
+ |
+ 92.85% | +13/14 | +50% | +3/6 | +100% | +2/2 | +92.85% | +13/14 | +
| connect-db.js | +
+
+ |
+ 100% | +12/12 | +83.33% | +5/6 | +100% | +2/2 | +100% | +11/11 | +
| defaultState.js | +
+
+ |
+ 100% | +1/1 | +100% | +0/0 | +100% | +0/0 | +100% | +1/1 | +
| initialize-db.js | +
+
+ |
+ 100% | +7/7 | +50% | +1/2 | +100% | +1/1 | +100% | +7/7 | +
| server.js | +
+
+ |
+ 53.57% | +15/28 | +66.66% | +4/6 | +28.57% | +2/7 | +55.55% | +15/27 | +
| utility.js | +
+
+ |
+ 100% | +7/7 | +100% | +0/0 | +100% | +3/3 | +100% | +6/6 | +
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 | + + + + +2x +2x +2x +2x +2x +8x +8x + + + + | import { defaultState } from './defaultState';
+import { connectDB } from './connect-db'
+
+/* This code initializes the database with sample users.
+ Note, it does not drop the database - this can be done manually. Having code in your application that could drop your whole DB is a fairly risky choice.*/
+(async function initializeDB(){
+ let db = await connectDB();
+ let user = await db.collection(`users`).findOne({id:"U1"});
+ Eif (!user) {
+ for (let collectionName in defaultState) {
+ let collection = db.collection(collectionName);
+ await collection.insertMany(defaultState[collectionName]);
+ }
+ }
+})();
+ |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 +21 +22 +23 +24 +25 +26 +27 +28 +29 +30 +31 +32 +33 +34 +35 +36 +37 +38 +39 +40 +41 +42 +43 +44 +45 +46 +47 +48 +49 +50 +51 +52 +53 +54 +55 +56 +57 +58 +59 +60 +61 +62 +63 +64 +65 +66 +67 +68 | + + + + + + + + + + + + + +2x +2x + + + +2x + + + + + +2x + + +2x + + + + + + + + + +2x + + + + + + +2x + +2x +1x + + + + +2x +2x +2x +1x + + +2x + + + + + + + +2x | import { MongoClient } from 'mongodb';
+import path from 'path';
+
+import express from 'express';
+import cors from 'cors';
+import bodyParser from 'body-parser';
+
+import './initialize-db';
+import { authenticationRoute } from './authenticate'
+
+import { connectDB } from './connect-db'
+import { addNewTask, updateTask } from './communicate-db';
+
+
+let port = process.env.PORT || 7777;
+let app = express();
+
+
+
+app.use(
+ cors(),
+ bodyParser.urlencoded({extended:true}),
+ bodyParser.json()
+);
+
+authenticationRoute(app);
+
+// Only start the server if we're not in test mode
+Iif (process.env.NODE_ENV !== 'test') {
+ const server = app.listen(port, () => console.info("Server running, listening on port", port));
+ // Proper shutdown handling
+ process.on('SIGTERM', () => {
+ server.close(() => {
+ console.log('Server shutting down');
+ });
+ });
+}
+
+Iif (process.env.NODE_ENV == `production`) {
+ app.use(express.static(path.resolve(__dirname,'../../dist')));
+ app.get('/*',(req,res)=>{
+ res.sendFile(path.resolve('index.html'));
+ });
+}
+
+app.post('/task/new',async (req,res)=>{
+ // let task = req.body.task;
+ await addNewTask(req.body.task);
+ res.status(200).send();
+});
+
+
+
+app.post('/task/update',async (req,res)=>{
+ let db = await connectDB();
+ await updateTask(req.body.task);
+ res.status(200).send();
+});
+
+app.post('/comment/new',async (req,res)=>{
+ let comment = req.body.comment;
+ let db = await connectDB();
+ let collection = db.collection(`comments`);
+ await collection.insertOne(comment);
+ res.status(200).send();
+});
+
+module.exports = { app }; |
+ Press n or j to go to the next uncovered block, b, p or k for the previous block. +
+ +| 1 +2 +3 +4 +5 +6 +7 +8 +9 +10 +11 +12 +13 +14 +15 +16 +17 +18 +19 +20 | + + +5x + +5x +4x +4x + +6x + + +4x + + + + + + + | import { connectDB } from './connect-db'
+
+export async function assembleUserState(user){
+ let db = await connectDB();
+
+ let tasks = await db.collection(`tasks`).find({owner:user.id}).toArray();
+ let comments = await db.collection(`comments`).find({task:{$in:tasks.map(task=>task.id)}}).toArray();
+ let users = [
+ await db.collection(`users`).findOne({id:user.id}),
+ ...await db.collection(`users`).find({id:{$in:[...tasks,comments].map(x=>x.owner)}}).toArray()
+ ];
+
+ return {
+ session:{authenticated:`AUTHENTICATED`,id:user.id},
+ groups:await db.collection(`groups`).find({owner:user.id}).toArray(),
+ tasks,
+ users,
+ comments
+ };
+} |