| # Generic OAuth plugin |
| import re |
| import requests |
| |
| |
| async def process(formdata, session, server): |
| js = None |
| m = re.match(r"https?://(.+)/", formdata["oauth_token"]) |
| if m: |
| oauth_domain = m.group(1) |
| headers = {"User-Agent": "Pony Mail OAuth Agent/0.1"} |
| # This is a synchronous process, so we offload it to an async runner in order to let the main loop continue. |
| rv = await server.runners.run( |
| requests.post, formdata["oauth_token"], headers=headers, data=formdata |
| ) |
| js = rv.json() |
| js["oauth_domain"] = oauth_domain |
| js["authoritative"] = True |
| return js |
