File content as of revision 4:a682455428ae:

// Load .env config (silently fail if no .env present)
require('dotenv').config({ silent: true });

// Require necessary libraries
var async = require('async');
var ioLib = require('socket.io');
var http = require('http');
var path = require('path');
var express = require('express');
var MbedConnectorApi = require('mbed-connector-api');

// CONFIG (change these)
var accessKey = process.env.ACCESS_KEY || "ChangeMe";
var port = process.env.PORT || 8080;

// Paths to resources on the endpoints
var blinkResourceURI = '/3201/0/5850';
var blinkPatternResourceURI = '/3201/0/5853';
var colorResourceURI = '/3201/0/5855';
var ZXingURI = '/3202/0/5700';

// Instantiate an mbed Device Connector object
var mbedConnectorApi = new MbedConnectorApi({
  accessKey: accessKey
});

// Create the express app
var app = express();
app.set('views', path.join(__dirname, 'views'));
app.set('view engine', 'hbs');
app.use(express.static(path.join(__dirname, 'public')));

app.get('/', function (req, res) {
  // Get all of the endpoints and necessary info to render the page
  mbedConnectorApi.getEndpoints(function(error, endpoints) {
    if (error) {
      throw error;
    } else {
      // Setup the function array
      var functionArray = endpoints.map(function(endpoint) {
        return function(mapCallback) {
          mbedConnectorApi.getResourceValue(endpoint.name, blinkPatternResourceURI, function(error, value) {
            endpoint.blinkPattern = value;
            mbedConnectorApi.getResourceValue(endpoint.name, colorResourceURI, function(error, value) {
              endpoint.color = value;
              mapCallback(error);
            });
          });
        };
      });

    // Fetch all blink patterns in parallel, finish when all HTTP
    // requests are complete (uses Async.js library)
      async.parallel(functionArray, function(error) {
        if (error) {
          res.send(String(error));
        } else {
          res.render('index', {
            endpoints: endpoints
          });
        }
      });
    }
  });
});

// Handle unexpected server errors
app.use(function(err, req, res, next) {
  console.log(err.stack);
  res.status(err.status || 500);
  res.render('error', {
    message: err.message,
    error: err
  });
});

var sockets = [];
var server = http.Server(app);
var io = ioLib(server);

// Setup sockets for updating web UI
io.on('connection', function (socket) {
  // Add new client to array of client upon connection
  sockets.push(socket);

  socket.on('subscribe-to-decode', function (data) {
    // Subscribe to all changes of resource /3202/0/5700 (Barcode decoded Data)
    mbedConnectorApi.putResourceSubscription(data.endpointName, ZXingURI, function(error) {
      if (error) throw error;
      socket.emit('subscribed-to-decode', {
        endpointName: data.endpointName
      });
    });
  });

  socket.on('unsubscribe-to-decode', function(data) {
    // Unsubscribe from the resource /3202/0/5700 (Barcode decoded Data)
    mbedConnectorApi.deleteResourceSubscription(data.endpointName, ZXingURI, function(error) {
      if (error) throw error;
      socket.emit('unsubscribed-to-decode', {
        endpointName: data.endpointName
      });
    });
  });

  socket.on('get-decode', function(data) {
    // Read data from GET resource /3202/0/5700 (Barcode decoded Data)
    mbedConnectorApi.getResourceValue(data.endpointName, ZXingURI, function(error, value) {
      if (error) throw error;
      socket.emit('decode', {
        endpointName: data.endpointName,
        value: value
      });
    });
  });

  socket.on('update-blink-pattern', function(data) {
    // Set data on PUT resource /3201/0/5853 (pattern of LED blink)
    mbedConnectorApi.putResourceValue(data.endpointName, blinkPatternResourceURI, data.blinkPattern, function(error) {
      if (error) throw error;
    });
  });

  socket.on('update-color', function(data) {
    // Set data on PUT resource /3201/0/5855 (LED color)
    mbedConnectorApi.putResourceValue(data.endpointName, colorResourceURI, data.color, function(error) {
      if (error) throw error;
    });
  });

  socket.on('blink', function(data) {
    // POST to resource /3201/0/5850 (start blinking LED)
    mbedConnectorApi.postResource(data.endpointName, blinkResourceURI, null, function(error) {
      if (error) throw error;
    });
  });

  socket.on('disconnect', function() {
    // Remove this socket from the array when a user closes their browser
    var index = sockets.indexOf(socket);
    if (index >= 0) {
      sockets.splice(index, 1);
    }
  })
});

// When notifications are received through the notification channel, pass the
// button presses data to all connected browser windows
mbedConnectorApi.on('notification', function(notification) {
  if (notification.path === ZXingURI) {
    sockets.forEach(function(socket) {
      socket.emit('decode', {
        endpointName: notification.ep,
        value: notification.payload
      });
    });
  }
});

// Start the app
server.listen(port, function() {
  // Set up the notification channel (pull notifications)
  mbedConnectorApi.startLongPolling(function(error) {
    if (error) throw error;
    console.log('mbed Device Connector Quickstart listening at http://localhost:%s', port);
  })
});