fs read write tests

Author: abose

LICENSE-thirdParty

@@ -0,0 +1,17 @@
+## thirparty/buffer-min.js
+
+The buffer module from node.js, for the browser.
+
+
+Git: https://github.com/feross/buffer
+Copyright (C) Feross Aboukhadijeh, and other contributors.
+Originally forked from an MIT-licensed module by Romain Beauxis.
+MIT License
+
+## thirparty/idb-min.js
+ISC License (ISC)
+Copyright (c) 2016, Jake Archibald <jaffathecake@gmail.com>
+
+## thirparty/globmatch.js
+modified version of https://www.npmjs.com/package/minimatch
+ISC License (ISC)

dist/virtualfs.js

@@ -17,7 +17,9 @@
     "testDist": "npm run build && open-cli http://127.0.0.1:8080/test/index-dist.html",
     "test": "open-cli http://127.0.0.1:8080/test/index.html",
     "build-sw": "parcel build src/virtualfs.js --detailed-report",
+    "build-nonopt": "parcel build src/virtualfs.js --detailed-report --no-optimize",
     "build": "npm run eslint && npm run build-sw",
+    "build:dev": "npm run eslint && npm run build-nonopt",
     "predev": "npm run build",
     "serve": "http-server . -p 8080 -c-1",
     "bumpPatchVersion": "npm --no-git-tag-version version patch",

dist/virtualfs.js.map

@@ -17,7 +17,7 @@
  */
 
 // jshint ignore: start
-/*global BroadcastChannel*/
+/*global BroadcastChannel, globalObject*/
 /*eslint no-console: 0*/
 /*eslint strict: ["error", "global"]*/
 
@@ -37,7 +37,7 @@ function _setupBroadcastChannel() {
     }
     if(typeof BroadcastChannel === 'undefined'){
         /* eslint no-console: 0 */
-        console.warn('window.BroadcastChannel not supported. File system watch events across tabs wont be synced.');
+        console.warn('BroadcastChannel not supported. File system watch events across tabs wont be synced.');
         return;
     }
     _channel = new BroadcastChannel(WATCH_EVENT_NOTIFICATION);
@@ -60,7 +60,7 @@ function _isAnIgnoredPath(path, ignoreGlobList) {
 }
 
 function _isSameOrSubDirectory(parent, child) {
-    return !(window.path.relative(parent, child).startsWith('..'));
+    return !(globalObject.path.relative(parent, child).startsWith('..'));
 }
 
 // event{ path, eventName}
