feat: fs.writeFile api and tests for node ws apis working

Author: abose

dist/phoenix-fs.js

@@ -105,7 +105,8 @@ const WS_COMMAND = {
     GET_WINDOWS_DRIVES: "getWinDrives",
     READ_DIR: "readDir",
     STAT: "stat",
-    READ_BIN_FILE: "readBinFile"
+    READ_BIN_FILE: "readBinFile",
+    WRITE_BIN_FILE: "writeBinFile"
 };
 
 const LARGE_DATA_THRESHOLD = 2*1024*1024; // 2MB
@@ -220,6 +221,21 @@ function _readBinaryFile(ws, metadata) {
         }).catch((err)=>_reportError(ws, metadata, err, `Failed to read file at path ${fullPath}`));
 }
 
+/**
+ *
+ * @param ws
+ * @param metadata
+ * @param dataBuffer {ArrayBuffer}
+ * @private
+ */
+function _writeBinaryFile(ws, metadata, dataBuffer) {
+    const fullPath = metadata.data.path;
+    fs.writeFile(fullPath, Buffer.from(dataBuffer))
+        .then( ()=> {
+            _sendResponse(ws, metadata);
+        }).catch((err)=>_reportError(ws, metadata, err, `Failed to write file at path ${fullPath}`));
+}
+
 function processWSCommand(ws, metadata, dataBuffer) {
     try{
         switch (metadata.commandCode) {
@@ -241,6 +257,9 @@ function processWSCommand(ws, metadata, dataBuffer) {
         case WS_COMMAND.READ_BIN_FILE:
             _readBinaryFile(ws, metadata);
             return;
+        case WS_COMMAND.WRITE_BIN_FILE:
+            _writeBinaryFile(ws, metadata, dataBuffer);
+            return;
         case WS_COMMAND.LARGE_DATA_SOCKET_ANNOUNCE:
             console.log("Large Data Transfer Socket established, socket Group: ", metadata.socketGroupID);
             ws.isLargeData = true;

dist/virtualfs.js

@@ -105,7 +105,8 @@ const WS_COMMAND = {
     GET_WINDOWS_DRIVES: "getWinDrives",
     READ_DIR: "readDir",
     STAT: "stat",
-    READ_BIN_FILE: "readBinFile"
+    READ_BIN_FILE: "readBinFile",
+    WRITE_BIN_FILE: "writeBinFile"
 };
 
 const LARGE_DATA_THRESHOLD = 2*1024*1024; // 2MB
@@ -220,6 +221,21 @@ function _readBinaryFile(ws, metadata) {
         }).catch((err)=>_reportError(ws, metadata, err, `Failed to read file at path ${fullPath}`));
 }
 
+/**
+ *
+ * @param ws
+ * @param metadata
+ * @param dataBuffer {ArrayBuffer}
+ * @private
+ */
+function _writeBinaryFile(ws, metadata, dataBuffer) {
+    const fullPath = metadata.data.path;
+    fs.writeFile(fullPath, Buffer.from(dataBuffer))
+        .then( ()=> {
+            _sendResponse(ws, metadata);
+        }).catch((err)=>_reportError(ws, metadata, err, `Failed to write file at path ${fullPath}`));
+}
+
 function processWSCommand(ws, metadata, dataBuffer) {
     try{
         switch (metadata.commandCode) {
@@ -241,6 +257,9 @@ function processWSCommand(ws, metadata, dataBuffer) {
         case WS_COMMAND.READ_BIN_FILE:
             _readBinaryFile(ws, metadata);
             return;
+        case WS_COMMAND.WRITE_BIN_FILE:
+            _writeBinaryFile(ws, metadata, dataBuffer);
+            return;
         case WS_COMMAND.LARGE_DATA_SOCKET_ANNOUNCE:
             console.log("Large Data Transfer Socket established, socket Group: ", metadata.socketGroupID);
             ws.isLargeData = true;

dist/virtualfs.js.map

@@ -35,7 +35,8 @@ const WS_COMMAND = {
     GET_WINDOWS_DRIVES: "getWinDrives",
     READ_DIR: "readDir",
     STAT: "stat",
-    READ_BIN_FILE: "readBinFile"
+    READ_BIN_FILE: "readBinFile",
+    WRITE_BIN_FILE: "writeBinFile"
 };
 
 // each browser context belongs to a single socket group. So multiple websocket connections can be pooled
@@ -366,14 +367,26 @@ function readBinaryFile(path) {
     });
 }
 
+function writeBinaryFile(path, dataArrayBuffer) {
+    return new Promise((resolve, reject)=>{
+        const platformPath = Utils.getTauriPlatformPath(path);
+        _execCommand(WS_COMMAND.WRITE_BIN_FILE, {path: platformPath}, dataArrayBuffer)
+            .then(resolve)
+            .catch((err)=>{
+                reject(mapNodeTauriErrorMessage(err, path, 'Failed to write file: '));
+            });
+    });
+}
+
 const NodeTauriFS = {
     testNodeWsEndpoint,
     setNodeWSEndpoint,
     stopNodeWSEndpoint,
     getNodeWSEndpoint,
     readdir,
     stat,
-    readBinaryFile
+    readBinaryFile,
+    writeBinaryFile
 };
 
 module.exports = {

src-tauri/node-src/phoenix-fs.js

@@ -544,6 +544,7 @@ function readFile(path, options, callback) {
  */
 function writeFile (path, data, options, callback) {
     try{
+        path = globalObject.path.normalize(path);
         callback = arguments[arguments.length - 1];
         options = Utils.validateFileOptions(options, Constants.BINARY_ENCODING, 'w');
         let arrayBuffer;
@@ -561,9 +562,16 @@ function writeFile (path, data, options, callback) {
             }
             arrayBuffer = Utils.getEncodedArrayBuffer(data, options.encoding);
         }
-        path = globalObject.path.normalize(path);
-        const platformPath = Utils.getTauriPlatformPath(path);
+        if(!window.__TAURI__ || preferNodeWs) {
+            NodeTauriFS.writeBinaryFile(path, arrayBuffer)
+                .then(() => {
+                    callback(null);
+                })
+                .catch(callback);
+            return;
+        }
 
+        const platformPath = Utils.getTauriPlatformPath(path);
         __TAURI__.fs.writeBinaryFile(platformPath, arrayBuffer)
             .then(() => {
                 callback(null);