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

let gateway;
const sub_device1 = fixtures.sub_device1;
const sub_device2 = fixtures.sub_device2;

beforeAll(()=> {
  return new Promise((resolve, reject)=>{
    gateway = aliyunIot.gateway({...fixtures.sdk_gateway1});
    gateway.on('connect', () => {
      resolve();
    });
  })
},3000)

afterAll(() => {
  gateway.end();
});

describe('device test', () => {
  test('gateway connect linkPlatform should be ok', done => {
    if(gateway.connected){
      done();
    }
  });

  test('get topo should not be ok', done => {
    try {
        //网关获子设备 ok, aliyunIot.gateway#getTopo()
        gateway.getTopo(
          (res)=>{
              console.log('>>>>>getTopo',res)
              done();
          }
      );
    } catch (e) { console.error(e)}
  });

  test('add topo should not be ok', done => {
    try {
      // 添加topo ok 
      gateway.addTopo(
        [sub_device1,sub_device2],
        (res)=>{
          console.log('>>>>>addTopo',res.message,res.data);
          done();
        }
      );
    } catch (e) { console.error(e)}
  });

  test('delete topo should not be ok', done => {
    try {
      // 删除设备ok
      gateway.removeTopo( 
        [sub_device2],
        (res)=>{
            console.log('>>>>>removeTopo')
            console.log(res)
            done();
        }
    );
    } catch (e) { console.error(e)}
  });

  

});