diff --git a/src/js/app.js b/src/js/app.js index a89f2fc..175e833 100644 --- a/src/js/app.js +++ b/src/js/app.js @@ -8,11 +8,22 @@ const port = 3000; const mongoClient = new MongoClient(); app.get('/test', (request, response) => { - mongoClient.insert('test', {creationDate: new Date()}, () => { - mongoClient.find('test', {}, results => { - console.log(results); - response.send(JSON.stringify(results)); - }); + mongoClient.find('test', {}, results => { + response.json(results); + }); +}); + +app.get('/test2', (request, response) => { + // mongoClient.insert('test', {address: 'localhost'}, (result) => { + // response.json(result); + // }); + + // mongoClient.update('test', {_id: '5f54b1c0f4dca82b7ad825bc', address: '127.0.0.1', updated: new Date()}, (result) => { + // response.json(result); + // }); + + mongoClient.delete('test', '5f54b6c52d9355311a4e68a0', () => { + response.status(200).send('Deleted'); }); }); diff --git a/src/js/mongoClient.js b/src/js/mongoClient.js index df3ec58..1b60bf4 100644 --- a/src/js/mongoClient.js +++ b/src/js/mongoClient.js @@ -1,4 +1,5 @@ const mongodb = require('mongodb'); +const ObjectID = require('mongodb').ObjectID; const assert = require('assert'); const mongoConfig = { @@ -21,7 +22,6 @@ class MongoClient { this.db.collection(collectionName).find(query).toArray() .then(results => { console.log(`Entities ${collectionName} founded.`); - console.log(results); callback(results); }) .catch(error => console.error(error)); @@ -36,19 +36,19 @@ class MongoClient { }); } - update(collectionName, entity, query, callback) { - this.db.collection(collectionName).update(query, entity, (error, result) => { + update(collectionName, entity, callback) { + this.db.collection(collectionName).save(entity, (error) => { assert.equal(null, error, `Unable to update ${collectionName} entity: ${error}.`); console.log(`Entity ${collectionName} updated.`); - callback(result); + callback(); }); } delete(collectionName, entityId, callback) { - this.db.collection(collectionName).deleteOne({id: entityId}, (error, result) => { + this.db.collection(collectionName).deleteOne({id: new ObjectID(entityId)}, (error) => { assert.equal(null, error, `Unable to delete ${collectionName} entity with id ${entityId}: ${error}.`); console.log(`Entity ${collectionName} with id ${entityId} deleted.`); - callback(result); + callback(); }); } }