Implement Kopia storage filesystem opts

pkg/kopia/cli/errors.go

@@ -28,4 +28,6 @@ var (
 var (
 	// ErrUnsupportedStorage is returned when the storage is not supported.
 	ErrUnsupportedStorage = errors.New("unsupported storage")
+	// ErrInvalidRepoPath is returned when the repoPath is empty.
+	ErrInvalidRepoPath = errors.New("repository path cannot be empty")
 )

pkg/kopia/cli/repository/storage/fs/fs.go

@@ -0,0 +1,45 @@
+// Copyright 2024 The Kanister Authors.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//      http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package fs
+
+import (
+	"github.com/kanisterio/safecli/command"
+
+	"github.com/kanisterio/kanister/pkg/kopia/cli"
+	"github.com/kanisterio/kanister/pkg/kopia/cli/internal"
+	"github.com/kanisterio/kanister/pkg/log"
+)
+
+const (
+	defaultFSMountPath = "/mnt/data"
+)
+
+// New creates a new subcommand for the filesystem storage.
+func New(location internal.Location, repoPathPrefix string, _ log.Logger) command.Applier {
+	path, err := generateFileSystemMountPath(location.Prefix(), repoPathPrefix)
+	if err != nil {
+		return command.NewErrorArgument(err)
+	}
+	return command.NewArguments(subcmdFilesystem, optRepoPath(path))
+}
+
+// generateFileSystemMountPath generates the mount path for the filesystem storage.
+func generateFileSystemMountPath(locPrefix, repoPrefix string) (string, error) {
+	fullRepoPath := internal.GenerateFullRepoPath(locPrefix, repoPrefix)
+	if fullRepoPath == "" {
+		return "", cli.ErrInvalidRepoPath
+	}
+	return defaultFSMountPath + "/" + fullRepoPath, nil
+}

pkg/kopia/cli/repository/storage/fs/fs_opts.go

@@ -0,0 +1,34 @@
+// Copyright 2024 The Kanister Authors.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//      http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package fs
+
+import (
+	"github.com/kanisterio/safecli/command"
+
+	"github.com/kanisterio/kanister/pkg/kopia/cli"
+)
+
+var (
+	subcmdFilesystem = command.NewArgument("filesystem")
+)
+
+// optRepoPath creates a new path option with a given path.
+// If the path is empty, it returns an error.
+func optRepoPath(path string) command.Applier {
+	if path == "" {
+		return command.NewErrorArgument(cli.ErrInvalidRepoPath)
+	}
+	return command.NewOptionWithArgument("--path", path)
+}

pkg/kopia/cli/repository/storage/fs/fs_opts_test.go

@@ -0,0 +1,40 @@
+// Copyright 2024 The Kanister Authors.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//      http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package fs
+
+import (
+	"testing"
+
+	"github.com/kanisterio/safecli/command"
+	"github.com/kanisterio/safecli/test"
+	"gopkg.in/check.v1"
+
+	"github.com/kanisterio/kanister/pkg/kopia/cli"
+)
+
+func TestFilesystemOptions(t *testing.T) { check.TestingT(t) }
+
+var _ = check.Suite(&test.ArgumentSuite{Cmd: "cmd", Arguments: []test.ArgumentTest{
+	{
+		Name:        "optRepoPath",
+		Argument:    command.NewArguments(optRepoPath("/path/to/repo")),
+		ExpectedCLI: []string{"cmd", "--path=/path/to/repo"},
+	},
+	{
+		Name:        "Invalid RepoPath",
+		Argument:    command.NewArguments(optRepoPath("")),
+		ExpectedErr: cli.ErrInvalidRepoPath,
+	},
+}})

pkg/kopia/cli/repository/storage/fs/fs_test.go

@@ -0,0 +1,53 @@
+// Copyright 2024 The Kanister Authors.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//      http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package fs
+
+import (
+	"testing"
+
+	"github.com/kanisterio/safecli/command"
+	"github.com/kanisterio/safecli/test"
+	"gopkg.in/check.v1"
+
+	"github.com/kanisterio/kanister/pkg/kopia/cli"
+	"github.com/kanisterio/kanister/pkg/kopia/cli/internal"
+)
+
+func TestNewFilesystem(t *testing.T) { check.TestingT(t) }
+
+func newFilesystem(prefix, repoPath string) command.Applier {
+	l := internal.Location{
+		"prefix": []byte(prefix),
+	}
+	return New(l, repoPath, nil)
+}
+
+var _ = check.Suite(&test.ArgumentSuite{Cmd: "cmd", Arguments: []test.ArgumentTest{
+	{
+		Name:        "NewFilesystem",
+		Argument:    newFilesystem("prefix", "repoPath"),
+		ExpectedCLI: []string{"cmd", "filesystem", "--path=/mnt/data/prefix/repoPath/"},
+	},
+	{
+		Name:        "NewFilesystem with empty repoPath",
+		Argument:    newFilesystem("prefix", ""),
+		ExpectedCLI: []string{"cmd", "filesystem", "--path=/mnt/data/prefix/"},
+	},
+	{
+		Name:        "NewFilesystem with empty local prefix and repo prefix should return error",
+		Argument:    newFilesystem("", ""),
+		ExpectedErr: cli.ErrInvalidRepoPath,
+	},
+}})