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
|
# Copyright 2015 Open Platform for NFV Project, Inc. and its contributors
# This software is distributed under the terms and conditions of the 'Apache-2.0'
# license which can be found in the file 'LICENSE' in this package distribution
# or at 'http://www.apache.org/licenses/LICENSE-2.0'.
import os
import time
import hashlib
from oslo_config import cfg
from oslo_log import log as logging
import oslo_messaging
from moon_orchestrator.dockers import DockerBase
LOG = logging.getLogger(__name__)
CONF = cfg.CONF
DOMAIN = "moon_orchestrator"
__CWD__ = os.path.dirname(os.path.abspath(__file__))
# TODO (asteroide): select the right template folder
TEMPLATES_FOLDER = os.path.join(__CWD__, "..", "conf", "dockers")
# TODO (asteroide): add specific configuration options for that plugin
class AuthzFunction(DockerBase):
id = "moon_session_function"
__build = """RUN mkdir -p /etc/moon/
COPY conf /etc/moon/
ADD dist/{py_pkg}.tar.gz /root
WORKDIR /root/{py_pkg}
RUN pip3 install -r requirements.txt
RUN pip3 install .
"""
def __init__(self, uuid, conf_file="", docker=None, network_config=None):
self.id = "session_"+hashlib.sha224(uuid.encode("utf-8")).hexdigest()
super(AuthzFunction, self).__init__(
name="moon_authz",
run_cmd=["python3", "-m", "moon_authz", uuid],
conf_file=conf_file,
docker=docker,
network_config=network_config,
build_cmd=self.__build,
id=self.id,
tag=""
# tag=CONF.security_function.container
)
# note(asteroide): time to let the new docker boot
time.sleep(3)
# self.get_status()
def get_status(self):
return True
# transport = oslo_messaging.get_transport(CONF)
# target = oslo_messaging.Target(topic=self.id, version='1.0')
# client = oslo_messaging.RPCClient(transport, target)
# LOG.info("Calling Status on {}".format(self.id))
# ret = client.call({"component_id": self.id}, 'get_status', args=None)
# LOG.info(ret)
# return ret
def run(uuid, conf_file="", docker=None, network_config=None):
return AuthzFunction(uuid,
conf_file=conf_file,
docker=docker,
network_config=network_config)
|
