added text filter and first or last filter options

Author: iLLiCiTiT

ayon_api/_api_helpers/events.py

@@ -40,13 +40,16 @@ def get_events(
         project_names: Optional[Iterable[str]] = None,
         statuses: Optional[Iterable[EventStatus]] = None,
         users: Optional[Iterable[str]] = None,
+        text_filter: Optional[str] = None,
         include_logs: Optional[bool] = None,
         has_children: Optional[bool] = None,
         newer_than: Optional[str] = None,
         older_than: Optional[str] = None,
         fields: Optional[Iterable[str]] = None,
         limit: Optional[int] = None,
         order: Optional[SortOrder] = None,
+        first: Optional[int] = None,
+        last: Optional[int] = None,
         states: Optional[Iterable[str]] = None,
     ) -> Generator[dict[str, Any], None, None]:
         """Get events from server with filtering options.
@@ -62,6 +65,7 @@ def get_events(
             statuses (Optional[Iterable[EventStatus]]): Filtering by statuses.
             users (Optional[Iterable[str]]): Filtering by users
                 who created/triggered an event.
+            text_filter (Optional[str]): Filtering by text in event payload.
             include_logs (Optional[bool]): Query also log events.
             has_children (Optional[bool]): Event is with/without children
                 events. If 'None' then all events are returned, default.
@@ -75,6 +79,8 @@ def get_events(
             order (Optional[SortOrder]): Order events in ascending
                 or descending order. It is recommended to set 'limit'
                 when used descending.
+            first (Optional[int]): Get first n events.
+            last (Optional[int]): Get last n events.
             states (Optional[Iterable[str]]): DEPRECATED Filtering by states.
                 Use 'statuses' instead.
 
@@ -111,6 +117,9 @@ def get_events(
             ("hasChildrenFilter", has_children),
             ("newerThanFilter", newer_than),
             ("olderThanFilter", older_than),
+            ("textFilter", text_filter),
+            ("firstFilter", first),
+            ("lastFilter", last),
         ):
             if filter_value is not None:
                 filters[filter_key] = filter_value

ayon_api/graphql_queries.py

@@ -593,6 +593,9 @@ def events_graphql_query(fields, order, use_states=False):
     has_children_var = query.add_variable("hasChildrenFilter", "Boolean!")
     newer_than_var = query.add_variable("newerThanFilter", "String!")
     older_than_var = query.add_variable("olderThanFilter", "String!")
+    text_filter_var = query.add_variable("textFilter", "String!")
+    first_n_var = query.add_variable("firstFilter", "Int!")
+    last_n_var = query.add_variable("lastFilter", "Int!")
 
     statuses_filter_name = "statuses"
     if use_states:
@@ -607,6 +610,9 @@ def events_graphql_query(fields, order, use_states=False):
     events_field.set_filter("hasChildren", has_children_var)
     events_field.set_filter("newerThan", newer_than_var)
     events_field.set_filter("olderThan", older_than_var)
+    events_field.set_filter("filter", text_filter_var)
+    events_field.set_filter("first", first_n_var)
+    events_field.set_filter("last", last_n_var)
 
     nested_fields = fields_to_dict(set(fields))