Function UploadRepo

cli/pkg/cmdutil/archive.go:14–56

UploadRepo uploads a local project files to rill managed store. Internally it creates an asset object on admin service and returns its id which can be supplied while creating/updating project.

(ctx context.Context, repo drivers.RepoStore, ch *Helper, org, name string)

// UploadRepo uploads a local project files to rill managed store.
// Internally it creates an asset object on admin service and returns its id which can be supplied while creating/updating project.
func UploadRepo(ctx context.Context, repo drivers.RepoStore, ch *Helper, org, name string) (string, error) {
	// list files
	entries, err := repo.ListGlob(ctx, "**", false)
	if err != nil {
		return "", err
	}

	adminClient, err := ch.Client()
	if err != nil {
		return "", err
	}

	rootPath, err := repo.Root(ctx)
	if err != nil {
		return "", fmt.Errorf("failed to get root path: %w", err)
	}

	b, err := archive.Create(ctx, entries, rootPath)
	if err != nil {
		return "", err
	}

	estimatedSizeBytes := int64(b.Len())

	// generate a upload URL
	asset, err := adminClient.CreateAsset(ctx, &adminv1.CreateAssetRequest{
		Org:                org,
		Type:               "deploy",
		Name:               name,
		Extension:          "tar.gz",
		EstimatedSizeBytes: estimatedSizeBytes,
	})
	if err != nil {
		return "", err
	}

	err = archive.Upload(ctx, asset.SignedUrl, b, asset.SigningHeaders)
	if err != nil {
		return "", err
	}

	return asset.AssetId, nil
}