Updates Python Workers examples to use new cloudflare.workers API

Author: dom96

src/content/docs/d1/examples/query-d1-from-python-workers.mdx

@@ -82,7 +82,7 @@ The value of `binding` is how you will refer to your database from within your W
 To create a Python Worker, create an empty file at `src/entry.py`, matching the value of `main` in your `wrangler.toml` file with the contents below:
 
 ```python
-from js import Response
+from cloudflare.workers import Response
 
 async def on_fetch(request, env):
     # Do anything else you'd like on request here!

src/content/docs/workers/examples/103-early-hints.mdx

@@ -111,7 +111,7 @@ export default {
 
 ```py
 import re
-from js import Response, Headers
+from cloudflare.workers import Response
 
 CSS = "body { color: red; }"
 HTML = """
@@ -129,11 +129,11 @@ HTML = """
 """
 def on_fetch(request):
     if re.search("test.css", request.url):
-        headers = Headers.new({"content-type": "text/css"}.items())
-        return Response.new(CSS, headers=headers)
+        headers = {"content-type": "text/css"}
+        return Response(CSS, headers=headers)
     else:
-        headers = Headers.new({"content-type": "text/html","link": "</test.css>; rel=preload; as=style"}.items())
-        return Response.new(HTML, headers=headers)
+        headers = {"content-type": "text/html","link": "</test.css>; rel=preload; as=style"}
+        return Response(HTML, headers=headers)
 ```
 
 </TabItem> </Tabs>

src/content/docs/workers/examples/ab-testing.mdx

@@ -100,7 +100,7 @@ export default {
 ```py
 import random
 from urllib.parse import urlparse, urlunparse
-from js import Response, Headers, fetch
+from cloudflare.workers import Response, fetch
 
 NAME = "myExampleWorkersABTest"
 
@@ -132,8 +132,7 @@ async def on_fetch(request):
         res = await fetch(urlunparse(url))
         headers = dict(res.headers)
         headers["Set-Cookie"] = f'{NAME}={group}; path=/'
-        headers  = Headers.new(headers.items())
-        return Response.new(res.body, headers=headers)
+        return Response(res.body, headers=headers)
 
     return fetch(urlunparse(url))
 ```

src/content/docs/workers/examples/accessing-the-cloudflare-object.mdx

@@ -60,13 +60,14 @@ export default {
 
 ```py
 import json
-from js import Response, Headers, JSON
+from cloudflare.workers import Response
+from js import JSON
 
 def on_fetch(request):
     error = json.dumps({ "error": "The `cf` object is not available inside the preview." })
     data = request.cf if request.cf is not None else error
-    headers = Headers.new({"content-type":"application/json"}.items())
-    return Response.new(JSON.stringify(data, None, 2), headers=headers)
+    headers = {"content-type":"application/json"}
+    return Response(JSON.stringify(data, None, 2), headers=headers)
 ```
 
 </TabItem> </Tabs>

src/content/docs/workers/examples/aggregate-requests.mdx

@@ -61,19 +61,21 @@ export default {
 </TabItem> <TabItem label="Python" icon="seti:python">
 
 ```py
-from js import Response, fetch, Headers, JSON, Promise
+from cloudflare.workers import Response, fetch
+import asyncio
+import json
 
 async def on_fetch(request):
     # some_host is set up to return JSON responses
     some_host = "https://jsonplaceholder.typicode.com"
     url1 = some_host + "/todos/1"
     url2 = some_host + "/todos/2"
 
-    responses = await Promise.all([fetch(url1), fetch(url2)])
-    results = await Promise.all(map(lambda r: r.json(), responses))
+    responses = await asyncio.gather(*[fetch(url1), fetch(url2)])
+    results = await asyncio.gather(*map(lambda r: r.json(), responses))
 
-    headers = Headers.new({"content-type": "application/json;charset=UTF-8"}.items())
-    return Response.new(JSON.stringify(results), headers=headers)
+    headers = {"content-type": "application/json;charset=UTF-8"}
+    return Response(json.dumps(results), headers=headers)
 ```
 
 </TabItem> </Tabs>

src/content/docs/workers/examples/alter-headers.mdx

@@ -80,28 +80,27 @@ export default {
 </TabItem> <TabItem label="Python" icon="seti:python">
 
 ```py
-from js import Response, fetch
+from cloudflare.workers import Response, fetch
 
 async def on_fetch(request):
     response = await fetch("https://example.com")
 
-    # Clone the response so that it's no longer immutable
-    new_response = Response.new(response.body, response)
+    # Grab the response headers so they can be modified
+    new_headers = response.headers
 
     # Add a custom header with a value
-    new_response.headers.append(
-      "x-workers-hello",
-      "Hello from Cloudflare Workers"
-    )
-
+    new_headers["x-workers-hello"] = "Hello from Cloudflare Workers"
+    
     # Delete headers
-    new_response.headers.delete("x-header-to-delete")
-    new_response.headers.delete("x-header2-to-delete")
+    if "x-header-to-delete" in new_headers:
+        del new_headers["x-header-to-delete"]
+    if "x-header2-to-delete" in new_headers:
+        del new_headers["x-header2-to-delete"]
 
     # Adjust the value for an existing header
-    new_response.headers.set("x-header-to-change", "NewValue")
+    new_headers["x-header-to-change"] = "NewValue"
 
-    return new_response
+    return Response(response.body, headers=new_headers)
 ```
 
 </TabItem> </Tabs>

src/content/docs/workers/examples/auth-with-headers.mdx

@@ -79,20 +79,20 @@ export default {
 </TabItem> <TabItem label="Python" icon="seti:python">
 
 ```py
-from js import Response, fetch
+from cloudflare.workers import Response, fetch
 
 async def on_fetch(request):
     PRESHARED_AUTH_HEADER_KEY = "X-Custom-PSK"
     PRESHARED_AUTH_HEADER_VALUE = "mypresharedkey"
 
-    psk = request.headers.get(PRESHARED_AUTH_HEADER_KEY)
+    psk = request.headers[PRESHARED_AUTH_HEADER_KEY]
 
     if psk == PRESHARED_AUTH_HEADER_VALUE:
       # Correct preshared header key supplied. Fetch request from origin.
       return fetch(request)
 
     # Incorrect key supplied. Reject the request.
-    return Response.new("Sorry, you have supplied an invalid key.", status=403);
+    return Response("Sorry, you have supplied an invalid key.", status=403)
 ```
 
 </TabItem> </Tabs>

src/content/docs/workers/examples/block-on-tls.mdx

@@ -72,12 +72,12 @@ export default {
 </TabItem> <TabItem label="Python" icon="seti:python">
 
 ```py
-from js import Response, fetch
+from cloudflare.workers import Response, fetch
 
 async def on_fetch(request):
     tls_version = request.cf.tlsVersion
     if tls_version not in ("TLSv1.2", "TLSv1.3"):
-        return Response.new("Please use TLS version 1.2 or higher.", status=403)
+        return Response("Please use TLS version 1.2 or higher.", status=403)
     return fetch(request)
 ```
 

src/content/docs/workers/examples/bulk-redirects.mdx

@@ -76,7 +76,8 @@ export default {
 </TabItem> <TabItem label="Python" icon="seti:python">
 
 ```py
-from js import Response, fetch, URL
+from cloudflare.workers import Response, fetch
+from urllib.parse import urlparse
 
 async def on_fetch(request):
     external_hostname = "examples.cloudflareworkers.com"
@@ -88,14 +89,14 @@ async def on_fetch(request):
       "/bulk4": "https://google.com",
       }
 
-    url = URL.new(request.url)
-    location = redirect_map.get(url.pathname, None)
+    url = urlparse(request.url)
+    location = redirect_map.get(url.path, None)
 
     if location:
         return Response.redirect(location, 301)
 
-    # If request not in map, return the original request
-    return fetch(request)
+    # If request not in map, return 404
+    return Response("Not Found", status=404)
 ```
 
 </TabItem> </Tabs>

src/content/docs/workers/examples/conditional-response.mdx

@@ -120,37 +120,38 @@ export default {
 
 ```py
 import re
-from js import Response, URL, fetch
+from cloudflare.workers import Response
+from urllib.parse import urlparse
 
 async def on_fetch(request):
     blocked_hostnames = ["nope.mywebsite.com", "bye.website.com"]
-    url = URL.new(request.url)
+    url = urlparse(request.url)
 
     # Block on hostname
     if url.hostname in blocked_hostnames:
-        return Response.new("Blocked Host", status=403)
+        return Response("Blocked Host", status=403)
 
     # On paths ending in .doc or .xml
-    if re.search(r'\.(doc|xml)$', url.pathname):
-        return Response.new("Blocked Extension", status=403)
+    if re.search(r'\.(doc|xml)$', url.path):
+        return Response("Blocked Extension", status=403)
 
     # On HTTP method
     if "POST" in request.method:
-        return Response.new("Response for POST")
+        return Response("Response for POST")
 
     # On User Agent
     user_agent = request.headers["User-Agent"] or ""
     if "bot" in user_agent:
-        return Response.new("Block User Agent containing bot", status=403)
+        return Response("Block User Agent containing bot", status=403)
 
     # On Client's IP address
     client_ip = request.headers["CF-Connecting-IP"]
     if client_ip == "1.2.3.4":
-        return Response.new("Block the IP 1.2.3.4", status=403)
+        return Response("Block the IP 1.2.3.4", status=403)
 
     # On ASN
     if request.cf and request.cf.asn == 64512:
-        return Response.new("Block the ASN 64512 response")
+        return Response("Block the ASN 64512 response")
 
     # On Device Type
     # Requires Enterprise "CF-Device-Type Header" zone setting or
@@ -159,7 +160,7 @@ async def on_fetch(request):
     if device == "mobile":
         return Response.redirect("https://mobile.example.com")
 
-    return fetch(request)
+    return Response("Request Allowed")
 ```
 
 </TabItem> </Tabs>