Directory allocation
This commit is contained in:
@@ -0,0 +1,93 @@
|
||||
const express = require('express');
|
||||
const app = express();
|
||||
const { MongoClient, ObjectId } = require('mongodb');
|
||||
const request = require('request');
|
||||
const cheerio = require('cheerio');
|
||||
const URL = require('url-parse');
|
||||
|
||||
const port = process.env.PORT || 3001;
|
||||
|
||||
const uri = "mongodb://localhost:27017";
|
||||
|
||||
const client = new MongoClient(uri);
|
||||
|
||||
app.use(express.json());
|
||||
|
||||
app.get('/get', async (req, res) => {
|
||||
const data = await getDoc();
|
||||
res.send(data);
|
||||
});
|
||||
|
||||
app.post('/post', (req, res) => {
|
||||
let title;
|
||||
const pageToVisit = req.body.link;
|
||||
request(pageToVisit, (error, response, body) => {
|
||||
try {
|
||||
if(response.statusCode === 200) {
|
||||
// Parse the document body
|
||||
const $ = cheerio.load(body);
|
||||
|
||||
req.body.title = $('title').text();
|
||||
insertDoc(req.body);
|
||||
} else {
|
||||
req.body.title = null;
|
||||
insertDoc(req.body);
|
||||
}
|
||||
} catch (error) {
|
||||
console.log(error);
|
||||
req.body.title = null;
|
||||
insertDoc(req.body);
|
||||
}
|
||||
});
|
||||
});
|
||||
|
||||
app.delete('/delete', async (req, res) => {
|
||||
const id = req.body.id.toString();
|
||||
|
||||
await deleteDoc(id);
|
||||
|
||||
res.send(`Bookmark with ObjectId "${id}" deleted.`);
|
||||
});
|
||||
|
||||
async function insertDoc(doc) {
|
||||
try {
|
||||
const database = client.db("sample_db");
|
||||
const list = database.collection("list");
|
||||
const result = await list.insertOne(doc);
|
||||
}
|
||||
|
||||
catch(err) {
|
||||
console.log(err);
|
||||
}
|
||||
}
|
||||
|
||||
async function getDoc() {
|
||||
try {
|
||||
const database = client.db("sample_db");
|
||||
const list = database.collection("list");
|
||||
const result = await list.find({}).toArray();
|
||||
|
||||
return result;
|
||||
}
|
||||
|
||||
catch(err) {
|
||||
console.log(err);
|
||||
}
|
||||
}
|
||||
|
||||
async function deleteDoc(doc) {
|
||||
try {
|
||||
const database = client.db("sample_db");
|
||||
const list = database.collection("list");
|
||||
const result = await list.deleteOne({"_id": ObjectId(doc)});
|
||||
}
|
||||
|
||||
catch(err) {
|
||||
console.log(err);
|
||||
}
|
||||
}
|
||||
|
||||
app.listen(port, () => {
|
||||
console.log(`Success! running on port ${port}.`);
|
||||
client.connect();
|
||||
});
|
||||
Reference in New Issue
Block a user