Compare commits
No commits in common. "85ee64e92be281608c49042a1d210a2605521269" and "7809806b8308e9414725809ee671b7292d60c751" have entirely different histories.
85ee64e92b
...
7809806b83
@ -1,36 +0,0 @@
|
|||||||
const router = require('express').Router();
|
|
||||||
const checkPassword = require('pbkdf2-password')();
|
|
||||||
const jwt = require('jsonwebtoken');
|
|
||||||
const {EDATEAM_JWT_TOKEN} = require('./key');
|
|
||||||
|
|
||||||
const {getUser, _idToId, getResponse, requiredFields, signUp} = require('./controllers');
|
|
||||||
|
|
||||||
router.post('/sign-in', requiredFields(['email','password']), async (req, res)=>{
|
|
||||||
try{
|
|
||||||
const user = await getUser(req.body);
|
|
||||||
|
|
||||||
checkPassword({password:req.body.password, salt:user.salt},async(err, pass, salt, hash )=>{
|
|
||||||
if(err){
|
|
||||||
throw new Error(err);
|
|
||||||
}
|
|
||||||
|
|
||||||
if(user.password === hash){
|
|
||||||
const {password, salt:_salt, ...rest} = user;
|
|
||||||
const token = jwt.sign(_idToId(rest), EDATEAM_JWT_TOKEN);
|
|
||||||
return res.send(getResponse(null, token));
|
|
||||||
}
|
|
||||||
return res.status(400).send(getResponse('Wrong email or password!'));
|
|
||||||
} )
|
|
||||||
}
|
|
||||||
catch(error){
|
|
||||||
res.status(400).send(getResponse(error.message));
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
router.post('/sign-up', requiredFields(['email', 'login', 'password']), async (req, res) => {
|
|
||||||
let error = null
|
|
||||||
const data = await signUp(req.body).catch((e) => error = e.message)
|
|
||||||
return res.status(error ? 400 : 200).send(getResponse(error, data))
|
|
||||||
})
|
|
||||||
|
|
||||||
module.exports = router;
|
|
||||||
@ -1,217 +0,0 @@
|
|||||||
const ObjectId = require('mongodb').ObjectId;
|
|
||||||
const getHash = require('pbkdf2-password')();
|
|
||||||
const { getDB } = require('../../utils/mongo');
|
|
||||||
|
|
||||||
const USERS_COLLECTION = 'users';
|
|
||||||
const RECIPES_COLLECTION = 'recipes_collection';
|
|
||||||
const FAVORITES_USER = 'favorites_user'
|
|
||||||
let db =null;
|
|
||||||
|
|
||||||
const connect = async () => {
|
|
||||||
db = await getDB('edateam');
|
|
||||||
};
|
|
||||||
|
|
||||||
const init = async () => {
|
|
||||||
await connect();
|
|
||||||
};
|
|
||||||
|
|
||||||
init();
|
|
||||||
|
|
||||||
const _idToId = (data) => {
|
|
||||||
const { _id, ...rest } = data;
|
|
||||||
return {
|
|
||||||
id: _id,
|
|
||||||
...rest
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
const _idToArray = (data) => {
|
|
||||||
const _idToMap = data.map((item) => _idToId(item));
|
|
||||||
return _idToMap;
|
|
||||||
}
|
|
||||||
|
|
||||||
const getResponse = (error, data, success = true) => {
|
|
||||||
if (error) {
|
|
||||||
return {
|
|
||||||
success: false,
|
|
||||||
error,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return {
|
|
||||||
success,
|
|
||||||
data,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
const signUp = async ({ email, login, password }) => {
|
|
||||||
try {
|
|
||||||
db = await getDB('edateam');
|
|
||||||
const userCollection = db.collection(USERS_COLLECTION);
|
|
||||||
|
|
||||||
const userData = await userCollection.findOne({
|
|
||||||
$or: [
|
|
||||||
{ login },
|
|
||||||
{ email }
|
|
||||||
]
|
|
||||||
})
|
|
||||||
|
|
||||||
if (userData?.login === login) {
|
|
||||||
throw new Error('This login already in db!\nPlease come up with another login!');
|
|
||||||
}
|
|
||||||
|
|
||||||
if (userData?.email === email) {
|
|
||||||
throw new Error('This email already in db!\nPlease come up with another email!');
|
|
||||||
}
|
|
||||||
|
|
||||||
return new Promise((resolve, reject) => {
|
|
||||||
getHash({ password }, async (err, pass, salt, hash) => {
|
|
||||||
if (err) {
|
|
||||||
return reject(err);
|
|
||||||
}
|
|
||||||
const insertedCount = await userCollection.insertOne({ email, login, password: hash, salt });
|
|
||||||
|
|
||||||
if (!insertedCount) {
|
|
||||||
return reject(new Error('Insert error!'));
|
|
||||||
}
|
|
||||||
resolve({});
|
|
||||||
});
|
|
||||||
});
|
|
||||||
|
|
||||||
} catch (error) {
|
|
||||||
console.error(error);
|
|
||||||
throw error;
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
const getUser = async ({ email }) => {
|
|
||||||
if (db === null) {
|
|
||||||
throw new Error('no db connection :((');
|
|
||||||
}
|
|
||||||
|
|
||||||
try {
|
|
||||||
const userCollection = db.collection(USERS_COLLECTION);
|
|
||||||
const userData = await userCollection.findOne({ email });
|
|
||||||
if (userData) {
|
|
||||||
return userData;
|
|
||||||
}
|
|
||||||
throw new Error('Wrong email or password!');
|
|
||||||
} catch (error) {
|
|
||||||
throw new Error(error);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
const getListRecipes = async () => {
|
|
||||||
try {
|
|
||||||
db = await getDB('edateam');
|
|
||||||
const recipesCollection = db.collection(RECIPES_COLLECTION);
|
|
||||||
const recipesData = await recipesCollection.find().toArray();
|
|
||||||
|
|
||||||
if (recipesData.length > 0) {
|
|
||||||
return _idToArray(recipesData);
|
|
||||||
} else {
|
|
||||||
throw new Error('No recipes found in the database!');
|
|
||||||
}
|
|
||||||
} catch (error) {
|
|
||||||
console.error('Error in getListRecipes:', error.message);
|
|
||||||
throw new Error(error.message);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
const getRecipe = async (dishId ) => {
|
|
||||||
try {
|
|
||||||
db = await getDB('edateam');
|
|
||||||
const recipesCollection = db.collection(RECIPES_COLLECTION);
|
|
||||||
const id = dishId.id;
|
|
||||||
const recipeData = await recipesCollection.findOne({ _id :new ObjectId(id) } );
|
|
||||||
if (recipeData!=null) {
|
|
||||||
return _idToId(recipeData);
|
|
||||||
}
|
|
||||||
|
|
||||||
throw new Error('Not found recipe');
|
|
||||||
} catch (error) {
|
|
||||||
throw new Error(error);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
const addRecipe = async (recipe) => {
|
|
||||||
try {
|
|
||||||
db = await getDB('edateam');
|
|
||||||
const recipesCollection = db.collection(RECIPES_COLLECTION);
|
|
||||||
const result = await recipesCollection.insertOne(recipe);
|
|
||||||
|
|
||||||
if (!result.insertedId) {
|
|
||||||
throw new Error('Recipe insertion failed');
|
|
||||||
}
|
|
||||||
|
|
||||||
return {
|
|
||||||
success: true,
|
|
||||||
id: result.insertedId
|
|
||||||
};
|
|
||||||
} catch (error) {
|
|
||||||
console.error('Error in addRecipe:', error.message);
|
|
||||||
throw new Error(error.message);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
|
|
||||||
const requiredFields = (fields) => (req, res, next) => {
|
|
||||||
// eslint-disable-next-line no-restricted-syntax
|
|
||||||
for (const fieldName of fields) {
|
|
||||||
if (!req.body[fieldName]) {
|
|
||||||
throw new Error(`Параметр ${fieldName} не установлен`)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
next()
|
|
||||||
}
|
|
||||||
|
|
||||||
const addFavorite = async (userId, recipeId) => {
|
|
||||||
|
|
||||||
try {
|
|
||||||
db = await getDB('edateam');
|
|
||||||
const favoritesCollection = db.collection(FAVORITES_USER);
|
|
||||||
const result = await favoritesCollection.updateOne(
|
|
||||||
{ userId: new ObjectId(userId) },
|
|
||||||
{ $addToSet: { favorites: new ObjectId(recipeId) } },
|
|
||||||
{ upsert: true }
|
|
||||||
);
|
|
||||||
return result;
|
|
||||||
} catch (error) {
|
|
||||||
throw new Error('Error adding favorite: ' + error.message);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
const getFavorites = async (userId) => {
|
|
||||||
try {
|
|
||||||
db = await getDB('edateam');
|
|
||||||
const favoritesCollection = db.collection(FAVORITES_USER);
|
|
||||||
const userFavorites = await favoritesCollection.findOne({ userId: new ObjectId(userId) });
|
|
||||||
|
|
||||||
if (!userFavorites || !userFavorites.favorites || userFavorites.favorites.length === 0) {
|
|
||||||
return [];
|
|
||||||
}
|
|
||||||
|
|
||||||
const recipesCollection = db.collection(RECIPES_COLLECTION);
|
|
||||||
const favoriteRecipes = await recipesCollection.find({ _id: { $in: userFavorites.favorites } }).toArray();
|
|
||||||
|
|
||||||
return favoriteRecipes;
|
|
||||||
} catch (error) {
|
|
||||||
console.error(error);
|
|
||||||
throw new Error("Failed to get user favorites with recipes");
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
module.exports = {
|
|
||||||
getUser,
|
|
||||||
signUp,
|
|
||||||
getResponse,
|
|
||||||
_idToId,
|
|
||||||
_idToArray,
|
|
||||||
getListRecipes,
|
|
||||||
getRecipe,
|
|
||||||
addRecipe,
|
|
||||||
requiredFields,
|
|
||||||
getFavorites,
|
|
||||||
addFavorite
|
|
||||||
};
|
|
||||||
@ -1,25 +1,15 @@
|
|||||||
const router = require('express').Router();
|
const router = require('express').Router();
|
||||||
|
|
||||||
router.get('/recipe-data', (request, response) => {
|
router.get('/recipe-data', (request, response) => {
|
||||||
response.send(require('../json/recipe-data/success.json'));
|
response.send(require('./json/recipe-data/success.json'));
|
||||||
|
});
|
||||||
|
|
||||||
|
router.get('/userpage-data', (req, res)=>{
|
||||||
|
res.send(require('./json/userpage-data/success.json'));
|
||||||
});
|
});
|
||||||
|
|
||||||
router.get('/userpage-data', (req, res) => {
|
router.get('/homepage-data', (req, res)=>{
|
||||||
res.send(require('../json/userpage-data/success.json'));
|
res.send(require('./json/homepage-data/success.json'));
|
||||||
});
|
});
|
||||||
|
|
||||||
router.post('/userpage-data', (req, res) => {
|
|
||||||
res.send(require('../json/userpage-data/success.json'));
|
|
||||||
});
|
|
||||||
|
|
||||||
router.get('/homepage-data', (req, res) => {
|
|
||||||
res.send(require('../json/homepage-data/success.json'));
|
|
||||||
});
|
|
||||||
|
|
||||||
router.use('/auth', require('./auth'));
|
|
||||||
|
|
||||||
router.use('/recipe', require('./user'));
|
|
||||||
|
|
||||||
router.use('/main', require('./main'));
|
|
||||||
|
|
||||||
module.exports = router;
|
module.exports = router;
|
||||||
|
|||||||
@ -1,3 +0,0 @@
|
|||||||
const EDATEAM_JWT_TOKEN = 'secretyk token';
|
|
||||||
|
|
||||||
module.exports = {EDATEAM_JWT_TOKEN};
|
|
||||||
@ -1,51 +0,0 @@
|
|||||||
const { getListRecipes , getRecipe, addFavorite , getFavorites} = require('./controllers');
|
|
||||||
|
|
||||||
const router = require('express').Router();
|
|
||||||
|
|
||||||
router.get('/recipes', async (req, res) => {
|
|
||||||
try {
|
|
||||||
const result = await getListRecipes();
|
|
||||||
return res.status(200).json({ success: true, data: result });
|
|
||||||
} catch (error) {
|
|
||||||
console.error('Error in GET /recipes:', error.message);
|
|
||||||
return res.status(500).json({ success: false, message: error.message });
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
router.post('/recipe', async(req,res)=>{
|
|
||||||
try{
|
|
||||||
const result = await getRecipe(req.body);
|
|
||||||
|
|
||||||
return res.status(200).json({success:true, data: result});
|
|
||||||
}
|
|
||||||
catch(error){
|
|
||||||
console.error('Error in GET /recipes:', error.message);
|
|
||||||
return res.status(500).json({ success: false, message: error.message });
|
|
||||||
}
|
|
||||||
})
|
|
||||||
|
|
||||||
router.post('/favorites', async (req, res) => {
|
|
||||||
try {
|
|
||||||
|
|
||||||
const { userId, recipeId } = req.body;
|
|
||||||
const result = await addFavorite(userId, recipeId);
|
|
||||||
return res.status(200).json({ success: true, data: result });
|
|
||||||
} catch (error) {
|
|
||||||
console.error('Error in POST /favorites:', error.message);
|
|
||||||
return res.status(500).json({ success: false, message: error.message });
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
router.post('/get-favorites', async(req,res) =>{
|
|
||||||
try {
|
|
||||||
const { userId } = req.body;
|
|
||||||
const result = await getFavorites(userId);
|
|
||||||
console.log(result)
|
|
||||||
return res.status(200).json({ success: true, data: result });
|
|
||||||
} catch (error) {
|
|
||||||
console.error('Error in POST /get-favorites:', error.message);
|
|
||||||
return res.status(500).json({ success: false, message: error.message });
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
module.exports = router;
|
|
||||||
@ -1,35 +0,0 @@
|
|||||||
const { requiredFields , getFavorites, addRecipe} = require('./controllers');
|
|
||||||
|
|
||||||
const router = require('express').Router();
|
|
||||||
|
|
||||||
router.post('/favorites', requiredFields('id'), async(req,res)=>{
|
|
||||||
try{
|
|
||||||
const recipes = await getFavorites(req.body);
|
|
||||||
res.status(200).send(getResponse(recipes));
|
|
||||||
}
|
|
||||||
catch(error){
|
|
||||||
res.status(400).send(getResponse(error.message));
|
|
||||||
}
|
|
||||||
})
|
|
||||||
|
|
||||||
router.post('/add-recept', async (req, res) => {
|
|
||||||
let error = null;
|
|
||||||
let result = null;
|
|
||||||
|
|
||||||
try {
|
|
||||||
result = await addRecipe(req.body);
|
|
||||||
} catch (e) {
|
|
||||||
error = e.message;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (error) {
|
|
||||||
console.error(`Error in POST /add-recept: ${error}`);
|
|
||||||
}
|
|
||||||
|
|
||||||
return res.status(error ? 500 : 201).json({
|
|
||||||
message: error ? error : 'Recipe added successfully',
|
|
||||||
id: result?.id
|
|
||||||
});
|
|
||||||
});
|
|
||||||
|
|
||||||
module.exports = router;
|
|
||||||
Loading…
Reference in New Issue
Block a user