Mercurial > libervia-backend

comparison libervia/backend/plugins/plugin_pubsub_cache.py @ 4384:33468e175ade

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
backend: various fixes, and type hints improvments.
author Goffi <goffi@goffi.org>
date Sun, 03 Aug 2025 23:36:22 +0200
parents c9626f46b63e
children
comparison
equal deleted inserted replaced
4383:7c1d77efc752 4384:33468e175ade
348 async def analyse_node( 348 async def analyse_node(
349 self, 349 self,
350 client: SatXMPPEntity, 350 client: SatXMPPEntity,
351 service: jid.JID, 351 service: jid.JID,
352 node: str, 352 node: str,
353 pubsub_node: PubsubNode = None, 353 pubsub_node: PubsubNode|None = None,
354 ) -> dict: 354 ) -> dict:
355 """Use registered analysers on a node to determine what it is used for""" 355 """Use registered analysers on a node to determine what it is used for"""
356 analyse = {"service": service, "node": node} 356 analyse = {"service": service, "node": node}
357 if pubsub_node is None: 357 if pubsub_node is None:
358 try: 358 try:
479 max_items: Optional[int] = None, 479 max_items: Optional[int] = None,
480 item_ids: Optional[List[str]] = None, 480 item_ids: Optional[List[str]] = None,
481 sub_id: Optional[str] = None, 481 sub_id: Optional[str] = None,
482 rsm_request: Optional[rsm.RSMRequest] = None, 482 rsm_request: Optional[rsm.RSMRequest] = None,
483 extra: Optional[Dict[str, Any]] = None, 483 extra: Optional[Dict[str, Any]] = None,
484 ) -> Tuple[List[PubsubItem], dict]: 484 ) -> tuple[list[PubsubItem], dict]:
485 """Get items from cache, using same arguments as for external Pubsub request""" 485 """Get items from cache, using same arguments as for external Pubsub request"""
486 if extra is None: 486 if extra is None:
487 extra = {} 487 extra = {}
488 if "mam" in extra: 488 if "mam" in extra:
489 raise NotImplementedError("MAM queries are not supported yet") 489 raise NotImplementedError("MAM queries are not supported yet")