feat(api): adds deployment attempts and events (#157)

Author: jmgilman

foundry/api/client/client.go

@@ -29,9 +29,14 @@ type Client interface {
 	// Deployment operations
 	CreateDeployment(ctx context.Context, releaseID string) (*ReleaseDeployment, error)
 	GetDeployment(ctx context.Context, releaseID string, deployID string) (*ReleaseDeployment, error)
-	UpdateDeploymentStatus(ctx context.Context, releaseID string, deployID string, status DeploymentStatus, reason string) error
+	UpdateDeployment(ctx context.Context, releaseID string, deployment *ReleaseDeployment) (*ReleaseDeployment, error)
+	IncrementDeploymentAttempts(ctx context.Context, releaseID string, deployID string) (*ReleaseDeployment, error)
 	ListDeployments(ctx context.Context, releaseID string) ([]ReleaseDeployment, error)
 	GetLatestDeployment(ctx context.Context, releaseID string) (*ReleaseDeployment, error)
+
+	// Deployment event operations
+	AddDeploymentEvent(ctx context.Context, releaseID string, deployID string, name string, message string) (*ReleaseDeployment, error)
+	GetDeploymentEvents(ctx context.Context, releaseID string, deployID string) ([]DeploymentEvent, error)
 }
 
 // HTTPClient is an implementation of the Client interface that uses HTTP
@@ -76,7 +81,6 @@ func NewClient(baseURL string, options ...ClientOption) Client {
 // do performs an HTTP request and processes the response
 func (c *HTTPClient) do(ctx context.Context, method, path string, reqBody, respBody interface{}) error {
 	url := fmt.Sprintf("%s%s", c.baseURL, path)
-	fmt.Printf("Making %s request to %s", method, url)
 
 	var reqBodyReader io.Reader
 	if reqBody != nil {

foundry/api/client/deployment.go

@@ -32,19 +32,17 @@ func (c *HTTPClient) GetDeployment(ctx context.Context, releaseID string, deploy
 	return &resp, nil
 }
 
-// UpdateDeploymentStatus updates the status of a deployment
-func (c *HTTPClient) UpdateDeploymentStatus(ctx context.Context, releaseID string, deployID string, status DeploymentStatus, reason string) error {
-	path := fmt.Sprintf("/release/%s/deploy/%s/status", releaseID, deployID)
-
-	payload := struct {
-		Status DeploymentStatus `json:"status"`
-		Reason string           `json:"reason"`
-	}{
-		Status: status,
-		Reason: reason,
+// UpdateDeployment updates a deployment with new values
+func (c *HTTPClient) UpdateDeployment(ctx context.Context, releaseID string, deployment *ReleaseDeployment) (*ReleaseDeployment, error) {
+	path := fmt.Sprintf("/release/%s/deploy/%s", releaseID, deployment.ID)
+
+	var resp ReleaseDeployment
+	err := c.do(ctx, http.MethodPut, path, deployment, &resp)
+	if err != nil {
+		return nil, err
 	}
 
-	return c.do(ctx, http.MethodPut, path, payload, nil)
+	return &resp, nil
 }
 
 // ListDeployments retrieves all deployments for a release
@@ -60,6 +58,21 @@ func (c *HTTPClient) ListDeployments(ctx context.Context, releaseID string) ([]R
 	return resp, nil
 }
 
+// IncrementDeploymentAttempts increments the attempts counter for a deployment by 1
+func (c *HTTPClient) IncrementDeploymentAttempts(ctx context.Context, releaseID string, deployID string) (*ReleaseDeployment, error) {
+	// First get the current deployment
+	deployment, err := c.GetDeployment(ctx, releaseID, deployID)
+	if err != nil {
+		return nil, fmt.Errorf("failed to get deployment: %w", err)
+	}
+
+	// Increment the attempts counter
+	deployment.Attempts++
+
+	// Update the deployment
+	return c.UpdateDeployment(ctx, releaseID, deployment)
+}
+
 // GetLatestDeployment retrieves the most recent deployment for a release
 func (c *HTTPClient) GetLatestDeployment(ctx context.Context, releaseID string) (*ReleaseDeployment, error) {
 	path := fmt.Sprintf("/release/%s/deploy/latest", releaseID)

foundry/api/client/deployment_events.go

@@ -0,0 +1,41 @@
+package client
+
+import (
+	"context"
+	"fmt"
+	"net/http"
+)
+
+// AddDeploymentEvent adds an event to a deployment
+func (c *HTTPClient) AddDeploymentEvent(ctx context.Context, releaseID string, deployID string, name string, message string) (*ReleaseDeployment, error) {
+	path := fmt.Sprintf("/release/%s/deploy/%s/events", releaseID, deployID)
+
+	payload := struct {
+		Name    string `json:"name"`
+		Message string `json:"message"`
+	}{
+		Name:    name,
+		Message: message,
+	}
+
+	var resp ReleaseDeployment
+	err := c.do(ctx, http.MethodPost, path, payload, &resp)
+	if err != nil {
+		return nil, err
+	}
+
+	return &resp, nil
+}
+
+// GetDeploymentEvents retrieves all events for a deployment
+func (c *HTTPClient) GetDeploymentEvents(ctx context.Context, releaseID string, deployID string) ([]DeploymentEvent, error) {
+	path := fmt.Sprintf("/release/%s/deploy/%s/events", releaseID, deployID)
+
+	var resp []DeploymentEvent
+	err := c.do(ctx, http.MethodGet, path, nil, &resp)
+	if err != nil {
+		return nil, err
+	}
+
+	return resp, nil
+}