let iot = require('iot');
let network = require('network');

let net = network.openNetWorkClient();

/* 设备三元组信息 */
let productKey = 'ibneFAfjvhy';
let deviceName = 'ElectricalFireMonitoringSystem';
let deviceSecret = '9dc9c43e02ad25448de2d0913b49f802';

let device;
let topic = '/sys/' + productKey + '/' + deviceName + '/thing/event/property/post';

/* 模拟属性数据：JSON字符串*/
let json = '{"RC":0.5,"LineCurrent":8.0,"LineVotage":210.0,"LinePower":20.0}';

function createDevice() {
    device = iot.device({
        productKey: productKey,
        deviceName: deviceName,
        deviceSecret: deviceSecret
    });

    device.on('connect', function() {
        console.log('(re)connected');

        device.subscribe({
            topic: topic,
            qos: 0
        });

        setInterval(function() {
            /* post props */
            device.postProps(json);
        }, 5000);

        /* 云端设置属性事件 */
        device.onProps(function(res) {
            console.log('cloud req msg_id is ' + res.msg_id);
            console.log('cloud req params_len is ' + res.params_len);
            console.log('cloud req params is ' + res.params);
        });

        /* 云端下发服务事件 */
        device.onService(function(res) {
            console.log('received cloud msg_id is ' + res.msg_id);
            console.log('received cloud service_id is ' + res.service_id);
            console.log('received cloud params_len is ' + res.params_len);
            console.log('received cloud params is ' + res.params);
        });
    });

    /* 网络断开事件 */
    device.on('disconnect', function() {
        console.log('disconnect ');
    });

    /* mqtt消息 */
    device.on('message', function(res) {
        console.log('mqtt message')
        console.log('mqtt topic is ' + res.topic);
        console.log('mqtt payload is ' + res.payload);
    })

    /* 关闭连接事件 */
    device.on('end', function() {
        console.log('iot client just closed');
    });

    /* 发生错误事件 */
    device.on('error', function(err) {
        console.log('error ' + err);
    });
}

let status = net.getStatus();
console.log('net status is: ' + status);

if (status == 'connect') {
    createDevice();
} else {
    net.on('connect', function() {
        createDevice();
    });
}