Create stream system to get reply of automatics tweets and manage it

stream.py

@@ -0,0 +1,33 @@
+import tweepy, twitter_credentials, trello, trello_credentials, json, subprocess, argparse
+from app import db
+from app.models import User
+
+parser = argparse.ArgumentParser()
+parser.add_argument("user", type = int, help = "User id")
+args = parser.parse_args()
+user = User.query.filter_by(id = args.user).first()
+
+auth = tweepy.OAuthHandler(twitter_credentials.consumer_key, twitter_credentials.consumer_secret_key)
+auth.set_access_token(user.twitter_api.first().access_token, user.twitter_api.first().access_token_secret)
+api = tweepy.API(auth)
+
+class listener(tweepy.streaming.StreamListener):
+    def on_data(self, data):
+        all_data = json.loads(data)
+        for t in user.tweets.all():
+            if t.statu_id == int(all_data["in_reply_to_status_id"]) and api.me().id != int(all_data["user"]["id"]):
+                for w in eval(t.keywords.lower()):
+                    if all_data["text"].lower().find(w) != -1:
+                        api.create_favorite(int(all_data["id"]))
+                        user.trello_api.first().api_login().get_list(user.boards.first().column_id).add_card(f"{all_data['user']['name']}'s commission", f"Commission take on Twitter with the cyberplanificateur with this tweet : https://twitter.com/{all_data['user']['screen_name']}/status/{all_data['id']}")
+                        print("found")
+                        #Make slots system !
+                        break
+                break
+        return True
+
+    def on_error(self, status):
+        print(status)
+
+twitterStream = tweepy.Stream(auth, listener())
+twitterStream.filter(follow=[str(api.me().id)])