app.js

const express           = require('express');
const app               = express();
const bodyParser        = require('body-parser');
const fetch             = require("node-fetch");
const mongoose          = require('mongoose');

const redis = require("redis");
const client = redis.createClient();

const REDIS_BASIC        = require('./model/redis_basic');
const PHOTO_STORE        = require('./model/photo-store');
const PHOTO_STORE_COLL   = require('./database/photo_store-coll');

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

app.use(express.static('./public'));

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

const listProduct = [
    { 
        _id: 111,
        name: "Áo sơ mi trắng",
        price: "16$",
        image1: "http://bestjquery.com/tutorial/product-grid/demo9/images/img-1.jpg",
        image2: "http://bestjquery.com/tutorial/product-grid/demo9/images/img-2.jpg"
    },
    { 
        _id: 222,
        name: "Áo thun xanh lá",
        price: "5$",
        image1: "http://bestjquery.com/tutorial/product-grid/demo9/images/img-3.jpg",
        image2: "http://bestjquery.com/tutorial/product-grid/demo9/images/img-4.jpg"
    },
    { 
        _id: 333,
        name: "Áo sáng tạo",
        price: "5$",
        image1: "http://bestjquery.com/tutorial/product-grid/demo9/images/img-5.jpg",
        image2: "http://bestjquery.com/tutorial/product-grid/demo9/images/img-6.jpg"
    },
    { 
        _id: 444,
        name: "Áo sọc sọc",
        price: "6$",
        image1: "http://bestjquery.com/tutorial/product-grid/demo9/images/img-7.jpg",
        image2: "http://bestjquery.com/tutorial/product-grid/demo9/images/img-8.jpg"
    },
]

//========> MENU-CART
app.get('/', async (req, res) => {
    res.render("home")
});

app.get('/menu-cart', async (req, res) => {

    let nameCart = "myCart";
    let myCart = await REDIS_BASIC.myCart({ nameCart });
    res.render('menu', {listProduct, myCart });
});

app.get('/add-to-cart/:productID', async (req, res) => {

    let { productID } = req.params;
    let nameCart = "myCart";
    
    let addtoCart = await REDIS_BASIC.addToCart({ nameCart, productID });
    res.json(addtoCart)
})

app.get('/remove-in-cart/:productID', async (req, res) => {

    let { productID } = req.params;
    let nameCart = "myCart";
    
    let removeInCart = await REDIS_BASIC.removeInCart({ nameCart, productID });
    res.json(removeInCart)
})

app.get('/remove-all-cart/:nameCart', async (req, res) => {

    let { nameCart } = req.params;
    
    let removeAllCart = await REDIS_BASIC.removeAllCart({ nameCart });
    res.json(removeAllCart)
})

//===============> END

app.get('/photos', (req, res) => {
 
    // key to store results in Redis store
    const photosRedisKey = 'user:photos';
 
    // Try fetching the result from Redis first in case we have it cached
    return client.get(photosRedisKey, (err, photos) => {
 
        // If that key exists in Redis store
        if (photos) {
 
            return res.json({ source: 'cache', data: JSON.parse(photos) })
 
        } else { // Key does not exist in Redis store
 
            // Fetch directly from remote api
            fetch('https://jsonplaceholder.typicode.com/photos')
                .then(response => response.json())
                .then(photos => {
 
                    // Save the  API response in Redis store,  data expire time in 3600 seconds, it means one hour
                    client.setex(photosRedisKey, 3600, JSON.stringify(photos))
 
                    // Send JSON response to client
                    return res.json({ source: 'api', data: photos })
 
                })
                .catch(error => {
                    console.log(error)
                    // send error to the client 
                    return res.json(error.toString())
                })
        }
    });
});

app.get('/hashes', (req, res) => {
    res.render('hashes');
})

//============> THÊM, XÓA HASHES REDIS
app.post('/add-hashes', async (req, res) => {
    try {

        let { id, key, value } = req.body;

        let infoHashes = await REDIS_BASIC.insert({ id, key, value })
        res.json(infoHashes.data)
    } catch (error) {
        console.log(error);
    }
    
})

app.get('/info-hashes/:id', async (req, res) => {
    let { id } = req.params;
    let infoHashes = await REDIS_BASIC.infoHash({id});
    res.json(infoHashes.data)
}) 
//===========> END

//==========> LẤY VỊ TRÍ VÀ CỬA HÀNG XUNG QUANH
app.post('/add-photo', async (req, res) => {
    try {

        let { name, place, available } = req.body;

        let infoStorePhoto = await PHOTO_STORE.insert({ name, place, available })
        res.json(infoStorePhoto)
    } catch (error) {
        console.log(error);
    }
    
})

app.post('/stores', async (req, res) => {
    try {   
         // let lng = "106.797263"
        // let lat = "10.849314"
        //let placeHome = "lng, lat";
        let { lng, lat, maxDis } = req.body;

        let listPhotoStore = await PHOTO_STORE.getList({ lng, lat, maxDis });
        res.json(listPhotoStore);

    } catch (error) {
        console.log(error);
    }
});

app.get('/store-near', async (req, res) => {
    try {   
        
        let { lng, lat } = req.query;

        let listPhotoStoreNear = await PHOTO_STORE.getListStoreNear({ lng, lat });
        res.json(listPhotoStoreNear);

    } catch (error) {
        console.log(error);
    }
});

app.get('/find-store', async (req, res) => {

    res.render("find-store");
});

//==============> END

const uri = 'mongodb://localhost/demo-geo';

const PORT = process.env.PORT || 3000;

mongoose.set('useCreateIndex', true); //ẩn cảnh báo
mongoose.set('useUnifiedTopology', true); // ẩn cảnh báo

mongoose.connect(uri, { useNewUrlParser: true });
mongoose.connection.once('open', () => {
    app.listen(PORT, () => console.log(`Server started at PORT ${PORT}`));
});