@@ -97,7 +97,7 @@ function watch(path, ignoreGlobList, changeCallback, callback) {
 }
 
 function _triggerEvent(path, eventType) {
-    let pathLib = window.path;
+    let pathLib = globalObject.path;
     path = pathLib.normalize(path);
     let event = {
         event: eventType,

package.json

@@ -1,6 +1,7 @@
 /*global globalObject, virtualfs*/
 
 const Filer = require('filer');
+const buffer = require('./thirdparty/buffer-min');
 
 let virtualGlobalObject = {};
 let env = 'browser';
@@ -27,6 +28,7 @@ setupGlobalObject();
 
 const urlParams = new URLSearchParams(location.search);
 globalObject.Filer = Filer;
+globalObject.buffer = buffer;
 globalObject.virtualfs = {
     urlParams : urlParams,
     debugMode : urlParams.get('debug'),

src/fslib_watch.js

@@ -19,10 +19,37 @@
 
 <script src="../dist/virtualfs.js"></script>
 <script src="testInit.js"></script>
-<script src="test.worker.js"></script>
 <script src="test.browser.js"></script>
+<script src="test.worker.js"></script>
 <script class="mocha-exec">
-    mocha.run();
+    function openFolderAndRunTests() {
+        function mountNative() {
+            fs.mountNativeFolder((err, mountTestPath)=>{
+                if(!mountTestPath[0]) return;
+                window.mountTestPath = mountTestPath[0];
+                localStorage.setItem('mountTestPath', mountTestPath[0]);
+                document.getElementById('openFolderButton').style = "display:none";
+                mocha.run();
+            });
+        }
+
+        let mountTestPath = localStorage.getItem('mountTestPath');
+        if(!mountTestPath) {
+            mountNative();
+            return;
+        }
+        fs.readdir(mountTestPath, (err, contents)=>{
+            console.log("Checking if any mounted paths exists: ",err, contents);
+            if(err){
+                mountNative();
+                return;
+            }
+            window.mountTestPath = mountTestPath;
+            document.getElementById('openFolderButton').style = "display:none";
+            mocha.run();
+        });
+    }
 </script>
+<button id="openFolderButton" onclick="openFolderAndRunTests()">Open any blank folder to start tests</button>
 </body>
 </html>

src/thirdparty/buffer-min.js

@@ -1,6 +1,25 @@
 /* global expect , Filer, fs*/
 
 describe('Browser main tests', function () {
+    async function waitForTrue(checkFn, timeoutMs) {
+        let startTime = Date.now();
+        return new Promise((resolve)=>{
+            let interVal;
+            function checkMessage() {
+                if(checkFn() === true){
+                    resolve(true);
+                    clearInterval(interVal);
+                }
+                let elapsedTime = Date.now() - startTime;
+                if(elapsedTime > timeoutMs){
+                    resolve(false);
+                    clearInterval(interVal);
+                }
+            }
+            interVal = setInterval(checkMessage, 10);
+        });
+    }
+
     it('Should load Filer in browser', function () {
         expect(Filer).to.exist;
         expect(Filer.fs).to.exist;
@@ -12,4 +31,14 @@ describe('Browser main tests', function () {
         expect(fs).to.exist;
         expect(fs.name).to.equal('phoenixFS');
     });
+
+    it('Should phoenix native read write in browser', async function () {
+        let writeSuccess = false;
+        fs.writeFile(`${window.mountTestPath}/browserWrite.txt`, 'hello World', 'utf8', (err)=>{
+            if(!err){
+                writeSuccess = true;
+            }
+        });
+        waitForTrue(()=>{return writeSuccess;},1);
+    });
 });

src/virtualfs.js

@@ -1,13 +1,29 @@
-/* global expect */
+/* global expect,fs */
 
 describe('web worker tests', function () {
-    let worker = new Worker('worker-task.js?debug=true');
-    console.log(worker);
+    let worker;
     let messageFromWorker = null;
-    worker.onmessage= function (event) {
-        console.log('From Worker:', event);
-        messageFromWorker = event.data;
-    };
+    async function _requestWritePerm() {
+        return new Promise((resolve, reject)=>{
+            fs.writeFile(`${window.mountTestPath}/forTestPermissionOnFolder.txt`, 'hello World', 'utf8', (err)=>{
+                if(err){
+                    console.log(err);
+                    reject(err);
+                } else {
+                    resolve();
+                }
+            });
+        });
+    }
+    before(async function () {
+        await _requestWritePerm();
+        worker = new Worker(`worker-task.js?debug=true&mountTestPath=${window.mountTestPath}`);
+        console.log(worker);
+        worker.onmessage= function (event) {
+            console.log('From Worker:', event);
+            messageFromWorker = event.data;
+        };
+    });
 
     async function waitForWorkerMessage(message, timeoutMs) {
         let startTime = Date.now();
@@ -41,4 +57,11 @@ describe('web worker tests', function () {
         let status = await waitForWorkerMessage('phoenixFsCheck.ok', 1000);
         expect(status).to.be.true;
     });
+
+    it('Should phoenix native read write in worker', async function () {
+        messageFromWorker = null;
+        worker.postMessage('RWMountCheck');
+        let status = await waitForWorkerMessage('RWMountCheck.ok', 1000);
+        expect(status).to.be.true;
+    });
 });