Compare commits
3
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
ff99f65907
|
||
|
|
48791d1cf5 | ||
|
|
9523f357df |
+1
-2
@@ -40,8 +40,7 @@ ENV PATH="/opt/venv/bin:$PATH" \
|
|||||||
PYTHONDONTWRITEBYTECODE=1 \
|
PYTHONDONTWRITEBYTECODE=1 \
|
||||||
GRANIAN_HOST=0.0.0.0 \
|
GRANIAN_HOST=0.0.0.0 \
|
||||||
GRANIAN_PORT=8080 \
|
GRANIAN_PORT=8080 \
|
||||||
GRANIAN_INTERFACE=rsgi \
|
GRANIAN_INTERFACE=rsgi
|
||||||
GRANIAN_LOOP=rloop
|
|
||||||
|
|
||||||
USER app
|
USER app
|
||||||
|
|
||||||
|
|||||||
@@ -10,7 +10,6 @@ over the RSGI protocol.
|
|||||||
- **kaya-core** — routing and HTTP request/response handling
|
- **kaya-core** — routing and HTTP request/response handling
|
||||||
- **kaya-rsgi** — Granian (RSGI) adapter
|
- **kaya-rsgi** — Granian (RSGI) adapter
|
||||||
- **granian** — application server
|
- **granian** — application server
|
||||||
- **rloop** — Rust event loop used by Granian instead of the stdlib asyncio loop
|
|
||||||
- **httpx + pwo** — test client over kaya's ASGI transport
|
- **httpx + pwo** — test client over kaya's ASGI transport
|
||||||
|
|
||||||
No database, sessions, or authentication — the app is stateless.
|
No database, sessions, or authentication — the app is stateless.
|
||||||
@@ -35,10 +34,6 @@ The `/all` field order mirrors the reference site: `ip_addr`,
|
|||||||
`remote_host`, `user_agent`, `port`, `language`, `referer`, `connection`,
|
`remote_host`, `user_agent`, `port`, `language`, `referer`, `connection`,
|
||||||
`keep_alive`, `method`, `encoding`, `mime`, `charset`, `via`, `forwarded`.
|
`keep_alive`, `method`, `encoding`, `mime`, `charset`, `via`, `forwarded`.
|
||||||
|
|
||||||
The reported client IP/port honor the `Forwarded`, `X-Forwarded-For`,
|
|
||||||
`X-Forwarded-Host` and `X-Forwarded-Port` proxy headers (kaya ≥ 0.0.2);
|
|
||||||
without them the socket peer address is used.
|
|
||||||
|
|
||||||
Example:
|
Example:
|
||||||
|
|
||||||
```console
|
```console
|
||||||
@@ -65,14 +60,9 @@ python -m venv .venv && . .venv/bin/activate
|
|||||||
pip install --index-url https://gitea.woggioni.net/api/packages/woggioni/pypi/simple \
|
pip install --index-url https://gitea.woggioni.net/api/packages/woggioni/pypi/simple \
|
||||||
--extra-index-url https://pypi.org/simple \
|
--extra-index-url https://pypi.org/simple \
|
||||||
-e .
|
-e .
|
||||||
granian --interface rsgi --loop rloop --host 0.0.0.0 --port 8000 pyfconfig.app:app
|
granian --interface rsgi --host 0.0.0.0 --port 8000 pyfconfig.app:app
|
||||||
```
|
```
|
||||||
|
|
||||||
The `--loop rloop` flag (or `GRANIAN_LOOP=rloop`, already set in the
|
|
||||||
Docker image) makes Granian run the app on the
|
|
||||||
[rloop](https://github.com/gi0baro/rloop) Rust event loop instead of the
|
|
||||||
stdlib asyncio loop.
|
|
||||||
|
|
||||||
### Configuration
|
### Configuration
|
||||||
|
|
||||||
Environment variables (see `.env.example`):
|
Environment variables (see `.env.example`):
|
||||||
|
|||||||
+2
-3
@@ -9,12 +9,11 @@ description = "A clone of https://ifconfig.me/ built on the kaya framework"
|
|||||||
readme = "README.md"
|
readme = "README.md"
|
||||||
requires-python = ">=3.10"
|
requires-python = ">=3.10"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"kaya-core>=0.0.2",
|
"kaya-core",
|
||||||
"kaya-rsgi>=0.0.2",
|
"kaya-rsgi",
|
||||||
"granian>=2.0",
|
"granian>=2.0",
|
||||||
"httpx",
|
"httpx",
|
||||||
"pwo",
|
"pwo",
|
||||||
"rloop>=0.5.0",
|
|
||||||
]
|
]
|
||||||
|
|
||||||
[project.optional-dependencies]
|
[project.optional-dependencies]
|
||||||
|
|||||||
+2
-4
@@ -29,19 +29,17 @@ idna==3.19
|
|||||||
# via
|
# via
|
||||||
# anyio
|
# anyio
|
||||||
# httpx
|
# httpx
|
||||||
kaya-core==0.0.2
|
kaya-core==0.0.1
|
||||||
# via
|
# via
|
||||||
# kaya-rsgi
|
# kaya-rsgi
|
||||||
# pyfconfig (pyproject.toml)
|
# pyfconfig (pyproject.toml)
|
||||||
kaya-rsgi==0.0.2
|
kaya-rsgi==0.0.1
|
||||||
# via pyfconfig (pyproject.toml)
|
# via pyfconfig (pyproject.toml)
|
||||||
pwo==0.1.2
|
pwo==0.1.2
|
||||||
# via
|
# via
|
||||||
# kaya-core
|
# kaya-core
|
||||||
# kaya-rsgi
|
# kaya-rsgi
|
||||||
# pyfconfig (pyproject.toml)
|
# pyfconfig (pyproject.toml)
|
||||||
rloop==0.5.0
|
|
||||||
# via pyfconfig (pyproject.toml)
|
|
||||||
typing-extensions==4.16.0
|
typing-extensions==4.16.0
|
||||||
# via
|
# via
|
||||||
# anyio
|
# anyio
|
||||||
|
|||||||
+2
-12
@@ -12,10 +12,6 @@ from pyfconfig.app import app
|
|||||||
# httpx's ASGITransport populates the scope with this client tuple.
|
# httpx's ASGITransport populates the scope with this client tuple.
|
||||||
CLIENT_IP = "127.0.0.1"
|
CLIENT_IP = "127.0.0.1"
|
||||||
CLIENT_PORT = "123"
|
CLIENT_PORT = "123"
|
||||||
# First entry of the X-Forwarded-For header in ALL_HEADERS; since kaya 0.0.2
|
|
||||||
# ctx.client honors forwarded headers, ip_addr resolves to this instead of
|
|
||||||
# the socket peer address.
|
|
||||||
FORWARDED_IP = "203.0.113.7"
|
|
||||||
|
|
||||||
ALL_HEADERS = {
|
ALL_HEADERS = {
|
||||||
"User-Agent": "test-agent/1.0",
|
"User-Agent": "test-agent/1.0",
|
||||||
@@ -52,12 +48,6 @@ class RoutesTest(unittest.TestCase):
|
|||||||
self.assertEqual(200, r.status_code)
|
self.assertEqual(200, r.status_code)
|
||||||
self.assertEqual(CLIENT_IP, r.text.strip())
|
self.assertEqual(CLIENT_IP, r.text.strip())
|
||||||
|
|
||||||
@async_test
|
|
||||||
async def test_ip_honors_x_forwarded_for(self) -> None:
|
|
||||||
async with self.client() as client:
|
|
||||||
r = await client.get("/ip", headers={"X-Forwarded-For": "203.0.113.7"})
|
|
||||||
self.assertEqual("203.0.113.7", r.text.strip())
|
|
||||||
|
|
||||||
@async_test
|
@async_test
|
||||||
async def test_ua(self) -> None:
|
async def test_ua(self) -> None:
|
||||||
async with self.client() as client:
|
async with self.client() as client:
|
||||||
@@ -116,7 +106,7 @@ class RoutesTest(unittest.TestCase):
|
|||||||
keys,
|
keys,
|
||||||
)
|
)
|
||||||
values = dict(line.split(": ", 1) for line in lines)
|
values = dict(line.split(": ", 1) for line in lines)
|
||||||
self.assertEqual(FORWARDED_IP, values["ip_addr"])
|
self.assertEqual(CLIENT_IP, values["ip_addr"])
|
||||||
self.assertEqual("unavailable", values["remote_host"])
|
self.assertEqual("unavailable", values["remote_host"])
|
||||||
self.assertEqual("test-agent/1.0", values["user_agent"])
|
self.assertEqual("test-agent/1.0", values["user_agent"])
|
||||||
self.assertEqual(CLIENT_PORT, values["port"])
|
self.assertEqual(CLIENT_PORT, values["port"])
|
||||||
@@ -137,7 +127,7 @@ class RoutesTest(unittest.TestCase):
|
|||||||
r = await client.get("/all.json", headers=ALL_HEADERS)
|
r = await client.get("/all.json", headers=ALL_HEADERS)
|
||||||
self.assertEqual(200, r.status_code)
|
self.assertEqual(200, r.status_code)
|
||||||
data = json.loads(r.text)
|
data = json.loads(r.text)
|
||||||
self.assertEqual(FORWARDED_IP, data["ip_addr"])
|
self.assertEqual(CLIENT_IP, data["ip_addr"])
|
||||||
self.assertEqual("test-agent/1.0", data["user_agent"])
|
self.assertEqual("test-agent/1.0", data["user_agent"])
|
||||||
self.assertEqual(CLIENT_PORT, data["port"])
|
self.assertEqual(CLIENT_PORT, data["port"])
|
||||||
self.assertEqual("GET", data["method"])
|
self.assertEqual("GET", data["method"])
|
||||||
|
|||||||
Reference in New Issue
Block a user