summaryrefslogtreecommitdiff
path: root/runtime/rt/40_fs_events.js
diff options
context:
space:
mode:
authorBartek IwaƄczuk <biwanczuk@gmail.com>2020-12-13 19:45:53 +0100
committerGitHub <noreply@github.com>2020-12-13 19:45:53 +0100
commit2e74f164b6dcf0ecbf8dd38fba9fae550d784bd0 (patch)
tree61abe8e09d5331ace5d9de529f0e2737a8e05dbb /runtime/rt/40_fs_events.js
parent84ef9bd21fb48fb6b5fbc8dafc3de9f361bade3b (diff)
refactor: deno_runtime crate (#8640)
This commit moves Deno JS runtime, ops, permissions and inspector implementation to new "deno_runtime" crate located in "runtime/" directory. Details in "runtime/README.md". Co-authored-by: Ryan Dahl <ry@tinyclouds.org>
Diffstat (limited to 'runtime/rt/40_fs_events.js')
-rw-r--r--runtime/rt/40_fs_events.js52
1 files changed, 52 insertions, 0 deletions
diff --git a/runtime/rt/40_fs_events.js b/runtime/rt/40_fs_events.js
new file mode 100644
index 000000000..a36adecba
--- /dev/null
+++ b/runtime/rt/40_fs_events.js
@@ -0,0 +1,52 @@
+// Copyright 2018-2020 the Deno authors. All rights reserved. MIT license.
+
+((window) => {
+ const core = window.Deno.core;
+ const { errors } = window.__bootstrap.errors;
+
+ class FsWatcher {
+ #rid = 0;
+
+ constructor(paths, options) {
+ const { recursive } = options;
+ this.#rid = core.jsonOpSync("op_fs_events_open", { recursive, paths });
+ }
+
+ get rid() {
+ return this.#rid;
+ }
+
+ async next() {
+ try {
+ return await core.jsonOpAsync("op_fs_events_poll", {
+ rid: this.rid,
+ });
+ } catch (error) {
+ if (error instanceof errors.BadResource) {
+ return { value: undefined, done: true };
+ }
+ throw error;
+ }
+ }
+
+ return(value) {
+ core.close(this.rid);
+ return Promise.resolve({ value, done: true });
+ }
+
+ [Symbol.asyncIterator]() {
+ return this;
+ }
+ }
+
+ function watchFs(
+ paths,
+ options = { recursive: true },
+ ) {
+ return new FsWatcher(Array.isArray(paths) ? paths : [paths], options);
+ }
+
+ window.__bootstrap.fsEvents = {
+ watchFs,
+ };
+})(this);