Create app py

app py

@@ -0,0 +1,216 @@
+import os
+import time
+import json
+import logging
+import threading
+import requests
+from bs4 import BeautifulSoup
+from flask import Flask
+
+# ==========================================
+# ⚙️ الإعدادات والمتغيرات (تم توليدها تلقائياً)
+# ==========================================
+SNAPCHAT_USER = "Ah_md107"
+TELEGRAM_BOT_TOKEN = "8390641764:AAES8DscPm5HvSWUBqVyK-Ss9saw-Ppgzc4"
+TELEGRAM_CHAT_ID = "-5264228773"
+CHECK_INTERVAL = 15 * 60  # بالثواني
+
+# إعداد ملف تسجيل البيانات المنشورة لمنع التكرار
+POSTED_STORIES_FILE = "posted_stories.json"
+
+logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(levelname)s - %(message)s')
+
+app = Flask(__name__)
+
+def load_posted_stories():
+    if os.path.exists(POSTED_STORIES_FILE):
+        try:
+            with open(POSTED_STORIES_FILE, "r", encoding="utf-8") as f:
+                return json.load(f)
+        except Exception as e:
+            logging.error(f"خطأ في قراءة ملف السجل: {e}")
+    return []
+
+def save_posted_stories(posted_list):
+    try:
+        # نحتفظ بآخر 200 قصة فقط لعدم استهلاك المساحة
+        with open(POSTED_STORIES_FILE, "w", encoding="utf-8") as f:
+            json.dump(posted_list[-200:], f, ensure_ascii=False, indent=2)
+    except Exception as e:
+        logging.error(f"خطأ في حفظ ملف السجل: {e}")
+
+def send_to_telegram(media_url, is_video, caption):
+    """إرسال الوسائط إلى جروب/قناة التليجرام باستخدام Telegram Bot API المباشر"""
+    base_url = f"https://api.telegram.org/bot{TELEGRAM_BOT_TOKEN}/"
+    
+    try:
+        # تحميل الوسيطة في الذاكرة لتجاوز حماية الروابط المباشرة لسناب شات
+        logging.info(f"جاري تحميل الوسائط من سناب شات لإرسالها للتليجرام...")
+        headers = {
+            "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/130.0.0.0 Safari/537.36"
+        }
+        media_response = requests.get(media_url, headers=headers, timeout=30)
+        
+        if media_response.status_code != 200:
+            logging.error("فشل في تحميل محتوى القصة من الرابط.")
+            return False
+
+        files = {}
+        data = {'chat_id': TELEGRAM_CHAT_ID, 'caption': caption}
+        
+        if is_video:
+            endpoint = base_url + "sendVideo"
+            files['video'] = ('story.mp4', media_response.content, 'video/mp4')
+        else:
+            endpoint = base_url + "sendPhoto"
+            files['photo'] = ('story.jpg', media_response.content, 'image/jpeg')
+
+        logging.info("جاري الإرسال إلى تليجرام...")
+        resp = requests.post(endpoint, data=data, files=files, timeout=40)
+        
+        if resp.status_code == 200:
+            logging.info("✅ تم إرسال القصة إلى تليجرام بنجاح!")
+            return True
+        else:
+            logging.error(f"⚠️ خطأ من تليجرام: {resp.text}")
+            return False
+            
+    except Exception as e:
+        logging.error(f"حدث خطأ أثناء الإرسال للتليجرام: {e}")
+        return False
+
+def scrape_snapchat_stories():
+    """استخراج قصص سناب شات العامة من واجهة الويب (تعمل لعام 2026)"""
+    url = f"https://www.snapchat.com/add/{SNAPCHAT_USER}"
+    headers = {
+        "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/130.0.0.0 Safari/537.36",
+        "Accept-Language": "en-US,en;q=0.9,ar;q=0.8"
+    }
+    
+    try:
+        logging.info(f"فحص الحساب: {SNAPCHAT_USER} ...")
+        res = requests.get(url, headers=headers, timeout=20)
+        if res.status_code == 404:
+            logging.warning("الحساب غير موجود أو غير متاح للعامة.")
+            return []
+            
+        soup = BeautifulSoup(res.text, 'html.parser')
+        
+        # سناب شات يضع بيانات القصص في كود JSON مدمج في الصفحة
+        script_data = soup.find('script', id='__NEXT_DATA__')
+        if not script_data:
+            # محاولة البحث عن عنصر JSON البديل لعام 2026
+            script_data = soup.find('script', {'type': 'application/json'})
+            
+        if not script_data:
+            logging.warning("لم يتم العثور على بيانات القصص في الصفحة.")
+            return []
+
+        json_content = json.loads(script_data.string)
+        
+        # استخراج مصفوفة القصص (تختلف الهيكلية قليلاً حسب التحديثات، نبحث في الـ props)
+        stories = []
+        try:
+            # تتبع المسار المحتمل لقصص المستخدم
+            user_profile = json_content.get('props', {}).get('pageProps', {}).get('userProfile', {})
+            public_stories = user_profile.get('publicStories', [])
+            
+            # إذا لم تكن موجودة، قد تكون في state
+            if not public_stories:
+                snap_list = json_content.get('props', {}).get('pageProps', {}).get('story', {}).get('snaps', [])
+                public_stories = snap_list
+                
+            for snap in public_stories:
+                snap_id = snap.get('id') or snap.get('snapId')
+                media_url = snap.get('mediaUrl') or snap.get('url')
+                media_type = snap.get('mediaType', '') # VIDEO or IMAGE
+                timestamp = snap.get('timestampInSec') or snap.get('creationTimestamp')
+                
+                if snap_id and media_url:
+                    is_vid = "VIDEO" in str(media_type).upper() or ".mp4" in media_url
+                    stories.append({
+                        "id": str(snap_id),
+                        "url": media_url,
+                        "is_video": is_vid,
+                        "time": timestamp
+                    })
+        except Exception as ex:
+            logging.error(f"فشل في تحليل مسار الـ JSON: {ex}")
+            
+        return stories
+
+    except Exception as e:
+        logging.error(f"خطأ أثناء الاتصال بسناب شات: {e}")
+        return []
+
+def bot_worker():
+    """الحلقة التكرارية لعمل البوت في الخلفية"""
+    logging.info("🚀 بدء تشغيل عامل البوت في الخلفية...")
+    
+    # الانتظار قليلاً حتى يعمل الخادم
+    time.sleep(5)
+    
+    while True:
+        posted_ids = load_posted_stories()
+        current_stories = scrape_snapchat_stories()
+        
+        logging.info(f"تم العثور على {len(current_stories)} قصة عامة متاحة في صفحة الويب.")
+        
+        new_posted = False
+        for story in current_stories:
+            s_id = story["id"]
+            if s_id not in posted_ids:
+                logging.info(f"🌟 قصة جديدة تم رصدها! المعرف: {s_id[:10]}...")
+                
+                # تجهيز النص المرفق
+                caption = f"👻 منشور جديد من <b>{SNAPCHAT_USER}</b>\n\n🔗 <a href='https://www.snapchat.com/add/{SNAPCHAT_USER}'>مشاهدة الحساب على سناب شات</a>"
+                
+                success = send_to_telegram(story["url"], story["is_video"], caption)
+                if success:
+                    posted_ids.append(s_id)
+                    new_posted = True
+                    # الانتظار بين إرسال كل قصة لتجنب ضغط التليجرام
+                    time.sleep(3)
+        
+        if new_posted:
+            save_posted_stories(posted_ids)
+            
+        logging.info(f"💤 الدخول في وضع الانتظار لمدة {CHECK_INTERVAL // 60} دقيقة...")
+        time.sleep(CHECK_INTERVAL)
+
+# ==========================================
+# 🌐 خادم الويب للحفاظ على تشغيل Hugging Face
+# ==========================================
+@app.route('/')
+def home():
+    return f"""
+    <html>
+        <head>
+            <title>Snap2Tele Bot Status</title>
+            <meta charset="utf-8">
+            <style>
+                body {{ font-family: system-ui; text-align: center; padding: 50px; background: #f8fafc; color: #0f172a; }}
+                .status {{ display: inline-block; padding: 10px 20px; background: #22c55e; color: white; border-radius: 50px; font-weight: bold; }}
+            </style>
+        </head>
+        <body>
+            <h1>🚀 البوت يعمل بنجاح</h1>
+            <p class="status">● ONLINE</p>
+            <p>يتم مراقبة حساب سناب شات: <b>{SNAPCHAT_USER}</b></p>
+            <p>لإبقاء البوت يعمل 24/7 مجاناً، أضف هذا الرابط إلى موقع <b>cron-job.org</b></p>
+        </body>
+    </html>
+    """
+
+@app.route('/health')
+def health():
+    return {"status": "ok", "user": SNAPCHAT_USER, "timestamp": time.time()}
+
+if __name__ == '__main__':
+    # تشغيل مراقب السناب شات في Thread منفصل حتى لا يتعارض مع خادم الويب
+    worker_thread = threading.Thread(target=bot_worker, daemon=True)
+    worker_thread.start()
+    
+    # تشغيل خادم Flask على المنفذ 7860 المتوافق مع Hugging Face Spaces
+    port = int(os.environ.get('PORT', 7860))
+    app.run(host='0.0.0.0', port=port)