@@ -683,6 +683,7 @@ def _validate_get_all_args(
683683 endTime : typing .Optional [types .TEndTime ] = None ,
684684 reverse : typing .Optional [types .TReverse ] = None ,
685685 direction : typing .Optional [types .TDirection ] = None ,
686+ status : typing .Optional [types .TStatus ] = None ,
686687) -> None :
687688 # Validate limit
688689 if (limit is not None and not isinstance (limit , types .TLimit )) or (
@@ -737,6 +738,12 @@ def _validate_get_all_args(
737738 f'received "{ direction } "'
738739 )
739740
741+ if status is not None and not isinstance (status , types .TStatus ):
742+ raise exceptions .MessageError (
743+ 'the value of "status" is not valid, expected a string, '
744+ f'received "{ status } "'
745+ )
746+
740747
741748def get_all (
742749 limit : typing .Optional [types .TLimit ] = None ,
@@ -746,6 +753,7 @@ def get_all(
746753 endTime : typing .Optional [types .TEndTime ] = None ,
747754 reverse : typing .Optional [types .TReverse ] = None ,
748755 direction : typing .Optional [types .TDirection ] = None ,
756+ status : typing .Optional [types .TStatus ] = None ,
749757) -> TMessages :
750758 """
751759 Retrieve all messages.
@@ -765,6 +773,7 @@ def get_all(
765773 endTime = endTime ,
766774 reverse = reverse ,
767775 direction = direction ,
776+ status = status ,
768777 )
769778
770779 try :
@@ -783,7 +792,7 @@ def get_all(
783792 }
784793
785794 messages_get_request = request .Request (
786- f"{ _URL } { querystring .build (limit = limit , offset = offset , filter = filter ,startTime = startTime ,endTime = endTime ,reverse = reverse ,direction = direction )} " ,
795+ f"{ _URL } { querystring .build (limit = limit , offset = offset , filter = filter ,startTime = startTime ,endTime = endTime ,reverse = reverse ,direction = direction , status = status )} " ,
787796 headers = headers ,
788797 method = "GET" ,
789798 )
0 commit comments