uppy/packages/@uppy/companion/src/server/provider/facebook/index.js

const request = require('request')
const purest = require('purest')({ request })
const utils = require('../../helpers/utils')
const logger = require('../../logger')
const adapter = require('./adapter')
const AuthError = require('../error')

class Facebook {
  constructor (options) {
    this.authProvider = options.provider = Facebook.authProvider
    this.client = purest(options)
  }

  static get authProvider () {
    return 'facebook'
  }

  list ({ directory, token, query = {} }, done) {
    const qs = {
      fields: 'name,cover_photo,created_time,type'
    }

    if (query.cursor) {
      qs.after = query.cursor
    }

    let path = 'me/albums'
    if (directory) {
      path = `${directory}/photos`
      qs.fields = 'icon,images,name,width,height,created_time'
    }

    this.client
      .get(path)
      .qs(qs)
      .auth(token)
      .request((err, resp, body) => {
        if (err || resp.statusCode !== 200) {
          err = this._error(err, resp)
          logger.error(err, 'provider.facebook.list.error')
          return done(err)
        } else {
          this._getUsername(token, (err, username) => {
            err ? done(err) : done(null, this.adaptData(body, username, directory, query))
          })
        }
      })
  }

  _getUsername (token, done) {
    this.client
      .get('me')
      .qs({ fields: 'email' })
      .auth(token)
      .request((err, resp, body) => {
        if (err || resp.statusCode !== 200) {
          err = this._error(err, resp)
          logger.error(err, 'provider.facebook.user.error')
          return done(err)
        } else {
          done(null, body.email)
        }
      })
  }

  _getMediaUrl (body) {
    const sortedImages = adapter.sortImages(body.images)
    return sortedImages[sortedImages.length - 1].source
  }

  download ({ id, token }, onData) {
    return this.client
      .get(id)
      .qs({ fields: 'images' })
      .auth(token)
      .request((err, resp, body) => {
        if (err) return logger.error(err, 'provider.facebook.download.error')
        request(this._getMediaUrl(body))
          .on('data', onData)
          .on('end', () => onData(null))
          .on('error', (err) => {
            logger.error(err, 'provider.facebook.download.url.error')
          })
      })
  }

  thumbnail (_, done) {
    // not implementing this because a public thumbnail from facebook will be used instead
    const err = new Error('call to thumbnail is not implemented')
    logger.error(err, 'provider.facebook.thumbnail.error')
    return done(err)
  }

  size ({ id, token }, done) {
    return this.client
      .get(id)
      .qs({ fields: 'images' })
      .auth(token)
      .request((err, resp, body) => {
        if (err || resp.statusCode !== 200) {
          err = this._error(err, resp)
          logger.error(err, 'provider.facebook.size.error')
          return done(err)
        }

        utils.getURLMeta(this._getMediaUrl(body))
          .then(({ size }) => done(null, size))
          .catch((err) => {
            logger.error(err, 'provider.facebook.size.error')
            done()
          })
      })
  }

  adaptData (res, username, directory, currentQuery) {
    const data = { username: username, items: [] }
    const items = adapter.getItemSubList(res)
    items.forEach((item) => {
      data.items.push({
        isFolder: adapter.isFolder(item),
        icon: adapter.getItemIcon(item),
        name: adapter.getItemName(item),
        mimeType: adapter.getMimeType(item),
        id: adapter.getItemId(item),
        thumbnail: adapter.getItemThumbnailUrl(item),
        requestPath: adapter.getItemRequestPath(item),
        modifiedDate: adapter.getItemModifiedDate(item)
      })
    })

    data.nextPagePath = adapter.getNextPagePath(res, currentQuery, directory)
    return data
  }

  _error (err, resp) {
    if (resp) {
      if (resp.body && resp.body.error.code === 190) {
        // Invalid OAuth 2.0 Access Token
        return new AuthError()
      }

      const msg = resp.body && resp.body.error ? resp.body.error.message : ''
      return new Error(`request to ${this.authProvider} returned status: ${resp.statusCode}, message: ${msg}`)
    }

    return err
  }
}

module.exports = Facebook