Merge with work

Author: beatwad

LICENSE

@@ -7,3 +7,7 @@ Permission is hereby granted, free of charge, to any person obtaining a copy of
 The above copyright notice and this permission notice must be included in all copies or substantial portions of the Software.
 
 THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+
+Additional Notices
+
+This project is an active fork of Jobs_Applier_AI_Agent_AIHawk (https://github.com/feder-cr/Jobs_Applier_AI_Agent_AIHawk), which is MIT-licensed. Portions of this code are derived from that project. Original authors and contributors retain their copyrights in those portions.

README.md

@@ -1,11 +1,3 @@
-- check agent pipline with headless mode
-
-- Add tests for:
-    - job_manager (those methods that don't interact with the browser)
-
 Finsihing moves:
 - Remove address of your tg chat from app_config.py
-- Create new repo for this project
-- Remove playwright examples
-- Take the video of its work
 - Write an article for Medium, Reddit, Dev.to, Hashnode, Opensource.com

TODO

@@ -13,7 +13,7 @@
 otherwise ask LLM to select only those vacancies that suit you
 by interests or by tech stack
 """
-MONKEY_MODE = True
+MONKEY_MODE = False
 
 """
 In this mode app doesn't apply to the jobs, only creates resumes, cover letters and gathers skill statistics
@@ -23,7 +23,6 @@
 """
 TEST_MODE = False
 
-
 """
 In this mode app doesn't apply to the jobs or create resumes and cover letters, only gathers information for interesting jobs and
 their skill statistics and saves them to the files data/output/interesting_jobs.yaml and data/output/skill_stat.yaml."""
@@ -34,13 +33,13 @@
 If this mode is deactivated, app will apply to the jobs with Easy Apply and try to apply to the jobs with 3rd party applications
 WARNING: applying to the jobs with 3rd party applications is not guaranteed to be successful, but is guaranteed to consume at least 10-100x more tokens
 """
-EASY_APPLY_ONLY_MODE = False
+EASY_APPLY_ONLY_MODE = True
 
 """
-If this mode is activated, app will check if the last search was less than a day ago. 
+If this mode is activated, app will check if the last search was less than a day ago.
 This is useful if you want bot to automatically restart the search every 24 hours when LinkedIn resets the search limits.
 """
-CHECK_LAST_SEARCH_TIME = False
+RESTART_EVERY_DAY = False
 
 """
 If LLM evaluated the 'interest' level of the job not below this threshold - the job is considered interesting for application.
@@ -51,6 +50,16 @@
 """Minimum time spent on one job application"""
 MINIMUM_WAIT_TIME_SEC = 10
 
+"""
+If this mode is activated, app will try to decrease RPM to avoid rate limit errors
+"""
+FREE_TIER = False
+
+"""
+Free tier mode wait time in seconds
+"""
+FREE_TIER_RPM_LIMIT = 15
+
 """Telegram chat address and corresponding topic IDs for sending"""
 TG_CHAT_ID = "@linkedin_feedback"
 TG_ERR_TOPIC_ID = 2
@@ -86,7 +95,7 @@
 APPLY_AGENT_MODEL = "gemini-flash-latest"
 
 """
-Model temperature
+Easy Apply model temperature
 the higher it is, the more creative the model, but hallucinations may occur
 the lower it is, the more strictly the model follows the prompt and invents less
 """

config/app_config.py

@@ -7,7 +7,6 @@
 from config.constants import LOG_DIR
 from src.telegram.telegram_error_handler import AsyncTelegramSink
 
-
 logger.remove()
 
 if MINIMUM_LOG_LEVEL in ["DEBUG", "TRACE", "INFO", "WARNING", "ERROR", "CRITICAL"]:

config/logger_config.py

@@ -4,6 +4,4 @@ linkedin_password="[Your LinkedIn Password]"
 llm_api_key="[Your LLM API Key]"
 llm_proxy="[Your LLM Proxy in format http(s)://login:password@host:port]"
 
-tg_api_id="[Your Telegram API ID]"
-tg_api_hash="[Your Telegram API Hash]"
 tg_token="[Your Telegram Bot Token]"

examples/.env_example

@@ -5,10 +5,12 @@
 import time
 import traceback
 from pathlib import Path
+from threading import Lock
 
 import dotenv
+from pynput import keyboard as pynput_kb
 
-from config.app_config import CHECK_LAST_SEARCH_TIME
+from config.app_config import RESTART_EVERY_DAY
 from config.constants import BROWSER_STORAGE_STATE, RESUME_DIR, SEARCH_CONFIG_FILE
 from config.logger_config import logger
 from src.job_manager.authenticator import LinkedInAuthenticator
@@ -36,6 +38,11 @@
 RESUME_TEXT_FILE = Path(RESUME_DIR) / "resume_text.txt"
 READY_MADE_RESUME = Path(RESUME_DIR) / "resume.pdf"
 
+# Global pause state for keyboard control
+paused = False
+pause_lock = Lock()
+ctrl_pressed = False
+
 
 class ConfigError(Exception):
     pass
@@ -101,6 +108,49 @@ def validate_resume_structured(resume_structured_file: Path) -> dict:
             raise ConfigError(f"Structured resume validation error: {str(e)}")
 
 
+def on_press(key):
+    """Handle key press events"""
+    global paused, ctrl_pressed
+    try:
+        # Track Ctrl key state
+        if key in (pynput_kb.Key.ctrl_l, pynput_kb.Key.ctrl_r):
+            ctrl_pressed = True
+        # Check for 'x' key when Ctrl is pressed
+        elif hasattr(key, "char") and key.char == "x" and ctrl_pressed:
+            with pause_lock:
+                paused = not paused
+                if paused:
+                    logger.warning("⏸️  PAUSED - Press Ctrl+X to continue")
+                else:
+                    logger.info("▶️  RESUMED")
+    except AttributeError:
+        pass
+
+
+def on_release(key):
+    """Handle key release events"""
+    global ctrl_pressed
+    # Reset Ctrl key state
+    if key in (pynput_kb.Key.ctrl_l, pynput_kb.Key.ctrl_r):
+        ctrl_pressed = False
+
+
+def start_keyboard_listener():
+    """Start keyboard listener in background thread"""
+    listener = pynput_kb.Listener(on_press=on_press, on_release=on_release)
+    listener.daemon = True
+    listener.start()
+    logger.info("Keyboard listener started - Press Ctrl+X to pause/resume")
+
+
+async def check_pause():
+    """Check if execution is paused and wait if needed"""
+    global paused
+    if paused:
+        while paused:
+            await asyncio.sleep(0.5)
+
+
 async def create_and_run_bot(
     search_config: dict,
     secrets: dict,
@@ -170,9 +220,10 @@ async def create_and_run_bot(
         # Set bot facade
         bot = BotFacade(resume_anonymizer, search_component, apply_component, llm_agent_component)
         bot.set_parameters(search_config)
+        bot.set_pause_checker(check_pause)
 
         # Check if the last search was less than a day ago
-        if CHECK_LAST_SEARCH_TIME and not apply_component.check_the_last_search_time():
+        if RESTART_EVERY_DAY and not apply_component.check_the_last_search_time():
             logger.warning(
                 "Last search was less than a day ago, finishing work. If you want to restart the search, delete the file data/output/last_run.yaml file"
             )
@@ -206,44 +257,50 @@ async def create_and_run_bot(
 
 
 def main() -> None:
-    try:
-        # create output folder if it doesn't exist
-        data = Path("data")
-        output_folder = data / "output"
-        output_folder.mkdir(exist_ok=True)
-
-        # validate config files
-        config_validator = ConfigValidator()
-        secrets = config_validator.validate_secrets()
-        search_config = config_validator.validate_search_config(SEARCH_CONFIG_FILE)
-        resume_text = config_validator.validate_resume_text(RESUME_TEXT_FILE)
-        resume_structured = config_validator.validate_resume_structured(RESUME_STRUCTURED_FILE)
-
-        logger.info("Starting LinkedIn Job Applier...")
-        logger.info(f"Search config loaded with {len(search_config)} parameters")
-
-        # Run LinkedIn bot (async)
-        asyncio.run(create_and_run_bot(search_config, secrets, resume_text, resume_structured))
-        logger.info("LinkedIn bot completed successfully")
-
-        # Wait 1 hour total before next run
-        if CHECK_LAST_SEARCH_TIME:
-            time.sleep(3600)
-
-    except ConfigError as ce:
-        logger.error(f"Configuration error: {str(ce)}")
-    except FileNotFoundError as fnf:
-        tb_str = traceback.format_exc()
-        logger.error(f"File not found: {str(fnf)}\n{tb_str}")
-    except RuntimeError as re:
-        tb_str = traceback.format_exc()
-        logger.error(f"Runtime error: {str(re)}\n{tb_str}")
-    except Exception as e:
-        tb_str = traceback.format_exc()
-        logger.error(f"Unknown error: {str(e)}\n{tb_str}")
-    finally:
-        logger.info("Program completed")
-        # time.sleep(600)  # Commented out for testing
+    # Start keyboard listener for pause/resume functionality
+    start_keyboard_listener()
+
+    while True:
+        try:
+            # create output folder if it doesn't exist
+            data = Path("data")
+            output_folder = data / "output"
+            output_folder.mkdir(exist_ok=True)
+
+            # validate config files
+            config_validator = ConfigValidator()
+            secrets = config_validator.validate_secrets()
+            search_config = config_validator.validate_search_config(SEARCH_CONFIG_FILE)
+            resume_text = config_validator.validate_resume_text(RESUME_TEXT_FILE)
+            resume_structured = config_validator.validate_resume_structured(RESUME_STRUCTURED_FILE)
+
+            logger.info("Starting LinkedIn Job Applier...")
+            logger.info(f"Search config loaded with {len(search_config)} parameters")
+
+            # Run LinkedIn bot (async)
+            asyncio.run(create_and_run_bot(search_config, secrets, resume_text, resume_structured))
+            logger.info("LinkedIn bot completed successfully")
+
+        except ConfigError as ce:
+            logger.error(f"Configuration error: {str(ce)}")
+        except FileNotFoundError as fnf:
+            tb_str = traceback.format_exc()
+            logger.error(f"File not found: {str(fnf)}\n{tb_str}")
+        except RuntimeError as re:
+            tb_str = traceback.format_exc()
+            logger.error(f"Runtime error: {str(re)}\n{tb_str}")
+        except Exception as e:
+            tb_str = traceback.format_exc()
+            logger.error(f"Unknown error: {str(e)}\n{tb_str}")
+        finally:
+            logger.info("Program completed")
+            # Wait 1 hour total before next run
+            if RESTART_EVERY_DAY:
+                logger.info("Waiting 1 hour before next run")
+                time.sleep(3600)
+            else:
+                logger.info("Exiting program")
+                break
 
 
 if __name__ == "__main__":

main.py

@@ -27,6 +27,7 @@ dependencies = [
     "PyYAML==6.0.2",
     "reportlab==4.2.2",
     "telethon==1.39.0",
+    "pynput==1.8.1",
     "python-telegram-bot==21.9",
 ]
 

pyproject.toml

@@ -14,7 +14,9 @@ Levenshtein==0.25.1
 loguru==0.7.2
 playwright
 pydantic>=2.0.02
+pynput==1.7.7
 PyYAML==6.0.2
 reportlab==4.2.2
 telethon==1.39.0
+pynput==1.8.1
 python-telegram-bot==21.9

requirements.txt

@@ -101,6 +101,12 @@ def set_resume_generator(self, resume_generator_manager) -> None:
         self.apply_component.set_resume_generator_manager(resume_generator_manager)
         logger.info("Resume manager successfully started")
 
+    def set_pause_checker(self, pause_checker) -> None:
+        """Set pause checker function for pausing execution"""
+        logger.info("Setting pause checker function")
+        self.apply_component.set_pause_checker(pause_checker)
+        logger.info("Pause checker successfully set")
+
     async def start_apply(self) -> None:
         """Start resume sending process (async)"""
         self.state.validate_state(