prettify

Author: Peteredwardj

src/actions/twitter_actions.py

@@ -1,4 +1,4 @@
-import time,threading,os
+import time,threading
 from src.action_handler import register_action
 from src.helpers import print_h_bar
 from src.prompts import POST_TWEET_PROMPT, REPLY_TWEET_PROMPT
@@ -96,12 +96,8 @@ def like_tweet(agent, **kwargs):
     return False
 
 @register_action("respond-to-mentions")
-def respond_to_mentions(agent,**kwargs):
-    
-    if (os.environ.get("TWITTER_BEARER_TOKEN") is None):
-        agent.logger.warning("Twitter bearer token not found, skipping respond-to-mentions action listener")
-        return
-    
+def respond_to_mentions(agent,**kwargs): #REQUIRES TWITTER PREMIUM PLAN
+
     filter_str = f"@{agent.username} -is:retweet"
     stream_function = agent.connection_manager.perform_action(
         connection_name="twitter",

src/agent.py

@@ -172,8 +172,6 @@ def loop(self):
             logger.info(f"{i}...")
             time.sleep(1)
 
-        execute_action(self,"respond-to-mentions") # Set up listener for mentions, requires Twitter Premium & Bearer Token
-        
         try:
             while True:
                 success = False

src/connections/twitter_connection.py

@@ -531,7 +531,6 @@ def _delete_rules(self,rules) -> None:
             auth=self._bearer_oauth,
             json=payload
         )
-        print("Deleted rules : ",response.text)
         if response.status_code != 200:
             raise Exception(
                 "Cannot delete rules (HTTP {}): {}".format(
@@ -558,7 +557,7 @@ def _build_rule(self, filter_string, **kwargs) -> None:
 
 
     def stream_tweets(self, filter_string:str,**kwargs) ->Iterator[Dict[str, Any]]:
-        """Stream tweets"""
+        """Stream tweets. Requires Twitter Premium Plan and Bearer Token"""
         rules = self._get_rules()
         self._delete_rules(rules)
         self._build_rule(filter_string)