-
Notifications
You must be signed in to change notification settings - Fork 1
/
server.ts
117 lines (99 loc) · 2.98 KB
/
server.ts
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
const express = require('express');
const bodyParser = require('body-parser');
const app = express();
/**
* read from environment variables from file
*/
const dotenv = require('dotenv');
dotenv.config()
/**
* Swagger configuration.
*/
const swaggerUi = require('swagger-ui-express');
const swaggerDocument = require('./swagger.json');
app.use('/docs', swaggerUi.serve, swaggerUi.setup(swaggerDocument));
const MongoClient = require('mongodb').MongoClient;
const mongodb = require('mongodb');
let ObjectID = mongodb.ObjectID;
const connection_string = process.env.CONNECTION_STRING;
if (!connection_string) {
console.log('no connection string for db provided');
process.exit(1)
}
let db;
let itemsCollection;
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({extended: true}));
app.use((req, res, next) => {
res.setHeader("Access-Control-Allow-Origin", "*");
res.setHeader("Access-Control-Allow-Methods", "GET,HEAD,OPTIONS,POST,PUT,DELETE");
res.setHeader("Access-Control-Allow-Headers", "Origin, X-Requested-With, Content-Type, Accept, Authorization");
next();
});
app.all('/*', function (req, res, next) {
res.header('Access-Control-Allow-Origin', '*');
next();
});
app.get('/', (request, response) => {
response.send('Hello from Express!')
});
app.get('/items', (req, res) => {
itemsCollection.find({}).toArray((err, result) => {
if (err) {
res.status(404).send('we have faiced some issues');
} else {
res.status(200).send(result)
}
});
});
app.get('/items/:id', (req, res) => {
itemsCollection.findOne({_id: new ObjectID(req.params.id.toString())}, (err, result) => {
if (err) {
res.status(500).send('ups we have error');
} else {
res.status(200).send(result);
}
});
});
app.post('/items', (req, res) => {
itemsCollection.insertOne(req.body, (err, result) => {
if (err) {
res.status(500).send('not saved in database')
} else {
res.status(201).send(result);
console.log('saved to database');
}
});
});
app.put('/items/:id', (req, res) => {
itemsCollection.updateOne({_id: new ObjectID(req.params.id.toString())},
{ $set: { "title" : req.body.title, "completed": req.body.completed } }, (err, result) => {
if (err) {
res.status(500).send('not saved in database')
} else {
res.status(201).send(result);
console.log('saved to database');
}
});
});
app.delete('/items/:id', (req, res) => {
itemsCollection.deleteOne({_id: new ObjectID(req.params.id.toString())}, (err, result) => {
if (err) {
res.status(500).send('ups we have error');
} else {
console.log('result', result);
res.status(200).send();
}
})
});
MongoClient.connect(`${connection_string}`, {useNewUrlParser: true}, (err, database) => {
if (err) {
console.error(`error`, err);
process.exit(1);
}
db = database.db('todo-list');
itemsCollection = db.collection('todo-list-items');
app.listen(3000, () => {
console.log('listening on 3000');
});
});