-
Notifications
You must be signed in to change notification settings - Fork 14
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Add commands for deployment targets (#216)
* Add commands for deployment targets * Remove unused code * Sync with API changes * Remove useless character * Rename function, variable * Fixes after code review, using UUIDv4 * Add create_target_test, used UUIDv4 for mock * Enrich create target test * fix object rule mode: pattern->regex * Remove unused file * Use DescribeWithSecret instead of optional parameter * Better handling history cmd, object-rule parsing * Remove fmt printing
- Loading branch information
Showing
36 changed files
with
2,038 additions
and
74 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,244 @@ | ||
| package client | ||
|
|
||
| import ( | ||
| "encoding/json" | ||
| "errors" | ||
| "fmt" | ||
| "net/http" | ||
| "net/url" | ||
|
|
||
| models "github.com/semaphoreci/cli/api/models" | ||
| "github.com/semaphoreci/cli/api/uuid" | ||
| ) | ||
|
|
||
| type DeploymentTargetsApiV1AlphaApi struct { | ||
| BaseClient BaseClient | ||
| ResourceNameSingular string | ||
| ResourceNamePlural string | ||
| } | ||
|
|
||
| const ( | ||
| DeactivateOpName = "deactivate" | ||
| ActivateOpName = "activate" | ||
| ) | ||
|
|
||
| func NewDeploymentTargetsV1AlphaApi() DeploymentTargetsApiV1AlphaApi { | ||
| baseClient := NewBaseClientFromConfig() | ||
| baseClient.SetApiVersion("v1alpha") | ||
|
|
||
| return DeploymentTargetsApiV1AlphaApi{ | ||
| BaseClient: baseClient, | ||
| ResourceNamePlural: "deployment_targets", | ||
| ResourceNameSingular: "deployment_target", | ||
| } | ||
| } | ||
|
|
||
| func (c *DeploymentTargetsApiV1AlphaApi) Describe(targetId string) (*models.DeploymentTargetV1Alpha, error) { | ||
| return c.describe(targetId, false) | ||
| } | ||
|
|
||
| func (c *DeploymentTargetsApiV1AlphaApi) DescribeWithSecrets(targetId string) (*models.DeploymentTargetV1Alpha, error) { | ||
| return c.describe(targetId, true) | ||
| } | ||
|
|
||
| func (c *DeploymentTargetsApiV1AlphaApi) describe(targetId string, withSecrets bool) (*models.DeploymentTargetV1Alpha, error) { | ||
| var resource string | ||
| if withSecrets { | ||
| resource = fmt.Sprintf("%s?include_secrets=true", targetId) | ||
| } else { | ||
| resource = targetId | ||
| } | ||
| body, status, err := c.BaseClient.Get(c.ResourceNamePlural, resource) | ||
| if err != nil { | ||
| return nil, fmt.Errorf("connecting to Semaphore failed '%s'", err) | ||
| } | ||
|
|
||
| if status != http.StatusOK { | ||
| return nil, fmt.Errorf("http status %d with message \"%s\" received from upstream", status, body) | ||
| } | ||
|
|
||
| return models.NewDeploymentTargetV1AlphaFromJson(body) | ||
| } | ||
|
|
||
| func (c *DeploymentTargetsApiV1AlphaApi) DescribeByName(targetName, projectId string) (*models.DeploymentTargetV1Alpha, error) { | ||
| targets, err := c.list(projectId, targetName) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| if targets == nil || len(*targets) == 0 { | ||
| return nil, fmt.Errorf("target with the name '%s' doesn't exist in the project '%s'", targetName, projectId) | ||
| } | ||
| return (*targets)[0], nil | ||
| } | ||
|
|
||
| func (c *DeploymentTargetsApiV1AlphaApi) History(targetId string, historyRequest models.HistoryRequestFiltersV1Alpha) (*models.DeploymentsHistoryV1Alpha, error) { | ||
| if targetId == "" { | ||
| return nil, errors.New("target id must be provided") | ||
| } | ||
| values, err := historyRequest.ToURLValues() | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| query := fmt.Sprintf("%s/history", targetId) | ||
| if len(values) != 0 { | ||
| query = fmt.Sprintf("%s/history?%s", targetId, values.Encode()) | ||
| } | ||
|
|
||
| body, status, err := c.BaseClient.Get(c.ResourceNamePlural, query) | ||
| if err != nil { | ||
| return nil, fmt.Errorf("connecting to Semaphore failed '%s'", err) | ||
| } | ||
|
|
||
| if status != http.StatusOK { | ||
| return nil, fmt.Errorf("http status %d with message \"%s\" received from upstream", status, body) | ||
| } | ||
|
|
||
| return models.NewDeploymentsHistoryV1AlphaFromJson(body) | ||
| } | ||
|
|
||
| func (c *DeploymentTargetsApiV1AlphaApi) List(projectId string) (*models.DeploymentTargetListV1Alpha, error) { | ||
| kind := fmt.Sprintf("%s?project_id=%s", c.ResourceNamePlural, projectId) | ||
| body, status, err := c.BaseClient.List(kind) | ||
| if err != nil { | ||
| return nil, fmt.Errorf("connecting to Semaphore failed '%s'", err) | ||
| } | ||
|
|
||
| if status != http.StatusOK { | ||
| return nil, fmt.Errorf("http status %d with message \"%s\" received from upstream", status, body) | ||
| } | ||
| return models.NewDeploymentTargetListV1AlphaFromJson(body) | ||
| } | ||
|
|
||
| func (c *DeploymentTargetsApiV1AlphaApi) list(projectId string, targetNames ...string) (*models.DeploymentTargetListV1Alpha, error) { | ||
| kind := fmt.Sprintf("%s?project_id=%s", c.ResourceNamePlural, projectId) | ||
| for _, targetName := range targetNames { | ||
| kind = fmt.Sprintf("%s&target_name=%s", kind, url.PathEscape(targetName)) | ||
| } | ||
| body, status, err := c.BaseClient.List(kind) | ||
| if err != nil { | ||
| return nil, fmt.Errorf("connecting to Semaphore failed '%s'", err) | ||
| } | ||
|
|
||
| if status != http.StatusOK { | ||
| return nil, fmt.Errorf("http status %d with message \"%s\" received from upstream", status, body) | ||
| } | ||
| return models.NewDeploymentTargetListV1AlphaFromJson(body) | ||
| } | ||
|
|
||
| func (c *DeploymentTargetsApiV1AlphaApi) Delete(targetId string) error { | ||
| unique_token, err := uuid.NewUUIDv4() | ||
| if err != nil { | ||
| return fmt.Errorf("unique token generation failed: %s", err) | ||
| } | ||
| params := fmt.Sprintf("%s?unique_token=%s", targetId, unique_token) | ||
|
|
||
| body, status, err := c.BaseClient.Delete(c.ResourceNamePlural, params) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| if status != http.StatusOK { | ||
| return fmt.Errorf("http status %d with message \"%s\" received from upstream", status, body) | ||
| } | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| func (c *DeploymentTargetsApiV1AlphaApi) Create(createRequest *models.DeploymentTargetCreateRequestV1Alpha) (*models.DeploymentTargetV1Alpha, error) { | ||
| if createRequest == nil { | ||
| return nil, errors.New("create request must not be nil") | ||
| } | ||
| err := createRequest.LoadFiles() | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| unique_token, err := uuid.NewUUIDv4() | ||
| if err != nil { | ||
| return nil, fmt.Errorf("unique token generation failed: %s", err) | ||
| } | ||
| createRequest.UniqueToken = unique_token.String() | ||
| json_body, err := json.Marshal(createRequest) | ||
| if err != nil { | ||
| return nil, fmt.Errorf("failed to serialize deployment target create request: %s", err) | ||
| } | ||
|
|
||
| body, status, err := c.BaseClient.Post(c.ResourceNamePlural, json_body) | ||
| if err != nil { | ||
| return nil, fmt.Errorf("creating %s on Semaphore failed '%s'", c.ResourceNamePlural, err) | ||
| } | ||
|
|
||
| if status != http.StatusOK { | ||
| return nil, fmt.Errorf("http status %d with message \"%s\" received from upstream", status, body) | ||
| } | ||
|
|
||
| return models.NewDeploymentTargetV1AlphaFromJson(body) | ||
| } | ||
|
|
||
| func (c *DeploymentTargetsApiV1AlphaApi) Update(updateRequest *models.DeploymentTargetUpdateRequestV1Alpha) (*models.DeploymentTargetV1Alpha, error) { | ||
| if updateRequest == nil { | ||
| return nil, errors.New("update request must not be nil") | ||
| } | ||
| if updateRequest.Id == "" { | ||
| return nil, errors.New("update request id must not be empty") | ||
| } | ||
| if updateRequest.ProjectId == "" { | ||
| return nil, errors.New("update request project id must not be empty") | ||
| } | ||
| unique_token, err := uuid.NewUUIDv4() | ||
| if err != nil { | ||
| return nil, fmt.Errorf("unique token generation failed: %s", err) | ||
| } | ||
| updateRequest.UniqueToken = unique_token.String() | ||
|
|
||
| json_body, err := json.Marshal(updateRequest) | ||
| if err != nil { | ||
| return nil, fmt.Errorf("failed to serialize deployment target update request: %s", err) | ||
| } | ||
|
|
||
| body, status, err := c.BaseClient.Patch(c.ResourceNamePlural, updateRequest.Id, json_body) | ||
| if err != nil { | ||
| return nil, fmt.Errorf("creating %s on Semaphore failed '%s'", c.ResourceNamePlural, err) | ||
| } | ||
|
|
||
| if status != http.StatusOK { | ||
| return nil, fmt.Errorf("http status %d with message \"%s\" received from upstream", status, body) | ||
| } | ||
|
|
||
| return models.NewDeploymentTargetV1AlphaFromJson(body) | ||
| } | ||
|
|
||
| func (c *DeploymentTargetsApiV1AlphaApi) Activate(targetId string) (bool, error) { | ||
| return c.cordon(targetId, ActivateOpName) | ||
| } | ||
|
|
||
| func (c *DeploymentTargetsApiV1AlphaApi) Deactivate(targetId string) (bool, error) { | ||
| return c.cordon(targetId, DeactivateOpName) | ||
| } | ||
|
|
||
| func (c *DeploymentTargetsApiV1AlphaApi) cordon(targetId, opName string) (bool, error) { | ||
| query := fmt.Sprintf("%s/%s", targetId, opName) | ||
|
|
||
| body, status, err := c.BaseClient.Patch(c.ResourceNamePlural, query, nil) | ||
| if err != nil { | ||
| return false, fmt.Errorf("creating %s on Semaphore failed '%s'", c.ResourceNamePlural, err) | ||
| } | ||
| if status != http.StatusOK { | ||
| return false, fmt.Errorf("http status %d with message \"%s\" received from upstream", status, body) | ||
| } | ||
|
|
||
| response, err := models.NewCordonResponseV1AlphaFromJson(body) | ||
| if err != nil { | ||
| return false, fmt.Errorf("wrong response: %s", err) | ||
| } | ||
| if response.TargetId != targetId { | ||
| return false, fmt.Errorf("wrong target id in the response") | ||
| } | ||
| shouldBeCordoned := opName == DeactivateOpName | ||
| if response.Cordoned != shouldBeCordoned { | ||
| if response.Cordoned { | ||
| return false, fmt.Errorf("failed to activate deployment target") | ||
| } | ||
| return false, fmt.Errorf("failed to deactivate deployment target") | ||
| } | ||
| return true, nil | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.