NOJIRA: Remove SendAksInitData as it's obsolete. (#170)

Remove SendAksInitData as it's obsolete.

Author: Tsonov

internal/actions/send_aks_init_data_handler.go

@@ -27,7 +27,6 @@ const (
 type CastAIClient interface {
 	GetActions(ctx context.Context, k8sVersion string) ([]*ClusterAction, error)
 	AckAction(ctx context.Context, actionID string, req *AckClusterActionRequest) error
-	SendAKSInitData(ctx context.Context, req *AKSInitDataRequest) error
 	SendLog(ctx context.Context, e *LogEntry) error
 }
 
@@ -126,21 +125,6 @@ func createTLSConfig(ca string) (*tls.Config, error) {
 	}, nil
 }
 
-func (c *Client) SendAKSInitData(ctx context.Context, req *AKSInitDataRequest) error {
-	resp, err := c.rest.R().
-		SetBody(req).
-		SetContext(ctx).
-		Post(fmt.Sprintf("/v1/kubernetes/external-clusters/%s/aks-init-data", c.clusterID))
-	if err != nil {
-		return fmt.Errorf("sending aks init data: %w", err)
-	}
-	if resp.IsError() {
-		return fmt.Errorf("sending aks init data: request error status_code=%d body=%s", resp.StatusCode(), resp.Body())
-	}
-
-	return nil
-}
-
 func (c *Client) SendLog(ctx context.Context, e *LogEntry) error {
 	// Server expects fields values to be strings. If they're not it fails with BAD_REQUEST/400.
 	// Alternatively we could use "google/protobuf/any.proto" on server side but ATM it doesn't work.

internal/actions/send_aks_init_data_handler_test.go

@@ -34,7 +34,6 @@ type ClusterAction struct {
 	ActionChartUninstall    *ActionChartUninstall    `json:"actionChartUninstall,omitempty"`
 	ActionChartRollback     *ActionChartRollback     `json:"actionChartRollback,omitempty"`
 	ActionDisconnectCluster *ActionDisconnectCluster `json:"actionDisconnectCluster,omitempty"`
-	ActionSendAKSInitData   *ActionSendAKSInitData   `json:"actionSendAksInitData,omitempty"`
 	ActionCheckNodeDeleted  *ActionCheckNodeDeleted  `json:"actionCheckNodeDeleted,omitempty"`
 	ActionCheckNodeStatus   *ActionCheckNodeStatus   `json:"actionCheckNodeStatus,omitempty"`
 	ActionEvictPod          *ActionEvictPod          `json:"actionEvictPod,omitempty"`
@@ -74,9 +73,6 @@ func (c *ClusterAction) Data() interface{} {
 	if c.ActionDisconnectCluster != nil {
 		return c.ActionDisconnectCluster
 	}
-	if c.ActionSendAKSInitData != nil {
-		return c.ActionSendAKSInitData
-	}
 	if c.ActionCheckNodeDeleted != nil {
 		return c.ActionCheckNodeDeleted
 	}
@@ -189,8 +185,6 @@ type ActionCreateEvent struct {
 
 type ActionDisconnectCluster struct{}
 
-type ActionSendAKSInitData struct{}
-
 type ActionCheckNodeDeleted struct {
 	NodeName string `json:"nodeName"`
 	NodeID   string `json:"nodeId"`
@@ -250,9 +244,3 @@ func (c *ChartSource) Validate() error {
 	}
 	return nil
 }
-
-type AKSInitDataRequest struct {
-	CloudConfigBase64       string `json:"cloudConfigBase64"`
-	ProtectedSettingsBase64 string `json:"protectedSettingsBase64"`
-	Architecture            string `json:"architecture"`
-}

internal/castai/client.go

@@ -60,7 +60,6 @@ func NewService(
 			reflect.TypeOf(&castai.ActionChartUninstall{}):    actions.NewChartUninstallHandler(log, helmClient),
 			reflect.TypeOf(&castai.ActionChartRollback{}):     actions.NewChartRollbackHandler(log, helmClient, cfg.Version),
 			reflect.TypeOf(&castai.ActionDisconnectCluster{}): actions.NewDisconnectClusterHandler(log, clientset),
-			reflect.TypeOf(&castai.ActionSendAKSInitData{}):   actions.NewSendAKSInitDataHandler(log, castaiClient),
 			reflect.TypeOf(&castai.ActionCheckNodeDeleted{}):  actions.NewCheckNodeDeletedHandler(log, clientset),
 			reflect.TypeOf(&castai.ActionCheckNodeStatus{}):   actions.NewCheckNodeStatusHandler(log, clientset),
 			reflect.TypeOf(&castai.ActionEvictPod{}):          actions.NewEvictPodHandler(log, clientset),