node_helper.js

const NodeHelper = require("node_helper");
const request = require("request");
const jsonfile = require("./lib/jsonfile.js");
const path = require("path");
const dataFile = path.resolve(__dirname, "data.json");

module.exports = NodeHelper.create({

  client_id: "846766038767-8fs63le8h45dhjpf0umhc1ai07q4rhn7.apps.googleusercontent.com",
  client_secret: "kbJlTr7uQPCiClb5JSrGE-Ve",
  config: {
    //refresh_token
  },

  debug: false,

  tmpAuthData: undefined,
  tmpAccessToken: undefined,

  start: function () {
    console.log("MMM-GoogleFit helper started...");

    if (this.debug) {
      console.log(process.versions);
    }

    try {
      var c = jsonfile.readFileSync(dataFile);
      if (c.refresh_token) {
        this.config = c;
      }
    } catch (error) {
      // Probably have not yet written the file, no worries
    }
  },

  getAuthCode: function() {
    var self = this;

    var url = "https://accounts.google.com/o/oauth2/device/code";
    var scopes = "email profile https://www.googleapis.com/auth/fitness.activity.read https://www.googleapis.com/auth/fitness.body.read";

    request.post(url, { form: { client_id: self.client_id, scope: scopes } }, function(error, response, body) {
      if (!error && response.statusCode == 200) {
        var data = JSON.parse(body);
        self.tmpAuthData = data;

        self.sendSocketNotification("AUTH_CODE_BODY", data);
        self.getRefreshToken();
      } else {
        self.sendSocketNotification("AUTH_CODE_ERROR", response);
      }

      self.logRequest("getAuthCode", error, response, body);
    });
  },

  getRefreshToken: function () {
    var self = this;
    var url = "https://www.googleapis.com/oauth2/v4/token";
    var grant = "http://oauth.net/grant_type/device/1.0";

    request.post(url, { form: { client_id: self.client_id, client_secret: self.client_secret, code: self.tmpAuthData.device_code, grant_type: grant } }, function (error, response, body) {
      if (!error && response.statusCode == 200) {
        var data = JSON.parse(body);
        self.sendSocketNotification("REFRESH_TOKEN_BODY", data);

        self.config.refresh_token = data.refresh_token;
        self.writeConfig();

        self.getAccessToken();
      } else {
        console.error(response)
        self.sendSocketNotification("REFRESH_TOKEN_ERROR", response);
        setTimeout(function() { self.getRefreshToken() }, 10000);
      }

      self.logRequest("getRefreshToken", error, response, body);
    });
  },

  getAccessToken: function(clientConfig) {
    var self = this;
    var url = "https://www.googleapis.com/oauth2/v4/token";
    var grant = "refresh_token";

    request.post(url, { form: { client_id: self.client_id, client_secret: self.client_secret, refresh_token: self.config.refresh_token, grant_type: grant } }, function (error, response, body) {
      if (!error && response.statusCode == 200) {
        var data = JSON.parse(body);
        self.sendSocketNotification("ACCESS_TOKEN_BODY", data);
        self.tmpAccessToken = data;

        self.getStats(clientConfig);
      } else {
        self.sendSocketNotification("ACCESS_TOKEN_ERROR", response);
      }

      self.logRequest("getAccessToken", error, response, body);
    });
  },

  logRequest: function(title, error, response, body) {
    if (this.debug) {
      console.log(title);
      console.log("---------------------------------------------------------------------------------------------");
      console.log("error");
      console.log(error);
      console.log("response");
      console.log(response);
      console.log("body");
      console.log(body);
    }
  },

  getStats: function (clientConfig) {
    var self = this;
    // self.sendSocketNotification("STATS", self.debugData);
    // return;

    var url = "https://www.googleapis.com/fitness/v1/users/me/dataset:aggregate";

    var now = new Date();

    var req = {
      "aggregateBy": [{
        "dataSourceId": "derived:com.google.step_count.delta:com.google.android.gms:estimated_steps"
      }],
      "bucketByTime": { "durationMillis": 86400000 }, // 1 day per bucket
      "startTimeMillis": clientConfig.startTimeMillis,
      "endTimeMillis": clientConfig.endTimeMillis
    };

    if (clientConfig.displayWeight) {
      req.aggregateBy.push({
        "dataSourceId": "derived:com.google.weight:com.google.android.gms:merge_weight"
      });
    }

    var options = {
      url: url,
      json: req,
      headers: {
        Authorization: "Bearer " + self.tmpAccessToken.access_token
      }
    }

    request.post(options, function (error, response, body) {
      if (!error && response.statusCode == 200) {
        // body is already json at this point
        self.sendSocketNotification("STATS", body);
      } else {
        self.sendSocketNotification("STATS_ERROR", error);
        self.sendSocketNotification("STATS_ERROR", response);
        self.sendSocketNotification("STATS_ERROR", body);
      }

      self.logRequest("getStats", error, response, body);
    });
  },

  writeConfig: function() {
    jsonfile.writeFileSync(dataFile, this.config, { spaces: 2 });
  },

  //Subclass socketNotificationReceived received.
  socketNotificationReceived: function(notification, payload) {
    if (notification === "UPDATE") {
      if (this.config.refresh_token) {
        this.sendSocketNotification("REFRESH_TOKEN_BODY", this.config.refresh_token);
        this.getAccessToken(payload); // This will get an access token and then get stats afterwards if successful (payload is if we want last monday/sunday)
      } else if (this.tmpAuthData) {
        // Just in case refreshing the page before auth complete
        this.sendSocketNotification("AUTH_CODE_BODY", this.tmpAuthData);

        this.getRefreshToken();
      } else {
        this.getAuthCode();
      }
    }
  },

  debugData: { "bucket": [{ "startTimeMillis": "1515909600000", "endTimeMillis": "1515996000000", "dataset": [{ "dataSourceId": "derived:com.google.step_count.delta:com.google.android.gms:aggregated", "point": [{ "startTimeNanos": "1515913323392740449", "endTimeNanos": "1515996000000000000", "dataTypeName": "com.google.step_count.delta", "originDataSourceId": "raw:com.google.step_count.cumulative:Google:Pixel:a6e7d67b35d2c787:BMI160 Step counter", "value": [{ "intVal": 2823, "mapVal": [] }] }] }, { "dataSourceId": "derived:com.google.weight.summary:com.google.android.gms:aggregated", "point": [] }] }, { "startTimeMillis": "1515996000000", "endTimeMillis": "1516082400000", "dataset": [{ "dataSourceId": "derived:com.google.step_count.delta:com.google.android.gms:aggregated", "point": [{ "startTimeNanos": "1515996000000000000", "endTimeNanos": "1516079347050375104", "dataTypeName": "com.google.step_count.delta", "originDataSourceId": "raw:com.google.step_count.cumulative:Google:Pixel:a6e7d67b35d2c787:BMI160 Step counter", "value": [{ "intVal": 10226, "mapVal": [] }] }] }, { "dataSourceId": "derived:com.google.weight.summary:com.google.android.gms:aggregated", "point": [{ "startTimeNanos": "1516000634476000000", "endTimeNanos": "1516000634476000000", "dataTypeName": "com.google.weight.summary", "originDataSourceId": "raw:com.google.weight:com.popularapp.sevenmins:", "value": [{ "fpVal": 72.57477569580078, "mapVal": [] }, { "fpVal": 72.57477569580078, "mapVal": [] }, { "fpVal": 72.57477569580078, "mapVal": [] }] }] }] }, { "startTimeMillis": "1516082400000", "endTimeMillis": "1516168800000", "dataset": [{ "dataSourceId": "derived:com.google.step_count.delta:com.google.android.gms:aggregated", "point": [{ "startTimeNanos": "1516114999272563632", "endTimeNanos": "1516158363087565706", "dataTypeName": "com.google.step_count.delta", "originDataSourceId": "raw:com.google.step_count.cumulative:Google:Pixel:a6e7d67b35d2c787:BMI160 Step counter", "value": [{ "intVal": 1598, "mapVal": [] }] }] }, { "dataSourceId": "derived:com.google.weight.summary:com.google.android.gms:aggregated", "point": [] }] }, { "startTimeMillis": "1516168800000", "endTimeMillis": "1516255200000", "dataset": [{ "dataSourceId": "derived:com.google.step_count.delta:com.google.android.gms:aggregated", "point": [] }, { "dataSourceId": "derived:com.google.weight.summary:com.google.android.gms:aggregated", "point": [] }] }, { "startTimeMillis": "1516255200000", "endTimeMillis": "1516341600000", "dataset": [{ "dataSourceId": "derived:com.google.step_count.delta:com.google.android.gms:aggregated", "point": [] }, { "dataSourceId": "derived:com.google.weight.summary:com.google.android.gms:aggregated", "point": [] }] }, { "startTimeMillis": "1516341600000", "endTimeMillis": "1516428000000", "dataset": [{ "dataSourceId": "derived:com.google.step_count.delta:com.google.android.gms:aggregated", "point": [] }, { "dataSourceId": "derived:com.google.weight.summary:com.google.android.gms:aggregated", "point": [] }] }, { "startTimeMillis": "1516428000000", "endTimeMillis": "1516514399999", "dataset": [{ "dataSourceId": "derived:com.google.step_count.delta:com.google.android.gms:aggregated", "point": [] }, { "dataSourceId": "derived:com.google.weight.summary:com.google.android.gms:aggregated", "point": [] }] }] }

});