Function Push

internal/pullbox/s3/push.go:20–64

(
	ctx context.Context,
	creds *devopt.Credentials,
	dir, profile string,
)

)

func Push(
	ctx context.Context,
	creds *devopt.Credentials,
	dir, profile string,
) error {
	archivePath, err := tar.Compress(dir)
	if err != nil {
		return err
	}

	config, err := assumeRole(ctx, creds)
	if err != nil {
		return err
	}

	s3Client := manager.NewUploader(s3.NewFromConfig(*config))
	file, err := os.Open(archivePath)
	if err != nil {
		return err
	}
	defer file.Close()

	_, err = s3Client.Upload(ctx, &s3.PutObjectInput{
		Bucket: aws.String(bucket),
		Key: aws.String(
			fmt.Sprintf(
				"profiles/%s/%s.tar.gz",
				creds.Sub,
				profile,
			),
		),
		Body: io.Reader(file),
	})
	if err != nil {
		return err
	}

	ux.Fsuccessf(
		os.Stderr,
		"Profile successfully pushed (profile: %s)\n",
		profile,
	)

	return nil
}