Feat/#3 결제 요청 (#7)

## 작업 내역 (관련 이슈)
- 사용자의 XRPL 지갑 seed로 결제 트랜잭션을 서명 및 전송하고, 파일 판매자에게 XRP를 송금하며, RLUSD 할인 및
거래 이력을 반영하는 전체 결제 로직입니다.

## 특이 사항
-

Author: seyeon22

poetry.lock

@@ -15,6 +15,9 @@ boto3 = "^1.37.16"
 botocore = "^1.37.16"
 httpx = "^0.28.1"
 dotenv = "^0.9.9"
+xrpl-py = "^4.1.0"
+pymongo = "^4.11.3"
+motor = "^3.7.0"
 
 [build-system]
 requires = ["poetry-core"]

pyproject.toml

@@ -0,0 +1,9 @@
+import os
+from dotenv import load_dotenv
+import xrpl
+
+load_dotenv()
+
+XRPL_RPC_URL = os.getenv("XRPL_RPC_URL")
+
+client = xrpl.clients.JsonRpcClient(XRPL_RPC_URL)

src/main/config/XrplConfig.py

@@ -0,0 +1,10 @@
+import os
+from dotenv import load_dotenv
+from pymongo import MongoClient
+
+load_dotenv()
+
+MONGODB_URL = os.getenv("MONGODB_URL")
+
+def get_mongo_client() -> MongoClient:
+    return MongoClient(MONGODB_URL + "?retryWrites=true")

src/main/config/mongodb.py

@@ -0,0 +1,4 @@
+from pydantic import BaseModel
+
+class PaymentsRequestDto(BaseModel):
+    file_id: str

src/main/payments/dto/PaymentsRequestDto.py

@@ -0,0 +1,56 @@
+from pymongo import MongoClient
+from src.main.config.mongodb import get_mongo_client
+
+class PaymentsRepository:
+    def __init__(self):
+        client: MongoClient = get_mongo_client()
+        self.db = client["xrpedia-data"]
+        self.wallets_collection = self.db["wallets"]
+        self.document_collection = self.db["document_collection"]
+        self.transactions_collection = self.db["transactions"]
+
+    # MongoDB에서 user_id 기반으로 XRPL 지갑 정보 조회
+    def get_user_wallet(self, user_id: str):
+        return self.wallets_collection.find_one({"user_id": user_id}, {"_id": 0, "address": 1, "seed": 1})
+    
+    # MongoDB에서 파일 정보 전체 조회 (price + owner_id 포함)
+    def get_file_info(self, file_id: str):
+        return self.document_collection.find_one(
+            {"file_id": file_id}, 
+            {"_id": 0, "price": 1, "uploader_id": 1}
+        )
+    
+    # MongoDB에서 파일 가격 조회
+    def get_file_price(self, file_id: str):
+        file_info = self.document_collection.find_one(
+            {"file_id": file_id},
+            {"_id": 0, "price": 1}
+        )
+        return file_info["price"] if file_info else None
+    
+    def get_user_profile(self, user_id: str):
+        return self.wallets_collection.find_one(
+            {"user_id": user_id},
+            {"_id": 0, "profile": 1}
+        )
+    
+    def update_user_rlusd(self, user_id: str, new_rlusd: int):
+        self.wallets_collection.update_one(
+            {"user_id": user_id},
+            {"$set": {"rlusd": new_rlusd}}
+        )
+    
+    def is_transaction_exist(self, user_id: str, file_id: str):
+        print(f"Checking if transaction exists for user_id: {user_id}, file_id: {file_id}")
+        transaction = self.transactions_collection.find_one(
+            {"user_id": user_id, "file_id": file_id}
+        )
+        if transaction:
+            print(f"Transaction found: {transaction}")
+        else:
+            print("Transaction not found")
+        return transaction is not None
+    
+    def save_transaction(self, tx_data: dict):
+        print(f"Saving transaction: {tx_data}")
+        self.transactions_collection.insert_one(tx_data)

src/main/payments/dto/__init__.py

@@ -0,0 +1,21 @@
+from fastapi import APIRouter, Depends
+from fastapi.concurrency import run_in_threadpool
+from src.main.payments.dto.PaymentsRequestDto import PaymentsRequestDto
+from src.main.payments.service.PaymentsService import PaymentsService
+from src.main.auth.dependencies import get_current_user
+import uuid
+
+router = APIRouter(
+    prefix="/payments",
+    tags=["payments"],
+)
+
+@router.post("/_request")
+async def request_payment(
+    request: PaymentsRequestDto,
+    user_id: uuid.UUID = Depends(get_current_user),
+    payments_service: PaymentsService = Depends()
+):
+    return await run_in_threadpool(
+        payments_service.request_payment, str(user_id), request.file_id
+    )