osdfapp.py

   1 # -------------------------------------------------------------------------
   2 #   Copyright (c) 2015-2017 AT&T Intellectual Property
   3 #   Copyright (C) 2020 Wipro Limited.
   4 #
   5 #   Licensed under the Apache License, Version 2.0 (the "License");
   6 #   you may not use this file except in compliance with the License.
   7 #   You may obtain a copy of the License at
   8 #
   9 #       http://www.apache.org/licenses/LICENSE-2.0
  10 #
  11 #   Unless required by applicable law or agreed to in writing, software
  12 #   distributed under the License is distributed on an "AS IS" BASIS,
  13 #   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14 #   See the License for the specific language governing permissions and
  15 #   limitations under the License.
  16 #
  17 # -------------------------------------------------------------------------
  18 #
  19
  20 """
  21 OSDF Manager Main Flask Application
  22 """
  23
  24 import json
  25
  26 from threading import Thread  # for scaling up, may need celery with RabbitMQ or redis
  27
  28 from flask import request, g
  29
  30 from osdf.apps.baseapp import app, run_app
  31 from apps.nst.models.api.nstSelectionRequest import NSTSelectionAPI
  32 from apps.pci.models.api.pciOptimizationRequest import PCIOptimizationAPI
  33 from apps.nst.optimizers.nst_select_processor import process_nst_selection
  34 from apps.pci.optimizers.pci_opt_processor import process_pci_optimation
  35 from apps.placement.models.api.placementRequest import PlacementAPI
  36 from apps.placement.optimizers.conductor.remote_opt_processor import process_placement_opt
  37 from apps.route.optimizers.inter_domain_route_opt import InterDomainRouteOpt
  38 from apps.route.optimizers.simple_route_opt import RouteOpt
  39 from apps.slice_selection.models.api.nsi_selection_request import NSISelectionAPI
  40 from apps.slice_selection.models.api.nssi_selection_request import NSSISelectionAPI
  41 from apps.slice_selection.optimizers.conductor.remote_opt_processor import SliceSelectionOptimizer
  42 from osdf.adapters.policy.interface import get_policies
  43 from osdf.adapters.policy.interface import upload_policy_models
  44 from osdf.config.base import osdf_config
  45 from osdf.config.base import slice_config
  46 from osdf.logging.osdf_logging import MH, audit_log
  47 from osdf.operation.responses import osdf_response_for_request_accept as req_accept
  48 from osdf.utils import api_data_utils
  49 from osdf.webapp.appcontroller import auth_basic
  50 from apps.nxi_termination.optimizers.remote_opt_processor import process_nxi_termination_opt
  51 from apps.nxi_termination.models.api.nxi_termination_request import NxiTerminationApi
  52
  53
  54 @app.route("/api/oof/v1/healthcheck", methods=["GET"])
  55 def do_osdf_health_check():
  56     """Simple health check"""
  57     audit_log.info("A health check request is processed!")
  58     return "OK"
  59
  60
  61 @app.route("/api/oof/loadmodels/v1", methods=["GET"])
  62 def do_osdf_load_policies():
  63     audit_log.info("Uploading policy models")
  64     """Upload policy models"""
  65     response = upload_policy_models()
  66     audit_log.info(response)
  67     return "OK"
  68
  69
  70 @app.route("/api/oof/v1/placement", methods=["POST"])
  71 @auth_basic.login_required
  72 def do_placement_opt():
  73     return placement_rest_api()
  74
  75
  76 @app.route("/api/oof/placement/v1", methods=["POST"])
  77 @auth_basic.login_required
  78 def do_placement_opt_common_versioning():
  79     return placement_rest_api()
  80
  81
  82 def placement_rest_api():
  83     """Perform placement optimization after validating the request and fetching policies
  84     Make a call to the call-back URL with the output of the placement request.
  85     Note: Call to Conductor for placement optimization may have redirects, so account for them
  86     """
  87     request_json = request.get_json()
  88     req_id = request_json['requestInfo']['requestId']
  89     g.request_id = req_id
  90     audit_log.info(MH.received_request(request.url, request.remote_addr, json.dumps(request_json)))
  91     api_version_info = api_data_utils.retrieve_version_info(request, req_id)
  92     PlacementAPI(request_json).validate()
  93     policies = get_policies(request_json, "placement")
  94     audit_log.info(MH.new_worker_thread(req_id, "[for placement]"))
  95     t = Thread(target=process_placement_opt, args=(request_json, policies, osdf_config))
  96     t.start()
  97     audit_log.info(MH.accepted_valid_request(req_id, request))
  98     return req_accept(request_id=req_id,
  99                       transaction_id=request_json['requestInfo']['transactionId'],
 100                       version_info=api_version_info, request_status="accepted", status_message="")
 101
 102
 103 @app.route("/api/oof/route/v1", methods=["POST"])
 104 def do_route_calc():
 105     """
 106     Perform the basic route calculations and returnn the vpn-bindings
 107     """
 108     request_json = request.get_json()
 109     audit_log.info("Calculate Route request received!")
 110     response = RouteOpt().get_route(request_json, osdf_config)
 111     return response
 112
 113
 114 @app.route("/api/oof/mdons/route/v1", methods=["POST"])
 115 def do_mdons_route_calc():
 116     """
 117     Perform the inter domain route calculation
 118     """
 119     request_json = request.get_json()
 120     audit_log.info("Inter Domain Calculation  Route request received!")
 121     response = InterDomainRouteOpt().get_route(request_json, osdf_config)
 122     return response
 123
 124
 125 @app.route("/api/oof/v1/selection/nst", methods=["POST"])
 126 def do_nst_selection():
 127     request_json = request.get_json()
 128     req_id = request_json['requestInfo']['requestId']
 129     NSTSelectionAPI(request_json).validate()
 130     response = process_nst_selection(request_json, osdf_config)
 131     return response
 132
 133
 134 @app.route("/api/oof/v1/pci", methods=["POST"])
 135 @app.route("/api/oof/pci/v1", methods=["POST"])
 136 @auth_basic.login_required
 137 def do_pci_optimization():
 138     request_json = request.get_json()
 139     audit_log.info('request json obtained==>')
 140     audit_log.info(request_json)
 141
 142     req_id = request_json['requestInfo']['requestId']
 143     audit_log.info('requestID obtained==>')
 144     audit_log.info(req_id)
 145
 146     g.request_id = req_id
 147     audit_log.info(MH.received_request(request.url, request.remote_addr, json.dumps(request_json)))
 148     PCIOptimizationAPI(request_json).validate()
 149     # disable policy retrieval
 150     # policies = get_policies(request_json, "pciopt")
 151     audit_log.info(MH.new_worker_thread(req_id, "[for pciopt]"))
 152     t = Thread(target=process_pci_optimation, args=(request_json, osdf_config, None))
 153     t.start()
 154     audit_log.info(MH.accepted_valid_request(req_id, request))
 155     audit_log.info('reached upto return')
 156     return req_accept(request_id=req_id,
 157                       transaction_id=request_json['requestInfo']['transactionId'],
 158                       request_status="accepted", status_message="")
 159
 160
 161 @app.route("/api/oof/selection/nsi/v1", methods=["POST"])
 162 def do_nsi_selection():
 163     request_json = request.get_json()
 164     req_id = request_json['requestInfo']['requestId']
 165     g.request_id = req_id
 166     audit_log.info(MH.received_request(request.url, request.remote_addr, json.dumps(request_json)))
 167     NSISelectionAPI(request_json).validate()
 168     audit_log.info(MH.new_worker_thread(req_id, "[for NSI selection]"))
 169     slice_opt = SliceSelectionOptimizer(osdf_config, slice_config, request_json, 'NSI')
 170     slice_opt.start()
 171     return req_accept(request_id=req_id,
 172                       transaction_id=request_json['requestInfo']['transactionId'],
 173                       request_status="accepted", status_message="")
 174
 175
 176 @app.route("/api/oof/selection/nssi/v1", methods=["POST"])
 177 def do_nssi_selection():
 178     request_json = request.get_json()
 179     req_id = request_json['requestInfo']['requestId']
 180     g.request_id = req_id
 181     audit_log.info(MH.received_request(request.url, request.remote_addr, json.dumps(request_json)))
 182     NSSISelectionAPI(request_json).validate()
 183     audit_log.info(MH.new_worker_thread(req_id, "[for NSSI selection]"))
 184     slice_opt = SliceSelectionOptimizer(osdf_config, slice_config, request_json, 'NSSI')
 185     slice_opt.start()
 186     return req_accept(request_id=req_id,
 187                       transaction_id=request_json['requestInfo']['transactionId'],
 188                       request_status="accepted", status_message="")
 189
 190
 191 @app.route("/api/oof/terminate/nxi/v1",methods=["POST"])
 192 def do_nxi_terminaton():
 193     request_json = request.get_json()
 194     req_id = request_json['requestInfo']['requestId']
 195     g.request_id = req_id
 196     audit_log.info(MH.received_request(request.url, request.remote_addr, json.dumps(request_json)))
 197     NxiTerminationApi(request_json).validate()
 198     return process_nxi_termination_opt(request_json,osdf_config)
 199
 200
 201 if __name__ == "__main__":
 202     run_app()