fix race condition

Author: OutOfBedlam

mods/server/http.go

@@ -236,7 +236,7 @@ func (svr *httpd) Router() *gin.Engine {
 				svr.log.Infof("MQTT websocket handler enabled")
 			}
 			if svr.tqlLoader != nil {
-				svr.memoryFs = &MemoryFS{Prefix: "/web/api/tql-assets/"}
+				svr.memoryFs = NewMemoryFS("/web/api/tql-assets/")
 				go svr.memoryFs.Start()
 				svr.tqlLoader.SetVolatileAssetsProvider(svr.memoryFs)
 				group.GET("/api/tql-assets/*path", gin.WrapH(http.FileServer(svr.memoryFs)))

mods/server/http_assets.go

@@ -171,11 +171,17 @@ type MemoryFS struct {
 	stop     chan bool
 }
 
+func NewMemoryFS(prefix string) *MemoryFS {
+	return &MemoryFS{
+		Prefix: prefix,
+		list:   map[string]*MemoryFile{},
+		stop:   make(chan bool),
+	}
+}
+
 var _ tql.VolatileAssetsProvider = (*MemoryFS)(nil)
 
 func (fs *MemoryFS) Start() {
-	fs.stop = make(chan bool)
-	fs.list = map[string]*MemoryFile{}
 	ticker := time.NewTicker(30 * time.Second)
 	defer ticker.Stop()