Add aiohttp.ClientSession with methods.

- `base_url` parameter: to simplify reusing the session with
   different methods.

- `json` parameter.

Author: Carglglz

micropython/uaiohttpclient/clientsession_example.py

@@ -11,7 +11,8 @@ async def fetch(client):
 async def main():
     async with aiohttp.ClientSession() as client:
         html = await fetch(client)
-        print(html)
+        print(html.decode())
 
 
-asyncio.run(main())
+if __name__ == "__main__":
+    asyncio.run(main())

micropython/uaiohttpclient/clientsession_methods_example.py

@@ -0,0 +1,22 @@
+import uaiohttpclient as aiohttp
+import asyncio
+
+
+async def main():
+    async with aiohttp.ClientSession("http://httpbin.org") as session:
+        async with session.get("/get") as resp:
+            assert resp.status == 200
+            rget = await resp.text()
+            print(f"GET: {rget.decode()}")
+        async with session.post("/post", json={"foo": "bar"}) as resp:
+            assert resp.status == 200
+            rpost = await resp.text()
+            print(f"POST: {rpost.decode()}")
+        async with session.put("/put", data=b"data") as resp:
+            assert resp.status == 200
+            rput = await resp.json()
+            print("PUT: ", rput)
+
+
+if __name__ == "__main__":
+    asyncio.run(main())

micropython/uaiohttpclient/uaiohttpclient.py

@@ -1,4 +1,5 @@
 import uasyncio as asyncio
+import json as _json
 
 
 class ClientResponse:
@@ -11,6 +12,9 @@ def read(self, sz=-1):
     def text(self, sz=-1):
         return self.read(sz=sz)
 
+    async def json(self):
+        return _json.loads(await self.read())
+
     def __repr__(self):
         return "<ClientResponse %d %s>" % (self.status, self.headers)
 
@@ -57,23 +61,27 @@ async def __aexit__(self, *args):
 
 
 class ClientSession:
-    def __init__(self):
+    def __init__(self, base_url=""):
         self._reader = None
+        self._base_url = base_url
 
     async def __aenter__(self):
         return self
 
     async def __aexit__(self, *args):
         return await asyncio.sleep(0)
 
-    def request(self, method, url, ssl=None):
-        return _RequestContextManager(self, self._request(method, url, ssl=ssl))
+    def request(self, method, url, data=None, json=None, ssl=None):
+        return _RequestContextManager(
+            self,
+            self._request(method, self._base_url + url, data=data, json=json, ssl=ssl),
+        )
 
-    async def _request(self, method, url, ssl=None):
+    async def _request(self, method, url, data=None, json=None, ssl=None):
         redir_cnt = 0
         redir_url = None
         while redir_cnt < 2:
-            reader = yield from self.request_raw(method, url, ssl)
+            reader = yield from self.request_raw(method, url, data, json, ssl)
             headers = []
             sline = yield from reader.readline()
             sline = sline.split(None, 2)
@@ -105,7 +113,11 @@ async def _request(self, method, url, ssl=None):
         self._reader = reader
         return resp
 
-    async def request_raw(self, method, url, ssl=None):
+    async def request_raw(self, method, url, data=None, json=None, ssl=None):
+        if json and isinstance(json, dict):
+            data = _json.dumps(json)
+        if data is not None and method == "GET":
+            method = "POST"
         try:
             proto, dummy, host, path = url.split("/", 3)
         except ValueError:
@@ -129,20 +141,72 @@ async def request_raw(self, method, url, ssl=None):
         # Use protocol 1.0, because 1.1 always allows to use chunked transfer-encoding
         # But explicitly set Connection: close, even though this should be default for 1.0,
         # because some servers misbehave w/o it.
-        query = (
-            "%s /%s HTTP/1.0\r\nHost: %s\r\nConnection: close\r\nUser-Agent: compat\r\n\r\n"
-            % (
-                method,
-                path,
-                host,
+        if not data:
+            query = (
+                "%s /%s HTTP/1.0\r\nHost: %s\r\nConnection: close\r\nUser-Agent: compat\r\n\r\n"
+                % (
+                    method,
+                    path,
+                    host,
+                )
             )
-        )
+        else:
+            query = (
+                """%s /%s HTTP/1.0\r\nHost: %s\r\n%sContent-Length: %s\r\n\r\n%s\r\nConnection: close\r\nUser-Agent: compat\r\n\r\n"""
+                % (
+                    method,
+                    path,
+                    host,
+                    "Content-Type: application/json\r\n" if json else "",
+                    str(len(str(data))),
+                    data,
+                )
+            )
+
         yield from writer.awrite(query.encode("latin-1"))
         #    yield from writer.aclose()
         return reader
 
     def get(self, url, ssl=None):
-        return _RequestContextManager(self, self._request("GET", url, ssl=ssl))
+        return _RequestContextManager(
+            self, self._request("GET", self._base_url + url, ssl=ssl)
+        )
+
+    def post(self, url, data=None, json=None, ssl=None):
+        return _RequestContextManager(
+            self,
+            self._request("POST", self._base_url + url, data=data, json=json, ssl=ssl),
+        )
+
+    def put(self, url, data=None, json=None, ssl=None):
+        return _RequestContextManager(
+            self,
+            self._request("PUT", self._base_url + url, data=data, json=json, ssl=ssl),
+        )
+
+    def patch(self, url, data=None, json=None, ssl=None):
+        return _RequestContextManager(
+            self,
+            self._request("PATCH", self._base_url + url, data=data, json=json, ssl=ssl),
+        )
+
+    def delete(self, url, ssl=None):
+        return _RequestContextManager(
+            self,
+            self._request("DELETE", self._base_url + url, ssl=ssl),
+        )
+
+    def head(self, url, ssl=None):
+        return _RequestContextManager(
+            self,
+            self._request("HEAD", self._base_url + url, ssl=ssl),
+        )
+
+    def options(self, url, ssl=None):
+        return _RequestContextManager(
+            self,
+            self._request("OPTIONS", self._base_url + url, ssl=ssl),
+        )
 
 
 def request_raw(method, url):