Support symlink follow control

README.mbt.md

@@ -74,7 +74,7 @@ test "copy text between files" {
     e => raise e
   }
   @miniio.mkdir(dir)
-  defer ignore(try? @miniio.rmdir(dir, recursive=true))
+  defer (@miniio.rmdir(dir, recursive=true) catch { _ => () })
 
   @miniio.write_text_file(dir + "/input.txt", "hello\n")
   @miniio.copy_file(dir + "/input.txt", dir + "/output.txt")
@@ -92,7 +92,7 @@ test "append log file" {
     e => raise e
   }
   @miniio.mkdir(dir)
-  defer ignore(try? @miniio.rmdir(dir, recursive=true))
+  defer (@miniio.rmdir(dir, recursive=true) catch { _ => () })
 
   let path = dir + "/tool.log"
   @miniio.write_text_file(path, "start\n")
@@ -111,7 +111,7 @@ test "read and write json" {
     e => raise e
   }
   @miniio.mkdir(dir)
-  defer ignore(try? @miniio.rmdir(dir, recursive=true))
+  defer (@miniio.rmdir(dir, recursive=true) catch { _ => () })
 
   let path = dir + "/manifest.json"
   @miniio.write_json_file(path, { "name": "miniio", "portable": true })

example/cli_tools/moon.mod

@@ -0,0 +1,9 @@
+name = "moonbit-community/miniio-example-cli-tools"
+
+version = "0.1.0"
+
+import {
+  "moonbit-community/miniio@0.2.0",
+}
+
+preferred_target = "wasm"

example/lottie_manifest/moon.mod

@@ -0,0 +1,10 @@
+name = "moonbit-community/miniio-example-lottie-manifest"
+
+version = "0.1.0"
+
+import {
+  "moonbit-community/miniio@0.2.0",
+  "cg-zhou/moon_lottie@0.3.0",
+}
+
+preferred_target = "wasm"

example/lottie_manifest/moon.pkg

@@ -1,6 +1,6 @@
 import {
   "moonbit-community/miniio",
-  "cg-zhou/moon_lottie/lib/parser" @parser,
+  "cg-zhou/moon_lottie/lib/parser",
   "moonbitlang/core/json",
 }
 

example/morm_query/moon.mod

@@ -0,0 +1,10 @@
+name = "moonbit-community/miniio-example-morm-query"
+
+version = "0.1.0"
+
+import {
+  "moonbit-community/miniio@0.2.0",
+  "oboard/morm@0.3.15",
+}
+
+preferred_target = "wasm"

example/morm_query/moon.pkg

@@ -1,7 +1,7 @@
 import {
   "moonbit-community/miniio",
   "oboard/morm",
-  "oboard/morm/engine" @engine,
+  "oboard/morm/engine",
 }
 
 supported_targets = "wasm"

fd.mbt

@@ -42,16 +42,16 @@ pub fn File::tell(self : File) -> UInt64 raise Errno {
 }
 
 ///|
-pub impl @io.Reader for File with _get_internal_buffer(self) {
+pub impl @io.Reader for File with fn _get_internal_buffer(self) {
   self.read_buf
 }
 
 ///|
-pub impl @io.Reader for File with _direct_read(self, buf, offset~, max_len~) {
+pub impl @io.Reader for File with fn _direct_read(self, buf, offset~, max_len~) {
   wrap(() => self.raw.read(buf, offset~, max_len~))
 }
 
 ///|
-pub impl @io.Writer for File with write_once(self, data) {
+pub impl @io.Writer for File with fn write_once(self, data) {
   wrap(() => self.raw.write_once(data))
 }

fs.mbt

@@ -38,14 +38,21 @@ pub fn open(
   mode? : Mode = ReadOnly,
   append? : Bool = false,
   create_mode? : CreateMode = OpenExisting,
+  follow_symlink? : Bool = true,
 ) -> File raise Errno {
   {
     raw: wrap(() => {
+      let lookup_flags = if follow_symlink {
+        @raw.LookupFlags::new().symlink_follow()
+      } else {
+        @raw.LookupFlags::new()
+      }
       @raw.open(
         path,
         mode=mode.to_raw(),
         append~,
         create_mode=create_mode.to_raw(),
+        lookup_flags~,
       )
     }),
     read_buf: @io.ReaderBuffer::new(),
@@ -54,7 +61,7 @@ pub fn open(
 
 ///|
 pub fn create(path : StringView) -> File raise Errno {
-  { raw: wrap(() => @raw.create(path)), read_buf: @io.ReaderBuffer::new() }
+  open(path, mode=WriteOnly, create_mode=CreateOrTruncate)
 }
 
 ///|
@@ -85,8 +92,14 @@ pub fn readdir(
   path : StringView,
   include_hidden? : Bool = true,
   sort? : Bool = false,
+  follow_symlink? : Bool = true,
 ) -> Array[String] raise Errno {
-  let result = wrap(() => @raw.readdir_names(path))
+  let lookup_flags = if follow_symlink {
+    @raw.LookupFlags::new().symlink_follow()
+  } else {
+    @raw.LookupFlags::new()
+  }
+  let result = wrap(() => @raw.readdir_names(path, lookup_flags~))
   let result = if include_hidden {
     result
   } else {
@@ -147,7 +160,13 @@ pub fn is_file(path : StringView) -> Bool raise Errno {
 ///|
 pub fn rmdir(path : StringView, recursive? : Bool = false) -> Unit raise Errno {
   if recursive {
-    for entry in readdir(path, include_hidden=true, sort=false) {
+    for
+      entry in readdir(
+        path,
+        include_hidden=true,
+        sort=false,
+        follow_symlink=false,
+      ) {
       let entry_path = path.to_owned() + "/" + entry
       remove(entry_path) catch {
         Notempty => rmdir(entry_path, recursive=true)