service.js

const feathersKnex = require('feathers-knex')
const { hashPassword } = require('feathers-authentication-local').hooks
const { isProvider: isTransport, iff, discard } = require('feathers-hooks-common')
const isNil = require('ramda/src/isNil')

module.exports = function () {
  const app = this
  const db = app.get('db')

  const name = 'credentials'
  const options = { Model: db, name }

  app.use(name, feathersKnex(options))
  app.service(name).hooks(hooks)
}

const hooks = {
  before: {
    create: [
      hashPassword(),
      iff(hasNoAgent, setProfileData),
      iff(hasNoAgent, createAgent),
      getEmailFromRemote,
      clearRemoteData
    ],
    update: [ hashPassword() ],
    patch: [ hashPassword() ]
  },
  after: {
    all: [
      iff(isTransport('external'), discard('password'))
    ]
  },
  error: {
    create: [
      deleteIfCreateFailed
    ]
  }
}

function hasNoAgent (hook) {
  return isNil(hook.data.agentId)
}

function getEmailFromRemote (hook) {
  if (hook.params.oauth) {
    const remoteProvider = hook.params.oauth.provider
    const remoteData = hook.data[remoteProvider]
    const remoteProfile = remoteData.profile
    if (remoteProfile.emails && remoteProfile.emails.length > 0) {
      hook.data.email = remoteProfile.emails[0].value
    }
  }
  return hook
}

function createAgent (hook) {
  const agents = hook.app.service('agents')

  if (!hook.data) return Promise.resolve(hook)

  const data = {
    profile: hook.data.profile
  }
  delete hook.data.profile

  return agents.create(data, {
    // HACK for https://github.com/root-systems/cobuy/issues/253
    // see corresponding code in agents service
    isCreatingCredential: true
  })
  .then(agent => {
    hook.data.agentId = agent.id
    return hook
  })
}

function clearRemoteData (hook) {
  if (hook.params.oauth) {
    const remoteProvider = hook.params.oauth.provider
    delete hook.data[remoteProvider]
  }
  return hook
}

function setProfileData (hook) {
  // TODO: IK: fairly certain I added the email field in here for simpler population of Cobuy profiles which have emails, if so that was a mistake as profile migration of this repo has no email field
  if (!hook.data) return hook

  var name = hook.data.name
  // var email = hook.data.email
  var avatar
  delete hook.data.name

  if (hook.params.oauth) {
    const remoteProvider = hook.params.oauth.provider
    const remoteData = hook.data[remoteProvider]
    const remoteProfile = remoteData.profile
    name = remoteProfile.displayName
    if (remoteProfile.photos && remoteProfile.photos.length > 0) {
      avatar = remoteProfile.photos[0].value
    }
  }

  const { agentId } = hook.data

  hook.data.profile = {
    name,
    // email,
    avatar
  }

  return hook
}

// TODO replace this with proper database transactions
// https://github.com/feathersjs/feathers-knex/issues/91
function deleteIfCreateFailed (hook) {
  const agents = hook.app.service('agents')
  const profiles = hook.app.service('profiles')

  const { agentId } = hook.data
  if (!agentId) return hook

  return Promise.all([
    agents.remove({ id: agentId }),
    profiles.find({ agentId })
      .then((profileList) => {
        return Promise.all(profileList.map(profile => {
          return profiles.remove({ id: profile.id })
        }))
      })
  ]).then(() => hook)
}