salakojoshua1234_gmail.com
332b743fa5
Updated config.py to include the salary detection endpoint, headers, and sample payloads. Enhanced salary_detect.py to utilize the new configuration for making POST requests to the endpoint with random salary data. Improved error handling during the request process.
40 lines
1.2 KiB
Python
40 lines
1.2 KiB
Python
import time
|
|
import logging
|
|
import threading
|
|
import requests
|
|
from .config import SALARY_DETECT_URL, SALARY_DETECT_HEADERS, get_random_salary_payload
|
|
|
|
logging.basicConfig(level=logging.INFO)
|
|
logger = logging.getLogger(__name__)
|
|
|
|
class SalaryDetect:
|
|
def __init__(self):
|
|
self._running = False
|
|
self._thread = None
|
|
|
|
def _run(self):
|
|
while self._running:
|
|
logger.info(f"[{time.strftime('%Y-%m-%d %H:%M:%S')}] Detecting salary...")
|
|
try:
|
|
payload = get_random_salary_payload()
|
|
response = requests.post(SALARY_DETECT_URL, headers=SALARY_DETECT_HEADERS, json=payload)
|
|
logger.info(f"POST {SALARY_DETECT_URL} status: {response.status_code}, response: {response.text}")
|
|
except Exception as e:
|
|
logger.error(f"Error during POST: {e}")
|
|
logger.info(f"[{time.strftime('%Y-%m-%d %H:%M:%S')}] Salary detection complete")
|
|
time.sleep(120)
|
|
|
|
def start(self):
|
|
if not self._running:
|
|
self._running = True
|
|
self._thread = threading.Thread(target=self._run, daemon=True)
|
|
self._thread.start()
|
|
|
|
def stop(self):
|
|
self._running = False
|
|
if self._thread:
|
|
self._thread.join()
|
|
|
|
|
|
|