Merge pull request #26 from GetStream/upsert_users

Nicer upsert method and tests for teams

.github/workflows/initiate_release.yml

@@ -37,6 +37,7 @@ jobs:
         run: |
           gh pr create \
             -t "Release ${{ github.event.inputs.version }}" \
+            -l "ignore-for-release" \
             -b "# :rocket: ${{ github.event.inputs.version }}
             Make sure to use squash & merge when merging!
             Once this is merged, another job will kick off automatically and publish the package."

README.md

@@ -32,24 +32,14 @@ client = Stream(api_key="your_api_key", api_secret="your_api_secret")
 from getstream.models import UserRequest
 
 # sync two users using the update_users method, both users will get insert or updated
-client.update_users(users={
-    "tommaso-id": UserRequest(
-        id="tommaso-id",
-        name="tommaso",
-        role="admin",
-        custom={
-            "country": "NL"
-        }
+client.upsert_users(
+    UserRequest(
+        id="tommaso-id", name="tommaso", role="admin", custom={"country": "NL"}
     ),
-    "thierry-id": UserRequest(
-        id="thierry-id",
-        name="thierry",
-        role="admin",
-        custom={
-            "country": "US"
-        }
+    UserRequest(
+        id="thierry-id", name="thierry", role="admin", custom={"country": "US"}
     ),
-})
+)
 
 # Create a JWT token for the user to connect client-side (e.g. browser/mobile app)
 token = client.create_token("tommaso-id")

getstream/chat/rest_client.py

@@ -923,6 +923,37 @@ def get_reactions(
             path_params=path_params,
         )
 
+    def query_reactions(
+        self,
+        id: str,
+        limit: Optional[int] = None,
+        next: Optional[str] = None,
+        prev: Optional[str] = None,
+        user_id: Optional[str] = None,
+        sort: Optional[List[Optional[SortParam]]] = None,
+        filter: Optional[Dict[str, object]] = None,
+        user: Optional[UserRequest] = None,
+    ) -> StreamResponse[QueryReactionsResponse]:
+        path_params = {
+            "id": id,
+        }
+        json = build_body_dict(
+            limit=limit,
+            next=next,
+            prev=prev,
+            user_id=user_id,
+            sort=sort,
+            filter=filter,
+            user=user,
+        )
+
+        return self.post(
+            "/api/v2/chat/messages/{id}/reactions",
+            QueryReactionsResponse,
+            path_params=path_params,
+            json=json,
+        )
+
     def translate_message(
         self, id: str, language: str
     ) -> StreamResponse[MessageResponse]: