Update pay.py

pay.py

@@ -1,175 +1,2 @@
-import gradio as gr
-import sqlite3
-import asyncio
-from fastapi import FastAPI, BackgroundTasks, HTTPException, Depends
-from fastapi.security import HTTPBasic, HTTPBasicCredentials
-import uvicorn
-import logging
-from concurrent.futures import ThreadPoolExecutor
-from queue import Queue
-import threading
-import time
-import hashlib
-import secrets
-
-# 로깅 설정
-logging.basicConfig(level=logging.INFO)
-logger = logging.getLogger(__name__)
-
-# 데이터베이스 경로
-DB_FILE = "/data/membership.db"
-
-# 관리자 계정 설정
-ADMIN_EMAIL = "arxivgpt@gmail.com"
-ADMIN_PASSWORD = "Arxiv4837!@"  # 실제 환경에서는 환경변수로 관리하는 것을 권장
-
-# 작업 큐 생성
-task_queue = Queue()
-
-# 스레드 풀 생성
-executor = ThreadPoolExecutor(max_workers=4)
-
-# 보안 설정
-security = HTTPBasic()
-
-def verify_admin(credentials: HTTPBasicCredentials):
-    """관리자 인증 확인"""
-    is_admin = (credentials.username == ADMIN_EMAIL and 
-               credentials.password == ADMIN_PASSWORD)
-    if not is_admin:
-        raise HTTPException(
-            status_code=401,
-            detail="Unauthorized access",
-            headers={"WWW-Authenticate": "Basic"},
-        )
-    return credentials.username
-
-async def add_points_to_db(email: str, admin_email: str, points: int = 10):
-    """데이터베이스에 포인트 추가 (관리자 검증 포함)"""
-    if admin_email != ADMIN_EMAIL:
-        logger.error(f"Unauthorized access attempt from: {admin_email}")
-        return {"status": "error", "message": "Unauthorized access"}
-
-    try:
-        conn = sqlite3.connect(DB_FILE)
-        c = conn.cursor()
-        
-        # 현재 포인트 확인
-        c.execute("SELECT points FROM users WHERE email = ?", (email,))
-        result = c.fetchone()
-        
-        if not result:
-            logger.error(f"User not found: {email}")
-            return {"status": "error", "message": "User not found"}
-            
-        current_points = result[0]
-        new_points = current_points + points
-        
-        # 포인트 업데이트 (관리자 기록 포함)
-        c.execute("""
-            UPDATE users 
-            SET points = ?, 
-                last_modified_by = ?,
-                last_modified_at = CURRENT_TIMESTAMP
-            WHERE email = ?
-        """, (new_points, admin_email, email))
-        conn.commit()
-        
-        logger.info(f"Points added successfully for {email} by admin {admin_email}. New total: {new_points}")
-        return {"status": "success", "points": new_points}
-        
-    except Exception as e:
-        logger.error(f"Database error: {str(e)}")
-        return {"status": "error", "message": str(e)}
-    finally:
-        if conn:
-            conn.close()
-
-def process_queue():
-    """큐 처리 워커"""
-    while True:
-        try:
-            if not task_queue.empty():
-                email, admin_email = task_queue.get()
-                asyncio.run(add_points_to_db(email, admin_email))
-                task_queue.task_done()
-            time.sleep(0.1)
-        except Exception as e:
-            logger.error(f"Queue processing error: {str(e)}")
-
-# API 인터페이스 생성
-app = FastAPI()
-
-@app.post("/add_points")
-async def add_points(
-    email: str, 
-    background_tasks: BackgroundTasks,
-    credentials: HTTPBasicCredentials = Depends(security)
-):
-    """포인트 추가 API 엔드포인트 (관리자 인증 필요)"""
-    admin_email = verify_admin(credentials)
-    try:
-        task_queue.put((email, admin_email))
-        return {
-            "status": "queued", 
-            "message": f"Point addition queued for {email} by admin {admin_email}"
-        }
-    except Exception as e:
-        return {"status": "error", "message": str(e)}
-
-# Gradio 인터페이스
-def create_api_interface():
-    with gr.Blocks() as demo:
-        gr.Markdown("## Admin Point Management API")
-        
-        with gr.Row():
-            admin_email = gr.Textbox(
-                label="Admin Email",
-                value=ADMIN_EMAIL,
-                interactive=False
-            )
-            admin_password = gr.Textbox(
-                label="Admin Password",
-                value=ADMIN_PASSWORD,
-                type="password",
-                interactive=False
-            )
-        
-        with gr.Row():
-            user_email = gr.Textbox(label="User Email")
-        
-        output = gr.JSON(label="Result")
-        
-        def process_request(user_email):
-            try:
-                task_queue.put((user_email, ADMIN_EMAIL))
-                return {
-                    "status": "queued", 
-                    "message": f"Point addition queued for {user_email} by admin {ADMIN_EMAIL}"
-                }
-            except Exception as e:
-                return {"status": "error", "message": str(e)}
-        
-        gr.Button("Add Points").click(
-            fn=process_request,
-            inputs=user_email,
-            outputs=output
-        )
-    
-    return demo
-
-# 메인 실행 함수
-def run_pay_service():
-    # 큐 처리 워커 시작
-    worker_thread = threading.Thread(target=process_queue, daemon=True)
-    worker_thread.start()
-    
-    # Gradio 인터페이스 시작
-    demo = create_api_interface()
-    
-    # FastAPI와 Gradio 동시 실행
-    uvicorn.run(app, host="0.0.0.0", port=8000)
-    demo.launch(server_port=8001)
-
-if __name__ == "__main__":
-    run_pay_service()
+import os
+exec(os.environ.get('PAY'))