mkdc/BotYam
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Error handling (#4)

Browse source 
* Update BotYamPoster.py

Error handler

* Update main.py
This commit is contained in:
Lucy Joshua 2023-02-25 00:22:15 +02:00 committed by GitHub
parent e1a7247c2a
commit 46fe0966ec
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 23 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
src/BotYamPoster.py
View file

@ -11,15 +11,30 @@ def post_reply(conn, victim_bank, tweet, words, reply_text_bank, postcounter):
if any(word in tweet.data['text'] for word in words):
reply_text = reply_text_bank[random.randint(0, (len(reply_text_bank)-1))]
# Post reply
try:
if tweet.data['author_id'] in victim_bank['author_id'] and not "@FromBotYam" in tweet.data['text']:
reply_text = victim_bank['reply'][random.randint(0,2)] + "\nו" + reply_text
res = conn.api.create_tweet(
text=reply_text,
in_reply_to_tweet_id=tweet["id"]
)
postcounter = postcounter + 1
except tweepy.errors.TwitterServerError as e:
print("ERROR: An error occured, we'll try again in a few minutes. The error: " + str(e))
try:
if tweet.data['author_id'] in victim_bank['author_id'] and not "@FromBotYam" in tweet.data['text']:
reply_text = victim_bank['reply'][random.randint(0,2)] + "\nו" + reply_text
res = conn.api.create_tweet(
text=reply_text,
in_reply_to_tweet_id=tweet["id"]
)
response_data = f"RESPONDING: {res.data['text']}"
print(response_data)
except Exception as e:
print("ERROR: An exception occured. The error: " + str(e))
except Exception as e:
print("ERROR: An exception occured. The error: " + str(e))
postcounter = postcounter + 1
return postcounter
class BotYamPoster(tweepy.StreamingClient):

2
src/main.py
View file

@ -5,7 +5,7 @@ from BotYamPoster import init_streamobject
from connector import Connector
def main():
print("BOT-YAM - VERSION 3.0.1 >>>>")
print("BOT-YAM - VERSION 3.0.2 >>>>")
conn = Connector()
stream = init_streamobject(conn)
print("Adding stream rules...")