import Pusher from 'pusher'

const pusher = new Pusher({
  appId: process.env.PUSHER_APP_ID,
  key: process.env.PUSHER_APP_KEY,
  secret: process.env.PUSHER_APP_SECRET,
  cluster: process.env.PUSHER_APP_CLUSTER,
})

export const sendEvent = (channel, event, data) => {
  return new Promise((resolve, reject) =>
    pusher.trigger(channel, event, data, (err, res, response) => {
      if (err) {
        return reject(err)
      }
      resolve(response)
    })
  )
}

const auth = (req, res) => {
  const socketId = req.body.socket_id
  const channel = req.body.channel_name
  const auth = pusher.authenticate(socketId, channel)
  return res.send(auth)
}

export default {
  auth,
  sendEvent,
}