Commit ac4cb87b authored by Alex Kakiris's avatar Alex Kakiris
Browse files

refine log levels in Publish_Service_API

parent def23c98

services/TS29222_CAPIF_Publish_Service_API/published_apis/controllers/default_controller.py

+5 −5
Original line number Diff line number Diff line
@@ -71,7 +71,7 @@ def apf_id_service_apis_get(apf_id): # noqa: E501 


    :rtype: Union[List[ServiceAPIDescription], Tuple[List[ServiceAPIDescription], int], Tuple[List[ServiceAPIDescription], int, Dict[str, str]]

    """

    current_app.logger.info("Obtainig all service published")

    current_app.logger.debug("Obtainig all service published")

    res = service_operations.get_serviceapis(apf_id)



    return res
@@ -89,7 +89,7 @@ def apf_id_service_apis_post(apf_id, body): # noqa: E501 


    :rtype: Union[ServiceAPIDescription, Tuple[ServiceAPIDescription, int], Tuple[ServiceAPIDescription, int, Dict[str, str]]

    """

    current_app.logger.info("Publishing service")

    current_app.logger.debug("Publishing service")



    if 'supportedFeatures' not in body:

        return bad_request_error(
@@ -134,7 +134,7 @@ def apf_id_service_apis_service_api_id_delete(service_api_id, apf_id): # noqa: 


    :rtype: Union[None, Tuple[None, int], Tuple[None, int, Dict[str, str]]

    """

    current_app.logger.info("Removing service published")

    current_app.logger.debug("Removing service published")

    res = service_operations.delete_serviceapidescription(

        service_api_id, apf_id)
@@ -153,7 +153,7 @@ def apf_id_service_apis_service_api_id_get(service_api_id, apf_id): # noqa: E50 


    :rtype: Union[ServiceAPIDescription, Tuple[ServiceAPIDescription, int], Tuple[ServiceAPIDescription, int, Dict[str, str]]

    """

    current_app.logger.info("Obtaining service api with id: " + service_api_id)

    current_app.logger.debug("Obtaining service api with id: " + service_api_id)

    res = service_operations.get_one_serviceapi(service_api_id, apf_id)



    return res
@@ -173,7 +173,7 @@ def apf_id_service_apis_service_api_id_put(service_api_id, apf_id, body): # noq 


    :rtype: Union[ServiceAPIDescription, Tuple[ServiceAPIDescription, int], Tuple[ServiceAPIDescription, int, Dict[str, str]]

    """

    current_app.logger.info(

    current_app.logger.debug(

        "Updating service api id with id: " + service_api_id)



    if 'supportedFeatures' not in body:

services/TS29222_CAPIF_Publish_Service_API/published_apis/controllers/individual_apf_published_api_controller.py

+1 −1
Original line number Diff line number Diff line
@@ -69,7 +69,7 @@ def modify_ind_apf_pub_api(service_api_id, apf_id, body): # noqa: E501 


    :rtype: Union[ServiceAPIDescription, Tuple[ServiceAPIDescription, int], Tuple[ServiceAPIDescription, int, Dict[str, str]]

    """

    current_app.logger.info(

    current_app.logger.debug(

        "Patching service api id with id: " + service_api_id)

    if request.is_json:

        body = ServiceAPIDescriptionPatch.from_dict(request.get_json())  # noqa: E501

services/TS29222_CAPIF_Publish_Service_API/published_apis/core/auth_manager.py

+1 −1
Original line number Diff line number Diff line
@@ -17,7 +17,7 @@ class AuthManager(Resource): 
        else:

            auth_context["resources"]["services"] = [service_id]



        current_app.logger.info(auth_context)

        current_app.logger.debug(auth_context)

        cert_col.find_one_and_update({"id":apf_id}, {"$set":auth_context})

services/TS29222_CAPIF_Publish_Service_API/published_apis/core/consumer_messager.py

+2 −2
Original line number Diff line number Diff line
@@ -16,10 +16,10 @@ class Subscriber(): 
        self.p.subscribe("internal-messages")



    def listen(self):

        current_app.logger.info("Listening publish messages")

        current_app.logger.debug("Listening publish messages")

        for raw_message in self.p.listen():

            if raw_message["type"] == "message" and raw_message["channel"].decode('utf-8') == "internal-messages":

                current_app.logger.info("New internal event received")

                current_app.logger.debug("New internal event received")

                internal_redis_event = json.loads(

                    raw_message["data"].decode('utf-8'))

                if internal_redis_event.get('event') == "PROVIDER-REMOVED":

services/TS29222_CAPIF_Publish_Service_API/published_apis/core/internal_service_ops.py

+1 −1
Original line number Diff line number Diff line
@@ -13,7 +13,7 @@ class InternalServiceOps(Resource): 


    def delete_intern_service(self, apf_ids):



        current_app.logger.info("Provider removed, removing services published by APF")

        current_app.logger.debug("Provider removed, removing services published by APF")

        mycol = self.db.get_col_by_name(self.db.service_api_descriptions)

        for apf_id in apf_ids:

            my_query = {'apf_id': apf_id}