Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

No Man Is An Island #3

Open
wants to merge 6 commits into
base: main
Choose a base branch
from
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
14 changes: 7 additions & 7 deletions __tests__/customerRoutes.test.js
Original file line number Diff line number Diff line change
@@ -1,44 +1,44 @@
const request = require('supertest');
const app = require('../index'); // Adjust the path to where your Express app is exported
const app = require('../app'); // Adjust the path to where your Express app is exported

describe('Customer Resource CRUD Operations', () => {
let newCustomerId;

it('should create a new customer', async () => {
const customerData = { name: 'Jane Doe', email: 'jane.doe@example.com', isActive: true };
const response = await request(app)
.post('/customers')
.post('/users')
.send(customerData);
expect(response.statusCode).toBe(201);
expect(response.body).toHaveProperty('id');
newCustomerId = response.body.id; // Store the ID for use in subsequent tests
});

it('should list all customers', async () => {
const response = await request(app).get('/customers');
const response = await request(app).get('/users');
expect(response.statusCode).toBe(200);
expect(Array.isArray(response.body)).toBe(true);
});

it('should fetch a single customer by ID', async () => {
const response = await request(app).get(`/customers/${newCustomerId}`);
const response = await request(app).get(`/users/${newCustomerId}`);
expect(response.statusCode).toBe(200);
expect(response.body).toHaveProperty('id', newCustomerId);
});

it('should update a customer', async () => {
const updatedCustomerData = { name: 'John Doe Updated', email: 'johnupdated@example.com', isActive: false };
const response = await request(app)
.put(`/customers/${newCustomerId}`)
.put(`/users/${newCustomerId}`)
.send(updatedCustomerData);
expect(response.statusCode).toBe(200);
expect(response.body.name).toEqual(updatedCustomerData.name);
expect(response.body.isActive).toEqual(updatedCustomerData.isActive);
});

it('should delete a customer', async () => {
const response = await request(app).delete(`/customers/${newCustomerId}`);
const response = await request(app).delete(`/users/${newCustomerId}`);
expect(response.statusCode).toBe(200);
expect(response.text).toContain('Customer successfully deleted');
expect(response.text).toContain('User successfully deleted');
});
});
107 changes: 107 additions & 0 deletions app.js
Original file line number Diff line number Diff line change
@@ -0,0 +1,107 @@
const Joi = require("joi");
const express = require("express");
const app = express();

const users = [
{
id: 1,
name: "user01",
email: "user01@email.com",
isActive: true,
},

{
id: 2,
name: "user02",
email: "user02@email.com",
isActive: false,
},
{
id: 3,
name: "user03",
email: "user03@email.com",
isActive: true,
},
];

//middleware
app.use(express.json());

app.get("/", (req, res) => {
res.send("Save The Planet");
});

//route handler for viewing all users
app.get("/users", (req, res) => {
res.send(users);
});

//route handler for viewing user by id
app.get("/users/:id", (req, res) => {
const findUser = users.find((user) => user.id === parseInt(req.params.id));

if (!findUser) {
res.status(404).send("The user was not found");
return;
}

res.send(findUser);
});

//route handler for creating a new user
app.post("/users", (req, res) => {
const { error } = validateUserNameAndEmail(req.body);
if (error) return res.status(400).send(error.details[0].message);

const isActiveAlwaysFalse = false;

const user = {
id: users.length + 1,
name: req.body.name,
email: req.body.email,
isActive: isActiveAlwaysFalse,
};

users.push(user);

res.status(201).send(user);
});

// //route handler for updating a user
app.put("/users/:id", (req, res) => {
const findUser = users.find((user) => user.id === parseInt(req.params.id));
if (!findUser) return res.status(404).send("The user was not found");

findUser.name = req.body.name;
findUser.email = req.body.email;
findUser.isActive = req.body.isActive;

res.send(findUser);
});

// way to validate input
function validateUserNameAndEmail(user) {
const schema = Joi.object({
name: Joi.string(),
email: Joi.string(),
isActive: Joi.boolean()
});

return schema.validate(user);
}

//route handler to delete book
app.delete("/users/:id", (req, res) => {
const findUser = users.find((user) => user.id === parseInt(req.params.id));

console.log(findUser);

if (!findUser) return res.status(404).send("The user was not found");

const index = users.indexOf(findUser);
users.splice(index, 1);

res.status(200).send("User successfully deleted");
});

module.exports = app;
90 changes: 90 additions & 0 deletions bin/www
Original file line number Diff line number Diff line change
@@ -0,0 +1,90 @@
#!/usr/bin/env node

/**
* Module dependencies.
*/

var app = require('../app');
var debug = require('debug')('04-07-i-still-need-a-restful-sleep:server');
var http = require('http');

/**
* Get port from environment and store in Express.
*/

var port = normalizePort(process.env.PORT || '3000');
app.set('port', port);

/**
* Create HTTP server.
*/

var server = http.createServer(app);

/**
* Listen on provided port, on all network interfaces.
*/

server.listen(port);
server.on('error', onError);
server.on('listening', onListening);

/**
* Normalize a port into a number, string, or false.
*/

function normalizePort(val) {
var port = parseInt(val, 10);

if (isNaN(port)) {
// named pipe
return val;
}

if (port >= 0) {
// port number
return port;
}

return false;
}

/**
* Event listener for HTTP server "error" event.
*/

function onError(error) {
if (error.syscall !== 'listen') {
throw error;
}

var bind = typeof port === 'string'
? 'Pipe ' + port
: 'Port ' + port;

// handle specific listen errors with friendly messages
switch (error.code) {
case 'EACCES':
console.error(bind + ' requires elevated privileges');
process.exit(1);
break;
case 'EADDRINUSE':
console.error(bind + ' is already in use');
process.exit(1);
break;
default:
throw error;
}
}

/**
* Event listener for HTTP server "listening" event.
*/

function onListening() {
var addr = server.address();
var bind = typeof addr === 'string'
? 'pipe ' + addr
: 'port ' + addr.port;
debug('Listening on ' + bind);
}
Loading