Commit 30c26fba authored by Guillermo Sanz López's avatar Guillermo Sanz López
Browse files

reorganize invokers

parent 896ed98a

capif_backend/backoffice_service/core/operations.py

+22 −90
Original line number Diff line number Diff line
@@ -13,55 +13,36 @@ class Operations: 
        self.config = Config().get_config()



    def get_invokers(self):

        # get invoker and user collections

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

        user_col = self.db.get_col_by_name_register(self.db.user)



        try:

            invokers = mycol.find({}, {"_id": 0})

            users = user_col.find({}, {"_id": 0})

            json_invokers = []

            for invoker in invokers:

                # user = user_col.find({

                # "list_invokers": invoker["api_invoker_id"]

                # }, 

                # {"_id": 0})

                # invoker.update(user)

                for user in users:

                    if invoker["api_invoker_id"] in user["list_invokers"]:

                        invoker["username"]=user["username"]

                json_invokers.append(invoker)



            #return jsonify(message="Invokers retrieved succesfully",

            #               object=json_invokers), 200

            json_invokers = self.retrieve_invokers()

            return jsonify(json_invokers), 200

        except Exception as e:

            return "Error when retreiving invoker list: ", e

            return "Error when retrieving invoker list: ", e



    def get_num_invokers(self):

        # get invoker and user collections

        try:

            json_invokers = self.retrieve_invokers()

            num_invokers = len(json_invokers)

            return jsonify(num_invokers), 200

        except Exception as e:

            return "Error when retrieving number of invokers: ", e



    def retrieve_invokers(self):

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

        user_col = self.db.get_col_by_name_register(self.db.user)



        try:

        invokers = mycol.find({}, {"_id": 0})

        users = user_col.find({}, {"_id": 0})



        json_invokers = []

        for invoker in invokers:

                # user = user_col.find({

                # "list_invokers": invoker["api_invoker_id"]

                # }, 

                # {"_id": 0})

                # invoker.update(user)

            for user in users:

                if invoker["api_invoker_id"] in user["list_invokers"]:

                    invoker["username"] = user["username"]

            json_invokers.append(invoker)



            num_invokers = len(json_invokers)

            return jsonify(num_invokers), 200

        except Exception as e:

            return "Error when retreiving number of invokers: ", e

        return json_invokers





    def get_invoker_security_context(self, invoker_id):

        print("ESTOY EN OPERATIONS     INVOKER ID: ", invoker_id)
@@ -81,53 +62,6 @@ class Operations: 
        except Exception as e:

            return "Error when retreiving invoker list: ", e

    

    def get_providers1(self):



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

        user_col = self.db.get_col_by_name_register(self.db.user)



        try:



            users = user_col.find({}, {"_id": 0})

            providers = mycol.find({}, {"_id": 0})



            json_providers = []

            for provider in providers:

                # user = user_col.find({

                # "list_providers": provider["api_prov_dom_id"]

                # }, 

                # {"_id": 0})

                # provider.update(user)

                for user in users:

                    if provider["api_prov_dom_id"] in user["list_providers"]:

                        provider["username"]=user["username"]

                json_providers.append(provider)



            #return jsonify(message="Providers retrieved succesfully",

            #               object=json_providers), 200



            return jsonify(json_providers), 200

        except Exception as e:

            return "Error when retreiving provider list: ", e

        

    def get_num_providers1(self):

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

        user_col = self.db.get_col_by_name_register(self.db.user)

        try:

            users = user_col.find({}, {"_id": 0})

            providers = mycol.find({}, {"_id": 0})



            json_providers = []

            for provider in providers:

                for user in users:

                    if provider["api_prov_dom_id"] in user["list_providers"]:

                        provider["username"]=user["username"]

                json_providers.append(provider)

            num_providers = len(json_providers)

            return jsonify(num_providers), 200

        except Exception as e:

            return "Error when retreiving provider list: ", e

    

    def get_providers(self):

        try:

            json_providers = self.retrieve_providers()
@@ -156,10 +90,8 @@ class Operations: 
                if provider["api_prov_dom_id"] in user["list_providers"]:

                    provider["username"] = user["username"]

            json_providers.append(provider)



        return json_providers





    def get_provider_services(self, id):



        services_col = self.db.get_col_by_name(self.db.services)