aboutsummaryrefslogtreecommitdiffstats
path: root/apps/nst/optimizers/nst_select_processor.py
blob: 04d5ba75c75c9819edd3226fcd1cf996ca85f438 (plain)
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
# -------------------------------------------------------------------------
#   Copyright (c) 2020 Huawei Intellectual Property
#
#   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 json
import os
BASE_DIR = os.path.dirname(__file__)
"""
This application generates NST SELECTION API calls using the information received from SO
"""


def get_nst_solution(request_json):
# the file is in the same folder for now will move it to the conf folder of the has once its integrated there...
    config_input_json = os.path.join(BASE_DIR, 'conf/configIinputs.json')
    try:
        with open(config_input_json, 'r') as openfile:
            serviceProfile = request_json["serviceProfile"]
            nstSolutionList = []
            resourceName = "NST"
            serviceProfileParameters = serviceProfile["serviceProfileParameters"]
            nst_object = json.load(openfile)
            for nst in nst_object[resourceName]:
                [(nstName, nstList)] = nst.items()
                individual_nst = dict()
                matchall = False
                for constraint_name in serviceProfileParameters:
                    value = serviceProfileParameters[constraint_name]
                    constraint_value = nstList.get(constraint_name)
                    if (not constraint_value):
                        matchall = False
                        break
                    else:
                        matchall = True
                if matchall:
                    individual_nst["NSTName"] = nstList.get("name")
                    individual_nst["UUID"] = nstList.get("modeluuid")
                    individual_nst["invariantUUID"] = nstList.get("modelinvariantuuid")
                    individual_nst["individual_nst"] = 1
                    nstSolutionList.append(individual_nst)

        return nstSolutionList
    except Exception as err:
        raise err


def process_nst_selection( request_json, osdf_config):
    """
    Process a PCI request from a Client (build config-db, policy and  API call, make the call, return result)
    :param req_object: Request parameters from the client
    :param osdf_config: Configuration specific to OSDF application (core + deployment)
    :return: response from NST Opt
    """
    solution = get_nst_solution(request_json)

    return {
        "requestId" : request_json['requestInfo']['requestId'],
        "transactionId" : request_json['requestInfo']['transactionId'],
        "statusMessage" : " ",
        "requestStatus" : "accepted",
        "solutions" : solution
    }