playing around

prototypes/example.coffee

@@ -0,0 +1,18 @@
+mach = require "./mach"
+
+server = mach.Server mach.Log mach.URLMap
+
+    "/": -> '<a href="/foo">Foo</a>'
+
+    "/foo": -> [200, {}, '<a href="/bar">Bar</a>']
+
+    "/bar": (req) ->
+        status: 200
+        headers: "content-type": "application/json"
+        content: JSON.stringify
+            method: req.method
+            url: req.url
+            headers: req.headers
+            , null, 2
+
+.listen 3333

prototypes/mach.js

@@ -0,0 +1,89 @@
+var Q = require("q");
+var HTTP = require("http");
+var FS = require("fs");
+var BufferedStream = require("bufferedstream");
+
+var MACH = exports;
+
+MACH.Server = function Server(app) {
+    return HTTP.createServer(function(nodeRequest, nodeResponse) {
+        var request = nodeRequest;
+        MACH.call(app, request).then(function(response) {
+            nodeResponse.writeHead(response.status, response.headers);
+            response.content.pipe(nodeResponse);
+            response.content.resume();
+        }, function(error) {
+            console.log(error);
+            nodeResponse.writeHead(500);
+            nodeResponse.end();
+        });
+    });
+};
+
+// We should include a "lint" module like Rack does to check for compliant apps/middleware
+// Should we hook it into MACH.call if enabled?
+// MACH.Lint = function(app) {
+//     return function(request) {
+//         return app(request);
+//     };
+// }
+
+// Simple MACH.call for handling immediate responses
+MACH.call = function(app, request) {
+    return Q.fcall(app, request);
+};
+
+// More coersion features for different response types
+MACH.call = function(app, request) {
+    return Q.when(app(request), function(response) {
+        if (typeof response === "object") {
+            if (Array.isArray(response)) {
+                response = {
+                    status: response[0],
+                    headers: response[1],
+                    content: response[2],
+                };
+            }
+        }
+        else if (typeof response === "string") {
+            response = { content: response };
+        }
+        else if (typeof response === "number") {
+            response = { status: response.status };
+        }
+
+        if (response.status === undefined) {
+            response.status = 200;
+        }
+        if (response.headers === undefined) {
+            response.headers = {};
+        }
+        if (response.content === undefined) {
+            response.content = "";
+        }
+        if (typeof response.content === "string") {
+            response.content = new BufferedStream(response.content);
+            response.content.pause();
+        }
+
+        return response;
+    });
+};
+
+MACH.Log = function(app) {
+    return function(request) {
+        console.log(request.url);
+        return app(request);
+    }
+}
+
+MACH.URLMap = function(map) {
+    var hasOwnProperty = Object.prototype.hasOwnProperty;
+    return function(request) {
+        if (hasOwnProperty.call(map, request.url)) {
+            return MACH.call(map[request.url], request);
+        } else {
+            return 404;
+        }
+    };
+}