fix(eds/share): replacing fsmount with filemount registration (celest…

…iaorg#2001)
tirom14 · Apr 3, 2023 · 22802ce · 22802ce
1 parent 2718b1d
commit 22802ce
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/share/eds/store.go b/share/eds/store.go
@@ -66,7 +66,7 @@ func NewStore(basepath string, ds datastore.Batching) (*Store, error) {
 	}
 
 	r := mount.NewRegistry()
-	err = r.Register("fs", &mount.FSMount{FS: os.DirFS(basepath + blocksPath)})
+	err = r.Register("fs", &mount.FileMount{Path: basepath + blocksPath})
 	if err != nil {
 		return nil, fmt.Errorf("failed to register FS mount on the registry: %w", err)
 	}
@@ -181,9 +181,8 @@ func (s *Store) Put(ctx context.Context, root share.DataHash, square *rsmt2d.Ext
 	}
 
 	ch := make(chan dagstore.ShardResult, 1)
-	err = s.dgstr.RegisterShard(ctx, shard.KeyFromString(key), &mount.FSMount{
-		FS:   os.DirFS(s.basepath + blocksPath),
-		Path: key,
+	err = s.dgstr.RegisterShard(ctx, shard.KeyFromString(key), &mount.FileMount{
+		Path: s.basepath + blocksPath + key,
 	}, ch, dagstore.RegisterOpts{})
 	if err != nil {
 		return fmt.Errorf("failed to initiate shard registration: %w", err)