Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
133 changes: 133 additions & 0 deletions controllers/orderControllers.js
Original file line number Diff line number Diff line change
@@ -0,0 +1,133 @@
const moment = require('moment');
const orderModel = require('../models/orderModel');
const {
authenticateOrder,
authenticateUser,
} = require('../utilities/authenticate');

exports.getAllOrders = async (req, res) => {
try {
const queryObj = { ...req.query };
const excludedFields = ['page', 'sort'];
excludedFields.forEach((el) => delete queryObj[el]);

let query = orderModel.find(queryObj);

if (req.query.sort) {
const sortBy = req.query.sort.split(',').join(' ');
query = query.sort(sortBy);
} else {
query = query.sort('total_price created_at');
}

if (req.query.state) {
query = query.find({ state: req.query.state });
} else {
query = query.find({ state: 1 });
}

if (req.query.page) {
const page = req.query.page * 1 || 1;
const limit = req.query.limit * 1 || 100;
const skip = (page - 1) * limit;
query = query.skip(skip).limit(limit);
}

const orders = await query;

const orderLength = orders.reduce((acc, cur) => (acc += 1), 0);

return res.json({ status: 'success', orderLength, orders });
} catch (err) {
res.status(404).json({
status: 'fail',
message: err,
});
}
};

exports.getOrder = async (req, res) => {
try {
await authenticateOrder(req, res, 'user');
const { id } = req.params;
const order = await orderModel.findById(id);

if (!order) {
return res.status(404).json({ status: false, order: null });
}

return res.json({ status: true, order });
} catch (err) {
res.status(404).json({
status: 'fail',
message: err,
});
}
};

exports.createOrder = async (req, res) => {
try {
await authenticateUser(req, res);
const body = req.body;
const total_price = body.items.reduce((prev, curr) => {
prev += curr.price * curr.quantity;
return prev;
}, 0);

const order = await orderModel.create({
items: body.items,
created_at: moment().toDate(),
total_price,
});

return res.json({ status: true, order });
} catch (err) {
res.status(404).json({
status: 'fail',
message: err,
});
}
};

exports.updateOrder = async (req, res) => {
try {
await authenticateOrder(req, res, 'admin');
const { id } = req.params;
const { state } = req.body;

const order = await orderModel.findById(id);

if (!order) {
return res.status(404).json({ status: false, order: null });
}

if (state < order.state) {
return res
.status(422)
.json({ status: false, order: null, message: 'Invalid operation' });
}

order.state = state;

await order.save();

return res.json({ status: true, order });
} catch (err) {}
};

exports.deleteOrder = async (req, res) => {
try {
await authenticateUser(req, res);
await authenticateOrder(req, res, 'admin');
const { id } = req.params;

const order = await orderModel.deleteOne({ _id: id });

return res.json({ status: true, message: 'order deleted', order });
} catch (err) {
res.status(404).json({
status: 'fail',
message: err,
});
}
};
93 changes: 93 additions & 0 deletions controllers/userControllers.js
Original file line number Diff line number Diff line change
@@ -0,0 +1,93 @@
const User = require('../models/userModel');
const { authenticateUser } = require('../utilities/authenticate');

exports.getAllUsers = async (req, res) => {
try {
await authenticateUser(req, res);
const users = await User.find();
res.status(200).json({
status: 'success',
data: {
users,
},
});
} catch (err) {
res.status(404).json({
status: 'fail',
message: err,
});
}
};

exports.getUser = async (req, res) => {
try {
const { id } = req.params;
const user = await User.findById(id);
res.status(200).json({
status: 'success',
data: {
user,
},
});
} catch (err) {
res.status(404).json({
status: 'fail',
message: err,
});
}
};

exports.createUser = async (req, res) => {
try {
const newUser = await User.create({
username: req.body.username,
email: req.body.email,
password: req.body.password,
});
res.status(200).json({
status: 'success',
data: {
newUser,
},
});
} catch (err) {
res.status(404).json({
status: 'fail',
message: err,
});
}
};

