Added command infrastructure - not finished

Author: codemental

src/application/command/common/common.go

@@ -0,0 +1,6 @@
+package common
+
+type CommandHandler interface {
+	CanHandle(command any) bool
+	Handle(command any) any
+}

src/application/command/http/client/client.go

@@ -0,0 +1,67 @@
+package client
+
+import (
+	"github.com/go-clarum/agent/application/command/common"
+	"github.com/go-clarum/agent/application/command/http/client/commands"
+	"github.com/go-clarum/agent/application/command/http/client/internal"
+	"github.com/go-clarum/agent/infrastructure/logging"
+	"net/http"
+)
+
+type handler struct {
+	endpoints map[string]*internal.Endpoint
+	logger    *logging.Logger
+}
+
+func (h *handler) CanHandle(command any) bool {
+	return true
+}
+
+func (h *handler) Handle(command any) any {
+	return nil
+}
+
+func NewHttpClientHandler() common.CommandHandler {
+	return &handler{
+		endpoints: make(map[string]*internal.Endpoint),
+		logger:    logging.NewLogger("HttpClientHandler"),
+	}
+}
+
+func (h *handler) InitializeEndpoint(req *commands.InitEndpointCommand) error {
+	newEndpoint, err := internal.NewEndpoint(req)
+
+	if err != nil {
+		h.logger.Errorf("failed to initialize HTTP client endpoint - %s", err)
+		return err
+	}
+
+	if oldEndpoint, exists := h.endpoints[newEndpoint.Name]; exists {
+		h.logger.Infof("HTTP client endpoint [%s] already exists - replacing", oldEndpoint.Name)
+	}
+
+	h.endpoints[newEndpoint.Name] = newEndpoint
+	logging.Infof("registered HTTP client endpoint [%s]", newEndpoint.Name)
+
+	return nil
+}
+
+func (h *handler) SendAction(sendAction *commands.SendCommand) error {
+	endpoint, exists := h.endpoints[sendAction.EndpointName]
+	if !exists {
+		h.logger.Errorf("HTTP client endpoint [%s] not found - action [%s] will not be executed",
+			sendAction.EndpointName, sendAction.Name)
+	}
+
+	return endpoint.Send(sendAction)
+}
+
+func (h *handler) ReceiveAction(receiveAction *commands.ReceiveCommand) (*http.Response, error) {
+	endpoint, exists := h.endpoints[receiveAction.EndpointName]
+	if !exists {
+		h.logger.Errorf("HTTP client endpoint [%s] not found - action [%s] will not be executed",
+			receiveAction.EndpointName, receiveAction.Name)
+	}
+
+	return endpoint.Receive(receiveAction)
+}

src/application/services/http/client/actions/actions.go renamed to src/application/command/http/client/commands/commands.go

@@ -1,20 +1,20 @@
-package actions
+package commands
 
 import (
 	"fmt"
-	"github.com/go-clarum/agent/application/services/http/common/model"
+	"github.com/go-clarum/agent/application/command/http/common/model"
 	"strconv"
 	"time"
 )
 
