-
Notifications
You must be signed in to change notification settings - Fork 31
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
adding (not working yet) webrequests.py. bleep is fixed. upping amy. …
…tested desktop(mac) and esp.
- Loading branch information
Showing
11 changed files
with
203 additions
and
44 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,142 @@ | ||
| # webrequests.py | ||
| # javascript version (as much as we can) of urequests.py | ||
|
|
||
|
|
||
| import json | ||
| import js | ||
|
|
||
| def as_bytearray(buffer): | ||
| """ | ||
| Given a JavaScript ArrayBuffer, convert it to a Python bytearray in a | ||
| MicroPython friendly manner. | ||
| """ | ||
| ui8a = js.Uint8Array.new(buffer) | ||
| size = ui8a.length | ||
| ba = bytearray(size) | ||
| for i in range(0, size): | ||
| ba[i] = ui8a[i] | ||
| return ba | ||
|
|
||
| ### wrap the response to grant Pythonic results | ||
| class _Response: | ||
| def __init__(self, response): | ||
| self._response = response | ||
|
|
||
| # grant access to response.ok and other fields | ||
| def __getattr__(self, attr): | ||
| return getattr(self._response, attr) | ||
|
|
||
| # exposed methods with Pythonic results | ||
| async def arrayBuffer(self): | ||
| buffer = await self._response.arrayBuffer() | ||
| # works in Pyodide | ||
| if hasattr(buffer, "to_py"): | ||
| return buffer.to_py() | ||
| # shims in MicroPython | ||
| return memoryview(as_bytearray(buffer)) | ||
|
|
||
| async def blob(self): | ||
| return await self._response.blob() | ||
|
|
||
| async def bytearray(self): | ||
| buffer = await self._response.arrayBuffer() | ||
| return as_bytearray(buffer) | ||
|
|
||
| async def json(self): | ||
| return json.loads(await self.text()) | ||
|
|
||
| async def text(self): | ||
| return await self._response.text() | ||
|
|
||
|
|
||
| ### allow direct await to _Response methods | ||
| class _DirectResponse: | ||
| @staticmethod | ||
| def setup(promise, response): | ||
| promise._response = _Response(response) | ||
| return promise._response | ||
|
|
||
| def __init__(self, promise): | ||
| self._promise = promise | ||
| promise._response = None | ||
| promise.arrayBuffer = self.arrayBuffer | ||
| promise.blob = self.blob | ||
| promise.bytearray = self.bytearray | ||
| promise.json = self.json | ||
| promise.text = self.text | ||
|
|
||
| async def _response(self): | ||
| if not self._promise._response: | ||
| await self._promise | ||
| return self._promise._response | ||
|
|
||
| async def arrayBuffer(self): | ||
| response = await self._response() | ||
| return await response.arrayBuffer() | ||
|
|
||
| async def blob(self): | ||
| response = await self._response() | ||
| return await response.blob() | ||
|
|
||
| async def bytearray(self): | ||
| response = await self._response() | ||
| return await response.bytearray() | ||
|
|
||
| async def json(self): | ||
| response = await self._response() | ||
| return await response.json() | ||
|
|
||
| async def text(self): | ||
| response = await self._response() | ||
| return await response.text() | ||
|
|
||
|
|
||
| def fetch(url, **kw): | ||
| # workaround Pyodide / MicroPython dict <-> js conversion | ||
| options = js.JSON.parse(json.dumps(kw)) | ||
| awaited = lambda response, *args: _DirectResponse.setup(promise, response) | ||
| promise = js.fetch(url, options).then(awaited) | ||
| _DirectResponse(promise) | ||
| return promise | ||
|
|
||
|
|
||
| """ | ||
| def get(url): | ||
| import js | ||
| print(f"fetching {url}...") | ||
| res = await js.fetch(url) | ||
| json = await res.json() | ||
| for i in dir(json): | ||
| print(f"{i}: {json[i]}") | ||
| return json | ||
| #def get(url, headers = {}): | ||
| # return await js.fetch(url, method='GET', headers=headers) | ||
| json = await res.json() | ||
| response = requests.get(base_url+"messages?limit=%d" % (chunk_size), headers = headers) | ||
| response = requests.get(base_url+"messages?limit=%d&before=%s" % (chunk_size, oldest_id), headers=headers) | ||
| api_response = requests.post( | ||
| files_base_url+"attachments", | ||
| headers=headers, | ||
| json={"files": [{"filename": filename, "file_size": filesize, "id": 1}]}, | ||
| ) | ||
| put_response = requests.put( | ||
| put_url, | ||
| headers={ | ||
| "Authorization": headers['Authorization'], | ||
| "User-Agent": headers['User-Agent'], | ||
| "Content-Length": str(filesize), | ||
| "Content-Type": "application/octet-stream", | ||
| }, | ||
| data=f, | ||
| ) | ||
| r = requests.post(files_base_url+"messages", headers = headers, data = json.dumps(payload)) | ||
| r = requests.post(text_base_url+"messages", headers = headers, data = json.dumps ( {"content":u + " ### " + message} )) | ||
| """ |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Binary file not shown.
Oops, something went wrong.