summaryrefslogtreecommitdiff
path: root/day9/task5/server.py
blob: 86b3e4c779f66a432131a0183a976c5803d76dc2 (plain)
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
from http.server import HTTPServer, BaseHTTPRequestHandler
from urllib.parse import parse_qs

from day9.task5_vue.router import run
from day9.task5_vue.utils import parse_multipart_form

import logging


class MyHTTPRequestHandler(BaseHTTPRequestHandler):
    def _set_response(self, code, content_type):
        self.send_response(code)
        self.send_header('Content-type', content_type)
        self.end_headers()

    def do_GET(self):
        try:
            content_length = int(self.headers['Content-Length'])
            get_data = parse_qs(self.rfile.read(content_length).decode('utf-8'))
        except TypeError:
            get_data = {}

        for key in get_data:
            get_data[key] = get_data[key][0]

        self.finalize_request(run({
            'url': self.path,
            'method': 'GET',
            'query': get_data
        }))

    def do_POST(self):
        content_length = int(self.headers['Content-Length'])
        content_type = self.headers['Content-type']
        post_data = self.rfile.read(content_length)

        if content_type.split(';')[0] == 'multipart/form-data':
            files = parse_multipart_form(post_data)
            self.finalize_request(run({
                'url': self.path,
                'method': 'POST',
                'query': {'files': files}
            }))

        elif content_type.split(';')[0] in ['text/plain', 'application/x-www-form-urlencoded']:
            post_data = parse_qs(post_data.decode('utf-8'))
            for key in post_data:
                post_data[key] = post_data[key][0]

            self.finalize_request(run({
                'url': self.path,
                'method': 'POST',
                'query': post_data
            }))

    def finalize_request(self, response):
        self._set_response(response.status_code, response.content_type)
        self.wfile.write(response.content)


def start_server(host, port):
    server_address = (host, port)
    httpd = HTTPServer(server_address, MyHTTPRequestHandler)
    logging.getLogger('tableApp').info(f'Server started on {host}:{port}')
    httpd.serve_forever()