OTA-远程升级组件（阿里云物联网平台）

import * as network from 'network';
import * as iot from 'iot';
import * as appota from 'appota'
import * as fs from 'fs'

/* device info */
var productKey = '';      /* your productKey */
var deviceName = '';      /* your deviceName */
var deviceSecret = '';  /* your deviceSecret */
var app_module_name = 'default';
var default_ver = '1.0.0';
var resource_module_name = 'resource';
var resource_ver = '0.0.0';
var resource_ver_file_path = 'jsamp/resource.json';

var ota;
var device;
var status;

/* download info */
var info = {
  url: '',
  store_path:'jsamp/pack.bin', 
  install_path:'jsamp/', 
  unpack_path:'jsamp/',
  length: 0,
  hashType: '',
  hash: ''
}

function createDevice(){
  if (!(iot && iot.device)) {
    throw new Error("iot: [failed] require(\'iot\')");
  }
  console.log('iot: [success] require(\'iot\')');
  
  device = iot.device({
    productKey: productKey,
    deviceName: deviceName,
    deviceSecret: deviceSecret,
    region: 'cn-shanghai',
  });
  
  device.on('connect', function() {
    console.log('iot device connected success!');
    var iotDeviceHandle = device.getDeviceHandle();
    ota = appota.open(iotDeviceHandle);
    var res = ota.report({
      device_handle: iotDeviceHandle,
      product_key: productKey,
      device_name: deviceName,
      module_name: app_module_name,
      version: default_ver
    });
    console.log('report resource module ver!');
    var fsize = fs.fileSize(resource_ver_file_path);
    if (fsize <= 0) {
      resource_ver = '0.0.0';
    }
    else {
      console.log('==================');
      var resource_info_value = fs.readSync(resource_ver_file_path);
      var sver = JSON.parse(resource_info_value);
      console.log('resource ver ' + sver.version);
      resource_ver = sver.version;
    }
    var res = ota.report({
      device_handle: iotDeviceHandle,
      product_key: productKey,
      device_name: deviceName,
      module_name: resource_module_name,
      version: resource_ver
    });
    ota.on('new', function(res) {
      console.log('length is ' + res.length);
      console.log('module_name is ' + res.module_name);
      console.log('version is ' + res.version);
      console.log('url is ' + res.url);
      console.log('hash is ' + res.hash);
      console.log('hash_type is ' + res.hash_type);
      
      info.url = res.url;
      info.length = res.length;
      info.module_name = res.module_name;
      info.version = res.version;
      info.hash = res.hash;
      info.hashType = res.hash_type;
      
      if (info.module_name == 'system')
      {
        console.log('download system bin.');
        ota.sysUpgrade({
          length: info.length,
          hash_type: info.hashType,
          hash: info.hash,
          module_name: info.module_name,
          version: info.version,
          url: info.url
        }, function(res) {
          if (res >= 0) {
            console.log('system upgrade success');
          } else {
            console.log('system upgrade failed.');
          }
        })
      }
      else if (info.module_name == 'default') {
        ota.download({
          url: info.url,
          store_path: info.store_path
        }, function(res) {
          if (res >= 0) {
            console.log('verify start');
            console.log(info.hashType);
            ota.verify({
              length: info.length,
              hash_type: info.hashType,
              hash: info.hash,
              store_path: info.store_path
            }, function(res) {
              if (res >= 0) {
                ota.upgrade({
                  length: info.length,
                  store_path: info.store_path,
                  install_path: info.install_path
                }, function(res) {
                  if (res < 0) {
                    console.log('upgrade success')
                  }
                })
              } else {
                console.log('verify failed');
              }
            })
          } else {
            console.log('download failed');
          }
        });
      }
      else if (info.module_name == 'resource') {
        console.log('module name:  resource, begin download');
        ota.download({
          url: info.url,
          store_path: info.store_path
        }, function(res) {
          if (res >= 0) {
            console.log('resource verify start');
            console.log(info.hashType);
            ota.verify({
              length: info.length,
              hash_type: info.hashType,
              hash: info.hash,
              store_path: info.store_path
            }, function(res) {
              if (res >= 0) {
                ota.unpack({
                  length: info.length,
                  store_path: info.store_path,
                  unpack_path: info.unpack_path
                }, function(res) {
                  if (res >= 0) {
                    console.log('unpack success');
                    var new_fsize = fs.fileSize(resource_ver_file_path);
                    if (new_fsize <= 0) {
                      console.log('new resource file ' + resource_ver_file_path + 'size is 0');
                    }
                    else {
                      console.log('==================');
                      var new_info_value = fs.readSync(resource_ver_file_path);
                      console.log('new resource ' + new_info_value);
                      var new_ver = JSON.parse(new_info_value);
                      console.log('new resource ver ' + new_ver.version);
                      resource_ver = new_ver.version;
                    }
                    var res = ota.report({
                      device_handle: iotDeviceHandle,
                      product_key: productKey,
                      device_name: deviceName,
                      module_name: resource_module_name,
                      version: resource_ver
                    });
                  }
                  else {
                    console.log('unpack fail');
                  }
                })
              } else {
                console.log('resource verify failed');
              }
            });
          } else {
            console.log('resource download failed');
          }
        });
        console.log('resource download finish');
      }
    });
  })
}

var net=network.openNetWorkClient();
var status=net.getStatus();
console.log('net status is: '+status);

if (status=='connect') {
  createDevice();
}else{
  net.on('connect',function(){
    console.log('net is connected success!');
    createDevice();
  });
}