Skip to content

Commit

Permalink
fix(compute/deploy): check package before service clone
Browse files Browse the repository at this point in the history
  • Loading branch information
@Integralist
Integralist committed Oct 2, 2023
1 parent a524074 commit 356b710
Showing 1 changed file with 50 additions and 71 deletions.
121 changes: 50 additions & 71 deletions pkg/commands/compute/deploy.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -112,7 +112,7 @@ func (c *DeployCommand) Exec(in io.Reader, out io.Writer) (err error) {
return err
}

newService, serviceID, serviceVersion, cont, err := serviceManagement(serviceID, source, c, in, out, fnActivateTrial, spinner)
newService, serviceID, serviceVersion, cont, err := serviceManagement(pkgPath, serviceID, source, c, in, out, fnActivateTrial, spinner)
if err != nil {
return err
}
Expand Down Expand Up @@ -146,15 +146,15 @@ func (c *DeployCommand) Exec(in io.Reader, out io.Writer) (err error) {
return err
}

cont, err = processPackage(
c, pkgPath, serviceID, serviceVersion.Number, spinner, out,
)
err = pkgUpload(spinner, c.Globals.APIClient, serviceID, serviceVersion.Number, pkgPath)
if err != nil {
c.Globals.ErrLog.AddWithContext(err, map[string]any{
"Package path": pkgPath,
"Service ID": serviceID,
"Service Version": serviceVersion,
})
return err
}
if !cont {
return nil
}

