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
|
# Copyright (C) 2014 Linaro Ltd.
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU Affero General Public License as
# published by the Free Software Foundation, either version 3 of the
# License, or (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU Affero General Public License for more details.
#
# You should have received a copy of the GNU Affero General Public License
# along with this program. If not, see <http://www.gnu.org/licenses/>.
"""The RequestHandler for /defconfig URLs."""
import tornado
from functools import partial
from tornado.web import asynchronous
from handlers.base import BaseHandler
from models.defconfig import DEFCONFIG_COLLECTION
from utils.db import delete
class DefConfHandler(BaseHandler):
"""Handle the /defconfig URLs."""
def __init__(self, application, request, **kwargs):
super(DefConfHandler, self).__init__(application, request, **kwargs)
@property
def collection(self):
return self.db[DEFCONFIG_COLLECTION]
def _valid_keys(self, method):
valid_keys = {
'GET': [
'job', 'kernel', 'status', 'job_id', 'created', 'defconfig'
],
}
return valid_keys.get(method, None)
@asynchronous
def post(self, *args, **kwargs):
"""Not implemented."""
self.write_error(status_code=501)
def _delete(self, defconf_id):
self.executor.submit(
partial(delete, self.collection, defconf_id)
).add_done_callback(
lambda future:
tornado.ioloop.IOLoop.instance().add_callback(
partial(self._create_valid_response, future.result())
)
)
|
