version 1

Author: ianyenien

api/app.js

@@ -0,0 +1,41 @@
+'use strict'
+
+var express = require('express');
+var bodyParser = require('body-parser');
+
+var app = express();
+
+//cargar rutas
+
+var userRoutes = require('./routes/user')
+var followRoutes = require('./routes/follow')
+var publicationRoutes = require('./routes/publication')
+var messageRoutes = require('./routes/message')
+
+//cargar middlewares
+app.use(bodyParser.urlencoded({extended: false}));
+app.use(bodyParser.json());
+
+
+//cors
+
+app.use((req, res, next) => {
+    res.header('Access-Control-Allow-Origin', '*');
+    res.header('Access-Control-Allow-Headers', 'Authorization, X-API-KEY, Origin, X-Requested-With, Content-Type, Accept, Access-Control-Allow-Request-Method');
+    res.header('Access-Control-Allow-Methods', 'GET, POST, OPTIONS, PUT, DELETE');
+    res.header('Allow', 'GET, POST, OPTIONS, PUT, DELETE');
+ 
+    next();
+});
+
+
+//rutas
+
+app.use('/api', userRoutes)
+app.use('/api', followRoutes)
+app.use('/api', publicationRoutes)
+app.use('/api', messageRoutes)
+
+//exportar
+
+module.exports = app;

api/controllers/follow.js

@@ -0,0 +1,122 @@
+'use strict'
+
+var path = require('path');
+var fs = require('fs');
+var mongoosePaginate = require('mongoose-pagination');
+
+var User = require('../models/user');
+var Follow = require('../models/follows');
+
+function saveFollow(req, res){
+    var params = req.body;
+    var follow = new Follow();
+    follow.user = req.user.sub;
+    follow.followed = params.followed;
+
+    follow.save((err, followStored)=>{
+        if(err) return res.status(500).send({message:'error en guardar el follow'})
+
+        if(!followStored) return res.status(404).send({message: 'el seguimiento no se ha guardado'})
+
+        return res.status(200).send({follow: followStored})
+    })
+}
+
+function deleteFollow(req, res){
+    var userId = req.user.sub;
+    var followId = req.params.id;
+
+    Follow.find({'user':userId, 'followed': followId}).remove(err => {
+        if(err) return res.status(500).send({message:'dejar de seguir'})
+    })
+
+    return res.status(200).send({message: 'el follow se ha eliminado'})
+}
+
+function getFollowingUsers(req, res){
+    var userId = req.user.sub;
+
+    if(req.params.id && req.params.page){
+        userId = req.params.id;
+    }
+
+    var page = 1;
+    
+    if(req.params.page){
+        page = req.params.page;
+    }else{
+        page = req.params.id;
+    }
+
+    var itemsPrePage = 4;
+
+    Follow.find({user: userId}).populate({path:'followed'}).paginate(page, itemsPrePage, (err, follows, total)=>{
+        if(err) return res.status(500).send({message:'error en el servidor'})
+
+        if(!follows) return res.status(404).send({message: 'no estas siguiendo a ningun usuario'})
+
+        return res.status(200).send({
+            total: total,
+            pages: Math.ceil(total/itemsPrePage),
+            follows
+        })
+    })
+}
+
+function getFollowedUser(req, res){
+    var userId = req.user.sub;
+
+    if(req.params.id && req.params.page){
+        userId = req.params.id;
+    }
+
+    var page = 1;
+    
+    if(req.params.page){
+        page = req.params.page;
+    }else{
+        page = req.params.id;
+    }
+
+    var itemsPrePage = 4;
+
+    Follow.find({followed: userId}).populate('user').paginate(page, itemsPrePage, (err, follows, total)=>{
+        if(err) return res.status(500).send({message:'error en el servidor'})
+
+        if(!follows) return res.status(404).send({message: 'no te sigue ningun usuario'})
+
+        return res.status(200).send({
+            total: total,
+            pages: Math.ceil(total/itemsPrePage),
+            follows
+        })
+    })
+}
+
+//devolver listado de usuarios
+function getMyFollows(req, res){
+    var userId = req.user.sub;
+
+    var find = Follow.find({user: userId});
+    
+    if(req.params.followed){
+        find = Follow.find({follow: userId});
+    }
+
+    find.populate('user followed').exec((err, follows)=>{
+        if(err) return res.status(500).send({message:'error en el servidor'})
+
+        if(!follows) return res.status(404).send({message: 'no estas siguiendo a ningun usuario'})
+
+        return res.status(200).send({follows})
+    })
+}
+
+
+module.exports = {
+    saveFollow,
+    deleteFollow,
+    getFollowingUsers,
+    getFollowedUser,
+    getMyFollows
+}