if err = processService(c, serviceID, serviceVersion.Number, spinner); err != nil {
return err
Expand Down Expand Up @@ -439,7 +439,7 @@ func preconfigureActivateTrial(endpoint, token string, httpClient api.HTTPClient
}

func serviceManagement(
serviceID string,
pkgPath, serviceID string,
source manifest.Source,
c *DeployCommand,
in io.Reader,
Expand Down Expand Up @@ -476,7 +476,36 @@ func serviceManagement(
}
}

serviceVersion, err = manageExistingServiceFlow(serviceID, c.ServiceVersion, c.Globals.APIClient, c.Globals.Verbose(), out, c.Globals.ErrLog)
serviceVersion, err = c.ServiceVersion.Parse(serviceID, c.Globals.APIClient)
if err != nil {
c.Globals.ErrLog.AddWithContext(err, map[string]any{
"Service ID": serviceID,
})
return false, "", serviceVersion, false, err
}

filesHash, err := getFilesHash(pkgPath)
if err != nil {
c.Globals.ErrLog.AddWithContext(err, map[string]any{
"Package path": pkgPath,
})
return false, "", nil, false, err
}

cont, err = pkgCompare(c.Globals.APIClient, serviceID, serviceVersion.Number, filesHash, out)
if err != nil {
c.Globals.ErrLog.AddWithContext(err, map[string]any{
"Package path": pkgPath,
"Service ID": serviceID,
"Service Version": serviceVersion,
})
return false, "", nil, false, err
}
if !cont {
return false, "", nil, false, err
}

serviceVersion, err = manageExistingServiceFlow(serviceID, serviceVersion, c.Globals.APIClient, c.Globals.Verbose(), out, c.Globals.ErrLog)
if err != nil {
return false, "", nil, false, err
}
Expand Down Expand Up @@ -703,20 +732,12 @@ func updateManifestServiceID(m *manifest.File, manifestFilename string, serviceI
// manageExistingServiceFlow clones service version if required.
func manageExistingServiceFlow(
serviceID string,
serviceVersionFlag cmd.OptionalServiceVersion,
currentServiceVersion *fastly.Version,
apiClient api.Interface,
verbose bool,
out io.Writer,
errLog fsterr.LogInterface,
) (serviceVersion *fastly.Version, err error) {
serviceVersion, err = serviceVersionFlag.Parse(serviceID, apiClient)
if err != nil {
errLog.AddWithContext(err, map[string]any{
"Service ID": serviceID,
})
return serviceVersion, err
}

// Validate that we're dealing with a Compute@Edge 'wasm' service and not a
// VCL service, for which we cannot upload a wasm package format to.
serviceDetails, err := apiClient.GetServiceDetails(&fastly.GetServiceInput{ID: serviceID})
Expand All @@ -743,17 +764,17 @@ func manageExistingServiceFlow(
// the compute deploy command is a composite of behaviours, and so as we
// already automatically activate a version we should autoclone without
// requiring the user to explicitly provide an --autoclone flag.
if serviceVersion.Active || serviceVersion.Locked {
if currentServiceVersion.Active || currentServiceVersion.Locked {
clonedVersion, err := apiClient.CloneVersion(&fastly.CloneVersionInput{
ServiceID: serviceID,
ServiceVersion: serviceVersion.Number,
ServiceVersion: currentServiceVersion.Number,
})
if err != nil {
errLogService(errLog, err, serviceID, serviceVersion.Number)
errLogService(errLog, err, serviceID, currentServiceVersion.Number)
return serviceVersion, fmt.Errorf("error cloning service version: %w", err)
}
if verbose {
msg := fmt.Sprintf("Service version %d is not editable, so it was automatically cloned. Now operating on version %d.", serviceVersion.Number, clonedVersion.Number)
msg := fmt.Sprintf("Service version %d is not editable, so it was automatically cloned. Now operating on version %d.", currentServiceVersion.Number, clonedVersion.Number)
text.Break(out)
text.Output(out, msg)
text.Break(out)
Expand Down Expand Up @@ -785,19 +806,18 @@ func checkServiceID(serviceID string, client api.Interface) error {

// pkgCompare compares the local package files hash against the existing service
// package version and exits early with message if identical.
func pkgCompare(client api.Interface, serviceID string, version int, filesHash string, out io.Writer) (bool, error) {
func pkgCompare(client api.Interface, serviceID string, version int, filesHash string, out io.Writer) (cont bool, err error) {
p, err := client.GetPackage(&fastly.GetPackageInput{
ServiceID: serviceID,
ServiceVersion: version,
})

if err == nil {
if filesHash == p.Metadata.FilesHash {
text.Info(out, "Skipping package deployment, local and service version are identical. (service %v, version %v) ", serviceID, version)
return false, nil
}
if err != nil {
return false, err
}
if filesHash == p.Metadata.FilesHash {
text.Info(out, "Skipping package deployment, local and service version are identical. (service %v, version %v) ", serviceID, version)
return false, nil
}

return true, nil
}

Expand Down Expand Up @@ -1109,47 +1129,6 @@ func processSetupCreation(
return nil
}

func processPackage(
c *DeployCommand,
pkgPath, serviceID string,
serviceVersion int,
spinner text.Spinner,
out io.Writer,
) (cont bool, err error) {
filesHash, err := getFilesHash(pkgPath)
if err != nil {
c.Globals.ErrLog.AddWithContext(err, map[string]any{
"Package path": pkgPath,
})
return false, err
}

cont, err = pkgCompare(c.Globals.APIClient, serviceID, serviceVersion, filesHash, out)
if err != nil {
c.Globals.ErrLog.AddWithContext(err, map[string]any{
"Package path": pkgPath,
"Service ID": serviceID,
"Service Version": serviceVersion,
})
return false, err
}
if !cont {
return false, nil
}

err = pkgUpload(spinner, c.Globals.APIClient, serviceID, serviceVersion, pkgPath)
if err != nil {
c.Globals.ErrLog.AddWithContext(err, map[string]any{
"Package path": pkgPath,
"Service ID": serviceID,
"Service Version": serviceVersion,
})
return false, err
}

return true, nil
}

func processService(c *DeployCommand, serviceID string, serviceVersion int, spinner text.Spinner) error {
if c.Comment.WasSet {
_, err := c.Globals.APIClient.UpdateVersion(&fastly.UpdateVersionInput{
Expand Down

0 comments on commit 356b710

Please sign in to comment.