Added

Twitter-Tg-bot/main.py

@@ -0,0 +1,25 @@
+import telegram
+import logging
+from telegram.ext import Updater,CommandHandler
+from urllib3.exceptions import ProtocolError
+import os
+import tweet_scrape as ts
+from dotenv import load_dotenv
+import time
+
+load_dotenv("keys.env")
+API_TOKEN = str(os.getenv("TELEGRAM_BOT"))
+
+def startbot():
+    twitter_stream = ts.TweetBot()
+    twitter_stream.fetch_tweets()
+
+if __name__ == '__main__':
+    updater = Updater(token=API_TOKEN,use_context=True)
+    dispatcher = updater.dispatcher
+    while True:
+        try:
+            startbot()
+            time.sleep(5)
+        except ProtocolError:
+            continue

Twitter-Tg-bot/tweet_scrape.py

@@ -0,0 +1,115 @@
+import html
+import os
+import time
+import tweepy as tp
+import telegram
+# from telegram import bot
+
+import json
+from userslist import *
+from dotenv import load_dotenv
+
+load_dotenv("keys.env")
+token = str(os.getenv("TELEGRAM_BOT"))
+chatid = int(os.getenv("CHAT_ID"))
+
+class TwitterStream(tp.StreamListener):
+
+    def on_data(self, data):
+        try:
+            tb = TweetBot()
+            d = json.loads(data)
+            tweet_url = tb.get_tweet_url(json_data=d)
+            has_media = tb.tweet_has_media(json_data=d)
+            reply = d['in_reply_to_screen_name']
+            tw_name = d['user']['name']
+            tw_screen_name = d['user']['screen_name']
+            tweet_id = d['id_str']
+            tweet_link = "https://twitter.com/"+tw_screen_name+"/status/"+tweet_id
+            if 'extended_tweet' in d:
+                tg_text = d['extended_tweet']['full_text']
+            else:
+                tg_text = d['text']
+            print(reply)
+            # print(tg_text)
+            if( str (reply) == 'None'):
+                if('RT @' not in tg_text):
+                    bot = telegram.Bot(token=token)
+                    # Bot = bot.Bot(token=token)
+                    if has_media:
+                        bot.sendMessage(chat_id=chatid, text=tg_text+"\n"+tweet_url+"\n"+"Via"+"|"+"<a href='"+tweet_link+"'>"+tw_name+"</a>"+"|",timeout=200,disable_web_page_preview=False,parse_mode=Telegram.ParseMode.HTML)
+                    else:
+                        print("sending")
+                        bot.sendMessage(chat_id=chatid,text=tg_text+"\n"+tweet_url+"\n"+"Via"+"|"+"<a href='"+tweet_link+"'>"+tw_name+"</a>"+"|",timeout=200,disable_web_page_preview=True,parse_mode=Telegram.ParseMode.HTML)
+                    time.sleep(3)
+                else:
+                    print("It's a retweet so not posting it")
+            else:
+                print("It's a reply so not posting that")
+        except Exception as e:
+            print(e)
+
+        return True
+
+    def on_error(self,status):
+        print(status.text)
+
+    def on_error(self,status_code):
+        if status_code == 420:
+            return False
+
+
+
+class TweetBot():
+
+    def __init__(self):
+        pass
+
+    def authorize(self):
+        consumer_key = str(os.getenv("CONSUMER_KEY"))
+        consumer_secret = str(os.getenv("CONSUMER_SECRET"))
+        access_token = str(os.getenv("ACCESS_TOKEN"))
+        access_token_secret = str(os.getenv("ACCESS_TOKEN_SECRET"))
+        autho = tp.OAuthHandler(consumer_key,consumer_secret)
+        autho.set_access_token(access_token,access_token_secret)
+        return autho
+
+
+    def fetch_tweets(self):
+        api = self.authorize()
+        listener = TwitterStream()
+        account_list = self.get_tweet_acid(userslist)
+        stream_tweet = tp.Stream(api,listener,tweet_mode='extended')
+        stream_tweet.filter(follow = account_list)
+
+    def get_tweet_acid(self,user_list):
+        api = self.authorize()
+        api_object = tp.API(api)
+        list_id = []
+        for i in user_list:
+            user = api_object.get_user(screen_name=str(i))
+            id = user.id
+            list_id.append(str(id))
+        return list_id    
+
+    def get_tweet_url(self,json_data):
+        tweet_url = ''
+        try:
+            for url in json_data['entities']['urls']:
+                if not 'https://twitter.com' in url['expanded_url']:
+                    tweet_url = tweet_url+"\n"+str(url['expanded_url'])
+        except:
+            tweet_url=''        
+        return tweet_url  
+
+    def tweet_has_media(self,json_data):
+        if 'extended_entities' in json_data:
+            if 'media' in json_data['extended_entities']:
+                return True
+            else:
+                return False
+        else:
+            if 'media' in json_data['entities']:
+                return True
+            else:
+                return False            

Twitter-Tg-bot/userlist.py

@@ -0,0 +1 @@
+userslist = ['AmitabhJha3']