app.js

import express from 'express'
import mongoose from 'mongoose'
import newsRoutes from './routes/newsRoutes'
import authRoutes from './routes/authRoutes'
import adminRoutes from './routes/adminRoutes'
import {seedSportsData} from './seed/seedData';
import jwt from 'jsonwebtoken'
import config from './config'
import user from './db/model/user.model' 

//Allen's imports
import http from 'http'
import path from 'path';
import socketIO from 'socket.io'
import { LocalStorage } from 'node-localstorage'
import iplocate from 'node-iplocate'
import publicIP from 'public-ip'
import newsRouter from './routes/newsRoutes'
const bodyparser = require('body-parser');
let localstorage = new LocalStorage('./Scratch')

const contactRoute = require('./contactUs');



//constants declared
const app = express();
const port = 8008;
//mongoose connection 
mongoose.connect('mongodb://127.0.0.1:27017/edureka',{useUnifiedTopology:true,useNewUrlParser:true})
const connection=mongoose.connection;
connection.once('open',()=>{
    console.log("MongoDB connected!!!!");
    seedSportsData();
})

const request = require('request');



//mongoose connection 

app.use(bodyparser.urlencoded({
    extended: true
}));



//app configurations

import article from './db/model/Article.model'

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

app.use(express.static(__dirname+'/public'));
app.get('/', (request, response) => {
    article.find({},(err,articles)=>{
        let nonSportsArticles = articles.filter((a)=>(
            a.topic !== "Sport"
        ));
        console.log(nonSportsArticles.length);
        getWeather().then(JSON.parse).then((weather)=>{
            article.find({"topic":"Sport"}).sort({createdAt:-1}).exec((err,sportsNews)=>{
                getStockPrice().then((resolve)=>{
                    response.render('index', {
                        articles: nonSportsArticles,
                        news:sportsNews,
                        weather: weather,
                        location: userLocation,
                        stock: resolve
                    })  
                })             
            })
        })
    }).sort({createdAt : -1}).limit(3)
})

import searchRoutes from './routes/searchRoutes';
app.use('/search', searchRoutes);

import sportsRoutes from './routes/sportsRoutes';
app.use('/sports', sportsRoutes);
// app.get('/sports', (request, response) => {
//     response.render('sports.ejs')
// })
import commentRoutes from './routes/commentRoutes';
app.use('/comments', commentRoutes);

app.get('/aboutus', (request, response) => {
    response.render('aboutus')
})
app.get('/login', (request, response) => {
    let localStorage = new LocalStorage('./Scratch')
    let token = localStorage.getItem('authToken')
    //console.log("token>>>",token)
    if (!token) {         
        response.render('login', {error: request.query.valid?request.query.valid:'',
        msg: request.query.msg?request.query.msg:''})
    } else {
        response.redirect('/admin/profile');
    }

})
app.get('/register', (request, response) => {
    response.render('register', { message: null, error: null })
})

app.use('/auth', authRoutes);
app.use('/admin', adminRoutes);
app.use('/news', newsRoutes);
app.use('/contactus', contactRoute);

// Weather API

var weatherUrl;
var userLocation;


app.get('/chatbox', (request, response) => {
    response.render('chatbox.ejs')
})
//Allen code
//index.html file
//server for chat
let server = http.createServer(app).listen(port,()=>{
    publicIP.v4()
    .then(ip=>{
        iplocate(ip)
        .then((results)=>{
            console.log("chat is up on: ", port);
            userLocation = results.city;
            weatherUrl =`http://api.openweathermap.org/data/2.5/forecast/daily?q=${userLocation}&mode=json&units=metric&cnt=5&appid=fbf712a5a83d7305c3cda4ca8fe7ef29`;
            console.log(userLocation);
            console.log(weatherUrl);
        })
    })
})
    

app.get('/weather', (req, res) => {
    var dataPromise = getWeather();
    dataPromise.then(JSON.parse)
    .then(function(result) {
        res.render('weather', { result, title: '***Weather App***' })
    })
})

function getWeather(url) {
    // Setting URL and headers for request
    var options = {
        url: weatherUrl,
        headers: {
            'User-Agent': 'request'
        }
    };
    // Return new promise 
    return new Promise(function(resolve, reject) {
        // Do async job
        request.get(options, function(err, resp, body) {
            if (err) {
                reject(err);
            } else {
                resolve(body);
            }
        })
    })
}

import fetch from 'node-fetch';

var getStockPrice = () =>  (new Promise((resolve)=>{
    let stockQuote = new Map();
    fetch('https://finnhub.io/api/v1/quote?symbol=QQQ&token=c1ik6nn48v6vit212vng')
    .then(response => response.json()).then(body => {
        console.log(body);
        stockQuote.set("QQQ",body);
        return fetch('https://finnhub.io/api/v1/quote?symbol=TSLA&token=c1ik6nn48v6vit212vng');
    })
    .then(response => response.json()).then(body => {
        console.log(body);
        stockQuote.set("TSLA",body);
        return fetch('https://finnhub.io/api/v1/quote?symbol=DIS&token=c1ik6nn48v6vit212vng');
    })
    .then(response => response.json()).then(body => {
        console.log(body);
        stockQuote.set("DIS",body);
        return fetch('https://finnhub.io/api/v1/quote?symbol=IVV&token=c1ik6nn48v6vit212vng');
    })
    .then(response => response.json()).then(body => {
        console.log(body);
        stockQuote.set("IVV",body);
        console.log(stockQuote);
        resolve(stockQuote);
    })
}))


app.get('/weatherwithoutpromise', (req, res) => {
    request(url, (err, response, body) => {
        if (err) {
            console.log(err);
        } else {

            const output = JSON.parse(body);
            res.send(output);
        }
    });
});

let io = socketIO(server)
io.sockets.on('connection', (socket) => {
    //console.log("connected")
    socket.on('nick', (nick) => {
        console.log(nick)
        socket.nickname = nick

        //fetching the location on name set
        publicIP.v4()
                .then(ip=>{
                    iplocate(ip)
                    .then((results)=>{
                        let city = JSON.stringify(results.city,null,2)
                        localstorage.setItem('userLocal',city)
                    })
                })
        })

        socket.on('chat',(data)=>{
            
            
            //console.log(data)
    
            let nickname = socket.nickname?socket.nickname:'';
                var time = new Date().toLocaleTimeString();
                if(nickname){
                    let list = socket.client.conn.server.clients
                    let users = Object.keys(list)
                    socket.emit('userList',users)

            let payload={
                message:data.message,
                nick:nickname,
                location:localstorage.getItem('userLocal'),
                time:time
            }
            if (data.message) {
                socket.emit('chat', payload)
                socket.broadcast.emit('chat', payload)
            }
        }
    })
})




//start express app
// app.listen(port,()=>{
//     console.log("app started !!", port)
// })