Ready

.gitignore

@@ -1,2 +1,4 @@
 .DS_Store
-node_modules
+node_modules
+.env
+.env.test

app.js

@@ -1,17 +1,39 @@
-const express = require('express'); // import express module (simplifies routing/requests, among other things)
-const app = express(); // create an instance of the express module (app is the conventional variable name used)
-const fetch = require('node-fetch'); // import node-fetch (enables the fetch API to be used server-side)
-const PORT = process.env.PORT || 5000; // use either the host env var port (PORT) provided by Heroku or the local port (5000) on your machine
+//import libs
+const express = require('express');
+const app = express();
+const PORT = process.env.PORT || 5000;
+require('dotenv').config()
 
-app.get('/', (req, res) => { // send a get request to root directory ('/' is this file (app.js))
-  fetch('https://www.boredapi.com/api/activity') // fetch activity from bored API - https://www.boredapi.com/about
-    .then(res => res.json()) // return a promise containing the response
-    .then(json => res.send(`<h1>Today's Activity: ${json.activity}!</h1>`)) // extract the JSON body content from the response (specifically the activity value) and sends it to the client
-    .catch(function(err){ // catch any errors
-      console.log(err); // log errors to the console
-    })
+//logging middleware
+const morgan = require('morgan');
+app.use(morgan('tiny'));
+
+//error handling for dev environment
+if (process.env.NODE_ENV === 'development') {
+  const errorhandler = require('errorhandler');
+  app.use(errorhandler());
+}
+
+//import routers
+const roomRouter = require('./routers/roomRouter'); //legacy
+const scenarioRouter = require('./routers/scenarioRouter'); //legacy
+
+const userRouter = require('./routers/userRouter');
+const nodeRouter = require('./routers/nodeRouter');
+const campRouter = require('./routers/campRouter');
+const infoRouter = require('./routers/infoRouter');
+
+//mount routers
+app.use('/room', roomRouter); //legacy
+app.use('/scenario', scenarioRouter); //legacy
+app.use('/user', userRouter);
+app.use('/node', nodeRouter);
+app.use('/camp', campRouter);
+app.use('/info', infoRouter);
+
+//start server
+app.listen(PORT, () => {
+  console.log(`App is running on ${PORT}`)
 })
 
-app.listen(PORT, () => { // start server and listen on specified port
-  console.log(`App is running on ${PORT}`) // confirm server is running and log port to the console
-}) 
+//test

appInfo/balancing.js

@@ -0,0 +1,13 @@
+const numbers = {
+  maxPlayersForQueueTop: 3,
+  titleMinChars: 3,
+  titleMaxChars: 50,
+  descriptionMinChars: 3,
+  descriptionMaxChars: 200,
+  scenarioMinCharacter: 3,
+  scenarioMaxCharacters: 600,
+}
+
+module.exports = {
+  numbers
+}

database/dbChecks.js

@@ -0,0 +1,107 @@
+//CHECKS STUFF IN THE DATABASE AND THROWS ERRORS IF THEY ARE FALSE
+const db = require('./dbConnect.js');
+
+//ERROR CHECKS
+async function CanAddNode(campId, userId) {
+
+  const lastFinishedNodeQ = await db.query(
+    `
+    SELECT
+        camps.finished,
+        nodes_0.creator_id AS last_scenario_creator_id
+    FROM camps
+    JOIN nodes_0 on nodes_0.camp_id = camps.id
+    WHERE camps.id = $1
+    AND nodes_0.finished_at IS NOT NULL
+    ORDER BY nodes_0.id DESC
+    LIMIT 1;
+    `,
+    [campId]
+  );
+
+  if (lastFinishedNodeQ.rowCount == 0) throw new Error('there is no camp with that id');
+  const { finished, last_scenario_creator_id } = lastFinishedNodeQ.rows[0];
+  if (finished) throw new Error('Cant add node, story is already finished');
+  if (last_scenario_creator_id == userId) throw new Error('Cant add node, because user added the last scenario');
+
+  const lastNodeQ = await db.query(
+    `
+    SELECT
+        nodes_0.created_at AS last_node_posted_at,
+        nodes_0.finished_at AS last_node_finished_at
+    FROM nodes_0
+    WHERE nodes_0.camp_id = $1
+    ORDER BY nodes_0.id DESC
+    LIMIT 1;
+    `,
+    [campId]
+  );
+
+  const { last_node_posted_at, last_node_finished_at } = lastNodeQ.rows[0];
+
+  //check if someone else is writing
+  if (last_node_finished_at) return;
+  const last_node_time = (new Date(last_node_posted_at)).getTime();
+  const current_time = (new Date()).getTime();
+  const diff = current_time - last_node_time;
+  const diffInMinutes = diff / 1000 / 60;
+  if (diffInMinutes < 20) {
+    throw new Error('Cant add node. Another player is currently writing');
+  }
+
+}
+
+async function CanAddScenario(campId, userId, isEnd) {
+
+  const q = await db.query(
+    `
+    SELECT
+        nodes_0.creator_id AS node_creator_id,
+        finished_at AS node_finish_time,
+        scenario,
+        camps.finished AS camp_finished
+    FROM nodes_0
+    LEFT JOIN scenarios_0 ON scenarios_0.node_id = nodes_0.id
+    JOIN camps ON camps.id = nodes_0.camp_id
+    WHERE camp_id = $1
+    ORDER BY nodes_0.id;
+    `,
+    [campId]
+  );
+
+  const nodeCount = q.rowCount;
+  const lastNode = q.rows[q.rows.length - 1];
+  const lastPosterId = lastNode.node_creator_id;
+  const lastNodeEmpty = (lastNode.node_finish_time == null)
+  const scenario = lastNode.scenario;
+  const campFinished = lastNode.camp_finished;
+
+  if (!lastNodeEmpty) throw new Error('Cant add scenario, because the last node is marked as finished');
+  if (lastPosterId != userId) throw new Error('Cant add scenario, because someone else owns the node');
+  if (isEnd && nodeCount < 30) throw new Error('Cant add end, because the story is not long enough. Current nodecount: ', nodeCount);
+  if (!isEnd && nodeCount == 40) throw new Error('Cant add scenario. Must add end, because the story has reached its max length: ', nodeCount);
+  if (campFinished) throw new Error('cant add scenario, story marked as finished');
+  if (scenario) throw new Error('Cant add scenario, there already exist one linked to the last node');
+
+}
+async function GoogleTokenExists(googleToken) {
+
+  const tokenQ = await db.query(
+    `
+    SELECT COUNT(*)
+    FROM users
+    WHERE google_token = $1
+    `,
+    [googleToken]
+  );
+
+  if (tokenQ.rows[0].count == 0) return false;
+  else return true;
+
+}
+
+module.exports = {
+  CanAddNode,
+  CanAddScenario,
+  GoogleTokenExists
+};

database/dbConnect.js

@@ -0,0 +1,29 @@
+const Pool = require('pg').Pool
+
+const pool = (
+
+  process.env.DATABASE_URL ?
+
+    //heroku
+    new Pool({
+      connectionString: process.env.DATABASE_URL,
+      ssl: {
+        rejectUnauthorized: false
+      }
+    })
+
+    :
+
+    //local
+    new Pool({
+      user: 'postgres',
+      host: 'localhost',
+      database: 'unwritten',
+      password: 'postgres',
+      port: 5432,
+    })
+
+)
+
+
+module.exports = pool;