const SerialPort = require('serialport'); //for Serial library
var  MilkCocoa = require('milkcocoa'); // for milkcocoa api

var milkcocoa = MilkCocoa.connectWithApiKey('catjhyx3g1b.mlkcca.com','FIEFCOFMNIPCLKEC','GcXfFnkSCYEfcPfiJGKmnkRJUKkHLMlaJccNSnNG'); //ここには各自のAPIキーを入れる
const Readline = SerialPort.parsers.Readline;
const port = new SerialPort('dev/ttyACM0');
const parser = new Readline();
port.pipe(parser);
const data = parser.on('data', function(input){
  var buffer = new Buffer(input, 'utf8');
  var jsonData;
  try {
      jsonData = JSON.parse(buffer);
      var ds = milkcocoa.dataStore('messages');
      ds.push(jsonData);
  } catch(e) {
      // データ受信がおかしい場合無視する
      return;
  }
});