Tweet text & images via api

wcdt-tweet.js

const admin = require("firebase-admin")

/*
const serviceAccount = require("./../key.json");
const { exit } = require("process");
admin.initializeApp({
  credential: admin.credential.cert(serviceAccount)
})
*/

const axios = require('axios');
const { TwitterApi } = require( 'twitter-api-v2')

const tweet = async (data,callback) => {
  console.log('tweet started')  
  if(!data) return null
  const TWITTER_CREDENTIALS = JSON.parse(process.env.TWITTER_API || '{"appKey":"","appSecret":"","accessToken":"","accessSecret":""}')
  const client = new TwitterApi(TWITTER_CREDENTIALS)
  await callback(client,data)
  console.log('tweet finished')
}

const getImage = async (remoteImageUrl) => {
  // Download the remote image
  const response = await axios.get(remoteImageUrl, { responseType: 'arraybuffer' });
  return {data:response.data,mime:response.headers['content-type']}
}

const getFromDb = async () => {
  //XXX implement here
  return null
}

const postPlaces = async () => {
  const post = await getFromDb()
  if(!post) return
  await Promise.all([
    tweet(post, async (client,post)=>{
      try{        
        let media = {}
        if(post.image){
          const {data,mime} = await getImage(post.image)
          const mediaId = await client.v1.uploadMedia(data,{ mimeType: mime });
          media = { media: {media_ids: [mediaId]} }
        }
        console.log(await client.v2.tweet(post.text,media))
      }catch(e){
        console.log(e)
      }
    })
  ])
}

exports.runTwitter = async () => {
  try{
    console.log('runTwitter started')
    try{
      await postPlaces()
    }catch(e){        
      console.log(e)
    } finally{
      
    }
    console.log('runTwitter finished')  
  }catch(e){
    console.log(e)
  }  
}

/*
//Uncomment to run locally. Execute "node wcdt-tweet.js" to run
(async ()=>{
  const { exit } = require("process")
  await this.runTwitter()
  exit(0)
})()
*/