René's URL Explorer Experiment

{"@context":"https://schema.org","@type":"DiscussionForumPosting","headline":"How to keep session alive when using async websockets?","articleBody":"I have this code to interact with a websocket api using `async` and `websokets` python libraries:\r\n\r\n```\r\n#!/usr/bin/env python3\r\n\r\nimport sys, json\r\nimport asyncio\r\nfrom websockets import connect\r\n\r\nclass AsyncWebsocket():\r\n    async def __aenter__(self):\r\n        self._conn = connect('wss://ws.myws.com/v2')\r\n        self.websocket = await self._conn.__aenter__()        \r\n        return self\r\n\r\n    async def __aexit__(self, *args, **kwargs):\r\n        await self._conn.__aexit__(*args, **kwargs)\r\n\r\n    async def send(self, message):\r\n        await self.websocket.send(message)\r\n\r\n    async def receive(self):\r\n        return await self.websocket.recv()\r\n\r\nclass mtest():\r\n    def __init__(self, api_token):\r\n        self.aws        = AsyncWebsocket()\r\n        self.loop       = asyncio.get_event_loop()\r\n        self.api_token  = api_token\r\n        \r\n        self.authorize()\r\n\r\n    def authorize(self):\r\n        jdata = self.__async_exec({\r\n                                    'authorize': self.api_token\r\n                                  })\r\n\r\n        try:\r\n            print (jdata['email'])\r\n            ret = True\r\n        except:\r\n            ret = False\r\n\r\n        return ret\r\n\r\n    def sendtest(self):\r\n\r\n        jdata = self.__async_exec({\r\n                                    \"hello\": 1\r\n                                  })\r\n\r\n        print (jdata)\r\n\r\n\r\n    def __async_exec(self, jdata):\r\n        try:\r\n            ret = json.loads(self.loop.run_until_complete(self.__async_send_recieve(jdata)))\r\n        except:\r\n            ret = None\r\n\r\n        return ret\r\n\r\n    async def __async_send_recieve(self, jdata):\r\n        async with self.aws:\r\n            await self.aws.send(json.dumps(jdata))\r\n            return await self.aws.receive()\r\n```\r\n\r\nSo I have the following in main.py:\r\n    \r\n```\r\nfrom webclass import *\r\n\r\na = mtest('12341234')\r\nprint (a.sendtest())\r\n```\r\n\r\nThe problem is that it doesn't preserve the authorized session, so this is the output:\r\n\r\n```\r\nroot@ubupc1:/home/dinocob# python3 test.py \r\nasd@gmail.com\r\n{'error': {'message': 'Please log in.', 'code': 'AuthorizationRequired'}}\r\n```\r\n\r\nAs you see, the login call are working ok, but when calling and sending the `hello` in `sendtest` function, the session is not the same. \r\n\r\n - Where is destroyed the session? \r\n - How could I preserve it (without drastically\r\n   modifying my class structure)?","author":{"url":"https://github.com/mllamazares","@type":"Person","name":"mllamazares"},"datePublished":"2017-02-09T17:18:59.000Z","interactionStatistic":{"@type":"InteractionCounter","interactionType":"https://schema.org/CommentAction","userInteractionCount":1},"url":"https://github.com/491/asyncio/issues/491"}