Spaces:

mnpx
/

hostb

Sleeping

App Files Files Community

mnpx commited on 27 days ago

Commit

2b1ccda

verified ·

1 Parent(s): 18b181f

Update app.py

Browse files

Files changed (1) hide show

app.py +28 -37

app.py CHANGED Viewed

@@ -1,9 +1,7 @@
-from fastapi import FastAPI, Request
 from fastapi.responses import HTMLResponse
 import uvicorn
-import asyncio
 import subprocess
-import re
 import threading
 from pathlib import Path
@@ -14,36 +12,41 @@ count_file.write_text("0")
 def increment_count():
     current = int(count_file.read_text().strip() or "0")
     count_file.write_text(str(current + 1))
-# Background thread to monitor Snowflake logs
 def monitor_snowflake():
     proc = subprocess.Popen(
         ["snowflake-proxy", "-verbose", "-relay", "https://snowflake.torproject.org/"],
         stdout=subprocess.PIPE,
         stderr=subprocess.STDOUT,
         text=True,
-        bufsize=1,
-        universal_newlines=True
     )
-    print("Snowflake proxy started... monitoring connections")
     for line in proc.stdout:
         line = line.strip()
-        if line:
-            print(line)  # for debugging in HF logs
-            # Count new client connections
-            if any(keyword in line.lower() for keyword in [
-                "client connected",
-                "accepted connection",
-                "new session",
-                "proxy: client"
-            ]):
-                increment_count()
-                print(f"✅ New person helped! Total: {count_file.read_text().strip()}")
-# Start monitoring in background
 threading.Thread(target=monitor_snowflake, daemon=True).start()
 @app.get("/", response_class=HTMLResponse)
@@ -54,35 +57,23 @@ async def dashboard():
     <head>
         <title>❄️ Living Snowflake Proxy</title>
         <style>
-            body {{
-                font-family: monospace;
-                text-align: center;
-                padding: 50px;
-                background: #0a0a0a;
-                color: #00ff9d;
-            }}
-            .counter {{
-                font-size: 5rem;
-                margin: 30px 0;
-                font-weight: bold;
-            }}
-            .status {{ color: #00ff00; }}
         </style>
         <script>
-            async function updateCount() {{
                 const res = await fetch('/count');
                 const data = await res.json();
                 document.getElementById('count').textContent = data.count;
             }}
-            setInterval(updateCount, 1500);
         </script>
     </head>
     <body>
         <h1>❄️ Living Snowflake Proxy</h1>
         <p>People I've helped today:</p>
         <div class="counter" id="count">{count}</div>
-        <p class="status">🟢 Proxy is running and helping people</p>
-        <p>Thank you for using my proxy ❤️</p>
     </body>
     </html>
     """

+from fastapi import FastAPI
 from fastapi.responses import HTMLResponse
 import uvicorn
 import subprocess
 import threading
 from pathlib import Path
 def increment_count():
     current = int(count_file.read_text().strip() or "0")
     count_file.write_text(str(current + 1))
+    print(f"✅ Counter increased! New total: {current + 1}")
 def monitor_snowflake():
+    print("Starting Snowflake proxy and monitoring...")
     proc = subprocess.Popen(
         ["snowflake-proxy", "-verbose", "-relay", "https://snowflake.torproject.org/"],
         stdout=subprocess.PIPE,
         stderr=subprocess.STDOUT,
         text=True,
+        bufsize=1
     )
     for line in proc.stdout:
         line = line.strip()
+        if not line:
+            continue
+        print(f"LOG: {line}")  # This will show in HF Logs
+        # Broader detection for client connections
+        lower_line = line.lower()
+        if any(x in lower_line for x in [
+            "client connected",
+            "accepted connection",
+            "new session",
+            "webrtc: peerconnection",
+            "data channel opened",
+            "proxy: client",
+            "established connection",
+            "starting session"
+        ]):
+            increment_count()
+# Start monitoring
 threading.Thread(target=monitor_snowflake, daemon=True).start()
 @app.get("/", response_class=HTMLResponse)
     <head>
         <title>❄️ Living Snowflake Proxy</title>
         <style>
+            body {{ font-family: monospace; text-align: center; padding: 40px; background: #0a0a0a; color: #00ff9d; }}
+            .counter {{ font-size: 6rem; margin: 20px 0; font-weight: bold; }}
         </style>
         <script>
+            async function update() {{
                 const res = await fetch('/count');
                 const data = await res.json();
                 document.getElementById('count').textContent = data.count;
             }}
+            setInterval(update, 2000);
         </script>
     </head>
     <body>
         <h1>❄️ Living Snowflake Proxy</h1>
         <p>People I've helped today:</p>
         <div class="counter" id="count">{count}</div>
+        <p>Proxy is running 24/7</p>
     </body>
     </html>
     """