konnector.js

/**
* MAIF Cozy's konnector
*/

'use strict'

const request = require('request')
const moment = require('moment')
const uuid = require('uuid')
const {baseKonnector,cozyClient, models, log, updateOrCreate} = require('cozy-konnector-libs');
const imp = require('./maifuser');
const MaifUser = imp.doctypeTest

const connectUrl = 'https://connect.maif.fr/connect'
const apikey = 'eeafd0bd-a921-420e-91ce-3b52ee5807e8'
const infoUrl = `https://openapiweb.maif.fr/prod/cozy/v1/mes_infos?apikey=${apikey}`
const clientId = '2921ebd6-5599-4fa6-a533-0537fac62cfe'
const secret = 'Z_-AMVTppsgj_F9tRLXfwUm6Wdq8OOv5a4ydDYzvbhFjMcp8aM90D0sdNp2kdaEczeGH_qYZhhd9JIzWkoWdGw'

const domain = cozyClient.cozyURL

const scope = 'openid+profile+offline_access'
const type = 'code'
const b64Client = new Buffer(`${clientId}:${secret}`).toString('base64')
let state = ''
let nonce = ''

if (state === '') {
  state = uuid()
}

if (nonce === '') {
  nonce = uuid()
}

const connector = module.exports = baseKonnector.createNew({
  name: 'MAIF',
  customView: '<%t konnector customview maif %>',
  connectUrl: `${connectUrl}/authorize?response_type=${type}&client_id=${clientId}&scope=${scope}&state=${state}&nonce=${nonce}&redirect_uri=`,

  color: {
    hex: '#007858',
    css: '#007858'
  },

  fields: {
    code: {
      type: 'hidden' // To get the Auth code returned on the redirection.
    },
    redirectPath: {
      type: 'hidden'
    },
    refreshToken: {
      type: 'hidden' // refreshToken
    }
  },

  dataType: [
    'bill',
    'contact'
  ],

  models: [MaifUser],
  fetchOperations: [
    refreshToken,
    fetchData,
    updateOrCreate(null, MaifUser)
  ]
})


function refreshToken (requiredFields, entries, data, next) {
  log('info', 'refreshToken')

  if (requiredFields.refreshToken && requiredFields.refreshToken !== '') {
    // Get a new access_token using the refreshToken.
    fetchToken({
      grant_type: 'refresh_token',
      refresh_token: requiredFields.refreshToken
    }, requiredFields, data, next)
  } else if (requiredFields.code && requiredFields.code !== '') {
    // Obtain tokens with the auth code.
    buildCallbackUrl(requiredFields, (err, redirectUrl) => {
      if (err) { return next(err) }
      fetchToken({
        grant_type: 'authorization_code',
        code: requiredFields.code,
        state,
        nonce,
        redirect_uri: ''
      }, requiredFields, data, next)
    })
  } else {
    next('token not found') // Need to perform OpenIdConnect steps.
  }
}

function fetchToken (form, requiredFields, data, next) {
  log('info', 'fetchToken')

  request.post({
    url: `${connectUrl}/token`,
    json: true,
    headers: {
      Authorization: `Basic ${b64Client}`
    },
    form
  }, (err, response, body) => {
    if (response.statusCode !== 200 && response.statusCode !== '200') {
      log('error', `fetchToken error: ${response.statusCode} - ${response.statusMessage}`)
      err = 'token not found'
    }

    if (err) {
      return next(err)
    }

    if (!body.id_token || !body.refresh_token) {
      log('error', `no token in body: ${body}`)
      return next('token not found')
    }

    data.accessToken = body.id_token
    requiredFields.refreshToken = body.refresh_token

    next()
  })
}

function buildCallbackUrl (requiredFields, callback) {
  let url = null
  let error = null
  try {
    let path = requiredFields.redirectPath.split('?')[0]
    if (path[0] === '/') {
      path = path.slice(1)
    }
    url = `${domain}apps/konnectors/${path}`
  } catch (e) {
    log('error', e)
    console.log(e)
    error = 'internal error'
  }
  callback(error, url)
}

/*
// Save konnector's fieldValues during fetch process.
function saveTokenInKonnector (requiredFields, entries, data, next) {
  log('info', 'saveTokenInKonnector')

  // Disable eslint because we can't require models/konnector at the top
  // of this file (or Konnector will be empty). It's because in the require
  // tree of models/konnector, there is the current file.
  //eslint-disable-next-line
  const Konnector = require('../models/konnector')

  Konnector.get(connector.slug, (err, konnector) => {
    if (err) {
      log('error', err)
      return next('internal error')
    }

    konnector.updateFieldValues({ accounts: [requiredFields] }, next)
  })
}
*/

function fetchData (requiredFields, entries, data, next) {
  log('info', 'fetchData')

  request.get({
    url: infoUrl,
    json: true,
    headers: {
      Authorization: `Bearer ${data.accessToken}`
    }
  }, (err, response, body) => {
    if (response.statusCode !== 200 && response.statusCode !== '200') {
      connector.logger.error(`fetchToken error: ${response.statusCode} - ${response.statusMessage}`)
      err = 'request error'
    }

    if (err) {
      return next(err)
    }
    moment.locale('fr')
    entries.maifusers = [{
      profile: body,
      date: moment().format('LLL')
    }]
    next()
  })
}

/*
function createOrUpdateInDB (requiredFields, entries, data, next) {
  log('info', 'createOrUpdateInDB')

  updateOrCreate(entries.maifusers[0], (err) => {
    if (err) {
      log('error', err)
      return next('internal error')
    }

    next()
  })
}
*/