exports.updateUser = async (req, res) => {
try {
await authenticateUser(req, res);
const updatedUser = await User.findByIdAndUpdate(req.params.id, req.body, {
new: true,
runValidators: true,
});
res.status(200).json({
status: 'success',
updatedUser,
});
} catch (err) {
res.status(404).json({
status: 'fail',
message: err,
});
}
};

exports.deleteUser = async (req, res) => {
try {
await Tour.findByIdAndDelete(req.params.id);
res.status(204).json({
status: 'success',
data: null,
});
} catch (err) {
res.status(404).json({
status: 'fail',
message: err,
});
}
};
20 changes: 20 additions & 0 deletions db/database.js
Original file line number Diff line number Diff line change
@@ -0,0 +1,20 @@
const moogoose = require('mongoose');
require('dotenv').config();

const MONGODB_URI = process.env.MONGODB_URI;

// connect to mongodb
function connection() {
moogoose.connect(MONGODB_URI);

moogoose.connection.on('connected', () => {
console.log('Connected to MongoDB successfully');
});

moogoose.connection.on('error', (err) => {
console.log('Error connecting to MongoDB', err);
})
}


module.exports = connection;
Empty file added db/users.json
Empty file.
107 changes: 31 additions & 76 deletions index.js
Original file line number Diff line number Diff line change
@@ -1,95 +1,50 @@
const express = require('express');
const moment = require('moment');
const mongoose = require('mongoose');
const orderModel = require('./orderModel');
const passport = require('passport');
const orderRouter = require('./routes/orderRoutes');
const authRouter = require('./routes/authRouter');
const userRouter = require('./routes/userRoutes');

const PORT = 3334
require('./db/database')();
require('dotenv').config();

const app = express()
require('./utilities/passport-jwt');

app.use(express.json());


app.get('/', (req, res) => {
return res.json({ status: true })
})


app.post('/order', async (req, res) => {
const body = req.body;

const total_price = body.items.reduce((prev, curr) => {
prev += curr.price
return prev
}, 0);

const order = await orderModel.create({
items: body.items,
created_at: moment().toDate(),
total_price
})

return res.json({ status: true, order })
})

app.get('/order/:orderId', async (req, res) => {
const { orderId } = req.params;
const order = await orderModel.findById(orderId)

if (!order) {
return res.status(404).json({ status: false, order: null })
}

return res.json({ status: true, order })
})
const PORT = process.env.PORT || 3000;

app.get('/orders', async (req, res) => {
const orders = await orderModel.find()

return res.json({ status: true, orders })
})

app.patch('/order/:id', async (req, res) => {
const { id } = req.params;
const { state } = req.body;
const app = express();

const order = await orderModel.findById(id)
app.set('view-engine', 'ejs');

if (!order) {
return res.status(404).json({ status: false, order: null })
}

if (state < order.state) {
return res.status(422).json({ status: false, order: null, message: 'Invalid operation' })
}

order.state = state;

await order.save()

return res.json({ status: true, order })
})

app.delete('/order/:id', async (req, res) => {
const { id } = req.params;
app.use(express.json());
app.use(express.urlencoded({ extended: false }));
app.use(passport.initialize());

const order = await orderModel.deleteOne({ _id: id})

return res.json({ status: true, order })
})
app.use('/', authRouter);

app.use(
'/orders',
passport.authenticate('jwt', { session: false }),
orderRouter
);
app.use('/users', userRouter);

mongoose.connect('mongodb://localhost:27017')
app.get('/', (req, res) => {
res.render('index.ejs');
});

mongoose.connection.on("connected", () => {
console.log("Connected to MongoDB Successfully");
app.get('/login', (req, res) => {
res.render('Login.ejs');
});

mongoose.connection.on("error", (err) => {
console.log("An error occurred while connecting to MongoDB");
console.log(err);
app.get('/signup', (req, res) => {
res.render('Signup.ejs');
});

app.listen(PORT, () => {
console.log('Listening on port, ', PORT)
})
console.log('Listening on port, ', PORT);
});

module.exports = app;
Loading