Put files of the api package together (#337)

Author: Noah Lee

internal/interactor/branch.go

@@ -1,5 +1,128 @@
 package api
 
+import (
+	"context"
+	"fmt"
+	"net/url"
+	"strconv"
+
+	"github.com/gitploy-io/gitploy/model/ent"
+	"github.com/gitploy-io/gitploy/model/ent/deployment"
+)
+
 type (
 	DeploymentsService service
+
+	DeploymentListOptions struct {
+		ListOptions
+
+		Env    string
+		Status deployment.Status
+	}
+
+	DeploymentCreateRequest struct {
+		Type string `json:"type"`
+		Ref  string `json:"ref"`
+		Env  string `json:"env"`
+	}
 )
+
+// List returns the deployment list.
+// It returns an error for a bad request.
+func (s *DeploymentsService) List(ctx context.Context, namespace, name string, options DeploymentListOptions) ([]*ent.Deployment, error) {
+	// Build the query.
+	vals := url.Values{}
+
+	vals.Add("page", strconv.Itoa(options.ListOptions.Page))
+	vals.Add("per_page", strconv.Itoa(options.PerPage))
+
+	if options.Env != "" {
+		vals.Add("env", options.Env)
+	}
+
+	if options.Status != "" {
+		if err := deployment.StatusValidator(options.Status); err != nil {
+			return nil, err
+		}
+
+		vals.Add("status", string(options.Status))
+	}
+
+	// Request a server.
+	req, err := s.client.NewRequest(
+		"GET",
+		fmt.Sprintf("api/v1/repos/%s/%s/deployments?%s", namespace, name, vals.Encode()),
+		nil,
+	)
+	if err != nil {
+		return nil, err
+	}
+
+	var ds []*ent.Deployment
+	err = s.client.Do(ctx, req, &ds)
+	if err != nil {
+		return nil, err
+	}
+
+	return ds, nil
+}
+
+// Get returns the deployment.
+func (s *DeploymentsService) Get(ctx context.Context, namespace, name string, number int) (*ent.Deployment, error) {
+	req, err := s.client.NewRequest(
+		"GET",
+		fmt.Sprintf("api/v1/repos/%s/%s/deployments/%d", namespace, name, number),
+		nil,
+	)
+	if err != nil {
+		return nil, err
+	}
+
+	var d *ent.Deployment
+	err = s.client.Do(ctx, req, &d)
+	if err != nil {
+		return nil, err
+	}
+
+	return d, nil
+}
+
+// Create requests a server to deploy a specific ref(branch, SHA, tag).
+func (s *DeploymentsService) Create(ctx context.Context, namespace, name string, body DeploymentCreateRequest) (*ent.Deployment, error) {
+	req, err := s.client.NewRequest(
+		"POST",
+		fmt.Sprintf("api/v1/repos/%s/%s/deployments", namespace, name),
+		body,
+	)
+	if err != nil {
+		return nil, err
+	}
+
+	var d *ent.Deployment
+	err = s.client.Do(ctx, req, &d)
+	if err != nil {
+		return nil, err
+	}
+
+	return d, nil
+}
+
+// Update requests to trigger the 'waiting' deployment.
+func (s *DeploymentsService) Update(ctx context.Context, namespace, name string, number int) (*ent.Deployment, error) {
+	req, err := s.client.NewRequest(
+		"PUT",
+		fmt.Sprintf("api/v1/repos/%s/%s/deployments/%d", namespace, name, number),
+		nil,
+	)
+	if err != nil {
+		return nil, err
+	}
+
+	var d *ent.Deployment
+	err = s.client.Do(ctx, req, &d)
+	if err != nil {
+		return nil, err
+	}
+
+	return d, nil
+}