app/services/pos_client.py

from typing import List
from httpx import AsyncClient
from pydantic import BaseModel
from datetime import datetime
from ..core.config import settings

class OrderSchema(BaseModel):
    id: str
    branch_id: str
    customer_id: str
    items: List[dict]
    total_amount: float
    status: str
    created_at: datetime
    updated_at: datetime | None

async def get_orders(branch_id: str) -> List[OrderSchema]:
    """
    Fetch orders from the POS system for a specific branch
    
    Args:
        branch_id: The ID of the branch to fetch orders for
        
    Returns:
        List[OrderSchema]: A list of orders from the POS system
    """
    async with AsyncClient() as client:
        response = await client.get(
            f"{settings.POS_API_URL}/internal/orders",
            params={"branch_id": branch_id},
            headers={"Authorization": f"Bearer {settings.SERVICE_TOKEN}"}
        )
        response.raise_for_status()
        return [OrderSchema(**order) for order in response.json()]