CAIP-9 fix missing files

Author: broHeryk

examples/services/streams.py

@@ -20,9 +20,7 @@ async def run():
         streams = bdk.streams()
 
         await streams.create_im(13056700579872)
-        await streams.create_room(
-            V3RoomAttributes(name="New fancy room", description="test room")
-        )
+        await streams.create_room(V3RoomAttributes(name="New fancy room", description="test room"))
 
         logging.debug(await streams.get_stream(stream_id))
         await streams.add_member_to_room(13056700579859, stream_id)

symphony/bdk/core/auth/auth_session.py

@@ -79,9 +79,7 @@ async def key_manager_token(self):
             return ""
 
         if self._key_manager_token is None:
-            self._key_manager_token = (
-                await self._authenticator.retrieve_key_manager_token()
-            )
+            self._key_manager_token = await self._authenticator.retrieve_key_manager_token()
         return self._key_manager_token
 
     @session_token.setter
@@ -125,8 +123,7 @@ def __init__(self, authenticator, user_id: int = None, username: str = None):
         super().__init__(authenticator)
         if user_id is not None and username is not None:
             raise AuthInitializationError(
-                "Username and user id for OBO authentication should not be defined at "
-                "a same time."
+                "Username and user id for OBO authentication should not be defined at a same time."
             )
         if user_id is None and username is None:
             raise AuthInitializationError(
@@ -138,16 +135,12 @@ def __init__(self, authenticator, user_id: int = None, username: str = None):
     async def refresh(self):
         """Trigger re-authentication to refresh the OBO session token."""
         if self.user_id is not None:
-            self._session_token = (
-                await self._authenticator.retrieve_obo_session_token_by_user_id(
-                    self.user_id
-                )
+            self._session_token = await self._authenticator.retrieve_obo_session_token_by_user_id(
+                self.user_id
             )
         if self.username is not None:
-            self._session_token = (
-                await self._authenticator.retrieve_obo_session_token_by_username(
-                    self.username
-                )
+            self._session_token = await self._authenticator.retrieve_obo_session_token_by_username(
+                self.username
             )
 
     @property
@@ -188,9 +181,7 @@ async def refresh(self) -> None:
 
         :return: None
         """
-        app_tokens = await self._authenticator.authenticate_and_retrieve_tokens(
-            self._app_token
-        )
+        app_tokens = await self._authenticator.authenticate_and_retrieve_tokens(self._app_token)
         self._symphony_token = app_tokens.symphony_token
         self._app_token = app_tokens.app_token
         self._expire_at = app_tokens.expire_at

symphony/bdk/core/service/message/message_service.py

@@ -78,9 +78,7 @@ async def send_message(
         message_object = (
             message
             if isinstance(message, Message)
-            else Message(
-                content=message, data=data, version=version, attachments=attachment
-            )
+            else Message(content=message, data=data, version=version, attachments=attachment)
         )
         return await self._send_message(
             stream_id,
@@ -125,17 +123,11 @@ async def _send_message(
             "version": version,
         }
         if attachment is not None:
-            params["attachment"] = (
-                attachment if isinstance(attachment, list) else [attachment]
-            )
+            params["attachment"] = attachment if isinstance(attachment, list) else [attachment]
         if preview is not None:
             params["preview"] = preview if isinstance(preview, list) else [preview]
 
-        return (
-            await self._messages_api.v4_stream_sid_multi_attachment_message_create_post(
-                **params
-            )
-        )
+        return await self._messages_api.v4_stream_sid_multi_attachment_message_create_post(**params)
 
     @retry
     async def suppress_message(self, message_id: str) -> MessageSuppressionResponse:
@@ -238,9 +230,7 @@ async def blast_message(
         message_object = (
             message
             if isinstance(message, Message)
-            else Message(
-                content=message, data=data, version=version, attachments=attachment
-            )
+            else Message(content=message, data=data, version=version, attachments=attachment)
         )
         return await self._blast_message(
             stream_ids,
@@ -285,9 +275,7 @@ async def _blast_message(
             "version": version,
         }
         if attachment is not None:
-            params["attachment"] = (
-                attachment if isinstance(attachment, list) else [attachment]
-            )
+            params["attachment"] = attachment if isinstance(attachment, list) else [attachment]
         if preview is not None:
             params["preview"] = preview if isinstance(preview, list) else [preview]
 
@@ -309,9 +297,7 @@ def __init__(
         auth_session: AuthSession,
         retry_config: BdkRetryConfig,
     ):
-        super().__init__(
-            messages_api, message_suppression_api, pod_api, auth_session, retry_config
-        )
+        super().__init__(messages_api, message_suppression_api, pod_api, auth_session, retry_config)
         self._message_api = message_api
         self._message_suppression_api = message_suppression_api
         self._streams_api = streams_api
@@ -345,9 +331,7 @@ async def list_messages(
         return message_list.value
 
     @retry
-    async def import_messages(
-        self, messages: List[V4ImportedMessage]
-    ) -> [V4ImportResponse]:
+    async def import_messages(self, messages: List[V4ImportedMessage]) -> [V4ImportResponse]:
         """Imports a list of messages to Symphony.
         See: `Import Message <https://developers.symphony.com/restapi/reference/import-message-v4>`_
 
@@ -364,9 +348,7 @@ async def import_messages(
         import_response_list = await self._messages_api.v4_message_import_post(**params)
         return import_response_list.value
 
-    async def get_attachment(
-        self, stream_id: str, message_id: str, attachment_id: str
-    ) -> str:
+    async def get_attachment(self, stream_id: str, message_id: str, attachment_id: str) -> str:
         """Downloads the attachment body by the stream ID, message ID and attachment ID.
         See: `Attachment <https://developers.symphony.com/restapi/reference/attachment>`_
 
@@ -451,15 +433,11 @@ async def list_attachments(
             params["since"] = since
         if to is not None:
             params["to"] = to
-        attachment_list = await self._streams_api.v1_streams_sid_attachments_get(
-            **params
-        )
+        attachment_list = await self._streams_api.v1_streams_sid_attachments_get(**params)
         return attachment_list.value
 
     @retry
-    async def list_message_receipts(
-        self, message_id: str
-    ) -> MessageReceiptDetailResponse:
+    async def list_message_receipts(self, message_id: str) -> MessageReceiptDetailResponse:
         """Fetches receipts details from a specific message.
         See: `List Message Receipts <https://developers.symphony.com/restapi/reference/list-message-receipts>`_
 
@@ -472,14 +450,10 @@ async def list_message_receipts(
             "message_id": message_id,
             "session_token": await self._auth_session.session_token,
         }
-        return await self._default_api.v1_admin_messages_message_id_receipts_get(
-            **params
-        )
+        return await self._default_api.v1_admin_messages_message_id_receipts_get(**params)
 
     @retry
-    async def get_message_relationships(
-        self, message_id: str
-    ) -> MessageMetadataResponse:
+    async def get_message_relationships(self, message_id: str) -> MessageMetadataResponse:
         """Gets the message metadata relationship.
         This API allows users to track the relationship between a message and all the forwards and replies of that
         message.

symphony/bdk/core/service/stream/stream_service.py

@@ -191,17 +191,13 @@ async def search_all_rooms(
         """
 
         async def search_rooms_one_page(skip, limit):
-            result = await self.search_rooms(
-                query, skip, limit, include_non_discoverable
-            )
+            result = await self.search_rooms(query, skip, limit, include_non_discoverable)
             return result.rooms if result.rooms else None
 
         return offset_based_pagination(search_rooms_one_page, chunk_size, max_number)
 
     @retry
-    async def update_room(
-        self, room_id: str, room_attributes: V3RoomAttributes
-    ) -> V3RoomDetail:
+    async def update_room(self, room_id: str, room_attributes: V3RoomAttributes) -> V3RoomDetail:
         """Updates the attributes of an existing chatroom.
         Wraps the `Update Room V3 <https://developers.symphony.com/restapi/reference/update-room-v3>`_ endpoint.
 
@@ -411,9 +407,7 @@ async def list_streams_admin_one_page(skip, limit):
             result = await self.list_streams_admin(stream_filter, skip, limit)
             return result.streams.value if result.streams else None
 
-        return offset_based_pagination(
-            list_streams_admin_one_page, chunk_size, max_number
-        )
+        return offset_based_pagination(list_streams_admin_one_page, chunk_size, max_number)
 
     @retry
     async def list_user_streams_admin(
@@ -498,9 +492,7 @@ async def list_stream_members_one_page(skip, limit):
             members = await self.list_stream_members(stream_id, skip, limit)
             return members.members.value if members.members else None
 
-        return offset_based_pagination(
-            list_stream_members_one_page, chunk_size, max_number
-        )
+        return offset_based_pagination(list_stream_members_one_page, chunk_size, max_number)
 
     @retry
     async def list_room_members(self, room_id: str) -> MembershipList: