mirror of
https://github.com/anyproto/anytype-heart.git
synced 2025-06-07 21:37:04 +09:00
43 lines
928 B
Go
43 lines
928 B
Go
package space
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/anyproto/anytype-heart/pkg/lib/localstore/addr"
|
|
)
|
|
|
|
func (s *service) initMarketplaceSpace(ctx context.Context) error {
|
|
ctrl, err := s.factory.CreateMarketplaceSpace(ctx)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
err = ctrl.Start(ctx)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
s.mu.Lock()
|
|
defer s.mu.Unlock()
|
|
wait := make(chan struct{})
|
|
close(wait)
|
|
s.waiting[addr.AnytypeMarketplaceWorkspace] = controllerWaiter{
|
|
wait: wait,
|
|
}
|
|
s.spaceControllers[addr.AnytypeMarketplaceWorkspace] = ctrl
|
|
return nil
|
|
}
|
|
|
|
func (s *service) createTechSpace(ctx context.Context) (err error) {
|
|
if s.techSpace, err = s.factory.CreateAndSetTechSpace(ctx); err != nil {
|
|
return err
|
|
}
|
|
close(s.techSpaceReady)
|
|
return
|
|
}
|
|
|
|
func (s *service) loadTechSpace(ctx context.Context) (err error) {
|
|
if s.techSpace, err = s.factory.LoadAndSetTechSpace(ctx); err != nil {
|
|
return err
|
|
}
|
|
close(s.techSpaceReady)
|
|
return
|
|
}
|