osdfapp.py

   1 # -------------------------------------------------------------------------
   2 #   Copyright (c) 2015-2017 AT&T Intellectual Property
   3 #
   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
   7 #
   8 #       http://www.apache.org/licenses/LICENSE-2.0
   9 #
  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.
  15 #
  16 # -------------------------------------------------------------------------
  17 #
  18
  19 """
  20 OSDF Manager Main Flask Application
  21 """
  22
  23 import json
  24
  25 from threading import Thread  # for scaling up, may need celery with RabbitMQ or redis
  26
  27 from flask import request, g
  28
  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
  47
  48
  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!")
  53     return "OK"
  54
  55
  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)
  62     return "OK"
  63
  64
  65 @app.route("/api/oof/v1/placement", methods=["POST"])
  66 @auth_basic.login_required
  67 def do_placement_opt():
  68     return placement_rest_api()
  69
  70
  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()
  75
  76
  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
  81     """
  82     request_json = request.get_json()
  83     req_id = request_json['requestInfo']['requestId']
  84     g.request_id = req_id
  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))
  91     t.start()
  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="")
  96
  97
  98 @app.route("/api/oof/route/v1", methods=["POST"])
  99 def do_route_calc():
 100     """
 101     Perform the basic route calculations and returnn the vpn-bindings
 102     """
 103     request_json = request.get_json()
 104     audit_log.info("Calculate Route request received!")
 105     response = RouteOpt().get_route(request_json, osdf_config)
 106     return response
 107
 108 @app.route("/api/oof/mdons/route/v1", methods=["POST"])
 109 def do_mdons_route_calc():
 110     """
 111     Perform the inter domain route calculation
 112     """
 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)
 116     return response
 117
 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)
 124     return response
 125
 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)
 133
 134     req_id = request_json['requestInfo']['requestId']
 135     audit_log.info('requestID obtained==>')
 136     audit_log.info(req_id)
 137
 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))
 145     t.start()
 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="")
 151
 152
 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))
 162     t.start()
 163     return req_accept(request_id=req_id,
 164                       transaction_id=request_json['requestInfo']['transactionId'],
 165                       request_status="accepted", status_message="")
 166
 167
 168 @app.route("/api/oof/selection/nssi/v1", methods=["POST"])
 169 def do_nssi_selection():
 170     request_json = request.get_json()
 171     req_id = request_json['requestInfo']['requestId']
 172     g.request_id = req_id
 173     audit_log.info(MH.received_request(request.url, request.remote_addr, json.dumps(request_json)))
 174     NSSISelectionAPI(request_json).validate()
 175     audit_log.info(MH.new_worker_thread(req_id, "[for NSSI selection]"))
 176     t = Thread(target=process_nsi_selection_opt, args=(request_json, osdf_config))
 177     t.start()
 178     return req_accept(request_id=req_id,
 179                       transaction_id=request_json['requestInfo']['transactionId'],
 180                       request_status="accepted", status_message="")
 181
 182
 183 if __name__ == "__main__":
 184     run_app()