feature: fileop: add ability to handle abort

Author: coderaiser

test/lib/emitters.js

@@ -80,3 +80,13 @@ module.exports.customEmitter = wraptile((fns) => {
 
     return emitter;
 });
+
+module.exports.abortEmitter = (from, to, names = to) => {
+    const emitter = new EventEmitter();
+    
+    emitter.abort = () => {
+        emitter.emit('abort');
+    };
+    
+    return emitter;
+};

test/server/remove.js

@@ -5,8 +5,9 @@ const {once} = require('events');
 const test = require('supertape');
 const mock = require('mock-require');
 const clear = require('clear-module');
+const wait = require('@iocmd/wait');
 
-const {errorEmitter} = require('../lib/emitters');
+const {errorEmitter, abortEmitter} = require('../lib/emitters');
 
 const clearFileop = require('../lib/clear');
 
@@ -43,3 +44,34 @@ test('operate: remove: error', async (t) => {
     t.end();
 });
 
+test('operate: remove: abort', async (t) => {
+    clearFileop();
+    clear(removePath);
+    
+    const from = '/hello';
+    const names = ['abc'];
+    
+    mock(removePath, abortEmitter);
+    const connect = require(connectPath);
+    
+    const {
+        socket,
+        done,
+    } = await connect();
+    
+    socket.emit('operation', 'remove', from, names);
+    const [id] = await once(socket, 'id');
+    
+    socket.emit(`${id}#start`);
+    const emit = socket.emit.bind(socket);
+    
+    await Promise.all([
+        once(socket, `${id}#end`),
+        wait(emit, `${id}#abort`),
+    ]);
+    
+    done();
+    
+    t.pass('abort');
+    t.end();
+});