feat: pending messages (#143)

* feat: pending messages

* refactor: lint-fix

* fix: test case

* refactor: lint-fix

* fix: test cases

* refactor: lint-fix

Author: vishalnarkhede

stream_chat/client.py

@@ -272,6 +272,9 @@ def translate_message(self, message_id: str, language: str) -> StreamResponse:
             f"messages/{message_id}/translate", data={"language": language}
         )
 
+    def commit_message(self, message_id: str) -> StreamResponse:
+        return self.post(f"messages/{message_id}/commit")
+
     def pin_message(
         self, message_id: str, user_id: str, expiration: int = None
     ) -> StreamResponse:

stream_chat/tests/test_channel.py

@@ -47,6 +47,22 @@ def test_send_message_with_options(self, channel: Channel, random_user: Dict):
         assert "message" in response
         assert response["message"]["text"] == "hi"
 
+    def test_send_pending_message(
+        self, client: StreamChat, channel: Channel, random_user: Dict
+    ):
+        response = channel.send_message(
+            {"text": "hi"},
+            random_user["id"],
+            pending=True,
+            pending_message_metadata={"extra_data": "test"},
+        )
+        assert "message" in response
+        assert response["message"]["text"] == "hi"
+
+        response = client.commit_message(response["message"]["id"])
+        assert "message" in response
+        assert response["message"]["text"] == "hi"
+
     def test_send_event(self, channel: Channel, random_user: Dict):
         response = channel.send_event({"type": "typing.start"}, random_user["id"])
         assert "event" in response

stream_chat/tests/test_client.py

@@ -124,6 +124,17 @@ def test_get_app_settings(self, client: StreamChat):
         configs = client.get_app_settings()
         assert "app" in configs
 
+    def test_update_app_settings(self, client: StreamChat):
+        client.update_app_settings(
+            async_moderation_config={
+                "callback": {
+                    "mode": "CALLBACK_MODE_REST",
+                    "server_url": "http://example.com/callback",
+                },
+                "timeout_ms": 10000,  # how long messages should stay pending before being deleted
+            }
+        )
+
     def test_update_user(self, client: StreamChat):
         user = {"id": str(uuid.uuid4())}
         response = client.update_user(user)