server.js

'use strict';

let nameArray = [];
let idArray = [];
const express = require('express');
const pg = require('pg');
const superagent = require('superagent');
require('dotenv').config();
require('ejs');
const methodOverride = require('method-override');
const { render } = require('ejs');

const app = express();
const PORT = process.env.PORT || 3001;
const client = new pg.Client(process.env.DATABASE_URL);
client.on('client error', error => {
  console.log('client error: ', error);
});

app.set('view engine', 'ejs');

// middleware

app.use(express.static('./public'));
app.use(express.urlencoded({ extended: true }));
app.use(methodOverride('_method'));

// paths

app.post('/pages', renderResults);
app.get('/', renderHome);
app.get('/index/:id', renderIndex);
app.post('/addplant', addToGreenhouse);
app.get('/greenhouse/:id', renderGreenhouse);
app.delete('/greenhouse/:id', deletePlant);
app.delete('/notes/:id', deleteNote);
app.get('/details/:id', renderDetails);
app.get('/aboutUs/:id', renderAboutUs);
app.put('/addNote/:id', addNotes);
app.put('/updateNotes/:id', updateNotes);
app.post('/addUser', addUser);
app.post('/signIn', signIn);
app.get('/error/:id', renderError);
app.post('/createplant/:id', createPlant);
app.post('/newplant', newPlant);

app.use('*', (request, response) => response.status(404).send('Page not Found'));

// ----- Functions -------

function renderHome(request, response)
{
  response.render('login');
}

//---------------------------
function renderIndex(request, response)
{
  response.status(200).render('index', {user: request.params.id, not_found: '', newplant: '', add_button: ''})
}

//-----------------------------
function renderResults(request, response)
{
  let found = false;
  let user_key = request.body.user_key; //grab user key
  let userSearch = request.body.search; // grab user search
  if(userSearch === '') // make sure user entered something
  {
    response.status(200).render('index', {user: user_key, not_found: '', newplant: '', add_button: ''});
  }else
  {
    let searchName = userSearch.toLowerCase().replace(/\s+/g, '').replace(/s$/, '');

    const url = 'http://harvesthelper.herokuapp.com/api/v1/plants'; //api url

    let queryParams = {
      api_key: process.env.PLANTS_API_KEY
    }

    const imageHash = 'https://res-5.cloudinary.com/do6bw42am/image/upload/c_scale,f_auto,h_300/v1/';

    let alreadyExists = false; // set flag to false
    let sql = 'SELECT * FROM greenhouse WHERE search_name=$1 AND user_key=$2;'; //search database for match
    let safeValue = [searchName, user_key]; //pass in searchName and user keys

    client.query(sql, safeValue).then (results =>
    {
      if(results.rowCount > 0) // check if plant was found in database
      {
        alreadyExists = true; // set flag to true
        response.render('pages/results.ejs', { target: results.rows[0], targetImg: '', alreadyExists: alreadyExists, user: user_key, search: searchName}); //render results page: pass in plant from db, change greenhouse button
      } else
      {
        alreadyExists = false;
        superagent.get(url).query(queryParams).then(results =>
        {
          if(nameArray.length < 1) //create nameArray & idArray first time thru
          {
            nameArray = results.body.map(plant => plant.name.toLowerCase().replace(/\s+/g, '').replace(/s$/, ''));
            idArray = results.body.map(plant => plant.id)
          }
          // search nameArray for match and grab index of match
          let index = nameArray.indexOf(searchName)

          if(index > -1) //check if match was found
          {
            results.body.forEach(plant => // go through each plant from api
            {
              if(plant.id === idArray[index]) // find plant id that matches id at the matching index
              {
                found = true
                response.status(200).render('pages/results.ejs', { target: plant, targetImg: imageHash, alreadyExists: alreadyExists, user : user_key, search: searchName});
              }
            })
          }
          if(found === false)
          {
            let buttonString = `add ${userSearch}`
            response.status(200).render('index', {user: user_key, not_found: `Unable to find ${userSearch}`, newplant: userSearch, add_button: buttonString});
          }
        }).catch((error) => {
          console.log('ERROR', error);
          response.redirect(`pages/error/${user_key}`);
        })
      }
    })
  }
}
//-----------------------
function addToGreenhouse(request, response)
{
  let {name, description, image_url, optimal_sun, optimal_soil, planting_considerations, when_to_plant, growing_from_seed, transplanting, spacing, watering, feeding, other_care, diseases, pests, harvesting, storage_use, search_name, user_key} = request.body;

  let sql = 'INSERT INTO greenhouse (name, description, image_url, optimal_sun, optimal_soil, planting_considerations, when_to_plant, growing_from_seed, transplanting, spacing, watering, feeding, other_care, diseases, pests, harvesting, storage_use, search_name, user_key) VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13, $14, $15, $16, $17, $18, $19) RETURNING id;';

  image_url = `https://res-5.cloudinary.com/do6bw42am/image/upload/c_scale,f_auto,h_300/v1/${image_url}`;

  let safeValues = [name, description, image_url, optimal_sun, optimal_soil, planting_considerations, when_to_plant, growing_from_seed, transplanting, spacing, watering, feeding, other_care, diseases, pests, harvesting, storage_use, search_name, user_key];

  client.query(sql, safeValues)
    .then(() =>
    {
      let imageHash = 'https://res-5.cloudinary.com/do6bw42am/image/upload/c_scale,f_auto,h_300/v1/';
      let alreadyExists = true;
      response.render('pages/results.ejs', { target: request.body, targetImg: imageHash, alreadyExists: alreadyExists, user: user_key})
    })
}

