spatialcache/handler.py at master · fpanettieri/spatialcache · GitHub

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
from BaseHTTPServer import BaseHTTPRequestHandler
from os.path import join as joinPath

from logger import Logger
from tiles import TilesManager
from seeder import Seeder
from cleaner import Cleaner
from params import ParamsDict
from util import readFile, workingPath

from constants.http.status import OK
from constants.mime import MIMETYPE_XML
from constants.parameters import FORMAT, CONTENT_TYPE, ACTION, EXCEPTIONS
from constants.actions import SEED, CLEAN
from constants.error import UNEXPECTED_ERROR
from constants.general import DEFAULT_EXCEPTIONS, CROSSDOMAIN_XML

class CacheRequestHandler(BaseHTTPRequestHandler):

	def do_GET(self):
		try:
			if CROSSDOMAIN_XML in self.path:
				self.send_response(OK)
				self.send_header(CONTENT_TYPE, MIMETYPE_XML)
				self.end_headers()
				self.wfile.write(readFile(joinPath(workingPath(), CROSSDOMAIN_XML)))
				return

			# Parse the parameter
			parameters = ParamsDict()
			parameters.parse(self.path)
			parameters[EXCEPTIONS] = DEFAULT_EXCEPTIONS
			tile, response_code = TilesManager().getTile(parameters)

			# Send headers
			self.send_response(response_code)
			if parameters.has_key(FORMAT):
				self.send_header(CONTENT_TYPE, parameters[FORMAT])
			self.end_headers()

			if(response_code == OK):
				self.wfile.write(tile)
		except:
			Logger().error(UNEXPECTED_ERROR)

	def do_POST(self):
		try:
			# Get post data
			content_length = int(self.headers["content-length"])
			post = self.rfile.read(content_length)

			# Parse the parameter
			params = ParamsDict()
			params.parse(post)

			# Check if action is defined
			action = SEED
			if params.has_key(ACTION):
				Logger().info("POST Action: %s" % ACTION)
				action = params[ACTION]
				params.pop(ACTION, None)

			if action == SEED:
				self._seed(params)
			elif action == CLEAN:
				self._clean(params)

			# Send headers
			self.send_response(200)
			self.end_headers()

		except:
			Logger().error(UNEXPECTED_ERROR)

	def do_DELETE(self):
		try:
			# Get post data
			content_length = int(self.headers["content-length"])
			post = self.rfile.read(content_length)

			# Parse the parameter
			params = ParamsDict()
			params.parse(post)

			self._clean(params)

			# Send response
			self.send_response(200)
			self.end_headers()

		except:
			Logger().error(UNEXPECTED_ERROR)

	def _seed(self, params):
		Logger().info("Seeding: " + str(params))

		seeder = Seeder()
		seeder.seed(params)

		Logger().info("Finished seeding: " + str(params))

	def _clean(self, params):
		Logger().info("Cleaning: " + str(params))

		cleaner = Cleaner()
		cleaner.clean(params)

		Logger().info("Finished cleaning: " + str(params))