tado-client.js

const EXPIRATION_WINDOW_IN_SECONDS = 300;

// const tado_auth_url = 'https://auth.tado.com';
const tado_url = 'https://my.tado.com';
// const oauth_path = '/oauth/token';
// const tado_config = {
//     client: {
//         id: 'tado-web-app',
//         secret: 'wZaRN7rpjn3FoNyF5IFuxg9uMzYJcvOoQ8QWiIqS3hfk6gLhVlG57j5YNoZL2Rtc',
//     },
//     auth: {
//         tokenHost: tado_auth_url,
//     }
// }

// const oauth2 = require('simple-oauth2').create(tado_config);
const ClientOAuth2 = require('client-oauth2');
const axios = require('axios');
const auth = new ClientOAuth2({
  clientId: 'tado-web-app',
  clientSecret: 'wZaRN7rpjn3FoNyF5IFuxg9uMzYJcvOoQ8QWiIqS3hfk6gLhVlG57j5YNoZL2Rtc',
  accessTokenUri: 'https://auth.tado.com/oauth/token',
  authorizationUri: 'https://auth.tado.com/oauth/authorize',
  scopes: ['home.user']
})

class Tado {
  constructor(log) {
    this._accessToken;
    this.log = log;
  }

  _refreshToken() {
    const token = this._accessToken;
    const expirationTimeInSeconds = token.expires.getTime() / 1000;
    const expirationWindowStart = expirationTimeInSeconds - EXPIRATION_WINDOW_IN_SECONDS;

    // If the start of the window has passed, refresh the token
    const nowInSeconds = (new Date()).getTime() / 1000;
    const shouldRefresh = nowInSeconds >= expirationWindowStart;

    return new Promise((resolve, reject) => {
      if (shouldRefresh) {
        this.log.info("Refreshing token");
        this._accessToken.refresh()
          .then(result => {
            this.log.info("Token refreshed");
            this._accessToken = result;
            resolve(this._accessToken);
          })
          .catch(error => {
            this.log.info("Token refresh failed");
            reject(error);
          });
      } else {
        this.log.info("Returning current accesstoken");
        resolve(this._accessToken);
      }
    });
  }

  login(username, password) {
    return new Promise((resolve, reject) => {
      // const credentials = {
      //     scope: 'home.user',
      //     username: username,
      //     password: password
      // };
      this.log.info("Fetching access token");
      auth.owner.getToken(username, password)
        .then(result => {
          this.log.info("succesfully fetched access token");
          this._accessToken = result;
          resolve(result);
        }, error => {
          this.log.info("error on getToken");
          reject(error);
        });
      // oauth2.ownerPassword.getToken(credentials)
      //     .then(result => {
      //         this._accessToken = oauth2.accessToken.create(result);
      //         resolve(this._accessToken);
      //     })
      //     .catch(error => {
      //         reject(error);
      //     });
    });
  }

  apiCall(url, method = 'get', data = {}) {
    return new Promise((resolve, reject) => {
      this.log.info("api call");
      if (this._accessToken) {
        this._refreshToken().then(() => {
          this.log.info("calling api using axios");
          axios({
            url: tado_url + url,
            method: method,
            data: data,
            headers: {
              Authorization: 'Bearer ' + this._accessToken.accessToken
            }
          }).then(response => {
            this.log.info("succesfully called api");
            resolve(response.data);
          }).catch(error => {
            this.log.info("error calling api");
            reject(error);
          });
        });
      } else {
        this.log.info("Error: no accesstoken");
        reject(new Error('Not yet logged in'));
      }
    });
  }

  getMe() {
    return this.apiCall('/api/v2/me');
  }

  getHome(home_id) {
    return this.apiCall(`/api/v2/homes/${home_id}`);
  }

  getWeather(home_id) {
    return this.apiCall(`/api/v2/homes/${home_id}/weather`);
  }

  getDevices(home_id) {
    return this.apiCall(`/api/v2/homes/${home_id}/devices`);
  }

  getInstallations(home_id) {
    return this.apiCall(`/api/v2/homes/${home_id}/installations`);
  }

  getUsers(home_id) {
    return this.apiCall(`/api/v2/homes/${home_id}/users`);
  }

  getState(home_id) {
    return this.apiCall(`/api/v2/homes/${home_id}/state`);
  }

  getMobileDevices(home_id) {
    return this.apiCall(`/api/v2/homes/${home_id}/mobileDevices`);
  }

  getMobileDevice(home_id, device_id) {
    return this.apiCall(`/api/v2/homes/${home_id}/mobileDevices/${device_id}`);
  }

  getMobileDeviceSettings(home_id, device_id) {
    return this.apiCall(`/api/v2/homes/${home_id}/mobileDevices/${device_id}/settings`);
  }

  getZones(home_id) {
    return this.apiCall(`/api/v2/homes/${home_id}/zones`);
  }

  getZoneState(home_id, zone_id) {
    return this.apiCall(`/api/v2/homes/${home_id}/zones/${zone_id}/state`);
  }

  getZoneCapabilities(home_id, zone_id) {
    return this.apiCall(`/api/v2/homes/${home_id}/zones/${zone_id}/capabilities`);
  }

  getZoneOverlay(home_id, zone_id) {
    return this.apiCall(`/api/v2/homes/${home_id}/zones/${zone_id}/overlay`);
  }

  getTimeTables(home_id, zone_id) {
    return this.apiCall(`/api/v2/homes/${home_id}/zones/${zone_id}/schedule/activeTimetable`);
  }

  getAwayConfiguration(home_id, zone_id) {
    return this.apiCall(`/api/v2/homes/${home_id}/zones/${zone_id}/awayConfiguration`);
  }

  getTimeTable(home_id, zone_id, timetable_id) {
    return this.apiCall(`/api/v2/homes/${home_id}/zones/${zone_id}/schedule/timetables/${timetable_id}/blocks`);
  }

  clearZoneOverlay(home_id, zone_id) {
    return this.apiCall(`/api/v2/homes/${home_id}/zones/${zone_id}/overlay`, 'delete');
  }

  setZoneOverlay(home_id, zone_id, power, temperature, termination) {
    var config = {
      setting: {
        type: "HEATING",
      },
      termination: {
      }
    }

    if (power.toLowerCase() == 'on') {
      config.setting.power = 'ON';

      if (temperature) {
        config.setting.temperature = {};
        config.setting.temperature.celsius = temperature;
      }
    } else {
      config.setting.power = 'OFF';
    }

    if (!isNaN(parseInt(termination))) {
      config.termination.type = 'TIMER';
      config.termination.durationInSeconds = termination;
    } else if (termination && termination.toLowerCase() == 'auto') {
      config.termination.type = 'TADO_MODE';
    } else {
      config.termination.type = 'MANUAL';
    }

    return this.apiCall(`/api/v2/homes/${home_id}/zones/${zone_id}/overlay`, 'put', config);
  }

  identifyDevice(device_id) {
    return this.apiCall(`/api/v2/devices/${device_id}/identify`, 'post');
  }
}

module.exports = Tado;