Spaces:

---

telegramjobupload

/

README

Like 0

Paused

import os

import re

import json

import time

import random

import requests

import csv

import ssl

from requests.adapters import HTTPAdapter

from urllib3.poolmanager import PoolManager

class TLSv1_2Adapter(HTTPAdapter):

def init_poolmanager(self, connections, maxsize, block=False, **pool_kwargs):

# Force TLS 1.2 to prevent UNEXPECTED_EOF_WHILE_READING errors on Hugging Face

context = ssl.SSLContext(ssl.PROTOCOL_TLSv1_2)

context.verify_mode = ssl.CERT_REQUIRED

context.check_hostname = True

context.load_default_certs()

self.poolmanager = PoolManager(

num_pools=connections,

maxsize=maxsize,

block=block,

ssl_context=context,

**pool_kwargs

)

original_init = requests.sessions.Session.__init__

def patched_init(self, *args, **kwargs):

original_init(self, *args, **kwargs)

self.mount("https://", TLSv1_2Adapter())

requests.sessions.Session.__init__ = patched_init

from datetime import datetime

from bs4 import BeautifulSoup

from flask import Flask

from threading import Thread

import telebot

from telebot.types import InlineKeyboardMarkup, InlineKeyboardButton, ForceReply

from playwright.sync_api import sync_playwright

from playwright_stealth import stealth_sync

from google import genai

from fpdf import FPDF

import groq

import base64

from dotenv import load_dotenv

load_dotenv(override=False)

import sys

from bot_features import generate_dynamic_cover_letter, generate_interview_prep, send_cold_email_if_found, check_for_interviews, sync_to_notion, wait_for_otp

from enterprise_adapters import execute_workday_adapter, execute_lever_adapter, execute_greenhouse_adapter

from instahyre_engine import run_instahyre_mass_apply

from bot_optimizer import minify_form_html, apply_regex_fallback, apply_rag_memory_fallback

class LoggerWriter:

def __init__(self, filename):

self.filename = filename

self.original_stdout = sys.__stdout__ # Use the real original stdout

def write(self, message):

try:

# Encode to ASCII-safe for Windows console, then decode back

safe_msg = message.encode('utf-8', errors='replace').decode('utf-8', errors='replace')

self.original_stdout.write(safe_msg)

self.original_stdout.flush()

except Exception:

pass

try:

with open(self.filename, "a", encoding="utf-8", errors="replace") as f:

f.write(message)

except Exception:

pass

def flush(self):

try:

self.original_stdout.flush()

except Exception:

pass

sys.stdout = LoggerWriter("debug.log")

sys.stderr = sys.stdout

print("--- NEW SERVER BOOT ---")

TELEGRAM_TOKEN = os.getenv("TELEGRAM_TOKEN", "8697043742:AAHU5HAJ0cit6ctZ-GqWZdvOW490K60Cky4")

TELEGRAM_CHAT_ID = os.getenv("TELEGRAM_CHAT_ID", "7607565831") # Hardcoded fallback so HF never forgets

GEMINI_API_KEY = os.getenv("GEMINI_API_KEY", "AIzaSyBP67pZqV9YruexvY7eRPu515AxuAkgt7A,AIzaSyClfxaBYwPTw_Qq54zJwe0XxT4GYlgZuE4,AQ.Ab8RN6LRR8fRVg8D3WcnKpLzyb__MVWOPuXFLBo_iIP5wr8G8w")

TARGET_CHANNEL = os.getenv("TARGET_CHANNEL", "JobSkull") # Primary channel (kept for backward compat)

_channels_env = os.getenv("TARGET_CHANNELS", "")

TARGET_CHANNELS = [c.strip().lstrip("@") for c in _channels_env.split(",") if c.strip()] if _channels_env else [

"JobSkull",

"KickCharm",

"OffCampusJobs4u",

"offcampusjobss",

"Freshershunt",