blob: c42ed66923b259fd3916e596484e167485f8133f (
plain) (
blame)
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
|
from functools import wraps
from canonicaljson import json
from jsonschema import validate
from contextlib import closing
import socket
def validate_schema(schema):
def _wrap_validate(func):
@wraps(func)
def _do_validate(self, request):
body = json.loads(request.content.read())
validate(instance=body, schema=schema)
return func(self, request, body)
return _do_validate
return _wrap_validate
def port_checker(port):
if port < 0 or 65535 < port:
return False
with closing(socket.socket(socket.AF_INET, socket.SOCK_STREAM)) as sock:
try:
sock.bind((socket.gethostname(), port))
sock.listen()
sock.close()
return True
except:
return False
def log_body_if_fail(func):
@wraps(func)
def _log_wrapper(request):
try:
return func(request)
except Exception:
body = json.loads(request.content.read())
print(body)
raise
return _log_wrapper
|
