add sql driver for storing projects

pkg/projects/manager/memory/memory.go

@@ -40,7 +40,6 @@ type SpaceDescription struct {
 	StorageID string `mapstructure:"storage_id" validate:"required"`
 	Path      string `mapstructure:"path"       validate:"required"`
 	Name      string `mapstructure:"name"       validate:"required"`
-	Type      string `mapstructure:"type"       validate:"required"`
 	Owner     string `mapstructure:"owner"      validate:"required"`
 	Readers   string `mapstructure:"readers"    validate:"required"`
 	Writers   string `mapstructure:"writers"    validate:"required"`
@@ -67,10 +66,6 @@ func NewWithConfig(ctx context.Context, c *Config) (projects.Catalogue, error) {
 	return &service{c: c}, nil
 }
 
-func (s *service) StoreProject(ctx context.Context, owner *userpb.UserId, path, name string, quota *provider.Quota) error {
-	panic("not yet implemented")
-}
-
 func (s *service) ListProjects(ctx context.Context, user *userpb.User) ([]*provider.StorageSpace, error) {
 	projects := []*provider.StorageSpace{}
 	for _, space := range s.c.Spaces {

pkg/projects/manager/sql/sql.go

@@ -0,0 +1,124 @@
+package sql
+
+import (
+	"context"
+	"database/sql"
+	"fmt"
+	"slices"
+
+	userpb "github.com/cs3org/go-cs3apis/cs3/identity/user/v1beta1"
+	provider "github.com/cs3org/go-cs3apis/cs3/storage/provider/v1beta1"
+	"github.com/cs3org/reva/internal/http/services/owncloud/ocs/conversions"
+	"github.com/cs3org/reva/pkg/projects"
+	"github.com/cs3org/reva/pkg/projects/manager/registry"
+	"github.com/cs3org/reva/pkg/spaces"
+	"github.com/cs3org/reva/pkg/utils/cfg"
+	"github.com/pkg/errors"
+)
+
+func init() {
+	registry.Register("sql", New)
+}
+
+type config struct {
+	DBUsername string `mapstructure:"db_username"`
+	DBPassword string `mapstructure:"db_password"`
+	DBAddress  string `mapstructure:"db_address"`
+	DBName     string `mapstructure:"db_name"`
+}
+
+type mgr struct {
+	c  *config
+	db *sql.DB
+}
+
+func New(ctx context.Context, m map[string]any) (projects.Catalogue, error) {
+	var c config
+	if err := cfg.Decode(m, &c); err != nil {
+		return nil, err
+	}
+	return NewFromConfig(ctx, &c)
+}
+
+type project struct {
+	StorageID string
+	Path      string
+	Name      string
+	Owner     string
+	Readers   string
+	Writers   string
+	Admins    string
+}
+
+// NewFromConfig creates a Repository with a SQL driver using the given config.
+func NewFromConfig(ctx context.Context, conf *config) (projects.Catalogue, error) {
+	db, err := sql.Open("mysql", fmt.Sprintf("%s:%s@tcp(%s)/%s", conf.DBUsername, conf.DBPassword, conf.DBAddress, conf.DBName))
+	if err != nil {
+		return nil, errors.Wrap(err, "sql: error opening connection to mysql database")
+	}
+
+	m := &mgr{
+		c:  conf,
+		db: db,
+	}
+	return m, nil
+}
+
+func (m *mgr) ListProjects(ctx context.Context, user *userpb.User) ([]*provider.StorageSpace, error) {
+	// TODO: for the time being we load everything in memory. We may find a better
+	// solution in future when the number of projects will grow.
+	query := "SELECT storage_id, path, name, owner, readers, writers, admins FROM projects"
+	results, err := m.db.QueryContext(ctx, query)
+	if err != nil {
+		return nil, errors.Wrap(err, "error getting projects from db")
+	}
+
+	var dbProjects []*project
+	for results.Next() {
+		var p project
+		if err := results.Scan(&p.StorageID, &p.Path, &p.Name, &p.Owner, &p.Readers, &p.Writers, &p.Admins); err != nil {
+			return nil, errors.Wrap(err, "error scanning rows from db")
+		}
+		dbProjects = append(dbProjects, &p)
+	}
+
+	var projects []*provider.StorageSpace
+	for _, p := range dbProjects {
+		if perms, ok := projectBelongToUser(user, p); ok {
+			projects = append(projects, &provider.StorageSpace{
+				Id: &provider.StorageSpaceId{
+					OpaqueId: spaces.EncodeSpaceID(p.StorageID, p.Path),
+				},
+				Owner: &userpb.User{
+					Id: &userpb.UserId{
+						OpaqueId: p.Owner,
+					},
+				},
+				Name:      p.Name,
+				SpaceType: spaces.SpaceTypeProject.AsString(),
+				RootInfo: &provider.ResourceInfo{
+					Path:          p.Path,
+					PermissionSet: perms,
+				},
+			})
+		}
+	}
+
+	return projects, nil
+}
+
+func projectBelongToUser(user *userpb.User, p *project) (*provider.ResourcePermissions, bool) {
+	if user.Id.OpaqueId == p.Owner {
+		return conversions.NewManagerRole().CS3ResourcePermissions(), true
+	}
+	if slices.Contains(user.Groups, p.Admins) {
+		return conversions.NewManagerRole().CS3ResourcePermissions(), true
+	}
+	if slices.Contains(user.Groups, p.Writers) {
+		return conversions.NewEditorRole().CS3ResourcePermissions(), true
+	}
+	if slices.Contains(user.Groups, p.Readers) {
+		return conversions.NewViewerRole().CS3ResourcePermissions(), true
+	}
+	return nil, false
+}

pkg/projects/projects.go

@@ -27,6 +27,5 @@ import (
 
 // Catalogue is the interface that stores the project spaces.
 type Catalogue interface {
-	StoreProject(ctx context.Context, owner *userpb.UserId, path, name string, quota *provider.Quota) error
 	ListProjects(ctx context.Context, user *userpb.User) ([]*provider.StorageSpace, error)
 }