node_helper.js

/*
  Node Helper module for MMM-MicrosoftToDo

  Purpose: Microsoft's OAutht 2.0 Token API endpoint does not support CORS,
  therefore we cannot make AJAX calls from the browser without disabling
  webSecurity in Electron.
*/
var NodeHelper = require('node_helper')
const request = require('request')

module.exports = NodeHelper.create({

  start: function () {
    console.log(this.name + ' helper started ...')
  },

  socketNotificationReceived: function (notification, payload) {
    if (notification === 'FETCH_DATA') {
      this.fetchData(payload)
    } else if (notification === 'COMPLETE_TASK') {
      this.completeTask(payload.taskId, payload.config)
    } else {
      console.log(this.name + ' - Did not process event: ' + notification)
    }
  },

  completeTask: function (taskId, config) {
    // copy context to be available inside callbacks
    var self = this

    var completeTaskUrl = 'https://graph.microsoft.com/beta/me/outlook/tasks/' + taskId + '/complete'

    request.post({
      url: completeTaskUrl,
      headers: {
        Authorization: 'Bearer ' + self.accessToken
      }
    }, function (error, response, body) {
      if (error) {
        console.error(self.name + ' - Error while requesting access token:')
        console.error(error)
        return
      }

      if (body && JSON.parse(body).error) {
        console.error(self.name + ' - Error while completing tasks:')
        console.error(JSON.parse(body).error)
        self.sendSocketNotification('COMPLETE_TASK_ERROR', { error: JSON.parse(body).error.code, errorDescription: JSON.parse(body).error.message })
        return
      }

      console.log(this.name + ' - Completed task with ID: ' + taskId)

      // update front-end about success to trigger a refresh of the task list
      self.sendSocketNotification('TASK_COMPLETED_' + config.id)
    })
  },

  getTodos: function (config) {
    // copy context to be available inside callbacks
    var self = this

    // get access token
    var tokenUrl = 'https://login.microsoftonline.com/common/oauth2/v2.0/token'
    var refreshToken = config.oauth2RefreshToken
    var data = {
      client_id: config.oauth2ClientId,
      scope: 'offline_access user.read ' + (config.completeOnClick ? 'tasks.readwrite' : 'tasks.read'),
      refresh_token: refreshToken,
      grant_type: 'refresh_token',
      client_secret: config.oauth2ClientSecret
    }
    request.post({
      url: tokenUrl,
      form: data
    },
    function (error, response, body) {
      if (error) {
        console.error(self.name + ' - Error while requesting access token:')
        console.error(error)
        return
      }

      if (body && JSON.parse(body).error) {
        console.error(self.name + ' - Error while requesting access token:')
        console.error(JSON.parse(body))

        self.sendSocketNotification('FETCH_INFO_ERROR_' + config.id, { error: JSON.parse(body).error, errorDescription: JSON.parse(body).error_description })

        return
      }

      const accessTokenJson = JSON.parse(body)
      var accessToken = accessTokenJson.access_token
      self.accessToken = accessToken

      // get tasks
      var _getTodos = function () {
        var orderBy = (config.orderBy === 'subject' ? '&$orderby=subject' : '') + (config.orderBy === 'dueDate' ? '&$orderby=duedatetime/datetime' : '')

        // Adding "if statement" to support "predefined/dynamic lists" from Microsoft
        if (config.dynamicList === undefined || config.dynamicList === '') {
          var listUrl = 'https://graph.microsoft.com/beta/me/outlook/taskFolders/' + config._listId + '/tasks?$select=subject,status,duedatetime&$top=' + config.itemLimit + '&$filter=status%20ne%20%27completed%27' + orderBy
        } else if (config.dynamicList === 'important') {
          // filter the predefined/dynamic list "Important"
          // To-Do for feature: adding support for all "predefined/dynamic lists"
          var listUrl = 'https://graph.microsoft.com/beta/me/outlook/taskFolders/' + config._listId + '/tasks?$select=subject,status,duedatetime&$top=' + config.itemLimit + '&$filter=status%20ne%20%27completed%27%20and%20importance%20eq%20%27high%27' + orderBy
        }

        request.get({
          url: listUrl,
          headers: {
            Authorization: 'Bearer ' + accessToken
          }
        }, function (error, response, body) {
          if (error) {
            console.error(self.name + ' - Error while requesting access token:')
            console.error(error)
          }

          if (body && JSON.parse(body).error) {
            console.error(self.name + ' - Error while requesting tasks:')
            console.error(JSON.parse(body).error)

            self.sendSocketNotification('FETCH_INFO_ERROR_' + config.id, { error: JSON.parse(body).error.code, errorDescription: JSON.parse(body).error.message })

            return
          }

          // send tasks to front-end
          const tasksJson = JSON.parse(body)
          self.sendSocketNotification('DATA_FETCHED_' + config.id, tasksJson.value)
        })
      }

      // get ID of task folder
      var taksFoldersUrl = 'https://graph.microsoft.com/beta/me/outlook/taskFolders/?$top=200'

      request.get({
        url: taksFoldersUrl,
        headers: {
          Authorization: 'Bearer ' + accessToken
        }
      }, function (error, response, body) {
        if (error) {
          console.error(self.name + ' - Error while requesting task folders:')
          console.error(error)

          self.sendSocketNotification('FETCH_INFO_ERROR_' + config.id, { error: 'Error while requesting task folders', errorDescription: error })

          return
        }

        // parse response from Microsoft
        var list = JSON.parse(body)

        // if list name was provided, retrieve its ID
        if (config.listName !== undefined && config.listName !== '') {
          list.value.forEach(element => element.name === config.listName ? (config._listId = element.id) : '')
        } else if (config.listId !== undefined && config.listId !== '') {
          // if list ID was provided copy it to internal list ID config and show deprecation warning
          config._listId = config.listId
          console.warn(self.name + ' - Warning, configuration parameter listId is deprecated, please use listName instead, otherwise the module will not work anymore in the future.')
          // TODO: during the next release uncomment the following line to not show the todo list, but the error message instead
          // self.sendSocketNotification('FETCH_INFO_ERROR_' + config.id, {
          // error: 'Config param "listId" is deprecated, use "listName" instead',
          // errorDescription: 'The configuration parameter listId is deprecated, please use listName instead. See https://github.com/thobach/MMM-MicrosoftToDo/blob/master/README.MD#installation' })
        } else if (config.dynamicList === 'important') {
          // if dynamicList is set, create an array of listId's
          list.value.foreach(element => config._listId = element.id)
        } else {
          // otherwise identify the list ID of the default task list first
          // set listID to default task list "Tasks"
          list.value.forEach(element => element.isDefaultFolder ? (config._listId = element.id) : '')
        }

        if (config._listId !== undefined && config._listId !== '') {
          // based on translated configuration data (listName -> listId), get tasks
          config._listId.forEach(element => _getTodos())
        } else {
          self.sendSocketNotification('FETCH_INFO_ERROR_' + config.id, { error: '"' + config.listName + '" task folder not found', errorDescription: 'The task folder "' + config.listName + '" could not be found.' })
          console.error(self.name + ' - Error while requesting task folders: Could not find task folder ID for task folder name "' + config.listName + '", or could not find default folder in case no task folder name was provided.')
        }
      } // function callback for task folders
      )
    })
  },

  fetchData: function (config) {
    this.getTodos(config)
  }
})