Commit 7aa6215f authored by Stavros-Anastasios Charismiadis's avatar Stavros-Anastasios Charismiadis
Browse files

Fix database connection (add interconnection db in mongodb object)

parent a9e1815a
Loading
Loading
Loading
Loading
Loading
+1 −0
Original line number Diff line number Diff line
@@ -38,6 +38,7 @@ class MongoDatabse():
        self.security_context_col = self.config['mongo']['col_security']
        self.events = self.config['mongo']['col_event']
        self.capif_configuration = self.config['mongo']['col_capif_configuration']
        self.interconnected = self.config['mongo']['col_interconnected']

        self.initialize_capif_configuration()

+1 −1
Original line number Diff line number Diff line
@@ -77,7 +77,7 @@ class CapifDomainOperations(Resource):
        current_app.logger.debug(inter_ccf)

        if response.status_code == 201:
            interconnected_col = self.db.get_col_by_name(self.db.col_interconnected)
            interconnected_col = self.db.get_col_by_name(self.db.interconnected)
            interconnected_ccf = interconnected_col.find_one({"ccf_id": inter_ccf['ccf_id']})
            if interconnected_ccf:
                current_app.logger.debug("CCF already interconnected : {}".format(inter_ccf['ccf_id']))
+1 −1
Original line number Diff line number Diff line
@@ -50,7 +50,7 @@ class CcfInstanceOperations(Resource):
        config_col = self.db.get_col_by_name(self.db.capif_configuration)
        config = config_col.find_one({}, {"_id": 0})

        interconnected_col = self.db.get_col_by_name(self.db.col_interconnected)
        interconnected_col = self.db.get_col_by_name(self.db.interconnected)
        interconnected_ccf = interconnected_col.find_one({"ccf_id": ccfinstancedetails.ccf_id})
        if interconnected_ccf:
            current_app.logger.debug("CCF already interconnected : {}".format(ccfinstancedetails.ccf_id))