New Views API & Updates for internal request method (#540)

* Some responses don't return json. Correcting initial assumption.

* Removing deprecated loop parameter

* Adding new views API method.

Author: RodneyU215

slack/rtm/client.py

@@ -323,7 +323,6 @@ async def _connect_and_read(self):
             try:
                 self._connection_attempts += 1
                 async with aiohttp.ClientSession(
-                    loop=self._event_loop,
                     timeout=aiohttp.ClientTimeout(total=self.timeout),
                 ) as session:
                     self._session = session

slack/web/base_client.py

@@ -245,24 +245,28 @@ async def _request(self, *, http_verb, api_url, req_args):
         Returns:
             A dictionary of the response data.
         """
+        session = None
         if self.session and not self.session.closed:
-            async with self.session.request(http_verb, api_url, **req_args) as res:
-                return {
-                    "data": await res.json(),
-                    "headers": res.headers,
-                    "status_code": res.status,
-                }
-        async with aiohttp.ClientSession(
-            loop=self._event_loop,
-            timeout=aiohttp.ClientTimeout(total=self.timeout),
-            auth=req_args.pop("auth"),
-        ) as session:
-            async with session.request(http_verb, api_url, **req_args) as res:
-                return {
-                    "data": await res.json(),
-                    "headers": res.headers,
-                    "status_code": res.status,
-                }
+            session = self.session
+        else:
+            session = aiohttp.ClientSession(
+                timeout=aiohttp.ClientTimeout(total=self.timeout),
+                auth=req_args.pop("auth", None),
+            )
+
+        response = None
+        async with session.request(http_verb, api_url, **req_args) as res:
+            data = {}
+            try:
+                data = await res.json()
+            except aiohttp.ContentTypeError:
+                self._logger.debug(
+                    f"No response data returned from the following API call: {api_url}."
+                )
+            response = {"data": data, "headers": res.headers, "status_code": res.status}
+
+        await session.close()
+        return response
 
     @staticmethod
     def _get_user_agent():

slack/web/client.py

@@ -1577,3 +1577,18 @@ def views_update(
             raise e.SlackRequestError("Either view_id or external_id is required.")
 
         return self.api_call("views.update", json=kwargs)
+
+    def views_publish(
+        self, *, user_id: str, view: dict, **kwargs
+    ) -> Union[Future, SlackResponse]:
+        """Publish a static view for a User.
+        Create or update the view that comprises an
+        app's Home tab (https://api.slack.com/surfaces/tabs)
+        for a specific user.
+        Args:
+            user_id (str): id of the user you want publish a view to.
+                e.g. 'U0BPQUNTA'
+            view (dict): The view payload.
+        """
+        kwargs.update({"user_id": user_id, "view": view})
+        return self.api_call("views.publish", json=kwargs)