core (memory/sqla): add attribute to filter on item_ids in getItems

This commit is contained in:
Goffi 2022-05-13 17:58:51 +02:00
commit 75684953be

View file

@ -1224,6 +1224,7 @@ class Storage:
self,
node: PubsubNode,
max_items: Optional[int] = None,
item_ids: Optional[list[str]] = None,
before: Optional[str] = None,
after: Optional[str] = None,
from_index: Optional[int] = None,
@ -1279,6 +1280,9 @@ class Storage:
.limit(max_items)
)
if item_ids is not None:
stmt = stmt.where(PubsubItem.name.in_(item_ids))
if not order_by:
order_by = [C.ORDER_BY_MODIFICATION]