[WIP] examples: adjusting

Author: sebastien

examples/client-gzip.py

@@ -4,35 +4,41 @@
 from extra.utils.codec import GZipDecoder
 
 
-# NOTE: Start "examples/sse.py"
+# --
+# ## HTTP Client Example
+#
+# Shows how to use the HTTP client module, in this case with GZipped content.
+# Note how the client API by default returns an iterator, which may be more
+# low-level than what you'd be used to (with
 async def main(path: str, host: str = "127.0.0.1", port: int = 443, ssl: bool = True):
-    transform = GZipDecoder()
+	transform = GZipDecoder()
 
-    with open("/dev/stdout", "wb") as f:
-        async for atom in HTTPClient.Request(
-            host=host,
-            method="GET",
-            port=port,
-            path=path,
-            timeout=11.0,
-            streaming=False,
-            headers={"Accept-Encoding": "gzip"},
-            ssl=ssl,
-        ):
-            if isinstance(atom, HTTPBodyBlob):
-                f.write(transform.feed(atom.payload) or b"")
-        f.write(transform.flush() or b"")
+	with open("/dev/stdout", "wb") as f:
+		async for atom in HTTPClient.Request(
+			host=host,
+			method="GET",
+			port=port,
+			path=path,
+			timeout=11.0,
+			streaming=False,
+			headers={"Accept-Encoding": "gzip"},
+			ssl=ssl,
+		):
+			if isinstance(atom, HTTPBodyBlob):
+				f.write(transform.feed(atom.payload) or b"")
+		f.write(transform.flush() or b"")
 
 
 if __name__ == "__main__":
-    import sys
+	import sys
 
-    args = sys.argv[2:] or ["/index"]
-    n = len(args)
-    asyncio.run(
-        main(
-            path="/gh/lodash/lodash/4.17.15-npm/lodash.min.js",
-            host="cdn.statically.io",
-        )
-    )
+	args = sys.argv[2:] or ["/index"]
+	n = len(args)
+	# Test: curl -v https://cdn.statically.io/gh/lodash/lodash/4.17.15-npm/lodash.min.js
+	asyncio.run(
+		main(
+			path="/gh/lodash/lodash/4.17.15-npm/lodash.min.js",
+			host="cdn.statically.io",
+		)
+	)
 # EOF

examples/client-sse.py

@@ -1,20 +1,32 @@
 import asyncio
 from extra.client import HTTPClient
+from extra.utils.logging import info
+
+
+# --
+# ## HTTP Client Sever Set Eevents
+#
+# This shows how to use the HTTP client with the `streaming=True` option
+# to process SSE responses.
+#
+# This should be run with the `examples/sse.py` as the server.
 
 
 # NOTE: Start "examples/sse.py"
-async def main():
-    async for atom in HTTPClient.Request(
-        host="127.0.0.1",
-        method="GET",
-        port=8001,
-        path="/time/5",
-        timeout=10.0,
-        streaming=True,
-        ssl=False,
-    ):
-        print("   >>> ", atom)
+async def main(host: str = "localhost", port=8003):
+	info("Connecting", Host=host, Port=port)
+	async for atom in HTTPClient.Request(
+		method="GET",
+		host=host,
+		port=port,
+		path="/time/5",
+		timeout=10.0,
+		streaming=True,
+		ssl=False,
+	):
+		info(f"Received atom: {atom}")
 
 
+info("Make sure you have an SSE server running, eg: 'python examples/sse.py")
 print(asyncio.run(main()))
 # EOF

examples/client.py

@@ -1,42 +1,44 @@
 import asyncio
 from extra.client import HTTPClient, pooling
+from extra.utils.logging import info
+from extra.utils.uri import URI
 
 
 # NOTE: Start "examples/sse.py"
 async def main(path: str, host: str = "127.0.0.1", port: int = 8000, ssl: bool = False):
-    print(f"Connecting to {host}:{port}{path}")
-    # NOTE: Connection pooling does not seem to be working
-    with pooling(idle=3600):
-        for _ in range(n := 5):
-            async for atom in HTTPClient.Request(
-                host=host,
-                method="GET",
-                port=port,
-                path=path,
-                timeout=10.0,
-                streaming=False,
-                # NOTE: If you se this to False and you get pooling,
-                # you'll get a Connection lost, which is expected.
-                keepalive=_ < n - 1,
-                ssl=ssl,
-            ):
-                pass
-                # print("   >>> ", atom)
-            await asyncio.sleep(0.25)
+	info(f"Client connecting to {host}:{port}{path}")
+	# NOTE: Connection pooling does not seem to be working
+	with pooling(idle=3600):
+		for _ in range(n := 5):
+			info("Trying request", Count=n)
+			async for atom in HTTPClient.Request(
+				host=host,
+				method="GET",
+				port=port,
+				path=path,
+				timeout=10.0,
+				streaming=False,
+				# NOTE: If you se this to False and you get pooling,
+				# you'll get a Connection lost, which is expected.
+				keepalive=_ < n - 1,
+				ssl=ssl,
+			):
+				info(f"Received atom: {atom}")
+			await asyncio.sleep(0.25)
 
 
 if __name__ == "__main__":
-    import sys
+	import sys
 
-    args = sys.argv[1:] or ["/index"]
-    n = len(args)
-    print(
-        asyncio.run(
-            main(
-                path=args[0],
-                host=args[1] if n > 1 else "127.0.0.1",
-                port=int(args[2]) if n > 2 else 8000,
-            )
-        )
-    )
+	uri = URI.Parse(sys.argv[1] if len(sys.argv) > 1 else "https://google.com/")
+	print(
+		asyncio.run(
+			main(
+				path=uri.path,
+				host=uri.host,
+				port=uri.port,
+				ssl=uri.ssl,
+			)
+		)
+	)
 # EOF