//------------------------------
function renderGreenhouse(request, response)
{

  let id = request.params.id;

  let sql2 = 'SELECT zipcode FROM user_table WHERE id=$1'
  let safeValue = [id]

  client.query(sql2, safeValue)
    .then(zippy => {
      if(zippy.rowCount > 0)
      {
        let zip = zippy.rows[0].zipcode;
        let url = 'http://api.weatherbit.io/v2.0/current';

        let queryParams =
        {
          key: process.env.WEATHER_API_KEY,
          postal_code: zip,
          days: 1,
          units: 'I'
        }
        superagent.get(url).query(queryParams).then(day =>
        {
          let fTemp = day.body.data[0].temp;
          let sql = `SELECT * FROM greenhouse WHERE user_key=${id} ;`;

          client.query(sql)
            .then(plants => {
              let plantArray = plants.rows;
              response.render('pages/greenhouse', {target: plantArray, user: id, temp: fTemp});

            }).catch((error) => {
              console.log('ERROR', error);
              response.redirect(`pages/error/${id}`);
            })
        })
      }else{
        let sql = `SELECT * FROM greenhouse WHERE user_key=${id} ;`;

        client.query(sql)
          .then(plants => {

            let plantArray = plants.rows;
            response.render('pages/greenhouse', {target: plantArray, user: id, temp: ''});

          }).catch((error) => {
            console.log('ERROR', error);
            response.redirect(`pages/error/${id}`);
          })
      }
    })
}

//------------------------------------
function deletePlant(request, response)
{
  let id = request.params.id;
  let sql = 'DELETE FROM greenhouse WHERE id=$1 RETURNING user_key;';
  let safeValue = [id];

  client.query(sql, safeValue)
    .then (theKey => {
      response.status(200).redirect(`/greenhouse/${theKey.rows[0].user_key}`);
    })
}

//--------------------------------------
function renderDetails(request, response)
{
  let id = request.params.id;
  let sql = 'SELECT * FROM greenhouse WHERE id=$1;';
  let safeValue = [id];
  let sql2 = 'SELECT * FROM notes WHERE plant_key=$1;';

  client.query(sql, safeValue)
    .then(plant => {
      client.query(sql2, safeValue)
        .then(ourNotes =>
        {
          response.status(200).render('pages/details',{detailsTarget: plant.rows[0], notesArray: ourNotes.rows, user: plant.rows[0].user_key});
        })
    }).catch((error) => {
      console.log('ERROR', error);
      response.redirect(`pages/error/${id}`);
    })
}

//-------------------------------------
function deleteNote(request, response)
{
  let id = request.params.id;
  let sql = 'DELETE FROM notes WHERE id=$1 RETURNING plant_key;';
  let safeValue = [id];

  client.query(sql, safeValue)
    .then (keys => {
      let keyID = keys.rows[0].plant_key;
      response.status(200).redirect(`/details/${keyID}`)
    })
}

//------------------------------------
function addNotes(request, response)
{
  let id = request.params.id;
  let notes = request.body.notes;
  let sql = 'INSERT INTO notes (user_notes, plant_key) VALUES ($1, $2);';
  let safeValues = [notes, id];

  client.query(sql, safeValues)
    .then(() =>
    {
      response.status(200).redirect(`/details/${id}`);
    })
}

