pullIncomings.js

require('dotenv').config()
const ovh = require('ovh')({
  appKey: process.env.OVH_APP_KEY,
  appSecret: process.env.OVH_APP_SECRET_KEY,
  consumerKey: process.env.OVH_CONSUMER_KEY
})
const axios = require('axios')

/**
 * Function to fetch incomings sms on OVH service
 * @returns err | data
 */
const tempData = async () => {
  const dataPromised = await new Promise((resolve, reject) => {
    ovh.request(
      'GET',
      `/sms/${process.env.OVH_SERVICE_NAME}/incoming`,
      (err, data) => {
        if (err) {
          reject(err)
        } else {
          resolve(data)
        }
      }
    )
  })

  return dataPromised
}

tempData()
  .then((messages) => {
    messages.forEach((messageID) => {
      ovh.request(
        'GET',
        `/sms/${process.env.OVH_SERVICE_NAME}/incoming/${messageID}`,
        (err, msgText) => {
          if (err) {
            console.log(err)
          } else {
            axios({
              method: 'post',
              url: process.env.SLACK_WEBHOOK,
              headers: { 'Content-type': 'application/json' },
              data: { text: msgText.message }
            })
          }
        }
      )

      ovh.request(
        'DELETE',
        `/sms/${process.env.OVH_SERVICE_NAME}/incoming/${messageID}`,
        (err, res) => {
          if (err) {
            console.log(err)
          } else {
            console.log(`Réponse supprimée : ${messageID}`)
            console.log(res)
          }
        }
      )
    })
  })
  .catch((err) => {
    console.error(err)
  })