Page MenuHomeDevCentral
Files F3764036

D3536.id9084.diff
No OneTemporary
Actions

D3536.id9084.diff
View Options

diff --git a/woof b/woof
--- a/woof
+++ b/woof
@@ -2,12 +2,18 @@
# woof -- an ad-hoc single file webserver
+from __future__ import annotations
+
+from typing import Generator, BinaryIO
+
import sys, os, errno, socket, getopt, subprocess, tempfile
-import cgi, urllib.request, urllib.parse, http.server
+import urllib.request, urllib.parse, http.server
+import email.parser
import readline
import configparser
import shutil, tarfile, zipfile
import struct
+from io import BytesIO, StringIO
maxdownloads = 1
cpid = -1
@@ -39,6 +45,27 @@
return candidates[0]
+def decode_multipart_form_data(
+ multipart_data: BinaryIO, headers: email.message.Message
+) -> list[tuple[dict[str, str], bytes]]:
+ """Decode multipart form data"""
+ content_type = headers["Content-Type"].encode("ascii")
+ content_len = int(headers["Content-Length"])
+ data = multipart_data.read(content_len)
+
+ content = b"Content-Type: %b\r\n%b" % (content_type, data)
+
+ parsed = email.parser.BytesParser().parsebytes(content)
+
+ results = []
+ for part in parsed.get_payload():
+ params = part.get_params(header="content-disposition")
+ payload: bytes = part.get_payload(decode=True)
+ result = dict(params), payload
+ results.append(result)
+ return results
+
+
# our own HTTP server class, fixing up a change in python 2.7
# since we do our fork() in the request handler
# the server must not shutdown() the socket.
@@ -63,7 +90,7 @@
def log_request (self, code='-', size='-'):
if code == 200:
- http.server.BaseHTTPRequestHandler.log_request (self, code, size)
+ super().log_request (code, size)
def do_POST (self):
@@ -73,31 +100,26 @@
self.send_error (501, "Unsupported method (POST)")
return
- # taken from
- # http://mail.python.org/pipermail/python-list/2006-September/402441.html
+ multi_form = decode_multipart_form_data(self.rfile, self.headers)
- ctype, pdict = cgi.parse_header (self.headers['Content-Type'])
- form = cgi.FieldStorage (fp = self.rfile,
- headers = self.headers,
- environ = {'REQUEST_METHOD' : 'POST'},
- keep_blank_values = 1,
- strict_parsing = 1)
- if "upfile" not in form:
- self.send_error (403, "No upload provided")
+ for form_dict, content in multi_form:
+ if form_dict.get("name") == "upfile":
+ break
+ else:
+ # Went through without break, did not find
+ self.send_error(403, "No upload provided")
return
- upfile = form["upfile"]
-
- if not upfile.file or not upfile.filename:
+ if not content or not form_dict.get("filename"):
self.send_error (403, "No upload provided")
return
- upfilename = upfile.filename
+ upfilename = form_dict["filename"]
if "\\" in upfilename:
- upfilename = upfilename.split ("\\")[-1]
+ upfilename = upfilename.rsplit ("\\", 1)[-1]
- upfilename = os.path.basename (upfile.filename)
+ upfilename = os.path.basename (upfilename)
destfile = None
for suffix in ["", ".1", ".2", ".3", ".4", ".5", ".6", ".7", ".8", ".9"]:
@@ -105,8 +127,8 @@
try:
destfile = os.open (destfilename, os.O_WRONLY | os.O_CREAT | os.O_EXCL, 0o644)
break
- except OSError as e:
- if e.errno == errno.EEXIST:
+ except OSError as ex:
+ if ex.errno == errno.EEXIST:
continue
raise
@@ -114,14 +136,17 @@
upfilename += "."
destfile, destfilename = tempfile.mkstemp (prefix = upfilename, dir = ".")
- print ("accepting uploaded file: %s -> %s" % (upfilename, destfilename), file=sys.stderr)
+ print ("Accepting uploaded file: %s -> %s" % (upfilename, destfilename), file=sys.stderr)
- shutil.copyfileobj (upfile.file, os.fdopen (destfile, "wb"))
+ with BytesIO(content) as readfile:
+ with open(destfile, "wb") as writefile:
+ shutil.copyfileobj (readfile, writefile)
- if upfile.done == -1:
- self.send_error (408, "upload interrupted")
+ # if upfile.done == -1:
+ # self.send_error (408, "upload interrupted")
txt = b"""\
+ <!DOCTYPE html>
<html>
<head><title>Woof Upload</title></head>
<body>
@@ -147,6 +172,7 @@
# Form for uploading a file
if upload:
txt = b"""\
+ <!DOCTYPE html>
<html>
<head><title>Woof Upload</title></head>
<body>
@@ -182,6 +208,7 @@
if self.path != location:
txt = """\
+ <!DOCTYPE html>
<html>
<head><title>302 Found</title></head>
<body>302 Found <a href="%s">here</a>.</body>
@@ -204,7 +231,6 @@
if cpid == 0:
# Child process
- child = None
type = None
if os.path.isfile (self.filename):
@@ -221,35 +247,35 @@
self.send_header ("Content-Disposition", "attachment;filename=%s" % urllib.parse.quote (os.path.basename (self.filename + self.archive_ext)))
if os.path.isfile (self.filename):
self.send_header ("Content-Length",
- os.path.getsize (self.filename))
+ str(os.path.getsize (self.filename)))
self.end_headers ()
try:
if type == "file":
- datafile = open (self.filename, "rb")
- shutil.copyfileobj (datafile, self.wfile)
- datafile.close ()
+ with open (self.filename, "rb") as datafile:
+ shutil.copyfileobj (datafile, self.wfile)
elif type == "dir":
if compressed == 'zip':
- zfile = zipfile.ZipFile (self.wfile, 'w', zipfile.ZIP_DEFLATED)
- stripoff = os.path.dirname (self.filename) + os.sep
-
- for root, dirs, files in os.walk (self.filename):
- for f in files:
- filename = os.path.join (root, f)
- if filename[:len (stripoff)] != stripoff:
- raise RuntimeException ("invalid filename assumptions, please report!")
- zfile.write (filename, filename[len (stripoff):])
- zfile.close ()
+ with zipfile.ZipFile(
+ self.wfile, "w", zipfile.ZIP_DEFLATED
+ ) as zfile:
+ stripoff = os.path.dirname (self.filename) + os.sep
+
+ for root, dirs, files in os.walk (self.filename):
+ for f in files:
+ filename = os.path.join (root, f)
+ if filename[:len (stripoff)] != stripoff:
+ raise RuntimeError ("invalid filename assumptions, please report!")
+ zfile.write (filename, filename[len (stripoff):])
else:
- tfile = tarfile.open (mode=('w|' + compressed),
- fileobj=self.wfile)
- tfile.add (self.filename,
- arcname=os.path.basename (self.filename))
- tfile.close ()
-
- except Exception as e:
- print (e)
+ with tarfile.open(
+ mode=("w|" + compressed), fileobj=self.wfile
+ ) as tfile:
+ tfile.add (self.filename,
+ arcname=os.path.basename (self.filename))
+
+ except Exception as ex:
+ print (ex)
print ("Connection broke. Aborting", file=sys.stderr)
@@ -546,4 +572,3 @@
main ()
except KeyboardInterrupt:
print ()
-

File Metadata

Mime Type
text/plain
Expires
Sat, Nov 23, 03:57 (11 h, 43 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2256943
Default Alt Text
D3536.id9084.diff (7 KB)

Event Timeline

Nasqueron DevCentral · If it had been much bigger the moon would have had a core of ice. · Powered by Phabricator