Fixed a mesh fs sync issue

Author: pajama-coder

agent/apps/ztm/chat/api.js

@@ -152,8 +152,23 @@ export default function ({ app, mesh }) {
     return Promise.resolve()
   }
 
+  var publishQueue = []
+  var isPublishing = false
+
   function publishMessage(dirname, message) {
-    return mesh.dir(dirname).then(filenames => {
+    publishQueue.push([dirname, message])
+    if (!isPublishing) {
+      isPublishing = true
+      publishNext()
+    }
+  }
+
+  function publishNext() {
+    if (publishQueue.length === 0) return (isPublishing = false)
+    var item = publishQueue.shift();
+    var dirname = item[0]
+    var message = item[1]
+    mesh.dir(dirname).then(filenames => {
       var timestamps = filenames.filter(
         name => name.endsWith('.json')
       ).map(
@@ -189,7 +204,7 @@ export default function ({ app, mesh }) {
           return mesh.write(filename, JSON.encode(list))
         }
       )
-    })
+    }).then(() => publishNext())
   }
 
   function allEndpoints() {

agent/fs.js

@@ -87,9 +87,9 @@ export default function(storeDir) {
     } catch {}
   }
 
-  function write(filename, data) {
+  function write(filename, data, time) {
     var path = os.path.normalize(filename)
-    var t = Date.now()
+    var t = time || Date.now()
     var h = hash(path, data)
     var meta = { pathname: path, timestamp: t }
     os.write(os.path.join(storeDir, h), data)

agent/mesh.js

@@ -1134,14 +1134,16 @@ export default function (rootDir, config) {
   }
 
   function syncFile(pathname) {
+    pathname = os.path.normalize(pathname)
+    var st = fs.stat(pathname)
     return findFile(pathname).then(meta => {
-      if (!meta || meta.size < 0) return null
-      pathname = os.path.normalize(pathname)
+      if (!meta) return st ? fs.raw(st.hash) : null
+      if (meta.size < 0) return st?.time > meta.time ? fs.raw(st.hash) : null
 
       var hash = meta.hash
-      var st = fs.stat(pathname)
+      var time = meta.time
       if (st?.hash === hash) return fs.raw(hash)
-      if (st?.time > meta.time) return fs.raw(hash)
+      if (st?.time > time) return fs.raw(st.hash)
 
       var sources = [...meta.sources]
       return pickOne()
@@ -1159,7 +1161,7 @@ export default function (rootDir, config) {
             logError(`Download of file ${hash} from ep ${ep} is corrupted`)
             return pickOne()
           }
-          fs.write(pathname, data)
+          fs.write(pathname, data, time)
           advertiseFilesystem()
           return data
         }).catch(ret => {
@@ -1319,6 +1321,7 @@ export default function (rootDir, config) {
         if (globalPath) {
           fs.write(globalPath, data)
           advertiseFilesystem()
+          return syncFile(globalPath)
         }
       }
       return Promise.resolve()