worker write tests

Author: abose

test/test.browser.js

@@ -39,6 +39,6 @@ describe('Browser main tests', function () {
                 writeSuccess = true;
             }
         });
-        waitForTrue(()=>{return writeSuccess;},1);
+        await waitForTrue(()=>{return writeSuccess;},1);
     });
 });

test/test.worker.js

@@ -58,10 +58,17 @@ describe('web worker tests', function () {
         expect(status).to.be.true;
     });
 
-    it('Should phoenix native read write in worker', async function () {
+    it('Should phoenix native write in worker', async function () {
         messageFromWorker = null;
-        worker.postMessage('RWMountCheck');
-        let status = await waitForWorkerMessage('RWMountCheck.ok', 1000);
+        worker.postMessage('writeMountCheck');
+        let status = await waitForWorkerMessage('writeMountCheck.ok', 1000);
+        expect(status).to.be.true;
+    });
+
+    it('Should phoenix native read in worker', async function () {
+        messageFromWorker = null;
+        worker.postMessage('readMountCheck');
+        let status = await waitForWorkerMessage('readMountCheck.ok', 1000);
         expect(status).to.be.true;
     });
 });

test/worker-task.js

@@ -16,22 +16,36 @@ function phoenixFsCheck() {
     }
 }
 
-function checkReadWriteInMountPath() {
-    fs.writeFile(`${mountTestPath}/a.txt`, 'hello World', 'utf8', (err)=>{
+function checkWriteInMountPath() {
+    console.log('worker: checkWriteInMountPath');
+    fs.writeFile(`${mountTestPath}/workerWrite.txt`, 'hello World', 'utf8', (err)=>{
         if(!err){
-            postMessage('RWMountCheck.ok');
+            postMessage('writeMountCheck.ok');
             return;
         }
         console.log(err);
     });
 }
 
+function checkReadInMountPath() {
+    console.log('worker: checkReadInMountPath');
+    fs.readFile(`${mountTestPath}/workerWrite.txt`,  (err, content)=>{
+        if(!err && content === 'hello World'){
+            postMessage('readMountCheck.ok');
+            return;
+        }
+        console.log('file read:', err, content);
+    });
+}
+
 self.addEventListener('message', (event) => {
-    console.log('Worker:', event);
+    console.log('Worker received: ', event);
     let command = event.data;
     switch (command) {
     case 'fsCheck': fsCheck(); break;
     case 'phoenixFsCheck': phoenixFsCheck(); break;
-    case 'RWMountCheck': checkReadWriteInMountPath(); break;
+    case 'writeMountCheck': checkWriteInMountPath(); break;
+    case 'readMountCheck': checkReadInMountPath(); break;
+    default: console.error('unknown worker command: ', command);
     }
 }, false);