from typing import List, Dict, Any from smelog.factory import BoundLogger from charts_push_messages.schemas import FeedMessageCreatedSchema from charts_push_messages.utils.common import handle_events_deserialization, handle_check_received_events def check_incoming_events(logger: BoundLogger, events: List[Dict[str, Any]]) -> List[int]: """Deserialize and check actuality of incoming Message Created events Args: logger: Logger events: List of Incoming Events Returns: List of actual event id(s) """ # Deserialize events for further data manipulations to check tha actuality of the events deserialized_events = handle_events_deserialization( logger=logger, schema=FeedMessageCreatedSchema(), events=events ) return handle_check_received_events(logger=logger, events=deserialized_events)