Commit 2cc7d8e4 authored by Jorge Moratinos's avatar Jorge Moratinos
Browse files

ACL UPDATE event when we update ACL using POST /update at security service

parent 1acd09eb

services/TS29222_CAPIF_Security_API/capif_security/core/servicesecurity.py

+9 −0
Original line number Diff line number Diff line
@@ -317,6 +317,7 @@ class SecurityOperations(Resource): 
                    "Service api not found with id: " + api_invoker_id)

                return not_found_error(detail="Service API not existing", cause="Not exist securiy information for this invoker")



            update_acls=list()

            for service_instance in service_security.security_info:

                if service_instance.interface_details is not None:

                    security_methods = service_instance.interface_details.security_methods
@@ -343,14 +344,22 @@ class SecurityOperations(Resource): 
                        valid_security_methods) & set(pref_security_methods)

                    service_instance.sel_security_method = list(

                        valid_security_method)[0]

                update_acls.append({"api_id": service_instance.api_id, "aef_id": service_instance.aef_id})



            service_security = service_security.to_dict()

            service_security = clean_empty(service_security)



            result = mycol.find_one_and_update(old_object, {"$set": service_security}, projection={

                                               '_id': 0, "api_invoker_id": 0}, return_document=ReturnDocument.AFTER, upsert=False)

            current_app.logger.debug(

                    "Inserted security context in database")



            # result = clean_empty(result)

            for update_acl in update_acls:

                # Send service instance to ACL

                current_app.logger.debug("Sending message to create ACL")

                publish_ops.publish_message("acls-messages", "create-acl:"+str(

                    api_invoker_id)+":"+str(update_acl['api_id'])+":"+str(update_acl['aef_id']))



            current_app.logger.debug("Updated security context")