Merge pull request #80 from Human-Connection/77-implement-delete-entry-method

Implement deleteEntry method & getEntry method

Author: matboehm

core/db.js

@@ -82,6 +82,31 @@ exports.getEntries = function(filter, callback){
     });
 };
 
+exports.getEntry = function(id, callback){
+    pool.getConnection(function(error, connection) {
+        if(error) {
+            console.log(error);
+            callback(true);
+            return;
+        }
+
+        let sql = 'SELECT * FROM entries WHERE id = ?';
+
+        connection.query(sql, [id], function(error, result) {
+            connection.release();
+            if(error) {
+                callback(result, error);
+                return;
+            }
+            if (!result || !result.length) {
+                callback(null, 'Entry with the specified id does not exist');
+                return;
+            }
+            callback(result, false);
+        });
+    });
+};
+
 exports.getUserByHash = function(hash, callback){
     pool.getConnection(function(err, connection) {
         if (err) { console.log(err); callback(true); return; }
@@ -113,6 +138,27 @@ exports.verifyEntry = function(hash, callback){
     });
 };
 
+exports.deleteEntry = function(id, callback){
+    pool.getConnection(function(error, connection) {
+        if(error) {
+            console.log(error);
+            callback(error);
+            return;
+        }
+        let sql = "DELETE FROM entries WHERE id = ?";
+
+        // make the query
+        connection.query(sql, [id], function(error) {
+            connection.release();
+            if(error) {
+                callback(error);
+                return;
+            }
+            callback(false);
+        });
+    });
+};
+
 exports.getCount = function(callback){
     pool.getConnection(function(err, connection) {
         if(err) { console.log(err); callback(true); return; }

core/entryController.js

@@ -78,6 +78,27 @@ exports.toggleStatus = function(req, res){
     });
 };
 
+exports.deleteEntry = function(request, response){
+    if(request.params.id && request.params.id > 0){
+        db.getEntry(request.params.id, function(result, error){
+            if(!error){
+                db.deleteEntry(request.params.id, function(error){
+                    if(!error) {
+                        console.log("!error");
+                        response.status(200).json({success: true});
+                    } else{
+                        response.status(400).json({error: error});
+                    }
+                });
+            } else {
+                response.status(400).json({error: error});
+            }
+        });
+    } else {
+        response.status(400).json({error: "No entry id specified"});
+    }
+};
+
 exports.getCount = function(req, res) {
     db.getCount(function(results, err){
         if(!err){

core/restapi.js

@@ -8,6 +8,7 @@ module.exports = function(app) {
     // non-auth routes
     // TODO: tmp until path can be changed
     app.route('/cube.php').get(entryController.getCount);
+    app.route('/count').get(entryController.getCount);
     app.route('/entries/verify/:k').get(entryController.verifyEntry);
 
     // intercept request and check for api key
@@ -27,4 +28,5 @@ module.exports = function(app) {
     app.route('/entries/toggle').post(entryController.toggleStatus);
     app.route('/entries').get(entryController.getAll);
     app.route('/countries').get(entryController.getCountries);
+    app.route('/delete/:id').get(entryController.deleteEntry);
 };