Resolved issue #5

code/index.js

@@ -87,15 +87,41 @@ listeners.accounting.socket.on ('listening', () => {
 listeners.accounting.socket.bind (config.ports.radius_accounting);
 
 // HTTP listener
+const respond = (res, content, status) {
+    res.write (content);
+    res.statusCode = status;
+    res.end ();
+};
+
 http.createServer(function (req, res) {
     var url = req.url.substring (0, req.url.lastIndexOf ("/")) || req.url;
     var endpoint = req.method + " " + url;
     switch (endpoint) {
 
         case "GET /health":
-            res.write ('OK\n\n');
+            respond (res, "OK\n\n", 200);
-            res.statusCode = 200;
+            break;
-            res.end ();
+
+        case "GET /users":
+            handlers.user.getall ((users, err) => {
+                if (!err) {
+                    respond (res, users, 200);
+                }
+                else {
+                    respond (res, err, 404);
+                }
+            });
+            break;
+
+        case "GET /user/":
+            handlers.user.getone (req.url.substring (req.url.lastIndexOf ("/") + 1), (user, err) => {
+                if (err) {
+                    respond (res, "Error\n\n", 500);
+                }
+                else {
+                    respond (res, user, 200);
+                }
+            });
             break;
 
         case "POST /user":
@@ -106,14 +132,10 @@ http.createServer(function (req, res) {
             req.on ('end', () => {
                 handlers.user.create (payload, (status, err) => {
                     if (err) {
-                        res.write ('Error\n');
+                        respond (res, "Error\n\n", 500);
-                        res.statusCode = 500;
-                        res.end ();
                     }
                     else {
-                        res.write (status);
+                        respond (res, status, 200);
-                        res.statusCode = 200;
-                        res.end ();
                     }
                 });
             });
@@ -127,14 +149,10 @@ http.createServer(function (req, res) {
             req.on ('end', () => {
                 handlers.user.update (payload, (status, err) => {
                     if (err) {
-                        res.write ('Error\n');
+                        respond (res, "Error\n\n", 500);
-                        res.statusCode = 500;
-                        res.end ();
                     }
                     else {
-                        res.write (status);
+                        respond (res, status, 200);
-                        res.statusCode = 200;
-                        res.end ();
                     }
                 });
             });
@@ -143,22 +161,16 @@ http.createServer(function (req, res) {
         case "DELETE /user":
             handlers.user.delete (req.url.substring (req.url.lastIndexOf ("/") + 1), (status, err) => {
                 if (err) {
-                    res.write ('Error\n');
+                    respond (res, "Error\n\n", 500);
-                    res.statusCode = 500;
-                    res.end ();
                 }
                 else {
-                    res.write (status);
+                    respond (res, status, 200);
-                    res.statusCode = 200;
-                    res.end ();
                 }
             });
             break;
 
         default:
-            res.write ('Not found\n');
+            respond (res, "Not found\n\n", 404);
-            res.statusCode = 404;
-            res.end ();
 
     }
 }).listen (8080);

code/lib/handlers.js

@@ -57,6 +57,8 @@ module.exports = {
     },
     user: {
         create: data.createUser,
+        getall: data.getUsers,
+        getone: data.getUser,
         update: data.updateUser,
         delete: data.deleteUser
     }