API script for communicating with the GUI frontend

api.coffee

@@ -0,0 +1,77 @@
+config = require './config'
+util = require 'util'
+http = require 'http'
+mongo = require 'mongodb'
+url  = require 'url'
+
+# regular expression objects
+DEVICES_REGEX = /^\/devices\/?$/
+DEVICE_REGEX = /^\/devices\/([a-zA-Z0-9\-\_]+)\/?$/
+
+# Create MongoDB connections
+dbserver = new mongo.Server(config.MONGODB_SOCKET, 0, {auto_reconnect: true, safe: true})
+tasksCollection = null
+devicesCollection = null
+db = new mongo.Db(config.DATABASE_NAME, dbserver, {native_parser:true})
+db.open( (err, db) ->
+  db.collection('tasks', (err, collection) ->
+    tasksCollection = collection
+    tasksCollection.ensureIndex({device: 1, timestamp: 1})
+  )
+
+  db.collection('devices', (err, collection) ->
+    devicesCollection = collection
+  )
+)
+
+cluster = require 'cluster'
+numCPUs = require('os').cpus().length
+
+if cluster.isMaster
+  for i in [1 .. numCPUs]
+    cluster.fork()
+  cluster.on('exit', (worker, code, signal) ->
+    console.log('worker ' + worker.process.pid + ' died')
+  )
+else
+  server = http.createServer (request, response) ->
+    if request.method != 'GET'
+      console.log '>>> 405 Method Not Allowed'
+      response.writeHead 405, {'Allow': 'GET'}
+      response.end('405 Method Not Allowed')
+      return
+
+    request.content = ''
+
+    request.addListener 'data', (chunk) ->
+      request.content += chunk
+
+    request.addListener 'end', () ->
+      urlParts = url.parse(request.url, true)
+      if DEVICES_REGEX.test(urlParts.pathname)
+        # TODO search for devices
+      else if DEVICE_REGEX.test(urlParts.pathname)
+        id = DEVICE_REGEX.exec(urlParts.pathname)[1]
+        devicesCollection.findOne({_id : id}, (err, device)->
+          if err
+            console.log("Error: " + err)
+            response.writeHead 500
+            response.end(err)
+            return
+
+          if device is null
+            response.writeHead 404
+            response.end()
+            return
+
+          response.end(JSON.stringify(device))
+          return
+        )
+        return
+
+      console.log '>>> 404 Not Found'
+      response.writeHead 404
+      response.end('404 Not Found')
+
+  server.listen config.API_PORT
+  console.log "Server listening on port #{config.API_PORT}"

common.coffee

@@ -0,0 +1,8 @@
+exports.endsWith = (str, suffix) ->
+  str.indexOf(suffix, str.length - suffix.length) isnt -1
+
+exports.arrayToHash = (arr) ->
+  hash = {}
+  for i in arr
+    hash[i[0]] = i[1]
+  return hash

config.coffee

@@ -1,6 +1,6 @@
-DATABASE_NAME = 'genie'
-ACS_PORT = 1337
-API_PORT = 1338
-CACHE_DURATION = 60000
-MONGODB_SOCKET = '/tmp/mongodb-27017.sock'
-MEMCACHED_SOCKET = '/tmp/memcached.sock'
+exports.DATABASE_NAME = 'genie'
+exports.ACS_PORT = 1337
+exports.API_PORT = 1338
+exports.CACHE_DURATION = 60000
+exports.MONGODB_SOCKET = '/tmp/mongodb-27017.sock'
+exports.MEMCACHED_SOCKET = '/tmp/memcached.sock'