bot.js

// Creating telegram bot and adding twitter interacting


// importing modules
const Telebot = require('telebot');
const twit = require('twit');
const fetch = require('node-fetch');
const fs = require('fs');


// Instantiating Telegram bot with API key provided // IMPORTANT, PLEASE MAKE CHANGES
const bot = new Telebot({
    token: 'Telegram Bot Token Here',       // IMPORTANT, PLEASE MAKE CHANGES
    usePlugins: ['commandButton', 'askUser']
});


// Saving Twitter configutaions to a const // IMPORTANT, PLEASE MAKE CHANGES
const tConfig = {
    consumer_key: 'Twitter Consumer Key Here',
    consumer_secret: 'Twitter Consumer Secret Here',
    access_token: 'Twitter Access Token Here',
    access_token_secret: 'Twitter Token Secret Here'
} // IMPORTANT, PLEASE MAKE CHANGES


// Instantiating Twit module with required twitter configurations
const T = new twit(tConfig);


// Twitter Methods Begin

// Method to Post a Twit
sendTwit = (msg) => {
    let id = msg.from.id;
    let replyToMessage = msg.message_id;
    let params = {
        status: `${msg.text}`
    }

    console.log(params.status);
    T.post('statuses/update', params, function (err, data, response) {
        if (data) {
            bot.sendMessage(
                id, "Sent Successfully", {
                    replyToMessage
                }
            );
        }
        if (err) {
            bot.sendMessage(id, "Sorry! error occured", {
                replyToMessage
            })
        }

    })
}


// Method to get own Timeline
ownTimeline = (msg) => {
    T.get('statuses/home_timeline', {
        count: 15,
        truncated: false,
        tweet_mode: 'extended'
    }, (err, data, response) => {
        data.forEach(element => {
            bot.sendMessage(msg.from.id, element.full_text);
        });
    });
}


// Method to get another users's timeline
userTimeline = (msg) => {
    let id = msg.from.id;
    let replyToMessage = msg.message_id;
    T.get('statuses/user_timeline', {
        screen_name: `${msg.text}`,
        count: 15,
        tweet_mode: 'extended'
    }, (err, data, response) => {
        if (data[0].full_text != undefined) {
                for(let i=0;i<2;i++){
                    if (i==0) {
                        bot.sendMessage(id, `Tweets from ${msg.text}`);
                    }else if(i==1){
                        data.forEach(element => {
                            bot.sendMessage(id, element.full_text);
                        });
                    }
                }
        } else {
            bot.sendMessage(id, "Sorry can't find User", {
                replyToMessage
            })
        }
        if (err) {
            bot.sendMessage(id, "Sorry can't find User", {
                replyToMessage
            })
        }
    });
}


tweetWithImage = (msg) => {
    // Method post a tweet with media
    let status = msg.caption;
    let id = msg.from.id;
    let replyToMessage = msg.message_id;
    let b64content = fs.readFileSync('./2.png', {
        encoding: 'base64'
    })

    console.log("Status:", status);

    if (status == undefined) {
        status = "."

    }

    // first we must post the media to Twitter
    T.post('media/upload', {
        media_data: b64content
    }, function (err, data, response) {
        // now we can assign alt text to the media, for use by screen readers and
        // other text-based presentations and interpreters
        let mediaIdStr = data.media_id_string
        let meta_params = {
            media_id: mediaIdStr,
        }

        T.post('media/metadata/create', meta_params, function (err, data, response) {
            if (!err) {
                // now we can reference the media and post a tweet (media will attach to the tweet)
                let params = {
                    status: status,
                    media_ids: [mediaIdStr]
                }

                T.post('statuses/update', params, function (err, data, response) {
                    if (data) {
                        bot.sendMessage(
                            id, "Sent Successfully", {
                                replyToMessage
                            } );
                            console.log(data);
                    }
                    if (err) {
                        bot.sendMessage(id, "Sorry! error occured", {
                            replyToMessage
                        })
                    }
                })
            }
        })
    })

}

// Twitter Methods End


//  Metohd to save file on disk from telegram server

async function saveFile(info, msg) {
    const res = fetch(info.fileLink)
    const result = await res;
    const dest = await fs.createWriteStream('./2.png');
    const save = await result.body.pipe(dest);
    return new Promise((resolve, reject) => {
        dest.on('finish', resolve)
        dest.on('error', reject)
    })
}





// Telegram Bot Setup starts


//  Command  /twitter
bot.on('/twitter', (msg) => {

    // Inline keyboard markup
    const replyMarkup = bot.inlineKeyboard([
        [
            // First row with command callback button
            bot.inlineButton('Get own timeline', {
                callback: '/getOwn'
            })
        ],
        [
            // Second row with command callback button
            bot.inlineButton('Get user tweets', {
                callback: '/getUser'
            })
        ],
        [
            // Third row with command callback button
            bot.inlineButton('Send Tweet', {
                callback: '/sendTweet'
            })
        ],

    ]);

    // Send message with keyboard markup
    return bot.sendMessage(msg.from.id, 'Choose Option', {
        replyMarkup
    });

});


// Command /getOwn
bot.on('/getOwn', msg => {
    return ownTimeline(msg);
});


// Command /getUser
bot.on('/getUser', msg => {
    const id = msg.from.id;
    return bot.sendMessage(id, 'Enter twitter username:', {
        ask: 'username'
    });
});



// Command /status
bot.on('/sendTweet', msg => {
    const id = msg.from.id;
    return bot.sendMessage(id, 'Enter status:', {
        ask: 'status'
    });
});


// Button callback
bot.on('callbackQuery', (msg) => {
    bot.answerCallbackQuery(msg.id);
});

// Addding buttons for Twitter interactivity

// Asking events

// Ask twitter username event
bot.on('ask.username', msg => {

    const id = msg.from.id;
    return userTimeline(msg);

});


// Ask status for twitter event
bot.on('ask.status', (msg, self) => {
    let id = msg.from.id;
    let replyToMessage = msg.message_id;
    let type = self.type;
    let parseMode = 'html';
   
    if (self.type == "photo") {
        return fileinfo =
            bot.getFile(msg.photo[(msg.photo).length - 1].file_id)
            .then(async (info) => {
                await saveFile(info, msg);
                await tweetWithImage(msg);
            });
    } else if (self.type == "text") {
        return sendTwit(msg);
    }

});

bot.start();