Seyyed_arc/hesabixAPI/adapters/api/v1/marketplace.py

from __future__ import annotations

from typing import Any, Dict
from fastapi import APIRouter, Depends, Request, Body
from sqlalchemy.orm import Session

from adapters.db.session import get_db
from app.core.auth_dependency import get_current_user, AuthContext
from app.core.permissions import require_business_access_dep
from app.core.responses import success_response
from app.services.marketplace_service import (
	list_plugins,
	purchase_plugin,
	list_orders,
	list_invoices,
	get_business_plugin_status,
	list_business_plugins,
	start_trial_plugin,
)


router = APIRouter(prefix="/marketplace", tags=["یکپارچه‌سازی"])


@router.get(
	"/plugins",
	summary="لیست افزونه‌ها و پلن‌ها",
)
def list_plugins_endpoint(
	request: Request,
	db: Session = Depends(get_db),
	ctx: AuthContext = Depends(get_current_user),
) -> dict:
	data = list_plugins(db)
	return success_response(data, request)


@router.post(
	"/business/{business_id}/purchase",
	summary="خرید افزونه برای کسب‌وکار (پرداخت از کیف‌پول در صورت کفایت)",
)
def purchase_plugin_endpoint(
	request: Request,
	business_id: int,
	payload: Dict[str, Any] = Body(...),
	_: None = Depends(require_business_access_dep),
	db: Session = Depends(get_db),
	ctx: AuthContext = Depends(get_current_user),
) -> dict:
	result = purchase_plugin(db, business_id=int(business_id), user_id=ctx.get_user_id(), payload=payload)
	return success_response(result, request)


@router.get(
	"/business/{business_id}/orders",
	summary="لیست سفارش‌های بازار افزونه برای کسب‌وکار",
)
def list_orders_endpoint(
	request: Request,
	business_id: int,
	limit: int = 20,
	skip: int = 0,
	_: None = Depends(require_business_access_dep),
	db: Session = Depends(get_db),
	ctx: AuthContext = Depends(get_current_user),
) -> dict:
	data = list_orders(db, business_id=int(business_id), limit=limit, skip=skip)
	return success_response(data, request)


@router.get(
	"/business/{business_id}/invoices",
	summary="لیست صورتحساب‌های بازار افزونه برای کسب‌وکار",
)
def list_invoices_endpoint(
	request: Request,
	business_id: int,
	limit: int = 20,
	skip: int = 0,
	_: None = Depends(require_business_access_dep),
	db: Session = Depends(get_db),
	ctx: AuthContext = Depends(get_current_user),
) -> dict:
	data = list_invoices(db, business_id=int(business_id), limit=limit, skip=skip)
	return success_response(data, request)


@router.get(
	"/business/{business_id}/plugins",
	summary="لیست افزونه‌های فعال کسب‌وکار",
	description="دریافت لیست تمام افزونه‌های فعال و غیرفعال کسب‌وکار",
)
def list_business_plugins_endpoint(
	request: Request,
	business_id: int,
	_: None = Depends(require_business_access_dep),
	db: Session = Depends(get_db),
	ctx: AuthContext = Depends(get_current_user),
) -> dict:
	import logging
	from app.core.responses import ApiError
	from sqlalchemy.exc import SQLAlchemyError
	
	logger = logging.getLogger(__name__)
	
	try:
		data = list_business_plugins(db, business_id=int(business_id))
		return success_response(data, request)
	except SQLAlchemyError as e:
		logger.error(
			f"Database error in list_business_plugins for business_id={business_id}",
			exc_info=True,
			extra={
				"business_id": business_id,
				"user_id": ctx.get_user_id() if ctx else None,
				"path": request.url.path,
			}
		)
		db.rollback()
		raise ApiError(
			"DATABASE_ERROR",
			"خطا در ارتباط با پایگاه داده. لطفاً بعداً تلاش کنید.",
			http_status=503
		)
	except Exception as e:
		logger.error(
			f"Unexpected error in list_business_plugins for business_id={business_id}: {str(e)}",
			exc_info=True,
			extra={
				"business_id": business_id,
				"user_id": ctx.get_user_id() if ctx else None,
				"path": request.url.path,
			}
		)
		raise ApiError(
			"INTERNAL_SERVER_ERROR",
			"خطای داخلی سرور رخ داد. لطفاً با پشتیبانی تماس بگیرید.",
			http_status=500
		)


@router.get(
	"/business/{business_id}/plugins/{plugin_id}/status",
	summary="وضعیت افزونه برای کسب‌وکار",
	description="بررسی وضعیت یک افزونه خاص برای کسب‌وکار",
)
def get_business_plugin_status_endpoint(
	request: Request,
	business_id: int,
	plugin_id: int,
	_: None = Depends(require_business_access_dep),
	db: Session = Depends(get_db),
	ctx: AuthContext = Depends(get_current_user),
) -> dict:
	data = get_business_plugin_status(db, business_id=int(business_id), plugin_id=int(plugin_id))
	if data is None:
		return success_response(None, request, "این افزونه برای این کسب‌وکار فعال نیست")
	return success_response(data, request)


@router.post(
	"/business/{business_id}/plugins/{plugin_id}/start-trial",
	summary="شروع دوره trial برای افزونه",
	description="شروع دوره تست رایگان برای یک افزونه (هر کسب‌وکار فقط یکبار می‌تواند از trial استفاده کند)",
)
def start_trial_plugin_endpoint(
	request: Request,
	business_id: int,
	plugin_id: int,
	_: None = Depends(require_business_access_dep),
	db: Session = Depends(get_db),
	ctx: AuthContext = Depends(get_current_user),
) -> dict:
	result = start_trial_plugin(
		db,
		business_id=int(business_id),
		plugin_id=int(plugin_id),
		user_id=ctx.get_user_id(),
	)
	return success_response(result, request, "دوره trial با موفقیت شروع شد")