Function DeployWar

deployments/deploy_war.go:26–99

(ctx context.Context, appName, warPath, gitRef string, opts DeployOpts)

}

func DeployWar(ctx context.Context, appName, warPath, gitRef string, opts DeployOpts) error {
	var warReadStream io.ReadCloser

	var warSize int64
	var warFileName string

	c, err := config.ScalingoClient(ctx)
	if err != nil {
		return errors.Wrapf(ctx, err, "fail to get Scalingo client")
	}

	if strings.HasPrefix(warPath, "http://") || strings.HasPrefix(warPath, "https://") {
		warReadStream, warSize, err = getURLInfo(ctx, warPath)
		if err != nil {
			return errors.Wrapf(ctx, err, "get WAR URL info")
		}
		warFileName = appName + ".war"
	} else {
		warReadStream, warSize, warFileName, err = getFileInfo(ctx, warPath)
		if err != nil {
			return errors.Wrapf(ctx, err, "get WAR file info")
		}
	}
	defer warReadStream.Close()
	// Create the tar header
	header := &tar.Header{
		Name:       fmt.Sprintf("%s/%s", appName, warFileName),
		Typeflag:   tar.TypeReg, // Is a regular file
		Mode:       0640,
		ModTime:    time.Now(),
		AccessTime: time.Now(),
		ChangeTime: time.Now(),
	}
	if warSize != 0 {
		header.Size = warSize
	} else {
		return errors.New(ctx, "unknown WAR size")
	}

	// Get the sources endpoints
	sources, err := c.SourcesCreate(ctx)
	if err != nil {
		return errors.Wrapf(ctx, err, "create WAR deployment source")
	}

	archiveBuffer := new(bytes.Buffer)
	gzWriter := gzip.NewWriter(archiveBuffer)
	tarWriter := tar.NewWriter(gzWriter)

	err = tarWriter.WriteHeader(header)
	if err != nil {
		return errors.Wrapf(ctx, err, "create tarball")
	}

	_, err = io.Copy(tarWriter, warReadStream)
	if err != nil {
		return errors.Wrapf(ctx, err, "copy war content")
	}