1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
|
#!/usr/bin/python
from retrace import *
from tempfile import *
def application(environ, start_response):
request = Request(environ)
if request.scheme != "https":
return response(start_response, "403 Forbidden",
"You must use HTTPS")
if len(get_active_tasks()) >= CONFIG["MaxParallelTasks"]:
return response(start_response, "503 Service Unavailable",
"Retrace server is fully loaded at the moment")
if request.method != "POST":
return response(start_response, "405 Method Not Allowed",
"You must use POST method")
if not request.content_type in HANDLE_ARCHIVE.keys():
return response(start_response, "415 Unsupported Media Type",
"Specified archive format is not supported")
if not request.content_length:
return response(start_response, "411 Length Required",
"You need to set Content-Length header properly")
if request.content_length > CONFIG["MaxPackedSize"] * 1048576:
return response(start_response, "413 Request Entity Too Large",
"Specified archive is too large")
if CONFIG["UseWorkDir"]:
workdir = CONFIG["WorkDir"]
else:
workdir = CONFIG["SaveDir"]
if not os.path.isdir(workdir):
try:
os.makedirs(workdir)
except:
return response(start_response, "500 Internal Server Error",
"Unable to create working directory")
space = free_space(workdir)
if not space:
return response(start_response, "500 Internal Server Error",
"Unable to obtain disk free space")
if space - request.content_length < CONFIG["MinStorageLeft"] * 1048576:
return response(start_response, "507 Insufficient Storage",
"There is not enough storage space on the server")
try:
archive = NamedTemporaryFile(mode="wb", delete=False, suffix=".tar.xz")
archive.write(request.body)
archive.close()
except:
return response(start_response, "500 Internal Server Error",
"Unable to save archive")
size = unpacked_size(archive.name, request.content_type)
if not size:
os.unlink(archive.name)
return response(start_response, "500 Internal Server Error",
"Unable to obtain unpacked size")
if size > CONFIG["MaxUnpackedSize"] * 1048576:
os.unlink(archive.name)
return response(start_response, "413 Request Entity Too Large",
"Specified archive's content is too large")
if space - size < CONFIG["MinStorageLeft"] * 1048576:
os.unlink(archive.name)
return response(start_response, "507 Insufficient Storage",
"There is not enough storage space on the server")
taskid, taskpass, taskdir = new_task()
if not taskid or not taskpass or not taskdir:
return response(start_response, "500 Internal Server Error",
"Unable to create new task")
try:
os.mkdir("%s/crash/" % taskdir)
os.chdir("%s/crash/" % taskdir)
unpack_retcode = unpack(archive.name, request.content_type)
os.unlink(archive.name)
if unpack_retcode != 0:
raise Exception
except:
os.chdir("/")
Popen(["rm", "-rf", taskdir])
return response(start_response, "500 Internal Server Error",
"Unable to unpack archive")
files = os.listdir(".")
for required_file in REQUIRED_FILES:
if not required_file in files:
os.chdir("/")
Popen(["rm", "-rf", taskdir])
return response(start_response, "403 Forbidden",
"Required file \"%s\" is missing" % required_file)
call(["/usr/bin/abrt-retrace-worker", "%d" % taskid])
return response(start_response, "201 Created", "",
[("X-Task-Id", "%d" % taskid),
("X-Task-Password", taskpass)])
|