//--------------------------------
function addUser(request, response)
{
  let {name, email, zipcode} = request.body;
  let sql = 'INSERT INTO user_table (name, email, zipcode) VALUES ($1, $2, $3) RETURNING id;';
  let safeValues = [name, email, zipcode];

  client.query(sql, safeValues)
    .then(obj =>
    {
      response.status(200).redirect(`index/${obj.rows[0].id}`)
    })
}

//-------------------------------
function signIn(request, response)
{
  let userEmail = request.body.email;
  let sql = 'SELECT id FROM user_table WHERE email=$1;';
  let safeValues = [userEmail];

  client.query(sql, safeValues)
    .then(mail => {
      if(mail.rowCount > 0)
      {
        response.status(200).redirect(`index/${mail.rows[0].id}`);
      }else{
        response.status(200).render('signup', {mail: userEmail});
      }
    })
}

//--------------------------------
function updateNotes(request, response)
{
  let id = request.params.id;
  let newNotes = request.body.notes;
  let sql = 'UPDATE notes SET user_notes=$1 WHERE id=$2 RETURNING plant_key;';
  let safeValues = [newNotes, id];

  client.query(sql, safeValues)
    .then(hope =>
    {
      let key = hope.rows[0].plant_key;
      response.status(200).redirect(`/details/${key}`);
    })
}

//--------------------------------
function createPlant(request, response)
{
  response.render('pages/createplant', { user: request.params.id, new_plant: request.body.new_plant});
}

//--------------------
function newPlant(request, response)
{
  let {name, description, image_url, optimal_sun, optimal_soil, planting_considerations, when_to_plant, growing_from_seed, transplanting, spacing, watering, feeding, other_care, diseases, pests, harvesting, storage_use, user_key} = request.body;
  // make function to put n/a in place of empty strings ??
  image_url === '' ? image_url = '/img/veggies.jpg' : '';
  description === '' ? description = 'n/a' : '';
  optimal_sun === '' ? optimal_sun = 'n/a' : '';
  optimal_soil === '' ? optimal_soil = 'n/a' : '';
  planting_considerations === '' ? planting_considerations = 'n/a' : '';
  when_to_plant === '' ? when_to_plant = 'n/a' : '';
  growing_from_seed === '' ? growing_from_seed = 'n/a' : '';
  transplanting === '' ? transplanting = 'n/a' : '';
  spacing === '' ? spacing = 'n/a' : '';
  watering === '' ? watering = 'n/a' : '';
  feeding === '' ? feeding = 'n/a' : '';
  other_care === '' ? other_care = 'n/a' : '';
  diseases === '' ? diseases = 'n/a' : '';
  pests === '' ? pests = 'n/a' : '';
  harvesting === '' ? harvesting = 'n/a' : '';
  storage_use === '' ? storage_use = 'n/a' : '';
  let search_name = name.toLowerCase().replace(/\s+/g, '').replace(/s$/, '');

  let sql = 'INSERT INTO greenhouse (name, description, image_url, optimal_sun, optimal_soil, planting_considerations, when_to_plant, growing_from_seed, transplanting, spacing, watering, feeding, other_care, diseases, pests, harvesting, storage_use, search_name, user_key) VALUES ($1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, $12, $13, $14, $15, $16, $17, $18, $19) RETURNING id;';

  let safeValues = [name, description, image_url, optimal_sun, optimal_soil, planting_considerations, when_to_plant, growing_from_seed, transplanting, spacing, watering, feeding, other_care, diseases, pests, harvesting, storage_use, search_name, user_key];

  client.query(sql, safeValues).then(newId =>
  {
    let id = newId.rows[0].id;
    let sql = 'SELECT * FROM greenhouse WHERE id=$1;';
    let safeValue = [id];
    let sql2 = 'SELECT * FROM notes WHERE plant_key=$1;';

    client.query(sql, safeValue).then(plant =>
    {
      client.query(sql2, safeValue).then(ourNotes =>
      {
        response.status(200).render('pages/details',{detailsTarget: plant.rows[0], notesArray: ourNotes.rows, user: plant.rows[0].user_key});
      })
    }).catch((error) => {
      console.log('ERROR', error);
      response.redirect(`pages/error/${id}`);
    })
  })
}

//--------------------------------
function renderAboutUs(request, response)
{
  response.render('pages/aboutUs', {user : request.params.id});
}

//--------------------------------
function renderError(request, response)
{
  response.render('pages/error', {user : request.params.id})
}

//--------------------------------
client.connect()
  .then(() => {
    app.listen(PORT, () => console.log(`listening on ${PORT}`));
  }).catch(err => console.log('error connecting', err));