diff --git a/app/routers/recipes.py b/app/routers/recipes.py index 1befb91..2ac45c6 100644 --- a/app/routers/recipes.py +++ b/app/routers/recipes.py @@ -29,7 +29,7 @@ class RecipeUploadRequest(BaseModel): class RecipeRunRequest(BaseModel): - inputs: List[str] = [] + inputs: dict = {} def get_recipe_service(): diff --git a/app/services/cache_service.py b/app/services/cache_service.py index c9b4a95..7c31ff2 100644 --- a/app/services/cache_service.py +++ b/app/services/cache_service.py @@ -108,3 +108,22 @@ class CacheService: def get_ipfs_cid(self, content_hash: str) -> Optional[str]: """Get IPFS CID for cached content.""" return self.cache.get_ipfs_cid(content_hash) + + async def list_media( + self, + actor_id: str = None, + username: str = None, + offset: int = 0, + limit: int = 24, + media_type: str = None, + ) -> List[Dict[str, Any]]: + """List media items in cache.""" + # Use list_items internally, converting offset to page + page = (offset // limit) + 1 if limit > 0 else 1 + result = await self.list_items( + actor_id=actor_id or username, + media_type=media_type, + page=page, + limit=limit, + ) + return result.get("items", [])