1 # -------------------------------------------------------------------------
2 # Copyright (c) 2015-2017 AT&T Intellectual Property
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 # -------------------------------------------------------------------------
20 OSDF Manager Main Flask Application
25 from threading import Thread # for scaling up, may need celery with RabbitMQ or redis
27 from flask import request, g
29 from osdf.apps.baseapp import app, run_app
30 from apps.nst.models.api.nstSelectionRequest import NSTSelectionAPI
31 from apps.pci.models.api.pciOptimizationRequest import PCIOptimizationAPI
32 from apps.nst.optimizers.nst_select_processor import process_nst_selection
33 from apps.pci.optimizers.pci_opt_processor import process_pci_optimation
34 from apps.placement.models.api.placementRequest import PlacementAPI
35 from apps.placement.optimizers.conductor.remote_opt_processor import process_placement_opt
36 from apps.route.optimizers.inter_domain_route_opt import InterDomainRouteOpt
37 from apps.route.optimizers.simple_route_opt import RouteOpt
38 from apps.slice_selection.models.api.nsi_selection_request import NSISelectionAPI
39 from apps.slice_selection.optimizers.conductor.remote_opt_processor import process_nsi_selection_opt
40 from osdf.adapters.policy.interface import get_policies
41 from osdf.adapters.policy.interface import upload_policy_models
42 from osdf.config.base import osdf_config
43 from osdf.logging.osdf_logging import MH, audit_log
44 from osdf.operation.responses import osdf_response_for_request_accept as req_accept
45 from osdf.utils import api_data_utils
46 from osdf.webapp.appcontroller import auth_basic
49 @app.route("/api/oof/v1/healthcheck", methods=["GET"])
50 def do_osdf_health_check():
51 """Simple health check"""
52 audit_log.info("A health check request is processed!")
56 @app.route("/api/oof/loadmodels/v1", methods=["GET"])
57 def do_osdf_load_policies():
58 audit_log.info("Uploading policy models")
59 """Upload policy models"""
60 response = upload_policy_models()
61 audit_log.info(response)
65 @app.route("/api/oof/v1/placement", methods=["POST"])
66 @auth_basic.login_required
67 def do_placement_opt():
68 return placement_rest_api()
71 @app.route("/api/oof/placement/v1", methods=["POST"])
72 @auth_basic.login_required
73 def do_placement_opt_common_versioning():
74 return placement_rest_api()
77 def placement_rest_api():
78 """Perform placement optimization after validating the request and fetching policies
79 Make a call to the call-back URL with the output of the placement request.
80 Note: Call to Conductor for placement optimization may have redirects, so account for them
82 request_json = request.get_json()
83 req_id = request_json['requestInfo']['requestId']
85 audit_log.info(MH.received_request(request.url, request.remote_addr, json.dumps(request_json)))
86 api_version_info = api_data_utils.retrieve_version_info(request, req_id)
87 PlacementAPI(request_json).validate()
88 policies = get_policies(request_json, "placement")
89 audit_log.info(MH.new_worker_thread(req_id, "[for placement]"))
90 t = Thread(target=process_placement_opt, args=(request_json, policies, osdf_config))
92 audit_log.info(MH.accepted_valid_request(req_id, request))
93 return req_accept(request_id=req_id,
94 transaction_id=request_json['requestInfo']['transactionId'],
95 version_info=api_version_info, request_status="accepted", status_message="")
98 @app.route("/api/oof/route/v1", methods=["POST"])
101 Perform the basic route calculations and returnn the vpn-bindings
103 request_json = request.get_json()
104 audit_log.info("Calculate Route request received!")
105 response = RouteOpt().get_route(request_json, osdf_config)
108 @app.route("/api/oof/mdons/route/v1", methods=["POST"])
109 def do_mdons_route_calc():
111 Perform the inter domain route calculation
113 request_json = request.get_json()
114 audit_log.info("Inter Domain Calculation Route request received!")
115 response = InterDomainRouteOpt().get_route(request_json, osdf_config)
118 @app.route("/api/oof/v1/selection/nst", methods=["POST"])
119 def do_nst_selection():
120 request_json = request.get_json()
121 req_id = request_json['requestInfo']['requestId']
122 NSTSelectionAPI(request_json).validate()
123 response = process_nst_selection(request_json, osdf_config)
126 @app.route("/api/oof/v1/pci", methods=["POST"])
127 @app.route("/api/oof/pci/v1", methods=["POST"])
128 @auth_basic.login_required
129 def do_pci_optimization():
130 request_json = request.get_json()
131 audit_log.info('request json obtained==>')
132 audit_log.info(request_json)
134 req_id = request_json['requestInfo']['requestId']
135 audit_log.info('requestID obtained==>')
136 audit_log.info(req_id)
138 g.request_id = req_id
139 audit_log.info(MH.received_request(request.url, request.remote_addr, json.dumps(request_json)))
140 PCIOptimizationAPI(request_json).validate()
141 # disable policy retrieval
142 # policies = get_policies(request_json, "pciopt")
143 audit_log.info(MH.new_worker_thread(req_id, "[for pciopt]"))
144 t = Thread(target=process_pci_optimation, args=(request_json, osdf_config, None))
146 audit_log.info(MH.accepted_valid_request(req_id, request))
147 audit_log.info('reached upto return')
148 return req_accept(request_id=req_id,
149 transaction_id=request_json['requestInfo']['transactionId'],
150 request_status="accepted", status_message="")
153 @app.route("/api/oof/selection/nsi/v1", methods=["POST"])
154 def do_nsi_selection():
155 request_json = request.get_json()
156 req_id = request_json['requestInfo']['requestId']
157 g.request_id = req_id
158 audit_log.info(MH.received_request(request.url, request.remote_addr, json.dumps(request_json)))
159 NSISelectionAPI(request_json).validate()
160 audit_log.info(MH.new_worker_thread(req_id, "[for NSI selection]"))
161 t = Thread(target=process_nsi_selection_opt, args=(request_json, osdf_config))
163 return req_accept(request_id=req_id,
164 transaction_id=request_json['requestInfo']['transactionId'],
165 request_status="accepted", status_message="")
168 if __name__ == "__main__":