feat: adding pagination for GET orders/order_id/statuses inputs to root_router and fleshing out mock root backend

Author: theodorehreuter

src/stapi_fastapi/backends/root_backend.py

@@ -35,8 +35,8 @@ async def get_order(self, order_id: str, request: Request) -> ResultE[Maybe[Orde
         ...
 
     async def get_order_statuses(
-        self, order_id: str, request: Request
-    ) -> ResultE[list[T]]:
+        self, order_id: str, request: Request, next: str | None, limit: int
+    ) -> ResultE[tuple[list[T], str]]:
         """
         Get statuses for order with `order_id`.
 

src/stapi_fastapi/routers/product_router.py

@@ -47,6 +47,10 @@ def __init__(
             tags=["Products"],
         )
 
+        # Any paginated POST or requires a body needs the same POST body to be sent
+        # method property on Link object needs to be set to POST
+        # next link for GET can just include next token dont need to specify method or body
+        # where there's a POST body, have to include post body body property is request.body()
         self.add_api_route(
             path="/opportunities",
             endpoint=self.search_opportunities,
@@ -171,7 +175,7 @@ async def search_opportunities(
                 return OpportunityCollection(
                     features=features,
                     links=[
-                        Link(
+                        Link(  # current bug is missing method set and setting body for
                             href=str(
                                 request.url_for(
                                     f"{self.root_router.name}:{self.product.id}:create-order",

src/stapi_fastapi/routers/root_router.py

@@ -241,9 +241,13 @@ async def get_order(self: Self, order_id: str, request: Request) -> Order:
                 raise AssertionError("Expected code to be unreachable")
 
     async def get_order_statuses(
-        self: Self, order_id: str, request: Request
+        self: Self,
+        order_id: str,
+        request: Request,
+        next: str | None = None,
+        limit: int = 10,
     ) -> OrderStatuses:
-        match await self.backend.get_order_statuses(order_id, request):
+        match await self.backend.get_order_statuses(order_id, request, next, limit):
             case Success(statuses):
                 return OrderStatuses(
                     statuses=statuses,

tests/application.py

@@ -80,9 +80,29 @@ async def get_order(self, order_id: str, request: Request) -> ResultE[Maybe[Orde
         return Success(Maybe.from_optional(self._orders_db._orders.get(order_id)))
 
     async def get_order_statuses(
-        self, order_id: str, request: Request
-    ) -> ResultE[list[OrderStatus]]:
-        return Success(self._orders_db._statuses[order_id])
+        self, order_id: str, request: Request, next: str | None, limit: int
+    ) -> ResultE[tuple[list[OrderStatus], str]]:
+        try:
+            start = 0
+            if limit > 100:
+                limit = 100
+            statuses = self._orders_db._statuses[order_id]
+
+            if next:
+                start = int(next)
+            if not statuses and not next:
+                return Success(([], ""))
+
+            end = start + limit
+            stati = statuses[start:end]
+
+            next = ""
+            if end < len(statuses):
+                next = str(end)
+            return Success((stati, next))
+            # return Success(self._orders_db._statuses[order_id])
+        except Exception as e:
+            return Failure(e)
 
 
 class MockProductBackend(ProductBackend):