working pre deploy (27bea988) · Commits · OCF / backoffice / backend

capif_backend/backoffice_service/config.py

0 → 100644

+18 −0

Original line number	Diff line number	Diff line
		import yaml
		import os

		class Config:
		def __init__(self):
		self.cached = 0
		# Usa una ruta absoluta para el archivo config.yaml
		self.file = os.path.join(os.path.dirname(__file__), '..', 'config.yaml')
		self.my_config = {}

		stamp = os.stat(self.file).st_mtime
		if stamp != self.cached:
		self.cached = stamp
		with open(self.file) as f:
		self.my_config = yaml.safe_load(f)

		def get_config(self):
		return self.my_config

capif_backend/backoffice_service/core/operations.py

+28 −24

Original line number	Diff line number	Diff line
		from flask import jsonify, make_response
		import requests
		from ..configs.config import Config
		# from ..configs.config import Config
		from ..config import Config
		import os
		import json
		import copy
		@@ -9,7 +10,6 @@ import sys
		from requests.auth import HTTPBasicAuth



		class Operations:

		def __init__(self):
		@@ -22,8 +22,9 @@ class Operations:
		def delete_users(self, uuids):
		def login1():
		try:
		url = f"https://{self.config['capif']['register']}/login"
		response = requests.post(
		"https://capifcore:8084/login",
		url,
		auth=HTTPBasicAuth(self.username, self.password),
		verify=False
		)
		@@ -49,7 +50,7 @@ class Operations:
		}

		for uuid in uuids:
		url = f'https://capifcore:8084/deleteUser/{uuid}'
		url = f"https://{self.config['capif']['register']}/deleteUser/{uuid}"
		print(f"Making DELETE request to URL: {url}")

		response = requests.delete(url, headers=headers, verify=False)
		@@ -69,8 +70,9 @@ class Operations:
		def retrieve_users_pages_order(self, page, page_size, sort_order):
		def login1():
		try:
		url = f"https://{self.config['capif']['register']}/login"
		response = requests.post(
		"https://capifcore:8084/login",
		url,
		auth=HTTPBasicAuth(self.username, self.password),
		verify=False
		)
		@@ -85,7 +87,8 @@ class Operations:
		def get_users(token):
		headers = {"Authorization": f"Bearer {token}"}
		try:
		response = requests.get("https://capifcore:8084/getUsers", headers=headers, verify=False)
		url = f"https://{self.config['capif']['register']}/getUsers"
		response = requests.get(url, headers=headers, verify=False)
		return response
		except requests.exceptions.RequestException as e:
		return None
		@@ -133,11 +136,12 @@ class Operations:
		except requests.exceptions.RequestException as e:
		return jsonify({"error": f"Error when retrieving user list: {str(e)}"}), 500

		def get_number_of_users(self, page, page_size, sort_order):
		def get_number_of_users(self):
		def login2():
		try:
		url = f"https://{self.config['capif']['register']}/login"
		response = requests.post(
		"https://capifcore:8084/login",
		url,
		auth=HTTPBasicAuth(self.username, self.password),
		verify=False
		)
		@@ -152,7 +156,8 @@ class Operations:
		def get_users(token):
		headers = {"Authorization": f"Bearer {token}"}
		try:
		response = requests.get("https://10.95.228.109:8084/getUsers", headers=headers, verify=False)
		url = f"https://{self.config['capif']['register']}/getUsers"
		response = requests.get(url, headers=headers, verify=False)
		return response
		except requests.exceptions.RequestException as e:
		return None
		@@ -184,7 +189,7 @@ class Operations:


		def get_invokers(self):
		url = f"https://capifcore/helper/getInvokers"
		url = f"https://{self.config['capif']['helper']}/getInvokers"

		try:
		response = requests.get(url, verify='/etc/ssl/certs/ca_root.crt', cert=('/etc/ssl/certs/superadmin.crt', '/etc/ssl/private/superadmin.key'))
		@@ -215,7 +220,7 @@ class Operations:
		responses.append({'invoker_id': None, 'message': 'Invalid invoker ID'})
		continue

		url = 'https://{}/api-invoker-management/v1/onboardedInvokers/{}'.format(os.getenv('CAPIF_HOSTNAME'), invoker_id)
		url = "https://{}/api-invoker-management/v1/onboardedInvokers/{}".format(os.getenv('CAPIF_HOSTNAME'), invoker_id)
		response = requests.delete(url, cert=(
		'/etc/ssl/certs/superadmin.crt',
		'/etc/ssl/private/superadmin.key'),
		@@ -263,7 +268,7 @@ class Operations:


		def get_num_invokers(self):
		url = f"https://capifcore/helper/getInvokers"
		url = f"https://{self.config['capif']['helper']}/getInvokers"

		try:
		response = requests.get(url, verify='/etc/ssl/certs/ca_root.crt', cert=('/etc/ssl/certs/superadmin.crt', '/etc/ssl/private/superadmin.key'))
		@@ -390,8 +395,7 @@ class Operations:
		# return "Error when retrieving invoker list: ", e

		def get_invokers_pages_order1(self, page, page_size, sort_order):
		capif_hostname = "CAPIF_HOSTNAME" # Reemplaza con el valor adecuado
		url = f"https://capifcore/helper/getInvokers"
		url = f"https://{self.config['capif']['helper']}/getInvokers"

		# params = {
		# 'page': page,
		@@ -409,7 +413,7 @@ class Operations:
		return jsonify({"error": str(e)}), 500

		def get_invokers_pages_order(self, page, page_size, sort_order):
		url = f"https://capifcore/helper/getInvokers"
		url = f"https://{self.config['capif']['helper']}/getInvokers"

		try:
		response = requests.get(url, verify='/etc/ssl/certs/ca_root.crt', cert=('/etc/ssl/certs/superadmin.crt', '/etc/ssl/private/superadmin.key'))
		@@ -485,7 +489,7 @@ class Operations:


		def get_providers(self):
		url = f"https://capifcore/helper/getProviders"
		url = f"https://{self.config['capif']['helper']}/getProviders"

		try:
		response = requests.get(url, verify='/etc/ssl/certs/ca_root.crt', cert=('/etc/ssl/certs/superadmin.crt', '/etc/ssl/private/superadmin.key'))
		@@ -504,7 +508,7 @@ class Operations:
		return jsonify({"error": str(e)}), 500

		def get_num_providers(self):
		url = f"https://capifcore/helper/getProviders"
		url = f"https://{self.config['capif']['helper']}/getProviders"

		try:
		response = requests.get(url, verify='/etc/ssl/certs/ca_root.crt', cert=('/etc/ssl/certs/superadmin.crt', '/etc/ssl/private/superadmin.key'))
		@@ -590,7 +594,7 @@ class Operations:
		# return "Error when retrieving provider list: ", e

		def get_providers_pages_order(self, page, page_size, sort_order):
		url = f"https://capifcore/helper/getProviders"
		url = f"https://{self.config['capif']['helper']}/getProviders"

		try:
		response = requests.get(url, verify='/etc/ssl/certs/ca_root.crt', cert=('/etc/ssl/certs/superadmin.crt', '/etc/ssl/private/superadmin.key'))
		@@ -932,7 +936,7 @@ class Operations:
		responses.append({'provider_id': None, 'message': 'Invalid provider ID'})
		continue

		url = 'https://{}/api-provider-management/v1/registrations/{}'.format(os.getenv('CAPIF_HOSTNAME'), provider_id)
		url = "https://{}/api-provider-management/v1/registrations/{}".format(os.getenv('CAPIF_HOSTNAME'), provider_id)
		# response = requests.delete(url, cert=(
		# '/usr/src/app/backoffice_service/certs/backoffice_vault_cert.crt',
		# '/usr/src/app/backoffice_service/certs/backoffice_vault_private_key.key'),
		@@ -1004,7 +1008,7 @@ class Operations:
		responses.append({'api_id': api['api_id'], 'message': 'Invalid API.'})
		continue

		url = 'https://{}/published-apis/v1/{}/service-apis/{}'.format(os.getenv('CAPIF_HOSTNAME'), api['apf_id'], api['api_id'])
		url = "https://{}/published-apis/v1/{}/service-apis/{}".format(os.getenv('CAPIF_HOSTNAME'), api['apf_id'], api['api_id'])

		# response = requests.delete(url, cert=(
		# '/usr/src/app/backoffice_service/certs/backoffice_vault_cert.crt',
		@@ -1176,7 +1180,7 @@ class Operations:


		def get_apis1(self):
		url = f"https://capifcore/helper/getServices"
		url = f"https://{self.config['capif']['helper']}/getServices"

		try:
		response = requests.get(url, verify='/etc/ssl/certs/ca_root.crt', cert=('/etc/ssl/certs/superadmin.crt', '/etc/ssl/private/superadmin.key'))
		@@ -1195,7 +1199,7 @@ class Operations:
		return jsonify({"error": str(e)}), 500

		def get_apis(self):
		url = f"https://capifcore/helper/getServices"
		url = f"https://{self.config['capif']['helper']}/getServices"

		try:
		response = requests.get(url, verify='/etc/ssl/certs/ca_root.crt', cert=('/etc/ssl/certs/superadmin.crt', '/etc/ssl/private/superadmin.key'))
		@@ -1250,7 +1254,7 @@ class Operations:
		# return "Error when retrieving apis list: ", e

		def get_apis_pages_order(self, page, page_size, sort_order):
		url = f"https://capifcore/helper/getServices"
		url = f"https://{self.config['capif']['helper']}/getServices"

		try:
		response = requests.get(url, verify='/etc/ssl/certs/ca_root.crt', cert=('/etc/ssl/certs/superadmin.crt', '/etc/ssl/private/superadmin.key'))
		@@ -1340,7 +1344,7 @@ class Operations:
		# return json_apis

		def get_num_apis(self):
		url = f"https://capifcore/helper/getServices"
		url = f"https://{self.config['capif']['helper']}/getServices"

		try:
		response = requests.get(url, verify='/etc/ssl/certs/ca_root.crt', cert=('/etc/ssl/certs/superadmin.crt', '/etc/ssl/private/superadmin.key'))

capif_backend/config.yaml

+3 −1

Original line number	Diff line number	Diff line
		@@ -21,7 +21,9 @@ mongo_register: {
		}

		capif: {
		'host': 'capifcore'
		'host': 'capifcore',
		'register': 'capifcore:8084',
		'helper': 'capifcore/helper'
		}

		ca_factory: {