server.js

// eslint-disable no-console
const express = require("express");
const bodyParser = require("body-parser");
const fs = require("fs");
const MongoClient = require('mongodb').MongoClient;
const app = express();
const url = "mongodb://localhost:27017/digitalCapsule";
const cog = require("./cog.js");
let database;

app.set("port", process.env.PORT || 3001);

// Parse application/x-www-form-urlencoded
app.use(bodyParser.urlencoded({ limit: '16mb', extended: true }))

// Parse application/json
app.use(bodyParser.json( {limit: '16mb'} ))

app.use((req, res, next) => {
  res.setHeader('Access-Control-Allow-Origin', 'http://localhost:3000');
  res.setHeader('Access-Control-Allow-Methods', 'GET, POST, PUT, DELETE');
  res.setHeader('Access-Control-Allow-Headers', 'Access-Control-*, X-Requested-With, Content-Type');
  res.setHeader('Access-Control-Allow-Credentials', true);
  next();
});

app.use((err, req, res, next) => {
  res.sendStatus(500).json(err);
});

// Express only serves static assets in production
if (process.env.NODE_ENV === "production") {
  app.use(express.static("app/build"));
}

MongoClient.connect(url, { useNewUrlParser: true }, (err, db) => {
  database = db.db("digitalCapsule");
  if (err) throw err;
  console.log("Database created!");
  const music = JSON.parse(fs.readFileSync("schemas/music.json"));
  const photos = JSON.parse(fs.readFileSync("schemas/photos.json"));
  const text = JSON.parse(fs.readFileSync("schemas/text.json"));
  const timeCapsules = JSON.parse(fs.readFileSync("schemas/timeCapsules.json"));
  const users = JSON.parse(fs.readFileSync("schemas/users.json"));
  database.createCollection("music", {
    validator: {
      $jsonSchema: music
    }
  }, (err) => {
    if (err) throw new Error("Error creating music collection: " + err.message);
    console.log("Music collection created!");
  });
  database.createCollection("photos", {
    validator: {
      $jsonSchema: photos
    }
  }, (err) => {
    if (err) throw new Error("Error creating photos collection: " + err.message);
    console.log("Photos collection created!");
  });
  database.createCollection("text", {
    validator: {
      $jsonSchema: text
    }
  }, (err) => {
    if (err) throw new Error("Error creating text collection: " + err.message);
    console.log("Text collection created!");
  });
  database.createCollection("timeCapsules", {
    validator: {
      $jsonSchema: timeCapsules
    }
  }, (err) => {
    if (err) throw new Error("Error creating timeCapsules collection: " + err.message);
    console.log("TimeCapsules collection created!");
  });
  database.createCollection("users", {
    validator: {
      $jsonSchema: users
    }
  }, (err) => {
    if (err) throw new Error("Error creating users collection: " + err.message);
    console.log("Users collection created!");
  });
});

