Control plane - get and update app services manifest endpoints (#126)

Author: alonmr

pkg/controlplane/http/session.go

@@ -386,6 +386,45 @@ func (s *session) ReloadArtifactVersionManifest(ctx context.Context) (string, er
 	return jobOutput.ID, nil
 }
 
+// GetAppServicesManifests returns app services manifests of tenant related to session's access key
+func (s *session) GetAppServicesManifests(
+	getAppServicesManifestsInput *v3ioc.GetAppServicesManifestsInput) (*v3ioc.GetAppServicesManifestsOutput, error) {
+
+	// prepare app services manifests response resource
+	getAppServicesManifestsOutput := v3ioc.GetAppServicesManifestsOutput{}
+
+	if err := s.listResource(getAppServicesManifestsInput.Ctx,
+		"app_services_manifests",
+		&getAppServicesManifestsInput.ControlPlaneInput,
+		&getAppServicesManifestsOutput.ControlPlaneOutput,
+		&getAppServicesManifestsOutput.AppServicesManifests); err != nil {
+		return nil, errors.Wrap(err, "Failed to list app services manifests resource")
+	}
+
+	return &getAppServicesManifestsOutput, nil
+}
+
+// UpdateAppServicesManifest updates app services manifests of tenant related to session's access key
+func (s *session) UpdateAppServicesManifest(
+	updateAppServicesManifestInput *v3ioc.UpdateAppServicesManifestInput) (*v3ioc.GetJobOutput, error) {
+
+	// prepare job response resource
+	getJobOutput := v3ioc.GetJobOutput{}
+
+	// try to update the resource
+	if err := s.updateResource(updateAppServicesManifestInput.Ctx,
+		"app_services_manifests",
+		"app_services_manifest",
+		&updateAppServicesManifestInput.ControlPlaneInput,
+		&updateAppServicesManifestInput.AppServicesManifestAttributes,
+		&getJobOutput.ControlPlaneOutput,
+		&getJobOutput.JobAttributes); err != nil {
+		return nil, errors.Wrap(err, "Failed to update app services manifests resource")
+	}
+
+	return &getJobOutput, nil
+}
+
 // WaitForJobCompletion waits for completion of job with given id (blocking)
 func (s *session) WaitForJobCompletion(ctx context.Context, jobID string, retryInterval, timeout time.Duration) error {
 	getJobInput := v3ioc.GetJobInput{
@@ -667,6 +706,48 @@ func (s *session) getResource(ctx context.Context,
 	return nil
 }
 
+func (s *session) listResource(ctx context.Context,
+	path string,
+	controlPlaneInput *v3ioc.ControlPlaneInput,
+	controlPlaneOutput *v3ioc.ControlPlaneOutput,
+	responseData interface{}) error {
+
+	// allocate request
+	httpRequest := fasthttp.AcquireRequest()
+	defer fasthttp.ReleaseRequest(httpRequest)
+
+	responseInstance, err := s.sendRequest(ctx,
+		&request{
+			method:      http.MethodGet,
+			path:        "api/" + path,
+			httpRequest: httpRequest,
+		}, controlPlaneInput.Timeout)
+
+	if err != nil {
+		return errors.Wrapf(err, "Failed to list resource (%s)", path)
+	}
+
+	// if we got cookies, set them
+	if len(responseInstance.cookies) > 0 {
+		s.cookies = responseInstance.cookies
+	}
+
+	// unmarshal
+	if responseInstance.body != nil && controlPlaneOutput != nil {
+		responseBuffer := bytes.NewBuffer(responseInstance.body)
+
+		jsonAPIResponse := jsonapiResources{
+			Data: responseData,
+		}
+
+		if err := json.NewDecoder(responseBuffer).Decode(&jsonAPIResponse); err != nil {
+			return errors.Wrap(err, "Failed to decode json api response")
+		}
+	}
+
+	return nil
+}
+
 func (s *session) deleteResource(ctx context.Context,
 	path string,
 	kind string,

pkg/controlplane/http/types.go

@@ -44,3 +44,7 @@ type jsonapiData struct {
 type jsonapiResource struct {
 	Data jsonapiData `json:"data,omitempty"`
 }
+
+type jsonapiResources struct {
+	Data interface{} `json:"data,omitempty"`
+}

pkg/controlplane/resources.go

@@ -207,3 +207,19 @@ type JobAttributes struct {
 	UpdatedAt              string       `json:"updated_at,omitempty"`
 	Handler                string       `json:"handler,omitempty"`
 }
+
+type AppServicesManifest struct {
+	Type       string                        `json:"type,omitempty"`
+	ID         int                           `json:"id,omitempty"`
+	Attributes AppServicesManifestAttributes `json:"attributes,omitempty"`
+}
+
+type AppServicesManifestAttributes struct {
+	AppServices            interface{} `json:"app_services,omitempty"`
+	ClusterName            string      `json:"cluster_name,omitempty"`
+	LastModificationJob    string      `json:"last_modification_job,omitempty"`
+	RunningModificationJob string      `json:"running_modification_job,omitempty"`
+	State                  string      `json:"state,omitempty"`
+	TenantID               string      `json:"tenant_id,omitempty"`
+	TenantName             string      `json:"tenant_name,omitempty"`
+}

pkg/controlplane/types.go

@@ -74,6 +74,12 @@ type Session interface {
 	// ReloadArtifactVersionManifestAndWaitForCompletion reloads the platform artifact version manifest and waits for completion (blocking)
 	ReloadArtifactVersionManifestAndWaitForCompletion(ctx context.Context, retryInterval, timeout time.Duration) error
 
+	// UpdateAppServicesManifest updates app services manifests of tenant related to session's access key
+	UpdateAppServicesManifest(*UpdateAppServicesManifestInput) (*GetJobOutput, error)
+
+	// GetAppServicesManifests returns app services manifests of tenant related to session's access key
+	GetAppServicesManifests(*GetAppServicesManifestsInput) (*GetAppServicesManifestsOutput, error)
+
 	// WaitForJobCompletion waits for completion of a job with a given id (blocking)
 	WaitForJobCompletion(ctx context.Context, jobID string, retryInterval, timeout time.Duration) error
 
@@ -215,3 +221,20 @@ type JobOutput struct {
 	ControlPlaneOutput
 	JobAttributes
 }
+
+// GetAppServicesManifestsInput specifies how to get a app services manifests
+type GetAppServicesManifestsInput struct {
+	ControlPlaneInput
+}
+
+// GetAppServicesManifestsOutput holds the response from get app services manifests
+type GetAppServicesManifestsOutput struct {
+	ControlPlaneOutput
+	AppServicesManifests []AppServicesManifest
+}
+
+// UpdateAppServicesManifestInput specifies how to get a app services manifests
+type UpdateAppServicesManifestInput struct {
+	ControlPlaneInput
+	AppServicesManifestAttributes
+}