garm-provider-edge-connect/internal/client/client.go

package client

import (
	"bytes"
	"context"
	"encoding/json"
	"fmt"
	"io"
	"net/http"
)

type EdgeConnect struct {
	BaseURL     string
	HttpClient  *http.Client
	Credentials Credentials
}

type Credentials struct {
	Username string
	Password string
}

// curl -X POST https://mc.orca.platform.mg3.mdb.osc.live/api/v1/auth/ctrl/CreateAppInst -H 'Content-Type: application/json' -H "Authorization: Bearer $EDGEXR_TOKEN" -S --data "$CREATEAPPINSTANCE_JSON" --fail-with-body

func (e *EdgeConnect) NewAppInstance(ctx context.Context, input NewAppInstanceInput) error {
	token, err := e.RetrieveToken(ctx)
	if err != nil {
		return err
	}

	json_data, err := json.Marshal(input)
	if err != nil {
		return err
	}

	request, err := http.NewRequestWithContext(ctx, "POST", e.BaseURL+"/api/v1/auth/ctrl/CreateAppInst", bytes.NewBuffer(json_data))
	if err != nil {
		return err
	}
	request.Header.Set("Content-Type", "application/json")
	request.Header.Set("Authorization", fmt.Sprintf("Bearer %s", token))

	resp, err := e.HttpClient.Do(request)
	if err != nil {
		return err
	}

	defer resp.Body.Close()

	fmt.Printf("Header: %v\n", request.Header)
	bodyBytes, err := io.ReadAll(resp.Body)
	if err != nil {
		return err
	}
	fmt.Printf("Response: %v\n", string(bodyBytes))

	return nil
}

func (e *EdgeConnect) NewApp(ctx context.Context, input NewAppInput) error {
	token, err := e.RetrieveToken(ctx)
	if err != nil {
		return err
	}

	json_data, err := json.Marshal(input)
	if err != nil {
		return err
	}

	request, err := http.NewRequestWithContext(ctx, "POST", e.BaseURL+"/api/v1/auth/ctrl/CreateApp", bytes.NewBuffer(json_data))
	if err != nil {
		return err
	}
	request.Header.Set("Content-Type", "application/json")
	request.Header.Set("Authorization", fmt.Sprintf("Bearer %s", token))

	resp, err := e.HttpClient.Do(request)
	if err != nil {
		return err
	}

	defer resp.Body.Close()

	fmt.Printf("Header: %v\n", request.Header)
	bodyBytes, err := io.ReadAll(resp.Body)
	if err != nil {
		return err
	}
	fmt.Printf("Response: %v\n", string(bodyBytes))

	return nil
}

func (e *EdgeConnect) ShowApp(ctx context.Context, appkey AppKey, region string) (App, error) {
	token, err := e.RetrieveToken(ctx)
	if err != nil {
		return App{}, err
	}

	input := struct {
		App struct {
			Key AppKey `json:"key"`
		} `json:"App"`
		Region string `json:"Region"`
	}{
		App: struct {
			Key AppKey `json:"key"`
		}{
			Key: appkey,
		},
		Region: region,
	}

	json_data, err := json.Marshal(input)
	if err != nil {
		return App{}, err
	}

	request, err := http.NewRequestWithContext(ctx, "POST", e.BaseURL+"/api/v1/auth/ctrl/ShowApp", bytes.NewBuffer(json_data))
	if err != nil {
		return App{}, err
	}
	request.Header.Set("Content-Type", "application/json")
	request.Header.Set("Authorization", fmt.Sprintf("Bearer %s", token))

	resp, err := e.HttpClient.Do(request)
	if err != nil {
		return App{}, err
	}

	defer resp.Body.Close()
	var response struct {
		Data App `json:"data"`
	}
	err = json.NewDecoder(resp.Body).Decode(&response)
	if err != nil {
		return App{}, err
	}

	return response.Data, nil
}

func (e *EdgeConnect) RetrieveToken(ctx context.Context) (string, error) {
	json_data, err := json.Marshal(map[string]string{
		"username": e.Credentials.Username,
		"password": e.Credentials.Password,
	})
	if err != nil {
		return "", err
	}

	request, err := http.NewRequestWithContext(ctx, "POST", e.BaseURL+"/api/v1/login", bytes.NewBuffer(json_data))
	if err != nil {
		return "", err
	}
	request.Header.Set("Content-Type", "application/json")

	resp, err := e.HttpClient.Do(request)
	if err != nil {
		return "", err
	}

	defer resp.Body.Close()

	var respData struct {
		Token string `json:"token"`
	}
	err = json.NewDecoder(resp.Body).Decode(&respData)
	if err != nil {
		return "", err
	}

	return respData.Token, nil
}