fix emoji donwloadStream

lib/rocketchat/emoji.js

@@ -20,14 +20,17 @@ module.exports = async function (context) {
     const filename = `${result.name}.${result.extension}`
     const dest = `${context.config.target.filesPath}/custom_emoji/${filename}`
 
-    const srcFilename = Utils.srcPath(context.config.source.customEmojiPath, filename)
-    if (srcFilename) {
-      Utils.copyFile(srcFilename, dest)
-    } else {
-      await Utils.downloadGridFSByName(context, fileCollection, filename, dest)
+    try {
+      const srcFilename = Utils.srcPath(context.config.source.customEmojiPath, filename)
+      if (srcFilename) {
+        Utils.copyFile(srcFilename, dest)
+      } else {
+        await Utils.downloadGridFSByName(context, fileCollection, filename, dest)
+      }
+      log.info(`... copied ${result.name}`)
+    } catch (err) {
+      log.warn(`... skipping emoji "${result.name}": ${err.message}`)
     }
-
-    log.info(`... copied ${result.name}`)
   }
   return context
 }

lib/rocketchat/utils.js

@@ -182,10 +182,12 @@ utils.downloadGridFSByName = async function (context, collection, filename, dest
 
   const bucket = context.rocketchat.gridFsBucket(collection.collectionName)
   const destStream = fs.createWriteStream(dest)
-  bucket.openDownloadStreamByName(filename).pipe(destStream)
+  const downloadStream = bucket.openDownloadStreamByName(filename)
+  downloadStream.pipe(destStream)
   return new Promise((resolve, reject) => {
     destStream.on('finish', resolve)
     destStream.on('error', reject)
+    downloadStream.on('error', reject)
   })
 }