Fully operational

- Extensive instructions and warnings in README
- Working WeMo accessory shim
- Working HomeBridge server

app.js

@@ -1,4 +1,118 @@
+var fs = require('fs');
+var path = require('path');
+var storage = require('node-persist');
 
+console.log("Starting HomeBridge server...");
+
+// Look for the configuration file
+var configPath = path.join(__dirname, "config.json");
+
+// Complain and exit if it doesn't exist yet
+if (!fs.existsSync(configPath)) {
+    console.log("Couldn't find a config.json file in the same directory as app.js. Look at config-sample.json for examples of how to format your config.js and add your home accessories.");
+    process.exit(1);
+}
+
+// Initialize persistent storage
+storage.initSync();
+
+// Load up the configuration file
+var config = JSON.parse(fs.readFileSync(configPath));
+
+function loadAccessories() {
+    console.log("Loading " + config.accessories.length + " accessories...");
+
+    var accessories = [];
+
+    // Instantiate all accessories in the config
+    for (var i=0; i<config.accessories.length; i++) {
+
+        var accessoryConfig = config.accessories[i];
+        console.log(accessoryConfig);
+
+        // Load up the class for this accessory
+        var accessoryName = accessoryConfig["accessory"]; // like "WeMo"
+        var accessoryModule = require('./accessories/' + accessoryName + ".js"); // like "./accessories/WeMo.js"
+        var accessoryConstructor = accessoryModule.accessory; // like "WeMoAccessory", a JavaScript constructor
+
+        // Create a custom logging function that prepends the Siri name for debugging
+        var siriName = accessoryConfig["siri_name"];
+        var log = function(siriName) { return function(s) { console.log("[" + siriName + "] " + s); }; }(siriName);
+
+        log("Initializing " + accessoryName + " accessory...");
+        var accessory = new accessoryConstructor(log, accessoryConfig);
+        accessories.push(accessory);
+
+        // Extract the raw "accessoryData" for this accessory which is a big object-blob describing the various
+        // hooks in and out of HomeKit for the HAP-NodeJS server.
+        var accessoryData = accessory.accessoryData();
+
+        // Create the HAP server for this accessory
+        createHAPServer(accessoryData);
+    }
+}
+
+//
+// Creates the actual HAP servers which listen on different sockets
+//
+
+// Pull in required HAP-NodeJS stuff
 var accessory_Factor = new require("./lib/HAP-NodeJS/Accessory.js");
+var accessoryController_Factor = new require("./lib/HAP-NodeJS/AccessoryController.js");
+var service_Factor = new require("./lib/HAP-NodeJS/Service.js");
+var characteristic_Factor = new require("./lib/HAP-NodeJS/Characteristic.js");
 
-console.log(accessory_Factor);
+// Each accessory has its own little server. We'll need to allocate some ports for these servers
+var nextPort = 51826;
+var nextServer = 0;
+var accessoryServers = [];
+var accessoryControllers = [];
+
+function createHAPServer(data) {
+    var accessoryController = new accessoryController_Factor.AccessoryController();
+
+    //loop through services
+    for (var j = 0; j < data.services.length; j++) {
+        var service = new service_Factor.Service(data.services[j].sType);
+
+        //loop through characteristics
+        for (var k = 0; k < data.services[j].characteristics.length; k++) {
+            var options = {
+                type: data.services[j].characteristics[k].cType,
+                perms: data.services[j].characteristics[k].perms,
+                format: data.services[j].characteristics[k].format,
+                initialValue: data.services[j].characteristics[k].initialValue,
+                supportEvents: data.services[j].characteristics[k].supportEvents,
+                supportBonjour: data.services[j].characteristics[k].supportBonjour,
+                manfDescription: data.services[j].characteristics[k].manfDescription,
+                designedMaxLength: data.services[j].characteristics[k].designedMaxLength,
+                designedMinValue: data.services[j].characteristics[k].designedMinValue,
+                designedMaxValue: data.services[j].characteristics[k].designedMaxValue,
+                designedMinStep: data.services[j].characteristics[k].designedMinStep,
+                unit: data.services[j].characteristics[k].unit
+            };
+
+            var characteristic = new characteristic_Factor.Characteristic(options, data.services[j].characteristics[k].onUpdate);
+
+            service.addCharacteristic(characteristic);
+        }
+        accessoryController.addService(service);
+    }
+
+    //increment ports for each accessory
+    nextPort = nextPort + (nextServer*2);
+
+    // create a unique "username" for this accessory
+    var pincode = "031-45-154";
+    var username = "DD:22:3D:EE:5E:" + ("00" + nextServer.toString(16)).substr(-2);
+    console.log("username: " + username);
+
+    var accessory = new accessory_Factor.Accessory(data.displayName, username, storage, parseInt(nextPort), pincode, accessoryController);
+    accessoryServers[nextServer] = accessory;
+    accessoryControllers[nextServer] = accessoryController;
+    accessory.publishAccessory();
+
+    nextServer++;
+}
+
+loadAccessories();