utils.js

const moment = require('moment');
const chalk = require('chalk');
const exec = require('child_process').exec;
const path = require('path');
const https = require('https');
const fs = require('fs');

// ffmpeg -i in.mp3 -c:a aac -ar 44100 -metadata:g com.android.version="8.0.0" -movflags use_metadata_tags out.mp4
exports.createVoicemailFile = () => {
    const inputPath = path.format({dir: __dirname, base: 'voicemail.mp3'});
    const outputPath = path.format({dir: __dirname, base: 'voicemail.mp4'});
    if( !fs.existsSync(outputPath) ){    
        console.log(chalk.yellow('voicemail file creation in progress...'));
        exec(`ffmpeg -i ${inputPath} -c:a aac -ar 44100 -metadata:g com.android.version="8.0.0" -movflags use_metadata_tags ${outputPath}`, (error, stdout) => {
            if( error ){
                console.log(error);
            }
            console.log(chalk.green('voicemail file created!'));
        });
    } else {
        console.log(chalk.yellow('voicemail file found!'));
    }
}

exports.messageLogger = (client, data, threads) => {
    const timestamp = moment(data.message.timestamp / 1000);
    console.log(chalk.magenta(`+---NEW MESSAGE---+`));
    console.log(chalk.yellow(`Conversation with: ${threads.get(data.message.thread_id)}`));
    console.log(chalk.yellow(`Date: ${timestamp}`));
    switch(data.message.item_type){
        case 'text':
            if(!data.message.hasOwnProperty('reactions')){
                console.log(chalk.grey(`${data.message.text}`));
            }else{
                if( data.message.reactions.likes[0].sender_id !== client.state.cookieUserId ){
                    console.log(chalk.grey(`${threads.get(data.message.thread_id)} liked your last message!`));
                }
            }
            break;
        case 'voice_media':
            //thread.voice_media.media.audio.audio_src
            const filename = new URL(data.message.voice_media.media.audio.audio_src).pathname.split('/').pop();
            const downloadDir = path.format({dir: __dirname, base: `media/${filename}`});
            const stream = fs.createWriteStream(downloadDir);
            https.get(data.message.voice_media.media.audio.audio_src, (response) => {
                response.pipe(stream);
                console.log(chalk.yellow(`New vocal message received and saved in: ${downloadDir}\n`));
            });
            break;
    }
    console.log(chalk.magenta(`-------------------\n`));
}