mirror of
https://github.com/kopia/kopia.git
synced 2026-01-25 23:08:01 -05:00
1b014c875a
completely rewrote password storage: - by default passwords are kept in OS-specific keyring (Keychain on macOS, Windows Credentials Manager on Windows), which can be optionally disabled to store password in a local file. - on Linux keychain is disabled by default (does not work reliably in terminal sessions), but can be enabled using command-line flag.
97 lines
3.5 KiB
Go
97 lines
3.5 KiB
Go
package cli
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"fmt"
|
|
|
|
"github.com/kopia/kopia/internal/units"
|
|
"github.com/kopia/kopia/repo"
|
|
"github.com/kopia/kopia/repo/block"
|
|
"github.com/kopia/kopia/repo/object"
|
|
"github.com/kopia/kopia/repo/storage"
|
|
)
|
|
|
|
var (
|
|
createCommand = repositoryCommands.Command("create", "Create new repository in a specified location.")
|
|
|
|
createMetadataEncryptionFormat = createCommand.Flag("metadata-encryption", "Metadata item encryption.").PlaceHolder("FORMAT").Default(repo.DefaultEncryptionAlgorithm).Enum(repo.SupportedEncryptionAlgorithms...)
|
|
createObjectFormat = createCommand.Flag("object-format", "Format of repository objects.").PlaceHolder("FORMAT").Default(block.DefaultFormat).Enum(block.SupportedFormats...)
|
|
createObjectSplitter = createCommand.Flag("object-splitter", "The splitter to use for new objects in the repository").Default("DYNAMIC").Enum(object.SupportedSplitters...)
|
|
|
|
createMinBlockSize = createCommand.Flag("min-block-size", "Minimum size of a data block.").PlaceHolder("KB").Default("1024").Int()
|
|
createAvgBlockSize = createCommand.Flag("avg-block-size", "Average size of a data block.").PlaceHolder("KB").Default("10240").Int()
|
|
createMaxBlockSize = createCommand.Flag("max-block-size", "Maximum size of a data block.").PlaceHolder("KB").Default("20480").Int()
|
|
|
|
createOverwrite = createCommand.Flag("overwrite", "Overwrite existing data (DANGEROUS).").Bool()
|
|
createOnly = createCommand.Flag("create-only", "Create repository, but don't connect to it.").Short('c').Bool()
|
|
)
|
|
|
|
func init() {
|
|
setupConnectOptions(createCommand)
|
|
}
|
|
|
|
func newRepositoryOptionsFromFlags() *repo.NewRepositoryOptions {
|
|
return &repo.NewRepositoryOptions{
|
|
MetadataEncryptionAlgorithm: *createMetadataEncryptionFormat,
|
|
BlockFormat: *createObjectFormat,
|
|
|
|
Splitter: *createObjectSplitter,
|
|
MinBlockSize: *createMinBlockSize * 1024,
|
|
AvgBlockSize: *createAvgBlockSize * 1024,
|
|
MaxBlockSize: *createMaxBlockSize * 1024,
|
|
}
|
|
}
|
|
|
|
func ensureEmpty(ctx context.Context, s storage.Storage) error {
|
|
hasDataError := errors.New("has data")
|
|
err := s.ListBlocks(ctx, "", func(cb storage.BlockMetadata) error {
|
|
return hasDataError
|
|
})
|
|
if err == hasDataError {
|
|
if !*createOverwrite {
|
|
return fmt.Errorf("found existing data in storage, specify --overwrite to use anyway")
|
|
}
|
|
}
|
|
|
|
return err
|
|
}
|
|
|
|
func runCreateCommandWithStorage(ctx context.Context, st storage.Storage) error {
|
|
err := ensureEmpty(ctx, st)
|
|
if err != nil {
|
|
return fmt.Errorf("unable to get repository storage: %v", err)
|
|
}
|
|
|
|
options := newRepositoryOptionsFromFlags()
|
|
|
|
creds := mustGetPasswordFromFlags(true, false)
|
|
|
|
printStderr("Initializing repository with:\n")
|
|
printStderr(" metadata encryption: %v\n", options.MetadataEncryptionAlgorithm)
|
|
printStderr(" block format: %v\n", options.BlockFormat)
|
|
switch options.Splitter {
|
|
case "DYNAMIC":
|
|
printStderr(" object splitter: DYNAMIC with block sizes (min:%v avg:%v max:%v)\n",
|
|
units.BytesStringBase2(int64(options.MinBlockSize)),
|
|
units.BytesStringBase2(int64(options.AvgBlockSize)),
|
|
units.BytesStringBase2(int64(options.MaxBlockSize)))
|
|
|
|
case "FIXED":
|
|
printStderr(" object splitter: FIXED with with block size: %v\n", units.BytesStringBase2(int64(options.MaxBlockSize)))
|
|
|
|
case "NEVER":
|
|
printStderr(" object splitter: NEVER\n")
|
|
}
|
|
|
|
if err := repo.Initialize(ctx, st, options, creds); err != nil {
|
|
return fmt.Errorf("cannot initialize repository: %v", err)
|
|
}
|
|
|
|
if *createOnly {
|
|
return nil
|
|
}
|
|
|
|
return runConnectCommandWithStorageAndPassword(ctx, st, creds)
|
|
}
|