internal_client.go

package sdnclient

import (
	"encoding/json"
	"fmt"
	"net/http"

	l2smv1 "github.com/Networks-it-uc3m/L2S-M/api/v1"
)

// InternalClient is part of the Client interface, and implements the SessionClient, which is a wrapper of the http function.
// this type of client is for the specific l2sm-controller onos app, which manages intra cluster networks.
type InternalClient struct {
	Session *SessionClient
}

type VnetPayload struct {
	NetworkId string `json:"networkId"`
}
type VnetPortPayload struct {
	NetworkId string   `json:"networkId"`
	Port      []string `json:"networkEndpoints,omitempty"`
}

func (c *InternalClient) beginSessionController() bool {
	resp, err := c.Session.Get("/vnets/api/status")

	if err != nil {
		fmt.Println(err)
		return false
	}
	defer resp.Body.Close()
	// Check if the status code indicates success (HTTP 200 OK).
	return resp.StatusCode == http.StatusOK
}

// CreateNetwork creates a new network in the SDN controller
func (c *InternalClient) CreateNetwork(networkType l2smv1.NetworkType, config interface{}) error {

	//TODO: Remove hard-code
	networkType = "vnets"
	jsonData, err := json.Marshal(config)
	if err != nil {
		return err
	}
	response, err := c.Session.Post(fmt.Sprintf("/%s/api", networkType), jsonData)
	if err != nil {
		return err
	}
	defer response.Body.Close()

	if response.StatusCode != http.StatusNoContent {
		return fmt.Errorf("failed to create network, status code: %d", response.StatusCode)
	}

	return nil
}

// CheckNetworkExists checks if the specified network exists in the SDN controller
func (c *InternalClient) CheckNetworkExists(networkType l2smv1.NetworkType, networkID string) (bool, error) {
	networkType = "vnets"

	response, err := c.Session.Get(fmt.Sprintf("/%s/api/%s", networkType, networkID))
	if err != nil {
		return false, err
	}
	defer response.Body.Close()

	return response.StatusCode == http.StatusOK, nil
}

// DeleteNetwork deletes an existing network from the SDN controller
func (c *InternalClient) DeleteNetwork(networkType l2smv1.NetworkType, networkID string) error {
	networkType = "vnets"

	response, err := c.Session.Delete(fmt.Sprintf("/%s/api/%s", networkType, networkID))
	if err != nil {
		return err
	}

	defer response.Body.Close()

	if response.StatusCode != http.StatusNoContent {
		return fmt.Errorf("SDN controller responded with status code: %d", response.StatusCode)
	}

	return nil
}

// AttachPodToNetwork checks if the specified network exists in the SDN controller
func (c *InternalClient) AttachPodToNetwork(networkType l2smv1.NetworkType, config interface{}) error {

	networkType = "vnets"
	jsonData, err := json.Marshal(config)
	if err != nil {
		return err
	}
	response, err := c.Session.Post(fmt.Sprintf("/%s/api/port", networkType), jsonData)
	if err != nil {
		return err
	}
	defer response.Body.Close()

	if response.StatusCode != http.StatusNoContent {
		return fmt.Errorf("failed to create network, status code: %d", response.StatusCode)
	}

	return nil
}

// DetachPodFromNetwork detaches the pod from the network, so it can be used in the future
// TODO: Implement in onos
func (c *InternalClient) DetachPodFromNetwork(networkType l2smv1.NetworkType, portID string) error {

	// networkType = "vnets"
	// response, err := c.Session.Delete(fmt.Sprintf("%s/api/port/%s", networkType,portID))
	// if err != nil {
	// 	return err
	// }
	// defer response.Body.Close()

	// if response.StatusCode != http.StatusNoContent {
	// 	return fmt.Errorf("failed to create network, status code: %d", response.StatusCode)
	// }

	return nil
}