Skip to content

Commit 9deba4e

Browse files
committed
Add Worker.mkdir()
1 parent 4718fa1 commit 9deba4e

File tree

3 files changed

+27
-1
lines changed

3 files changed

+27
-1
lines changed

docs/api.md

Lines changed: 10 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1,10 @@
1-
WIP
1+
API
2+
===
3+
4+
- createWorker()
5+
- Worker.write()
6+
- Worker.read()
7+
- Worker.mkdir()
8+
- Worker.remove()
9+
- Worker.transcode()
10+
- Worker.run()

src/createWorker.js

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -91,6 +91,12 @@ module.exports = (_options = {}) => {
9191
}))
9292
);
9393

94+
const mkdir = (path, jobId) => (
95+
startJob(createJob({
96+
id: jobId, action: 'mkdir', payload: { path },
97+
}))
98+
);
99+
94100
const run = (args, jobId) => (
95101
startJob(createJob({
96102
id: jobId, action: 'run', payload: { args },
@@ -139,6 +145,7 @@ module.exports = (_options = {}) => {
139145
transcode,
140146
read,
141147
remove,
148+
mkdir,
142149
run,
143150
terminate,
144151
};

src/worker-script/index.js

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -89,6 +89,15 @@ const remove = ({
8989
res.resolve({ message: `Delete ${path}` });
9090
};
9191

92+
const mkdir = ({
93+
payload: {
94+
path,
95+
},
96+
}, res) => {
97+
Module.FS.mkdir(path);
98+
res.resolve({ message: `Create Directory ${path}` });
99+
};
100+
92101
const run = ({
93102
payload: {
94103
args,
@@ -118,6 +127,7 @@ exports.dispatchHandlers = (packet, send) => {
118127
transcode,
119128
read,
120129
remove,
130+
mkdir,
121131
run,
122132
})[packet.action](packet, res);
123133
} catch (err) {

0 commit comments

Comments
 (0)