const Buffer = require('buffer').Buffer;
const util = require('util');
const aliyunIot = require('../../lib');
const fixtures = require('../fixtures');

const device = aliyunIot.device({...fixtures.sdk_device1});
// base_sdk_device2
// const device = aliyunIot.device({ ...fixtures.base_sdk_device2})

// const deviceConfig = {
//     "productKey": "a1FVHNuAmvq",
//     "deviceName": "testdevice1",
//     "deviceSecret": "QNNcinhgbY5VgpnQT0DtIUXAlV4jYthO",
//     "region":"cn-shanghai"
//   }
// const device = aliyunIot.device(deviceConfig);

// device.subscribe(`${device.productKey}/${device.deviceName}/user/get`);
// device.on('message', (topic, payload) => {
//     console.log(topic, payload);
//     console.log("^:message",topic);
//     device.end();
// });

// 测试上报一条设备标签数据
device.on('connect', () => {

  // devicebeok() //测试动态注册
  console.log('>>>>>connect');
  // 上报设备属性
  device.onService('wakeup_sync', function (res) {
    // 处理服务参数
    console.log('1^:device.serve',res);
  });


});

// 测试直连设备动态注册功能 ok
function testDirectRegiest(){
  const registerDeviceInfo = {
    productKey:"a15YDgQGhU0",
    productSecret:"AP4HnuqhNqqArIkH",
    deviceName:"device1"
  }
  // 动态注册ok
  aliyunIot.register(registerDeviceInfo,(error,res)=>{
    if(error){console.log("register faild",error);return}
    console.log("register succeed,data:",res);
  })
}


// 测试直连设备动态注册功能 ok
function testSubDeivceRegiest(){
  const registerDeviceInfo = {
    productKey:"a15YDgQGhU0",
    productSecret:"AP4HnuqhNqqArIkH",
    deviceName:"device1"
  }
  // 动态注册ok
  aliyunIot.register(registerDeviceInfo,(error,res)=>{
    if(error){console.log("register faild",error);return}
    console.log("register succeed,data:",res);
  })
}


// 测试ok的
function devicebeok() {
  //连接ok
  console.log('>>>>>connect');
  
  // 上报设备属性
  device.postProps({
    LightSwitch: 0
  }, (res) => {
    console.log(res);
  });
  //订阅可以收到服务调用下发
  device.onService('wakeup_async', function (res) {
    // 处理服务参数
    console.log('1^:device.serve');
  });
  //重复订阅不会多次执行回调函数
  device.onService('wakeup_async', function (res) {
    // 处理服务参数
    console.log('1^:device.serve');
  });

  // postevent 事件上班 ok
  device.postEvent("lowpower", {
    power: 10,
  }, (res) => {
    console.log(`1postEvent:${res}`);
  })
  //回调函数不重复
  device.postEvent("lowpower", {
    power: 20,
  }, (res) => {
    console.log(`2postEvent:${res}`);
  })

  //删除标签ok
  device.deleteTags(['a'], (res) => {
    console.log(`tagid:${res.id}^ delete succeed`);
  });
  //删除多个标签回调函数不冲突
  device.deleteTags(['b'], (res) => {
    console.log(`tagid:${res.id}^ delete succeed`);
  });
  // 添加标签ok
  device.postTags(
    [{
        "attrKey": "Temperature",
        "attrValue": "311"
      },
      {
        "attrKey": "a",
        "attrValue": "avalue"
      },
      {
        "attrKey": "b",
        "attrValue": "bvalue"
      }
    ],
    (res) => {
      console.log(res);
    }
  );
  
  // 获取远程配置功能ok 
  device.getConfig((res) => {
    console.log(`getConfig:${res.data.toString()}`);
  });

  // 获取远程接收云端下发 todo
  device.onConfig((res) => {
    console.log(`onConfig:${res.data.toString()}`);
  });


  //订阅影子设备返回值
  device.onShadow((res) => {
    console.log('获取最新设备影子,%o', res);
  })
  // 设备主动获取影子 ok
  device.getShadow();
  // 设备上报实际值
  device.postShadow({
    a: "avalue11"
  });

  // 删除影子属性 ok
  // 参数 属性key，若为空则删除全部
  device.deleteShadow("a");
  device.deleteShadow(["a","b"]);
  device.deleteShadow()
  
}