admin/debweb
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects 1 Releases 5 Wiki Activity

many things

Browse Source
This commit is contained in:
pablusha
2025-08-09 19:28:04 +03:00
parent ee4d1f90a3
commit a638f39cc5
5 changed files with 106 additions and 82 deletions
Download Patch File Download Diff File Expand all files Collapse all files
config.py
+11 -2
View File
@@ -15,5 +15,14 @@ start_msg="started at <ADDR>"
conn_msg="conn from <ADDR>"
get_msg="<ADDR> got <FILE>"
e404_file="404.html"
e404_msg="<ADDR> err 404 <FILE>"
err_files = {
404: "html/404.html",
403: "html/403.html",
418: "html/418.html"
}
err_msgs = {
404: "<ADDR> err 404 <FILE>",
403: "<ADDR> err 403 <FILE>",
418: "<ADDR> err 418 (teapot) <FILE>"
}
html/403.html
+9
View File
@@ -0,0 +1,9 @@
<html>
<head><title>404 Forbidden</title></head>
<body>
<center><h1>404 Forbidden</h1></center>
<hr><center>debweb</center>
</body>
</html>
<!-- точно не спиздил с nginx'a!!! -->
404.html → html/404.html
View File
html/418.html
+9
View File
@@ -0,0 +1,9 @@
<html>
<head><title>418 teapot</title></head>
<body>
<center><h1>пошолнахуй</h1></center>
<hr><center>debweb</center>
</body>
</html>
<!-- точно не спиздил с nginx'a!!! -->
main.py
+86 -89
View File
@@ -7,85 +7,50 @@ import asyncio
import config
import os
STATUS = {
200: "200 OK",
403: "403 Forbidden",
404: "404 Not Found",
405: "405 Method Not Allowed",
418: "418 I'm a teapot"
}
# file_size = os.path.getsize(file_path)
class WebServer:
def __init__(self):
self.name = config.name
self.proxied = config.proxied
self._addr = config.addr
self._port = config.port
self._log_file = config.log_file
self.preset_file = config.preset_file
self.directory = config.directory
self._read_buffer = config.read_buffer
self._write_size = config.write_buffer
self.conn_msg = config.conn_msg
self.start_msg = config.start_msg
self.get_msg = config.get_msg
self._e404_file = config.e404_file
self.e404_msg = config.e404_msg
async def log(self, text: str, addr: tuple=None, file: str=None) -> None:
text = text.replace("<ADDR>", f"{addr[0]}:{addr[1]}" if addr else "")
text = text.replace("<FILE>", file if file else "")
if self._log_file:
async with aiofiles.open(self._log_file, mode="a") as file:
if config.log_file:
async with aiofiles.open(config.log_file, mode="a") as file:
await file.write(text + "\n")
else:
print(text)
async def handle(self, reader: asyncio.StreamReader, writer: asyncio.StreamWriter) -> None:
addr = writer.get_extra_info("peername")
await self.log(self.conn_msg, addr)
rdata = await reader.read(self._read_buffer)
data = rdata.decode()
if not data: return
real_addr = None
for line in data.split("\n"):
if line.startswith("X-Real-IP: "):
real_addr = line[len("X-Real-IP: "):].strip()
break
if real_addr and self.proxied:
addr = (real_addr, addr[1])
request = data.split("\n")[0]
parts = request.split()
if len(parts) < 2: return
path = unquote(parts[1])
file_name = path[1:] if path.startswith('/') else path
file_path = os.path.abspath(os.path.join(self.directory, file_name))
if os.path.isfile(file_path):
mime, _ = mimetypes.guess_type(file_path)
file_size = os.path.getsize(file_path)
if not mime: mime = "application/octet-stream"
if mime.startswith("text"): mime += "; charset=utf-8"
async def send_headers(self, writer: asyncio.StreamWriter, status: int, file_size: int, mime: str="text/html; charset=utf-8") -> None:
headers = (
"HTTP/1.1 200 OK\r\n"
f"HTTP/1.1 {STATUS[status]}\r\n"
f"Content-Type: {mime}\r\n"
f"Content-Length: {file_size}\r\n"
f"Server: {self.name}\r\n"
f"Server: {config.name}\r\n"
"\r\n"
)
writer.write("".join(headers).encode())
writer.write(headers.encode())
await writer.drain()
async def send_file(self, writer: asyncio.StreamWriter, file_path: str, file_size: int):
if not os.path.isfile(file_path):
writer.write("file error")
await writer.drain()
sent = 0
async with aiofiles.open(file_path, "rb") as f:
while sent < file_size:
chunk = await f.read(self._write_size)
chunk = await f.read(config.write_buffer)
if not chunk: break
writer.write(chunk)
@@ -94,13 +59,59 @@ class WebServer:
sent += len(chunk)
async def handle(self, reader: asyncio.StreamReader, writer: asyncio.StreamWriter) -> None:
addr = writer.get_extra_info("peername")
await self.log(config.conn_msg, addr)
rdata = await reader.read(config.read_buffer)
data = rdata.decode()
if not data: return
real_addr = None
for line in data.split("\n"):
if line.startswith("X-Real-IP: "):
real_addr = line[len("X-Real-IP: "):].strip()
break
if real_addr and config.proxied:
addr = (real_addr, addr[1])
request = data.split("\n")[0]
parts = request.split()
if len(parts) < 2: return
path = unquote(parts[1])
file_name = path[1:] if path.startswith('/') else path
file_path = os.path.abspath(os.path.join(config.directory, file_name))
if not file_path.startswith(os.path.abspath(config.directory)):
await self.log(config.err_msgs[418], addr, file_path)
file_size = os.path.getsize(config.err_files[418])
await self.send_headers(writer, 418, file_size)
await self.send_file(writer, config.err_files[418], file_size)
await writer.close()
await writer.wait_closed()
return
if os.path.isfile(file_path):
mime, _ = mimetypes.guess_type(file_path)
file_size = os.path.getsize(file_path)
if not mime: mime = "application/octet-stream"
if mime.startswith("text"): mime += "; charset=utf-8"
await self.send_headers(writer, 200, file_size, mime)
await self.send_file(writer, file_path, file_size)
elif os.path.isdir(file_path):
resp = ""
async with aiofiles.open(self.preset_file, "r") as f:
async with aiofiles.open(config.preset_file, "r", encoding="utf-8") as f:
resp = await f.read()
files = ""
base_path = os.path.relpath(file_path, self.directory).replace('\\', '/')
base_path = os.path.relpath(file_path, config.directory).replace('\\', '/')
if base_path == '.':
base_path = ''
@@ -108,10 +119,8 @@ class WebServer:
item_path = os.path.join(file_path, item)
is_dir = os.path.isdir(item_path)
if base_path:
rel_path = f"{base_path}/{item}"
else:
rel_path = item
if base_path: rel_path = f"{base_path}/{item}"
else: rel_path = item
if is_dir:
rel_path += "/"
@@ -127,37 +136,25 @@ class WebServer:
resp = resp.replace("<FILES>", files)
resp = resp.encode()
headers = (
"HTTP/1.1 200 OK\r\n"
f"Content-Type: text/html; charset=utf-8\r\n"
f"Server: {self.name}\r\n"
f"Content-Length: {len(resp)}\r\n"
"\r\n"
)
writer.write(headers.encode() + resp)
await self.send_headers(writer, 200, len(resp))
writer.write(resp)
await writer.drain()
else:
await self.log(self.e404_msg, addr, file_path)
async with aiofiles.open(self._e404_file, "r", encoding="utf-8") as f:
content = await f.read()
response = (
"HTTP/1.1 404 Not Found\r\n"
"Content-Type: text/html; charset=utf-8\r\n"
f"Server: {self.name}\r\n"
"\r\n"
f"{content}"
)
writer.write(response.encode())
await writer.drain()
file_size = os.path.getsize(file_path)
await self.send_headers(writer, 404, file_size)
await self.send_file(writer, self._e404_file, file_size)
writer.close()
await writer.wait_closed()
return
await self.log(self.get_msg, addr, file_path)
await writer.drain()
await self.log(config.get_msg, addr, file_path)
writer.close()
await writer.wait_closed()
@@ -165,10 +162,10 @@ class WebServer:
async def start(self) -> None:
server = await asyncio.start_server(
self.handle,
self._addr,
self._port
config.addr,
config.port
)
await self.log(f"{self.start_msg}", (self._addr, self._port))
await self.log(f"{config.start_msg}", (config.addr, config.port))
async with server:
await server.serve_forever()