server/plugins/oauthGeneric.py

# Generic OAuth plugin for services such as Apache OAuth
import re
import requests
import aiohttp

ASF_OAUTH_URL = "https://oauth.apache.org/token"
OAUTH_DOMAIN = "apache.org"

async def process(formdata, session, server):
    js = None
    url = ASF_OAUTH_URL
    headers = {"User-Agent": "ASF Boxer 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.
    async with aiohttp.ClientSession() as session:
        async with session.post(url, data=formdata) as rv:
            js = await rv.json()
            assert rv.status == 200, f"Unexpected return code for GET on {url}: {rv.status}"
            js["oauth_domain"] = OAUTH_DOMAIN
            js["authoritative"] = True
            return js