1 # Copyright (c) 2015 SONATA-NFV and Paderborn University
4 # Licensed under the Apache License, Version 2.0 (the "License");
5 # you may not use this file except in compliance with the License.
6 # You may obtain a copy of the License at
8 # http://www.apache.org/licenses/LICENSE-2.0
10 # Unless required by applicable law or agreed to in writing, software
11 # distributed under the License is distributed on an "AS IS" BASIS,
12 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 # See the License for the specific language governing permissions and
14 # limitations under the License.
16 # Neither the name of the SONATA-NFV, Paderborn University
17 # nor the names of its contributors may be used to endorse or promote
18 # products derived from this software without specific prior written
21 # This work has been performed in the framework of the SONATA project,
22 # funded by the European Commission under Grant number 671517 through
23 # the Horizon 2020 and 5G-PPP programmes. The authors would like to
24 # acknowledge the contributions of their colleagues of the SONATA
25 # partner consortium (www.sonata-nfv.eu).
29 from flask
import Flask
, request
30 from flask_restful
import Api
, Resource
31 from gevent
.pywsgi
import WSGIServer
34 LOG
= logging
.getLogger("api.openstack.base")
37 class BaseOpenstackDummy(Resource
):
39 This class is the base class for all openstack entrypoints of son-emu.
42 def __init__(self
, listenip
, port
):
47 self
.http_server
= None
48 self
.server_thread
= None
49 self
.playbook_file
= '/tmp/son-emu-requests.log'
50 with
open(self
.playbook_file
, 'w'):
54 self
.app
= Flask(__name__
)
55 self
.api
= Api(self
.app
)
58 self
.server_thread
= threading
.Thread(target
=self
._start
_flask
, args
=())
59 self
.server_thread
.name
= self
.__class
__.__name
__
60 self
.server_thread
.start()
64 LOG
.info('Stopping %s' % self
.__class
__.__name
__)
65 self
.http_server
.stop(timeout
=1)
67 def _start_flask(self
):
68 LOG
.info("Starting %s endpoint @ http://%s:%d" % (
69 self
.__class
__.__name
__, self
.ip
, self
.port
))
70 self
.http_server
= WSGIServer(
73 log
=open("/dev/null", "w") # don't show http logs
75 self
.http_server
.serve_forever(stop_timeout
=1)
76 LOG
.info('Stopped %s' % self
.__class
__.__name
__)
78 def dump_playbook(self
):
79 with self
.manage
.lock
:
80 with
open(self
.playbook_file
, 'a') as logfile
:
81 if len(request
.data
) > 0:
82 data
= "# %s API\n" % str(
83 self
.__class
__).split('.')[-1].rstrip('\'>')
84 data
+= "curl -X {type} -H \"Content-type: application/json\" -d '{data}' {url}".format(type=request
.method
,
87 logfile
.write(data
+ "\n")