Connect to Tuya Cloud - NodeJS

tuya-nodejs-lib.js

const CryptoJS = require('crypto-js');
const axios = require('axios');

class TuyaAPIClient {
    constructor(options) {
    this.options = options;
    this.options.baseURL = 'https://openapi.tuyaus.com/v1.0';
    this.options.access_token="";

  }

 async  initClient(){
     await this.getAccessToken(this.options.client_id,this.options.secret);

  }
  getDefaultHeaders() {
    const timestamp = this.getTime();
    const signature = this.computeSignature(
      this.options.client_id,
      this.options.access_token,
      this.options.secret,
      timestamp
    );
    const headerParams = {
      client_id: this.options.client_id,
      access_token: this.options.access_token,
      sign: signature,
      t: timestamp,
      sign_method: 'HMAC-SHA256',
    };

    return headerParams;
  }

  async makePostRequest(resource,body) {
    //curlirize(axios);
    const headers = this.getDefaultHeaders();
    const baseURL = this.options.baseURL;
    try {
        return axios({
            baseURL: baseURL,
            url: resource,
            method: "POST",
            data: JSON.stringify(body),
            headers: {...headers,"Content-Type":"application/json"},
            maxRedirects: 5
          })
      } catch (error) {
        console.error(error)
      }

  }

  async makeRequest(resource, urlParams,method) {
    const headers = this.getDefaultHeaders();
    const baseURL = this.options.baseURL;
    try {
        return axios({
            baseURL: baseURL,
            url: resource,
            method: method || 'GET',
           // data: body ? body : null,
            headers: headers,
            maxRedirects: 5,
            params: urlParams ? urlParams : null,
          })
      } catch (error) {
        console.error(error)
      }

  }

  getTime() {
    const timestamp = new Date().getTime();
    return timestamp;
  }


  async getAccessToken(clientId, secret) {
    this.options.access_token="";
    const resp=await this.makeRequest("/token?grant_type=1");
    this.options.access_token=resp.data.result.access_token;

  }

  computeSignature(clientId, accessToken,secret, timestamp) {
    var str = clientId + accessToken + timestamp;
    const hash = CryptoJS.HmacSHA256(str, secret);
    const hashInBase64 = hash.toString();
    const signature = hashInBase64.toUpperCase();
    return signature;
  }

  async changeDeviceState(deviceId,switchType, changeToState) {
   const deviceParams= {
      "commands":[
        {
          "code": switchType,
          "value":changeToState
        }
      ]
    }
    return await this.makePostRequest(`/devices/${deviceId}/commands`,deviceParams);
  }


  async getDeviceInfo(deviceId) {

    return await this.makeRequest(`/devices/${deviceId}`);
  }

}

module.exports = TuyaAPIClient;

Usage :

const tuyaClient = new TuyaClient(tuyaCreds);
await tuyaClient.initClient();
const deviceInfo =await tuyaClient.getDeviceInfo("deviceId");
//change device state
await tuyaClient.changeDeviceState("deviceId","switch_1",true)