fix transfer file access error

handlers/worlds/chunk.go

@@ -137,8 +137,11 @@ func (w *worldsHandler) onBlobs(blobs []proxy.BlobResp, fromCache bool) (err err
 		}
 	}
 
+	w.worldStateLock.Lock()
+	defer w.worldStateLock.Unlock()
 	for pos, biome := range biomes {
-		ch, ok, err := w.currentWorld.LoadChunk(world.ChunkPos{pos[0], pos[2]})
+		wpos := world.ChunkPos{pos[0], pos[2]}
+		ch, ok, err := w.currentWorld.LoadChunk(wpos)
 		if err != nil {
 			return err
 		}
@@ -151,6 +154,11 @@ func (w *worldsHandler) onBlobs(blobs []proxy.BlobResp, fromCache bool) (err err
 		if err != nil {
 			return err
 		}
+
+		err = w.currentWorld.StoreChunk(wpos, ch, nil)
+		if err != nil {
+			return err
+		}
 	}
 
 	return nil

handlers/worlds/packets.go

@@ -239,8 +239,8 @@ func (w *worldsHandler) packetCB(_pk packet.Packet, toServer bool, timeReceived
 
 		// player
 	case *packet.AddPlayer:
-		w.currentWorld.AddPlayer(pk)
-		w.addPlayer(pk)
+		//w.currentWorld.AddPlayer(pk)
+		//w.addPlayer(pk)
 	case *packet.PlayerList:
 		if pk.ActionType == packet.PlayerListActionAdd { // remove
 			for _, player := range pk.Entries {

utils/proxy/blobcache.go

@@ -49,6 +49,10 @@ func blobKey(h uint64) []byte {
 	return k
 }
 
+func (b *Blobcache) Close() error {
+	return b.db.Close()
+}
+
 func (b *Blobcache) loadBlob(blobHash uint64) ([]byte, error) {
 	blob, err := b.db.Get(blobKey(blobHash), nil)
 	if err != nil {

utils/proxy/session.go

@@ -152,6 +152,7 @@ func (s *Session) Run(ctx context.Context, connect *utils.ConnectInfo) error {
 		return err
 	}
 	s.blobCache.OnBlobs = s.handlers.OnBlobs
+	defer s.blobCache.Close()
 
 	if connect.Replay != "" {
 		replay, err := CreateReplayConnector(ctx, connect.Replay, s.packetFunc, rpHandler)