95 lines
2.5 KiB
JavaScript
95 lines
2.5 KiB
JavaScript
import express from "express";
|
|
import { createRestaurant } from "../services/dataPrepServices.js";
|
|
import {
|
|
addRestaurantToUser,
|
|
fetchRestaurant,
|
|
fetchAllDishesForRestaurant,
|
|
removeRestaurant,
|
|
} from "../services/databaseServices.js";
|
|
import {
|
|
decodeAndSanitize,
|
|
validateRestaurant,
|
|
handleError,
|
|
validateUserToken,
|
|
verifyRestaurantAccess,
|
|
newError,
|
|
} from "../services/services.js";
|
|
import Restaurant from "../models/restaurant.js";
|
|
|
|
var router = express.Router();
|
|
|
|
// GET RESTAURANT BY ID
|
|
|
|
router.get("/", async (req, res) => {
|
|
try {
|
|
const query = decodeAndSanitize(req.query.restaurantId);
|
|
await validateRestaurant(query);
|
|
Restaurant.findById(query).then((data) => res.send(data));
|
|
} catch (error) {
|
|
handleError(error, res);
|
|
}
|
|
});
|
|
|
|
// ADD NEW RESTAURANT
|
|
|
|
router.post("/", async (req, res) => {
|
|
try {
|
|
const token = req.headers["x-auth-token"];
|
|
const user = validateUserToken(token);
|
|
const restaurant = await createRestaurant(req.body).catch((err) => {
|
|
throw newError("Nie udało się zapisać zdjęcia.", 500);
|
|
});
|
|
await restaurant.save();
|
|
await addRestaurantToUser(user, restaurant);
|
|
res.sendStatus(201);
|
|
} catch (error) {
|
|
handleError(error, res);
|
|
}
|
|
});
|
|
|
|
// UPDATE RESTAURANT
|
|
|
|
router.put("/", async (req, res) => {
|
|
try {
|
|
const token = req.headers["x-auth-token"];
|
|
const user = validateUserToken(token);
|
|
const oldRestaurant = await fetchRestaurant(req.body.restaurantId);
|
|
const newRestaurant = await createRestaurant(req.body, oldRestaurant);
|
|
await Restaurant.replaceOne({ _id: req.body.restaurantId }, newRestaurant);
|
|
res.send("Dane zostały zaktualizowane.");
|
|
} catch (error) {
|
|
handleError(error, res);
|
|
}
|
|
});
|
|
|
|
// GET ALL DISHES FROM A RESTAURANT ID
|
|
|
|
router.get("/dishes", async (req, res) => {
|
|
try {
|
|
const query = decodeAndSanitize(req.query.restaurantId);
|
|
await validateRestaurant(query);
|
|
let restaurant = await fetchRestaurant(query);
|
|
let dishes = await fetchAllDishesForRestaurant(restaurant);
|
|
res.send(dishes);
|
|
} catch (error) {
|
|
handleError(error, res);
|
|
}
|
|
});
|
|
|
|
// DELETE RESTAURANT
|
|
|
|
router.post("/delete", async (req, res) => {
|
|
try {
|
|
const token = req.headers["x-auth-token"];
|
|
const user = validateUserToken(token);
|
|
await validateRestaurant(req.body.restaurantId);
|
|
await verifyRestaurantAccess(req.body.restaurantId, user);
|
|
await removeRestaurant(req.body.restaurantId, user.id);
|
|
res.send("Restauracja została pomyślnie usunięta.");
|
|
} catch (error) {
|
|
handleError(error, res);
|
|
}
|
|
});
|
|
|
|
export default router;
|