test(fileop) server: copy: improve coverage

Author: coderaiser

.gitignore

@@ -1,9 +1,10 @@
+.nyc_output
 yarn-error.log
 yarn.lock
 package-lock.json
 node_modules
 npm-debug.log
-.nyc_output
+coverage
 
 dist
 dist-dev

.nycrc.json

@@ -0,0 +1,17 @@
+{
+    "check-coverage": true,
+    "all": true,
+    "exclude": [
+        "**/dist**",
+        "**/*.spec.js",
+        "**/fixture",
+        "test",
+        ".*.{js,mjs}",
+        "webpack**",
+        "coverage"
+    ],
+    "branches": 100,
+    "lines": 100,
+    "functions": 100,
+    "statements": 100
+}

test/lib/emitters.js

@@ -1,6 +1,7 @@
 'use strict';
 
 const {EventEmitter} = require('events');
+const wraptile = require('wraptile');
 
 module.exports.rawErrorEmitter = (from) => {
     const emitter = new EventEmitter();
@@ -66,3 +67,16 @@ module.exports.endEmitter = () => {
 
     return emitter;
 };
+
+module.exports.customEmitter = wraptile((fns) => {
+    const emitter = new EventEmitter();
+    
+    emitter.pause = fns.pause;
+    emitter.continue = fns.continue;
+    
+    process.nextTick(() => {
+        emitter.emit('end');
+    });
+    
+    return emitter;
+});

test/server/copy.js

@@ -2,7 +2,7 @@
 
 const {once} = require('events');
 
-const test = require('supertape');
+const {test, stub} = require('supertape');
 const mock = require('mock-require');
 const clear = require('clear-module');
 
@@ -11,6 +11,7 @@ const {
     errorEmitter,
     progressEmitter,
     fileEmitter,
+    customEmitter,
 } = require('../lib/emitters');
 
 const clearFileop = require('../lib/clear');
@@ -176,6 +177,41 @@ test('operate: copy: continue', async (t) => {
     t.end();
 });
 
+test('operate: copy: pause', async (t) => {
+    clearFileop();
+    clear(copyPath);
+    
+    const from = '/';
+    const to = '/world';
+    const names = ['abc'];
+    
+    const pause = stub();
+    mock(copyPath, customEmitter({
+        pause,
+        continue: stub(),
+    }));
+    
+    const connect = require(connectPath);
+    
+    const {
+        socket,
+        done,
+    } = await connect();
+    
+    socket.emit('operation', 'copy', from, to, names);
+    
+    const [id] = await once(socket, 'id');
+    socket.emit(`${id}#start`);
+    socket.emit(`${id}#pause`);
+    socket.emit(`${id}#continue`);
+    await once(socket, `${id}#end`);
+    
+    done();
+    
+    t.calledWithNoArgs(pause);
+    t.end();
+});
+
 test('operate: copy: error: root', async (t) => {
     clearFileop();
     clear(isRootPath);