api/controllers/message.js

@@ -0,0 +1,119 @@
+'use strict'
+
+var moment = require('moment');
+var mongoosePagination = require('mongoose-pagination');
+
+var User = require('../models/user');
+var Follow = require('../models/follows');
+var Message = require('../models/message');
+
+function saveMessage(req, res){
+    var params = req.body;
+
+    if(!params.text || !params.receiver){
+        return res.status(200).send({message: 'envia bien los datos'})
+    }
+
+    var message = new Message();
+    message.emitter = req.user.sub;
+    message.receiver = params.receiver;
+    message.text = params.text;
+    message.createdAt = moment().unix();
+    message.viewed = 'false';
+
+    message.save((err, messageStored) => {
+        if(err){
+            return res.status(500).send({message: 'error en la peticion'})
+        }
+        if(!messageStored){
+            return res.status(500).send({message: 'error al enviar el mensaje'})
+        }
+        return res.status(200).send({message: messageStored})
+    })
+}
+
+function getReceivedMessages(req, res){
+    var userId = req.user.sub;
+    
+    var page = 1;
+    if(req.params.page){
+        page = req.params.page
+    }
+
+    var itemsPrePage = 4;
+
+    Message.find({receiver: userId}).populate('emitter', 'name surname _id nick image').paginate(page, itemsPrePage, (err, message, total) => {
+        if(err){
+            return res.status(500).send({message: 'error en la peticion'})
+        }
+        if(!message){
+            return res.status(404).send({message: 'no hay mensajes que mostrar'})
+        }
+        return res.status(200).send({
+            total:total,
+            pages: Math.ceil(total/itemsPrePage),
+            messages
+        })
+
+    })
+}
+
+function getEmittMessages(req, res){
+    var userId = req.user.sub;
+    
+    var page = 1;
+    if(req.params.page){
+        page = req.params.page
+    }
+
+    var itemsPrePage = 4;
+
+    Message.find({emitter: userId}).populate('emitter receiver', 'name surname _id nick image').paginate(page, itemsPrePage, (err, message, total) => {
+        if(err){
+            return res.status(500).send({message: 'error en la peticion'})
+        }
+        if(!message){
+            return res.status(404).send({message: 'no hay mensajes que mostrar'})
+        }
+        return res.status(200).send({
+            total:total,
+            pages: Math.ceil(total/itemsPrePage),
+            messages
+        })
+
+    })
+}
+
+function getUnviewedMessages(req, res){
+    var userId = req.user.sub;
+
+    Message.count({receiver: userId, viewed:'false'}).exec((err, count) => {
+        if(err){
+            return res.status(500).send({message: 'error en la peticion'})
+        }
+        return res.status(200).send({
+            unviewed: count
+        })
+    })
+}
+
+function setViewedMessages(req, res){
+    var userId = req.user.sub;
+
+    Message.update({receiver: userId, viewed: 'false'},{viewed:'true'}, {'multi': true}, (err, messageUpdate) => {
+        if(err){
+            return res.status(500).send({message: 'error en la peticion'})
+        }
+        return res.status(200).send({
+            message: messageUpdate
+        })
+    })
+}
+
+module.exports = {
+    saveMessage,
+    getReceivedMessages,
+    getEmittMessages,
+    getUnviewedMessages,
+    setViewedMessages
+}