Enforce keyword arguments

ragna/deploy/_api.py

@@ -43,17 +43,17 @@ async def content_stream() -> AsyncIterator[bytes]:
 
     @router.get("/documents")
     async def get_documents(user: UserDependency) -> list[schemas.Document]:
-        return engine.get_documents(user.name)
+        return engine.get_documents(user=user.name)
 
     @router.get("/documents/{id}")
     async def get_document(user: UserDependency, id: uuid.UUID) -> schemas.Document:
-        return engine.get_document(user.name, id)
+        return engine.get_document(user=user.name, id=id)
 
     @router.get("/documents/{id}/content")
     async def get_document_content(
         user: UserDependency, id: uuid.UUID
     ) -> StreamingResponse:
-        schema_document = engine.get_document(user.name, id)
+        schema_document = engine.get_document(user=user.name, id=id)
         core_document = engine._to_core.document(schema_document)
         headers = {"Content-Disposition": f"inline; filename={schema_document.name}"}
 

ragna/deploy/_engine.py

@@ -182,7 +182,7 @@ async def store_documents(
 
         streams = dict(ids_and_streams)
 
-        documents = self.get_documents(user, streams.keys())
+        documents = self.get_documents(user=user, ids=streams.keys())
 
         for document in documents:
             core_document = cast(
@@ -191,13 +191,13 @@ async def store_documents(
             await core_document._write(streams[document.id])
 
     def get_documents(
-        self, user: str, ids: Collection[uuid.UUID] | None = None
+        self, *, user: str, ids: Collection[uuid.UUID] | None = None
     ) -> list[schemas.Document]:
         with self._database.get_session() as session:
             return self._database.get_documents(session, user=user, ids=ids)
 
-    def get_document(self, user: str, id: uuid.UUID) -> schemas.Document:
-        return next(iter(self.get_documents(user, [id])))
+    def get_document(self, *, user: str, id: uuid.UUID) -> schemas.Document:
+        return next(iter(self.get_documents(user=user, ids=[id])))
 
     def create_chat(
         self, *, user: str, chat_creation: schemas.ChatCreation