diff --git a/pyproject.toml b/pyproject.toml
index ce53b20b28317318c26c9602ddc443c8091eccd6..9b19cc16ca0671a37994def5eaf6dfaeae9ddb4c 100644
--- a/pyproject.toml
+++ b/pyproject.toml
@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
[project]
name = "opencapif_sdk"
-version = "0.1.7"
+version = "0.1.8.1"
authors = [
{ name="JorgeEcheva", email="jorge.echevarriauribarri.practicas@telefonica.com" },
{ name="dgs-cgm", email="daniel.garciasanchez@telefonica.com" }
diff --git a/sdk/api_schema_translator.py b/sdk/api_schema_translator.py
new file mode 100644
index 0000000000000000000000000000000000000000..ad16d52f3856661b01626a2fadc9c006b29a3056
--- /dev/null
+++ b/sdk/api_schema_translator.py
@@ -0,0 +1,166 @@
+import json
+import logging
+import os
+import re
+
+
+log_path = 'logs/builder_logs.log'
+
+log_dir = os.path.dirname(log_path)
+
+if not os.path.exists(log_dir):
+ os.makedirs(log_dir)
+
+logging.basicConfig(
+ level=logging.NOTSET, # Minimum severity level to log
+ # Log message format
+ format='%(asctime)s - %(name)s - %(levelname)s - %(message)s',
+ handlers=[
+ logging.FileHandler(log_path), # Log to a file
+ logging.StreamHandler() # Also display in the console
+ ]
+)
+
+
+class api_description_builder:
+
+ REQUIRED_COMPONENTS = ["openapi", "info", "servers", "paths", "components"]
+
+ def __init__(self, api_path):
+ self.api_path = os.path.abspath(api_path)
+ self.logger = logging.getLogger(self.__class__.__name__)
+ self.logger.setLevel(logging.DEBUG)
+ self.api_info = self.__load_api_file(self.api_path)
+ self.__validate_api_info()
+
+ def build(self, api_name, ip, port):
+ if not self.__validate_ip_port(ip, port):
+ self.logger.error("Invalid IP or port. Aborting build.")
+ return
+
+ api_data = {
+ "apiName": self.api_info["info"].get("title", api_name),
+ "aefProfiles": self.__build_aef_profiles(ip, port),
+ "description": self.api_info["info"].get("description", "No description provided"),
+ "supportedFeatures": "fffff",
+ "shareableInfo": {
+ "isShareable": True,
+ "capifProvDoms": ["string"]
+ },
+ "serviceAPICategory": "string",
+ "apiSuppFeats": "fffff",
+ "pubApiPath": {
+ "ccfIds": ["string"]
+ },
+ "ccfId": "string"
+ }
+
+ with open(f"{api_name}.json", "w") as outfile:
+ json.dump(api_data, outfile, indent=4)
+ self.logger.info(f"API description saved to {api_name}.json")
+
+ def __load_api_file(self, api_file: str):
+ """Loads the configuration file."""
+ try:
+ with open(api_file, 'r') as file:
+ return json.load(file)
+ except FileNotFoundError:
+ self.logger.warning(
+ f"Configuration file {api_file} not found. Using defaults or environment variables.")
+ return {}
+
+ def __validate_api_info(self):
+ """Validates that all required components are present in the API specification."""
+ missing_components = [comp for comp in self.REQUIRED_COMPONENTS if comp not in self.api_info]
+ if missing_components:
+ self.logger.warning(f"Missing components in API specification: {', '.join(missing_components)}")
+ else:
+ self.logger.info("All required components are present in the API specification.")
+
+ def __build_aef_profiles(self, ip, port):
+ """Builds the aefProfiles section based on the paths and components in the API info."""
+ aef_profiles = []
+
+ for path, methods in self.api_info.get("paths", {}).items():
+ resources = []
+ for method, details in methods.items():
+ resource = {
+ "resourceName": details.get("summary", "Unnamed Resource"),
+ "commType": "REQUEST_RESPONSE",
+ "uri": path,
+ "custOpName": f"http_{method}",
+ "operations": [method.upper()],
+ "description": details.get("description", "")
+ }
+ resources.append(resource)
+
+ # Example profile creation based on paths, customize as needed
+ aef_profile = {
+ "aefId": "AEF07a01ccd74a160c195e69b4f116d66", # Placeholder AEF ID
+ "versions": [
+ {
+ "apiVersion": "v1",
+ "expiry": "2100-11-30T10:32:02.004Z",
+ "resources": resources,
+ "custOperations": [
+ {
+ "commType": "REQUEST_RESPONSE",
+ "custOpName": "string",
+ "operations": ["POST"],
+ "description": "string"
+ },
+ {
+ "commType": "REQUEST_RESPONSE",
+ "custOpName": "check-authentication",
+ "operations": [
+ "POST"
+ ],
+ "description": "Check authentication request."
+ },
+ {
+ "commType": "REQUEST_RESPONSE",
+ "custOpName": "revoke-authentication",
+ "operations": [
+ "POST"
+ ],
+ "description": "Revoke authorization for service APIs."
+ }
+ ]
+ }
+ ],
+ "protocol": "HTTP_1_1",
+ "dataFormat": "JSON",
+ "securityMethods": ["Oauth"],
+ "interfaceDescriptions": [
+ {
+ "ipv4Addr": ip,
+ "port": port,
+ "securityMethods": ["Oauth"]
+ }
+ ]
+ }
+ aef_profiles.append(aef_profile)
+
+ return aef_profiles
+
+ def __validate_ip_port(self, ip, port):
+ """Validates that the IP and port have the correct format."""
+ ip_pattern = re.compile(r"^(?:[0-9]{1,3}\.){3}[0-9]{1,3}$")
+
+ # Validate IP
+ if not ip_pattern.match(ip):
+ self.logger.warning(f"Invalid IP format: {ip}. Expected IPv4 format.")
+ return False
+
+ # Validate each octet in the IP address
+ if any(int(octet) > 255 or int(octet) < 0 for octet in ip.split(".")):
+ self.logger.warning(f"IP address out of range: {ip}. Each octet should be between 0 and 255.")
+ return False
+
+ # Validate Port
+ if not (1 <= port <= 65535):
+ self.logger.warning(f"Invalid port number: {port}. Port should be between 1 and 65535.")
+ return False
+
+ self.logger.info("IP and port have correct format.")
+ return True
diff --git a/setup.py b/setup.py
index 4edc854890f14ebf2c23d8c4ff9b02307f3d0ea5..3e206719cef9d22531c8222f4c2a3a6798a1709f 100644
--- a/setup.py
+++ b/setup.py
@@ -5,5 +5,5 @@ from setuptools import setup, find_packages
setup(
name='opencapif_sdk',
packages=find_packages(include=["sdk"]),
- version="0.1.7",
+ version="0.1.8.1",
)
\ No newline at end of file