From 85efed77b3654c1586cba08406a74cf411b21bae Mon Sep 17 00:00:00 2001 From: jeromewu Date: Wed, 6 Nov 2019 23:30:24 +0000 Subject: [PATCH] Add Worker.mkdir() --- docs/api.md | 11 ++++++++++- src/createWorker.js | 7 +++++++ src/worker-script/index.js | 10 ++++++++++ 3 files changed, 27 insertions(+), 1 deletion(-) diff --git a/docs/api.md b/docs/api.md index 00d7bdd..4c7b6ba 100644 --- a/docs/api.md +++ b/docs/api.md @@ -1 +1,10 @@ -WIP +API +=== + +- createWorker() + - Worker.write() + - Worker.read() + - Worker.mkdir() + - Worker.remove() + - Worker.transcode() + - Worker.run() diff --git a/src/createWorker.js b/src/createWorker.js index 388792b..def3bc3 100644 --- a/src/createWorker.js +++ b/src/createWorker.js @@ -91,6 +91,12 @@ module.exports = (_options = {}) => { })) ); + const mkdir = (path, jobId) => ( + startJob(createJob({ + id: jobId, action: 'mkdir', payload: { path }, + })) + ); + const run = (args, jobId) => ( startJob(createJob({ id: jobId, action: 'run', payload: { args }, @@ -139,6 +145,7 @@ module.exports = (_options = {}) => { transcode, read, remove, + mkdir, run, terminate, }; diff --git a/src/worker-script/index.js b/src/worker-script/index.js index 29caa4b..3eb95b5 100644 --- a/src/worker-script/index.js +++ b/src/worker-script/index.js @@ -89,6 +89,15 @@ const remove = ({ res.resolve({ message: `Delete ${path}` }); }; +const mkdir = ({ + payload: { + path, + }, +}, res) => { + Module.FS.mkdir(path); + res.resolve({ message: `Create Directory ${path}` }); +}; + const run = ({ payload: { args, @@ -118,6 +127,7 @@ exports.dispatchHandlers = (packet, send) => { transcode, read, remove, + mkdir, run, })[packet.action](packet, res); } catch (err) {