-type InitEndpointAction struct {
+type InitEndpointCommand struct {
 	Name           string
 	BaseUrl        string
 	ContentType    string
 	TimeoutSeconds time.Duration
 }
 
-type SendAction struct {
+type SendCommand struct {
 	Name         string
 	Url          string
 	Path         []string
@@ -25,7 +25,7 @@ type SendAction struct {
 	EndpointName string
 }
 
-type ReceiveAction struct {
+type ReceiveCommand struct {
 	Name         string
 	PayloadType  model.PayloadType
 	StatusCode   int
@@ -34,7 +34,7 @@ type ReceiveAction struct {
 	EndpointName string
 }
 
-func (action *SendAction) ToString() string {
+func (action *SendCommand) ToString() string {
 	return fmt.Sprintf(
 		"["+
 			"Method: %s, "+
@@ -48,7 +48,7 @@ func (action *SendAction) ToString() string {
 		action.Headers, action.QueryParams, action.Payload)
 }
 
-func (action *ReceiveAction) ToString() string {
+func (action *ReceiveCommand) ToString() string {
 	statusCodeText := "none"
 	if action.StatusCode > 0 {
 		statusCodeText = strconv.Itoa(action.StatusCode)

src/application/services/http/client/internal/endpoint.go renamed to src/application/command/http/client/internal/endpoint.go

@@ -4,11 +4,11 @@ import (
 	"bytes"
 	"errors"
 	"fmt"
+	"github.com/go-clarum/agent/application/command/http/client/commands"
+	"github.com/go-clarum/agent/application/command/http/common/constants"
+	"github.com/go-clarum/agent/application/command/http/common/utils"
+	"github.com/go-clarum/agent/application/command/http/common/validators"
 	"github.com/go-clarum/agent/application/control"
-	"github.com/go-clarum/agent/application/services/http/client/actions"
-	"github.com/go-clarum/agent/application/services/http/common/constants"
-	"github.com/go-clarum/agent/application/services/http/common/utils"
-	"github.com/go-clarum/agent/application/services/http/common/validators"
 	"github.com/go-clarum/agent/application/utils/durations"
 	clarumstrings "github.com/go-clarum/agent/application/validators/strings"
 	"github.com/go-clarum/agent/infrastructure/config"
@@ -32,7 +32,7 @@ type responsePair struct {
 	error    error
 }
 
-func NewEndpoint(ic *actions.InitEndpointAction) (*Endpoint, error) {
+func NewEndpoint(ic *commands.InitEndpointCommand) (*Endpoint, error) {
 	if clarumstrings.IsBlank(ic.Name) {
 		return nil, errors.New("cannot create HTTP client endpoint - name is empty")
 	}
@@ -51,7 +51,7 @@ func NewEndpoint(ic *actions.InitEndpointAction) (*Endpoint, error) {
 	}, nil
 }
 
-func (endpoint *Endpoint) Send(action *actions.SendAction) error {
+func (endpoint *Endpoint) Send(action *commands.SendCommand) error {
 	if action == nil {
 		return endpoint.handleError("send action is nil", nil)
 	}
@@ -109,7 +109,7 @@ func closeBody(res *http.Response) {
 }
 
 // validationOptions pass by value is intentional
-func (endpoint *Endpoint) Receive(action *actions.ReceiveAction) (*http.Response, error) {
+func (endpoint *Endpoint) Receive(action *commands.ReceiveCommand) (*http.Response, error) {
 	if action == nil {
 		return nil, endpoint.handleError("receive action is nil", nil)
 	}
@@ -135,7 +135,7 @@ func (endpoint *Endpoint) Receive(action *actions.ReceiveAction) (*http.Response
 }
 
 // Put missing data into a message to send: baseUrl & ContentType Header
-func (endpoint *Endpoint) enrichSendAction(action *actions.SendAction) {
+func (endpoint *Endpoint) enrichSendAction(action *commands.SendCommand) {
 	if clarumstrings.IsBlank(action.Url) {
 		action.Url = endpoint.baseUrl
 	}
@@ -151,15 +151,15 @@ func (endpoint *Endpoint) enrichSendAction(action *actions.SendAction) {
 }
 
 // Put missing data into message to receive: ContentType Header
-func (endpoint *Endpoint) enrichReceiveAction(action *actions.ReceiveAction) {
+func (endpoint *Endpoint) enrichReceiveAction(action *commands.ReceiveCommand) {
 	if clarumstrings.IsNotBlank(endpoint.contentType) {
 		if _, exists := action.Headers[constants.ContentTypeHeaderName]; !exists {
 			action.Headers[constants.ContentTypeHeaderName] = endpoint.contentType
 		}
 	}
 }
 
-func (endpoint *Endpoint) validateMessageToSend(action *actions.SendAction) error {
+func (endpoint *Endpoint) validateMessageToSend(action *commands.SendCommand) error {
 	if clarumstrings.IsBlank(action.Method) {
 		return endpoint.handleError("send action is invalid - missing HTTP method", nil)
 	}
@@ -173,7 +173,7 @@ func (endpoint *Endpoint) validateMessageToSend(action *actions.SendAction) erro
 	return nil
 }
 
-func (endpoint *Endpoint) buildRequest(action *actions.SendAction) (*http.Request, error) {
+func (endpoint *Endpoint) buildRequest(action *commands.SendCommand) (*http.Request, error) {
 	url := utils.BuildPath(action.Url, action.Path...)
 
 	req, err := http.NewRequest(action.Method, url, bytes.NewBufferString(action.Payload))

src/application/services/http/common/constants/constants.go renamed to src/application/command/http/common/constants/constants.go

@@ -3,8 +3,8 @@ package validators
 import (
 	"errors"
 	"fmt"
-	"github.com/go-clarum/agent/application/services/http/common/model"
-	"github.com/go-clarum/agent/application/services/http/common/utils"
+	"github.com/go-clarum/agent/application/command/http/common/model"
+	"github.com/go-clarum/agent/application/command/http/common/utils"
 	"github.com/go-clarum/agent/application/utils/arrays"
 	clarumstrings "github.com/go-clarum/agent/application/validators/strings"
 	"github.com/go-clarum/agent/infrastructure/logging"

src/application/services/http/common/model/payload_type.go renamed to src/application/command/http/common/model/payload_type.go

@@ -1,19 +1,19 @@
-package actions
+package commands
 
 import (
 	"fmt"
-	"github.com/go-clarum/agent/application/services/http/common/model"
+	"github.com/go-clarum/agent/application/command/http/common/model"
 	"time"
 )
 
-type InitEndpointAction struct {
+type InitEndpointCommand struct {
 	Name           string
 	Port           uint
 	ContentType    string
 	TimeoutSeconds time.Duration
 }
 
-type SendAction struct {
+type SendCommand struct {
 	Name         string
 	PayloadType  model.PayloadType
 	StatusCode   int
@@ -22,7 +22,7 @@ type SendAction struct {
 	EndpointName string
 }
 
-type ReceiveAction struct {
+type ReceiveCommand struct {
 	Name         string
 	Url          string
 	Path         []string
@@ -34,7 +34,7 @@ type ReceiveAction struct {
 	EndpointName string
 }
 
-func (action *ReceiveAction) ToString() string {
+func (action *ReceiveCommand) ToString() string {
 	return fmt.Sprintf(
 		"["+
 			"Method: %s, "+