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
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
|
# Copyright 2017 Wind River Systems, Inc.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
import os
import json
from poster.encode import multipart_encode
from poster.streaminghttp import register_openers
import re
from rest_framework.views import APIView
from rest_framework.views import Response
from rest_framework.views import status
from multivimbroker.forwarder.base import BaseHandler
from rest_framework.parsers import MultiPartParser
#
class BaseServer(BaseHandler, APIView):
def get(self, request, vimid):
raise NotImplementedError()
def post(self, request, vimid):
raise NotImplementedError()
def put(self, request, vimid):
raise NotImplementedError()
def delete(self, request, vimid):
raise NotImplementedError()
def head(self, request, vimid):
raise NotImplementedError()
def patch(self, request, vimid):
raise NotImplementedError()
# proxy handler
class Identity(BaseServer):
def get(self, request, vimid):
return self.send(vimid, request.get_full_path(), request.body, "GET")
def post(self, request, vimid):
return self.send(vimid, request.get_full_path(), request.body, "POST")
class Registry(BaseServer):
def post(self, request, vimid):
return self.send(vimid, request.get_full_path(), request.body, "POST")
class UnRegistry(BaseServer):
def delete(self, request, vimid):
return self.send(vimid, request.get_full_path(), request.body,
"DELETE")
class Extension(BaseServer):
def get(self, request, vimid):
return self.send(vimid, request.get_full_path(), request.body, "GET")
class VIMTypes(BaseServer):
def get(self, request):
# Fix here unless we have plugin registry
json_file = os.path.join(os.path.dirname(__file__),
'../pub/config/provider-plugin.json')
with open(json_file, "r") as f:
plugins = json.load(f)
data = {"vim_types": plugins}
return Response(data=data, status=status.HTTP_200_OK)
# forward handler
class Forward(BaseServer):
def get(self, request, vimid):
return self.send(vimid, request.get_full_path(), request.body, "GET")
def post(self, request, vimid):
return self.send(vimid, request.get_full_path(), request.body, "POST",
headers=None)
def patch(self, request, vimid):
return self.send(vimid, request.get_full_path(), request.body, "PATCH",
headers=None)
def delete(self, request, vimid):
return self.send(vimid, request.get_full_path(), request.body,
"DELETE", headers=None)
def head(self, request, vimid):
return self.send(vimid, request.get_full_path(), request.body, "HEAD")
def put(self, request, vimid):
return self.send(vimid, request.get_full_path(), request.body, "PUT",
headers=None)
# Multipart view
class MultiPartView(BaseServer):
parser_classes = (MultiPartParser, )
def post(self, request, vimid):
register_openers()
datagen, headers = multipart_encode(dict(request.data.iterlists()))
# will convert the datagen to be accepted by httplib2 body param
requestData = "".join(datagen)
# MultiPart parser store the header keys in request.META
# A custom header in request body(for ex: Cloud_Type)
# will be transformed to HTTP_CLOUD_TYPE
regex = re.compile('^HTTP_')
for key, value in request.META.iteritems():
if key.startswith("HTTP_"):
headers[regex.sub('',key).replace('_','-')] = value
return self.send(vimid, request.path, requestData, "POST",
headers=headers)
|
