wip: implement writeFile and writeFileSync

Signed-off-by: Miguel Molina <[email protected]>

src/fs.re

@@ -168,6 +168,36 @@ let writeString = (~fd, ~string, ~offset, ~length) =>
 let writeStringSync = (~fd, ~string, ~offset, ~length) =>
   Unix.write_substring(fd, string, offset, length);
 
-let writeFile = (~file, ~data, ~options) => ();
-
-let writeFileSync = (~file, ~data, ~options) => ();
+type writeFileOptions = {
+  encoding: option(string),
+  mode: option(asyncFilePerm),
+  flags: list(asyncOpenFlag)
+};
+
+let defaultWriteFileFlags = [Unix.O_CREAT, Unix.O_TRUNC];
+
+let writeFile = (~options={encoding: None, mode: None, flags: []}, ~file, ~data) => {
+  let flags = List.length(options.flags) < 1 ? defaultWriteFileFlags : options.flags;
+  let mode = RenodeUtils.withDefault(options.mode, ~default=438);
+  Lwt.bind(
+    Lwt_unix.openfile(file, flags, mode),
+    fd => Lwt.bind(
+      write(fd, data, 0, Bytes.length(data)),
+      (_) => close(fd)
+    )
+  )
+};
+
+type writeFileSyncOptions = {
+  encoding: option(string),
+  mode: option(syncFilePerm),
+  flags: list(syncOpenFlag)
+};
+
+let writeFileSync = (~options={encoding: None, mode: None, flags: []}, ~file, ~data) => {
+  let flags = List.length(options.flags) < 1 ? defaultWriteFileFlags : options.flags;
+  let mode = RenodeUtils.withDefault(options.mode, ~default=438);
+  let fd = Unix.openfile(file, flags, mode);
+  let _ = writeSync(fd, data, 0, Bytes.length(data));
+  closeSync(fd);
+};

src/fs.rei

@@ -363,24 +363,18 @@ let writeString:
 let writeStringSync:
   (~fd: syncFileDescr, ~string: string, ~offset: int, ~length: int) => int;
 
-[@ocaml.deprecated
-  {|
-    Fs.writeFile has yet to be implemented.
-    Please open a Work-In-Progress pull request if you are interested in contributing.
-    We will help answer questions and push you in the right direction.
+type writeFileOptions = {
+  encoding: option(string),
+  mode: option(asyncFilePerm),
+  flags: list(asyncOpenFlag)
+};
 
-    Repo URL: https://github.com/kennetpostigo/reason-node
-  |}
-]
-let writeFile: (~file: 'a, ~data: 'b, ~options: 'c) => unit;
+let writeFile: (~options: writeFileOptions=?, ~file: string, ~data: bytes) => Node.t(unit);
 
-[@ocaml.deprecated
-  {|
-    Fs.writeFileSync has yet to be implemented.
-    Please open a Work-In-Progress pull request if you are interested in contributing.
-    We will help answer questions and push you in the right direction.
+type writeFileSyncOptions = {
+  encoding: option(string),
+  mode: option(syncFilePerm),
+  flags: list(syncOpenFlag)
+};
 
-    Repo URL: https://github.com/kennetpostigo/reason-node
-  |}
-]
-let writeFileSync: (~file: 'a, ~data: 'b, ~options: 'c) => unit;
+let writeFileSync: (~options: writeFileSyncOptions=?, ~file: string, ~data: bytes) => unit;

src/renodeUtils.re

@@ -157,4 +157,9 @@ let iterPathUntil = (~condition, ~list, ~f) => {
     f(arr[position^], position, ! (position^ > (-1)));
     position := position^ - 1;
   };
+};
+
+let withDefault = (opt, ~default) => switch opt {
+| Some(v) => v
+| None => default
 };