Scout Robot Car

// Copyright (c) Microsoft. All rights reserved.
// Licensed under the MIT license. See LICENSE file in the project root for full license information.

'use strict';

// Azure IoT packages
var Protocol = require('azure-iot-device-http').Http;
var Client = require('azure-iot-device').Client;
var ConnectionString = require('azure-iot-device').ConnectionString;
var Message = require('azure-iot-device').Message;

var keypress = require('keypress');
var five = require("johnny-five"),
  board, motor, led;
var BLESerialPort = require('ble-serial').SerialPort;
var bleSerial = new BLESerialPort();
var board = new five.Board({port: bleSerial, repl: false});

var hostName        = '<IOTHUB_HOST_NAME>';
var deviceId        = '<DEVICE_ID>';
var sharedAccessKey = '<SHARED_ACCESS_KEY>';

// String containing Hostname, Device Id & Device Key in the following formats:
//  "HostName=<iothub_host_name>;DeviceId=<device_id>;SharedAccessKey=<device_key>"
var connectionString = 'HostName=' + hostName + ';DeviceId=' + deviceId + ';SharedAccessKey=' + sharedAccessKey;

// Sensor data
var temperature = 0;
var humidity = 0;
var externalTemperature = 0;

// Create IoT Hub client
var client = Client.fromConnectionString(connectionString, Protocol);

// Helper function to print results for an operation
function printErrorFor(op) {
  return function printError(err) {
    if (err) console.log(op + ' error: ' + err.toString());
  };
}

// Send device meta data
var deviceMetaData = {
  'ObjectType': 'DeviceInfo',
  'IsSimulatedDevice': 0,
  'Version': '1.0',
  'DeviceProperties': {
    'DeviceID': deviceId,
    'HubEnabledState': 1,
    'CreatedTime': '2015-09-21T20:28:55.5448990Z',
    'DeviceState': 'normal',
    'UpdatedTime': null,
    'Manufacturer': 'Intel',
    'ModelNumber': 'Edison',
    'SerialNumber': '12345678',
    'FirmwareVersion': '159',
    'Platform': 'node.js',
    'Processor': 'Intel',
    'InstalledRAM': '64 MB',
    'Latitude': 47.617025,
    'Longitude': -122.191285
  },
  'Commands': [{
    'Name': 'SetTemperature',
    'Parameters': [{
      'Name': 'Temperature',
      'Type': 'double'
    }]
  },
    {
      'Name': 'SetHumidity',
      'Parameters': [{
        'Name': 'Humidity',
        'Type': 'double'
      }]
    }]
};


board.on("ready", function() {
  var temp = new five.Temperature({
    pin: "A0",
    controller: "GROVE"
  });
  
  // --------------CONTROL.JS PART --------------------
  
   //load atafruit motor shield configs
  var configs = five.Motor.SHIELD_CONFIGS.ADAFRUIT_V2;
  //create each motor
  var motor1 = new five.Motor(configs.M1);
  var motor2 = new five.Motor(configs.M2);
  var motor3 = new five.Motor(configs.M3);
  var motor4 = new five.Motor(configs.M4);

  //set high level drive functions
  function forward(speed){
    motor1.reverse(speed);
    motor2.forward(speed);
    motor3.forward(speed);
    motor4.reverse(speed);
    }

  function reverse(speed){
    motor1.forward(speed);
    motor2.reverse(speed);
    motor3.reverse(speed);
    motor4.forward(speed);
    }

  function left(speed){
    motor1.forward(speed);
    motor2.forward(speed);
    motor3.forward(speed);
    motor4.forward(speed);
    }

  function right(speed){
    motor1.reverse(speed);
    motor2.reverse(speed);
    motor3.reverse(speed);
    motor4.reverse(speed);
    }

    function stop(){
      motor1.stop();
      motor2.stop();
      motor3.stop();
      motor4.stop();
      }

  // make `process.stdin` begin emitting "keypress" events
    keypress(process.stdin);

    // listen for the "keypress" event
  process.stdin.on('keypress', function (ch, key) {
    console.log('got "keypress"', key);

    //make it so you can close the process with ctrl-c...
    if (key && key.ctrl && key.name == 'c') {
          process.exit();
        }

    if (key && key.name == 'w') {
      forward(255);
      console.log('forward command');

    }

    if (key && key.name == 's') {
      reverse(255);
      console.log('reverse command');

    }

    if (key && key.name == 'a') {
      left(255);
      console.log('left command');

    }

    if (key && key.name == 'd') {
      right(255);
      console.log('right command');

    }

    if (key && key.name == 'q') {
      stop();
      console.log('stop');

    }

  });

  process.stdin.setRawMode(true);

// ------------------- End Control.js ----------------------

  client.open(function (err, result) {
    if (err) {
      printErrorFor('open')(err);
    } else {
      console.log('Sending device metadata:\n' + JSON.stringify(deviceMetaData));
      client.sendEvent(new Message(JSON.stringify(deviceMetaData)), printErrorFor('send metadata'));

      client.on('message', function (msg) {
        console.log('receive data: ' + msg.getData());

        try {
          var command = JSON.parse(msg.getData());

          switch (command.Name) {
            case 'SetTemperature':
              temperature = command.Parameters.Temperature;
              console.log('New temperature set to :' + temperature + 'F');
              client.complete(msg, printErrorFor('complete'));
              break;
            case 'SetHumidity':
              humidity = command.Parameters.Humidity;
              console.log('New humidity set to :' + humidity + '%');
              client.complete(msg, printErrorFor('complete'));
              break;
            default:
              console.error('Unknown command: ' + command.Name);
              client.reject(msg, printErrorFor('complete'));
              break;
          }
        }
        catch (err) {
          printErrorFor('parse received message')(err);
          client.reject(msg, printErrorFor('reject'));
        }
      });

      // start event data send routing
      var sendInterval = setInterval(function () {
        temperature = temp.celsius;
        var data = JSON.stringify({
          'DeviceID': deviceId,
          'Temperature': temperature,
          'Humidity': humidity,
          'ExternalTemperature': externalTemperature
        });

        console.log('Sending device event data:\n' + data);
        client.sendEvent(new Message(data), printErrorFor('send event'));
      }, 1000);

      client.on('error', function (err) {
        printErrorFor('client')(err);
        if (sendInterval) clearInterval(sendInterval);
        client.close();
      });
    }
  });
});

{
  "name": "azure-samples-node-edison-rm",
  "version": "0.0.1",
  "private": true,
  "description": "Remote monitoring sample demonstrating how to use the Azure IoT device SDK for Node.js on the Intel Edison",
  "author": "Microsoft Corp.",
  "license": "MIT",
  "dependencies": {
    "azure-iot-common": "1.0.2",
    "azure-iot-device": "1.0.2",
    "azure-iot-device-amqp": "1.0.2",
    "azure-iot-device-http": "1.0.2",
    "azure-iot-device-mqtt": "1.0.2",
    "edison-io": "^0.9.4",
    "johnny-five": "^0.9.33"
  },
  "devDependencies": {
    "jshint": "^2.8.0"
  },
  "scripts": {
    "lint": "jshint --show-non-errors .",
    "test": "npm -s run lint"
  }
}