Add common functionality to abstract API operations

#!/usr/bin/env python3

# -*- coding: utf-8 -*-

##

# Copyright 2025-present by Software Networks Area, i2CAT.

# All rights reserved.

#

# This file is part of the Federation SDK

# Unauthorized copying of this file, via any medium is strictly prohibited.

#

# Contributors:

#   - Sergio Giménez (sergio.gimenez@i2cat.net)

##

import json

from typing import Optional

import requests

from pydantic import BaseModel

from src import logger

log = logger.get_logger(__name__)

class I2EdgeError(Exception):

    pass

class I2EdgeErrorResponse(BaseModel):

    message: str

    detail: dict

def get_error_message_from(response: requests.Response) -> str:

    try:

        error_response = I2EdgeErrorResponse(**response.json())

        return error_response.message

    except Exception as e:

        log.error("Failed to parse error response from i2edge: {}".format(e))

        return response.text

def i2edge_post(url: str, model_payload: BaseModel) -> dict:

    headers = {"Content-Type": "application/json", "accept": "application/json"}

    json_payload = json.dumps(model_payload.model_dump(mode="json"))

    try:

        response = requests.post(url, data=json_payload, headers=headers)

        response.raise_for_status()

        return response.json()

    except requests.exceptions.HTTPError as e:

        i2edge_err_msg = get_error_message_from(response)

        err_msg = "Failed to deploy app: {}. Detail: {}".format(i2edge_err_msg, e)

        log.error(err_msg)

        raise I2EdgeError(err_msg)

def i2edge_post_multiform_data(url: str, model_payload: BaseModel) -> dict:

    headers = {

        "accept": "application/json",

    }

    payload_dict = model_payload.model_dump(mode="json")

    payload_in_str = {k: str(v) for k, v in payload_dict.items()}

    try:

        response = requests.post(url, data=payload_in_str, headers=headers)

        response.raise_for_status()

        return response.json()

    except requests.exceptions.HTTPError as e:

        i2edge_err_msg = get_error_message_from(response)

        err_msg = "Failed to deploy app: {}. Detail: {}".format(i2edge_err_msg, e)

        log.error(err_msg)

        raise I2EdgeError(err_msg)

def i2edge_delete(url: str, id: str) -> dict:

    headers = {"accept": "application/json"}

    try:

        query = "{}/{}".format(url, id)

        response = requests.delete(query, headers=headers)

        response.raise_for_status()

        return response.json()

    except requests.exceptions.HTTPError as e:

        i2edge_err_msg = get_error_message_from(response)

        err_msg = "Failed to undeploy app: {}. Detail: {}".format(i2edge_err_msg, e)

        log.error(err_msg)

        raise I2EdgeError(err_msg)

def i2edge_get(url: str, params: Optional[dict]):

    headers = {"accept": "application/json"}

    try:

        response = requests.get(url, params=params, headers=headers)

        response.raise_for_status()

        return response.json()

    except requests.exceptions.HTTPError as e:

        i2edge_err_msg = get_error_message_from(response)

        err_msg = "Failed to get apps: {}. Detail: {}".format(i2edge_err_msg, e)

        log.error(err_msg)

        raise I2EdgeError(err_msg)