/*
  neqto:  IIJ IoT sample
*/
var IIJ_IOT_HOST = 'gw.iot.iij.jp';
var IIJ_IOT_PORT = 80;
var IIJ_IOT_SEND_PATH = '/v1';
var IIJ_IOT_STATUS_PATH = '/v1/dvc-state/json';
var IIJ_IOT_DEFAULT_TIMEOUT = 10 * 1000;
 
/**
 * IoTサービスにデータ送信する
 * @param {Object} json_data 送信するJSONオブジェクト
 * @param {Number} timeout POSTのタイムアウト(ms) default:10000ms
 * @return {Number} エラーコード 0:正常 0以外:異常
 */
function send_to_iot(json_data, timeout) {
    timeout === undefined ? IIJ_IOT_DEFAULT_TIMEOUT:timeout;
 
    var fin_flg = false;
    var fin_code = 0;
    var body = JSON.stringify(json_data);
    var header = {'Content-Type':'application/json;charset=UTF-8', 'Content-Length': body.length.toString()};
    var options = {method:'POST', host:IIJ_IOT_HOST, port:IIJ_IOT_PORT, path:IIJ_IOT_SEND_PATH, headers:header};
    var request = http.request(options, function(res){
        fin_flg = true;
    }, timeout);
    request.on('error', function() {
        fin_code = request.errCode;
        fin_flg = true;
    });
    request.write(body);
    request.end();
 
    //レスポンスが返ってくるまで待つ
    while(!fin_flg) {
        setTimeout(50).wait();
    }
    setTimeout(500).wait();
 
    return fin_code;   
}
 
/**
 * IoTサービスに設定されているデバイスのステータスを取得する
 * @param {Number} timeout POSTのタイムアウト(ms) default:10000ms
 * @return {Object} ステータスのJSONオブジェクト エラー時はnull
 */
function get_device_status(timeout) {
    timeout === undefined ? IIJ_IOT_DEFAULT_TIMEOUT:timeout;
 
    var fin_flg = false;
    var fin_code = 0;
    var body = '';
    var header = {};
    var options = {method:'GET', host:IIJ_IOT_HOST, port:IIJ_IOT_PORT, path:IIJ_IOT_STATUS_PATH, headers:header};
    var request = http.request(options, function(res){
        res.on('readable', function() {
            body += res.read();
        });
        res.on('end', function() {
            body += res.read();
            fin_flg = true;
        })
    }, timeout);
    request.on('error', function() {
        fin_code = request.errCode;
        fin_flg = true;
    });
    request.end();
 
    //レスポンスが返ってくるまで待つ
    while(!fin_flg) {
        setTimeout(50).wait();
    }
    setTimeout(500).wait();
 
    if(fin_code != 0 || body == "")   return null;
    return JSON.parse(body);
}

//--------------------------------------------------
// ここからは動作サンプル
log.setLevel(0);   //-1:NONE 0:ERROR 1:WARNING 2:DEBUG 3:TRACE
log.printLevel(3);  //0:DISABLE 1:LOG 2:CONSOLE 3:BOTH
log.clear();

var wait_time = 60;

while(1) {
    //IoTサービスにランダム値を送信する
    var data = {
        "namespace":"neqto",
        "name":"random",
        "value": Math.random() *100
    };
    var res = send_to_iot(data);
    if (res == 0) {
        print("data send OK. value=" + data["value"]);
    } else {
        print("data send ERROR. code=" + res);
    }

    //待ち
    setTimeout(1000 * wait_time).wait();
}

//--------------------------------------------------
// ここからは動作サンプル
   :
  中略
   :
while(1) {
    //--- ↓ここを追記する  ------------------------
    //IoTサービスからラベルを取得する
    var st = get_device_status();
    var label = st["labelContents"];
    if (label != null && label != undefined) {
        print("label=" + JSON.stringify(label));
        var w = label["wait"];
        if (w != undefined && !isNaN(w)) {
            wait_time = parseInt(w, 10);
        }
    }
    //--- ↑ここを追記する  ------------------------
 
   :
  中略
   :
}