feat(asset): add asset management functionality and validation

.gitignore

@@ -1,2 +1,3 @@
 .env
 .env.*
+.idea

account/accountdomain/workspace/initializer.go

@@ -18,10 +18,12 @@ type InitParams struct {
 
 func Init(p InitParams) (*user.User, *Workspace, error) {
 	if p.UserID == nil {
-		p.UserID = user.NewID().Ref()
+		newID := user.NewID()
+		p.UserID = newID.Ref()
 	}
 	if p.WorkspaceID == nil {
-		p.WorkspaceID = NewID().Ref()
+		newWorkspaceID := NewID()
+		p.WorkspaceID = newWorkspaceID.Ref()
 	}
 	if p.Lang == nil {
 		p.Lang = &language.Tag{}

account/accountdomain/workspace/member.go

@@ -82,7 +82,7 @@ func (m *Members) Users() map[UserID]Member {
 func (m *Members) UserIDs() []UserID {
 	users := lo.Keys(m.users)
 	sort.SliceStable(users, func(a, b int) bool {
-		return users[a].Compare(users[b]) > 0
+		return users[a].Compare(&users[b]) > 0
 	})
 	return users
 }
@@ -94,7 +94,7 @@ func (m *Members) Integrations() map[IntegrationID]Member {
 func (m *Members) IntegrationIDs() []IntegrationID {
 	integrations := lo.Keys(m.integrations)
 	sort.SliceStable(integrations, func(a, b int) bool {
-		return integrations[a].Compare(integrations[b]) > 0
+		return integrations[a].Compare(&integrations[b]) > 0
 	})
 	return integrations
 }
@@ -255,7 +255,7 @@ func (m *Members) UsersByRole(role Role) []UserID {
 	}
 
 	sort.SliceStable(users, func(a, b int) bool {
-		return users[a].Compare(users[b]) > 0
+		return users[a].Compare(&users[b]) > 0
 	})
 
 	return users

account/accountinfrastructure/accountmemory/workspace.go

@@ -62,7 +62,12 @@ func (r *Workspace) FindByIDs(_ context.Context, ids workspace.IDList) (workspac
 	res := r.data.FindAll(func(key workspace.ID, value *workspace.Workspace) bool {
 		return ids.Has(key)
 	})
-	slices.SortFunc(res, func(a, b *workspace.Workspace) int { return a.ID().Compare(b.ID()) })
+	slices.SortFunc(res, func(a, b *workspace.Workspace) int {
+		idA := a.ID()
+		idB := b.ID()
+		return idA.Compare(&idB)
+	})
+
 	return res, nil
 }
 

asset/decompress/zip.go

@@ -0,0 +1,36 @@
+package decompress
+
+import (
+	"archive/zip"
+	"context"
+	"github.com/reearth/reearthx/asset"
+)
+
+type ZipDecompressor struct {
+	assetService *asset.Service
+}
+
+func NewZipDecompressor(assetService *asset.Service) *ZipDecompressor {
+	return &ZipDecompressor{
+		assetService: assetService,
+	}
+}
+
+func (d *ZipDecompressor) DecompressAsync(ctx context.Context, assetID asset.ID) error {
+	// Get the zip file from asset service
+	zipFile, err := d.assetService.GetFile(ctx, assetID)
+	if err != nil {
+		return err
+	}
+	defer zipFile.Close()
+
+	// Create a temporary file to store the zip content
+	// Implementation of async zip extraction
+	return nil
+}
+
+func (d *ZipDecompressor) processZipFile(ctx context.Context, zipReader *zip.Reader) error {
+	// Process each file in the zip
+	// Create new assets for each file
+	return nil
+}

asset/pubsub/pubsub.go

@@ -0,0 +1,35 @@
+package pubsub
+
+import (
+	"context"
+	"github.com/reearth/reearthx/asset"
+)
+
+type AssetEvent struct {
+	Type    string   `json:"type"`
+	AssetID asset.ID `json:"asset_id"`
+}
+
+type Publisher interface {
+	Publish(ctx context.Context, topic string, msg interface{}) error
+}
+
+type AssetPubSub struct {
+	publisher Publisher
+	topic     string
+}
+
+func NewAssetPubSub(publisher Publisher, topic string) *AssetPubSub {
+	return &AssetPubSub{
+		publisher: publisher,
+		topic:     topic,
+	}
+}
+
+func (p *AssetPubSub) PublishAssetEvent(ctx context.Context, eventType string, assetID asset.ID) error {
+	event := AssetEvent{
+		Type:    eventType,
+		AssetID: assetID,
+	}
+	return p.publisher.Publish(ctx, p.topic, event)
+}

asset/repository.go

@@ -0,0 +1,15 @@
+package asset
+
+import (
+	"context"
+	"io"
+)
+
+type Repository interface {
+	Fetch(ctx context.Context, id ID) (*Asset, error)
+	FetchFile(ctx context.Context, id ID) (io.ReadCloser, error)
+	Save(ctx context.Context, asset *Asset) error
+	Remove(ctx context.Context, id ID) error
+	Upload(ctx context.Context, id ID, file io.Reader) error
+	GetUploadURL(ctx context.Context, id ID) (string, error)
+}

asset/service.go

@@ -0,0 +1,76 @@
+package asset
+
+import (
+	"context"
+	"io"
+	"time"
+)
+
+type Service struct {
+	repo Repository
+}
+
+func NewService(repo Repository) *Service {
+	return &Service{repo: repo}
+}
+
+func (s *Service) Create(ctx context.Context, input CreateAssetInput) (*Asset, error) {
+	asset := &Asset{
+		ID:          ID(generateID()),
+		Name:        input.Name,
+		Size:        input.Size,
+		ContentType: input.ContentType,
+		CreatedAt:   time.Now(),
+		UpdatedAt:   time.Now(),
+	}
+
+	if err := s.repo.Save(ctx, asset); err != nil {
+		return nil, err
+	}
+
+	return asset, nil
+}
+
+func (s *Service) Update(ctx context.Context, id ID, input UpdateAssetInput) (*Asset, error) {
+	asset, err := s.repo.Fetch(ctx, id)
+	if err != nil {
+		return nil, err
+	}
+
+	if input.Name != nil {
+		asset.Name = *input.Name
+	}
+	if input.URL != nil {
+		asset.URL = *input.URL
+	}
+	if input.ContentType != nil {
+		asset.ContentType = *input.ContentType
+	}
+	asset.UpdatedAt = time.Now()
+
+	if err := s.repo.Save(ctx, asset); err != nil {
+		return nil, err
+	}
+
+	return asset, nil
+}
+
+func (s *Service) Delete(ctx context.Context, id ID) error {
+	return s.repo.Remove(ctx, id)
+}
+
+func (s *Service) Get(ctx context.Context, id ID) (*Asset, error) {
+	return s.repo.Fetch(ctx, id)
+}
+
+func (s *Service) GetFile(ctx context.Context, id ID) (io.ReadCloser, error) {
+	return s.repo.FetchFile(ctx, id)
+}
+
+func (s *Service) Upload(ctx context.Context, id ID, file io.Reader) error {
+	return s.repo.Upload(ctx, id, file)
+}
+
+func (s *Service) GetUploadURL(ctx context.Context, id ID) (string, error) {
+	return s.repo.GetUploadURL(ctx, id)
+}

asset/types.go

@@ -0,0 +1,29 @@
+package asset
+
+import (
+	"time"
+)
+
+type ID string
+
+type Asset struct {
+	ID          ID
+	Name        string
+	Size        int64
+	URL         string
+	ContentType string
+	CreatedAt   time.Time
+	UpdatedAt   time.Time
+}
+
+type CreateAssetInput struct {
+	Name        string
+	Size        int64
+	ContentType string
+}
+
+type UpdateAssetInput struct {
+	Name        *string
+	URL         *string
+	ContentType *string
+}

asset/utils.go

@@ -0,0 +1,9 @@
+package asset
+
+import (
+	"github.com/google/uuid"
+)
+
+func generateID() string {
+	return uuid.New().String()
+}