app.post('/addMusic', (req, res, next) => {
  const musicDoc = req.body;
  cog.addMusic(database, musicDoc, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.post('/deleteMusic', (req, res, next) => {
  const musicId = req.body.musicId;
  const capsuleId = req.body.capsuleId;
  cog.deleteMusic(database, musicId, capsuleId, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.post('/updateMusic', (req, res, next) => {
  const musicDoc = req.body;
  cog.updateMusic(database, musicDoc, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.post('/addPhoto', (req, res, next) => {
  const photos = req.body;
  cog.addPhoto(database, photos, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.post('/deletePhoto', (req, res, next) => {
  const photoId = req.body.photoId;
  const capsuleId = req.body.capsuleId;
  cog.deletePhoto(database, photoId, capsuleId, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.post('/updatePhoto', (req, res, next) => {
  const photoDoc = req.body;
  cog.updatePhoto(database, photoDoc, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.post('/addText', (req, res, next) => {
  const textDoc = req.body;
  cog.addText(database, textDoc, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.post('/deleteText', (req, res, next) => {
  const textId = req.body.textId;
  const capsuleId = req.body.capsuleId;
  cog.deleteText(database, textId, capsuleId, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.post('/updateText', (req, res, next) => {
  const textDoc = req.body;
  cog.updateText(database, textDoc, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.post('/addCapsule', (req, res, next) => {
  const capsuleDoc = req.body;
  cog.addTimeCapsule(database, capsuleDoc, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.delete('/deleteCapsule', (req, res, next) => {
  const capsuleId = req.query.capsule;
  cog.deleteTimeCapsule(database, capsuleId, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.post('/registerUser', (req, res, next) => {
  const user = req.body;
  cog.addUser(database, user, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.get('/validateUser', (req, res, next) => {
  const username = req.query;
  cog.validateUser(database, username, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.get('/getCapsules', (req, res, next) => {
  const username = req.query;
  cog.getCapsules(database, username, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.post('/getCapsulesById', (req, res, next) => {
  const capsuleIds = req.body.capsuleIds;
  cog.getCapsulesById(database, capsuleIds, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.get('/getFriends', (req, res, next) => {
  const username = req.query;
  cog.getFriends(database, username, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.get('/getSentRequests', (req, res, next) => {
  const username = req.query;
  cog.getSentRequests(database, username, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.get('/getReceivedRequests', (req, res, next) => {
  const username = req.query;
  cog.getReceivedRequests(database, username, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.post('/sendFriendRequest', (req, res, next) => {
  const myUsername = req.body.myUsername;
  const friendUsername = req.body.friendUsername;
  cog.sendFriendRequest(database, myUsername, friendUsername, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.post('/deleteFriend', (req, res, next) => {
  const myUsername = req.body.myUsername;
  const friendUsername = req.body.friendUsername;
  cog.deleteFriend(database, myUsername, friendUsername, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.post('/acceptFriend', (req, res, next) => {
  const myUsername = req.body.myUsername;
  const friendUsername = req.body.friendUsername;
  cog.acceptFriend(database, myUsername, friendUsername, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.get('/getMedia', (req, res, next) => {
  const capsuleId = req.query;
  cog.getMedia(database, capsuleId, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.get('/searchUsers', (req, res, next) => {
  const params = req.query;
  cog.searchUsers(database, params.query, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.get('/searchCapsules', (req, res, next) => {
  const params = req.query;
  cog.searchCapsules(database, params.query, params.user, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.post('/requestAccess', (req, res, next) => {
  const capsuleId = req.body.capsuleId;
  const username = req.body.username;
  cog.requestAccess(database, capsuleId, username, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.get('/getRequestAccess', (req, res, next) => {
  const capsuleId = req.query.capsuleId;
  cog.getRequestAccess(database, capsuleId, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.post('/addContributor', (req, res, next) => {
  const capsuleId = req.body.capsuleId;
  const username = req.body.username;
  cog.addContributor(database, capsuleId, username, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.post('/deleteFriendRequest', (req, res, next) => {
  const body = req.body;
  cog.deleteFriendRequest(database, body.myUsername, body.friendUsername, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
})

app.post('/deleteCapsuleRequest', (req, res, next) => {
  const body = req.body;
  cog.deleteCapsuleRequest(database, body.capsuleId, body.username, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
})

app.post('/removeContributor', (req, res, next) => {
  const capsuleId = req.body.capsuleId;
  const username = req.body.username;
  cog.removeContributor(database, capsuleId, username, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.get('/capsuleOwner', (req, res, next) => {
  const params = req.query;
  cog.checkCapsuleOwner(database, params.capsule, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.get('/capsuleContributors', (req, res, next) => {
  const params = req.query;
  cog.getCapsuleContributors(database, params.capsule, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.get('/getUserByUsername', (req, res, next) => {
  const params = req.query;
  cog.getUserByUsername(database, params.username, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.post('/saveProfile', (req, res, next) => {
  const username = req.body.username;
  const profile = req.body.profile;
  cog.saveProfile(database, username, profile, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.get('/getUserSettings', (req, res, next) => {
  const params = req.query;
  cog.getUserSettings(database, params.username, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.post('/saveUserSettings', (req, res, next) => {
  const username = req.body.username;
  const settings = req.body.settings;
  cog.saveUserSettings(database, username, settings, (data, err) => {
    if (err) {
      return next(err);
    } else {
      return res.status(200).send(data);
    }
  });
});

app.listen(app.get("port"), () => {
  console.log(`Find the server at: http://localhost:${app.get("port")}/`);
});

module.exports = app;