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
|
# Copyright (c) 2018, George Tokmaji
# Permission to use, copy, modify, and/or distribute this software for any
# purpose with or without fee is hereby granted, provided that the above
# copyright notice and this permission notice appear in all copies.
# THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
# WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
# MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
# ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
# WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
# ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
# OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
import sys
import os, re, json, math
import requests
from bson.objectid import ObjectId
from bottle import install, run, Bottle, static_file, response, hook, JSONPlugin, get, post, error
import threading
class ParryEncoder(json.JSONEncoder):
_default = json.JSONEncoder.default
def default(self, obj):
if isinstance(obj, ObjectId):
return str(obj)
return self._default(obj)
install(JSONPlugin(json_dumps=lambda s: json.dumps(s, cls=ParryEncoder)))
os.chdir(os.path.dirname(__file__))
from .auth import *
def calculateHashForResource(resource : requests.Response) -> object:
hashobj = hashlib.sha1()
calculateHashForFile(resource.raw, hashobj)
if "content-length" not in resource.headers:
resource.headers["Content-Length"] = resource.raw.tell()
return hashobj
def calculateHashForFile(file, hashobj : object = None) -> object:
if hashobj is None:
hashobj = hashlib.sha1()
while True:
block = file.read(BLOCKSIZE)
if not block:
break
hashobj.update(block)
return hashobj
@route("<path:path>")
def default(path):
raise HTTPResponse(f"Cannot {request.method} {path}", 405)
@route("<path:path>", method="OPTIONS")
def options(path):
return HTTPResponse(status=204, headers={"Access-Control-Allow-Origin" : "*", "Access-Control-Allow-Methods" : "GET, POST, HEAD, PUT, PATCH, DELETE", "Access-Control-Allow-Headers" : "*"})
@hook("after_request")
def enable_cors():
response.headers["Access-Control-Allow-Origin"] = "*"
response.headers["Access-Control-Allow-Methods"] = "POST, GET, PUT, DELETE, PATCH, HEAD"
@error(500)
def internal_error(error):
if request.json is None:
error.exception = None
error._status_code = 400
error._body = "Invalid JSON specified"
def request_data():
return request.json if request.json else request.forms
|
