aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--stdlib/source/lux/control/monad.lux21
-rw-r--r--stdlib/source/lux/control/security/capability.lux6
-rw-r--r--stdlib/source/lux/world/file.lux350
-rw-r--r--stdlib/test/test/lux/world/file.lux228
4 files changed, 363 insertions, 242 deletions
diff --git a/stdlib/source/lux/control/monad.lux b/stdlib/source/lux/control/monad.lux
index 6f07ceb0a..6e0992444 100644
--- a/stdlib/source/lux/control/monad.lux
+++ b/stdlib/source/lux/control/monad.lux
@@ -127,6 +127,27 @@
(!/map (|>> (#.Cons _x)) (recur xs'))))
!/join)))))
+(def: #export (filter Monad<!> f)
+ {#.doc "Filter the values in a list with a monadic function."}
+ (All [! a b]
+ (-> (Monad !) (-> a (! Bit)) (List a)
+ (! (List a))))
+ (let [(^open "!/.") Monad<!>]
+ (function (recur xs)
+ (case xs
+ #.Nil
+ (!/wrap #.Nil)
+
+ (#.Cons head xs')
+ (|> (f head)
+ (!/map (function (_ verdict)
+ (!/map (function (_ tail)
+ (if verdict
+ (#.Cons head tail)
+ tail))
+ (recur xs'))))
+ !/join)))))
+
(def: #export (fold monad f init xs)
{#.doc "Fold a list with a monadic function."}
(All [M a b]
diff --git a/stdlib/source/lux/control/security/capability.lux b/stdlib/source/lux/control/security/capability.lux
new file mode 100644
index 000000000..572b52f3b
--- /dev/null
+++ b/stdlib/source/lux/control/security/capability.lux
@@ -0,0 +1,6 @@
+(.module:
+ [lux #*])
+
+(signature: #export (Capability input output)
+ (: (-> input output)
+ perform))
diff --git a/stdlib/source/lux/world/file.lux b/stdlib/source/lux/world/file.lux
index 9b53e4453..e0975799d 100644
--- a/stdlib/source/lux/world/file.lux
+++ b/stdlib/source/lux/world/file.lux
@@ -4,20 +4,22 @@
["." monad (#+ Monad do)]
["ex" exception (#+ Exception exception:)]
[security
- ["." taint (#+ Dirty taint)]]]
+ ["." taint (#+ Dirty taint)]
+ ["." capability (#+ Capability)]]]
[data
["." maybe]
- ["." error (#+ Error)]
+ ["." error (#+ Error) ("error/." Functor<Error>)]
["." text
format]
[collection
- ["." array (#+ Array)]]]
+ ["." array (#+ Array)]
+ ["." list ("list/." Functor<List>)]]]
[time
["." instant (#+ Instant)]
["." duration]]
[world
["." binary (#+ Binary)]]
- ["." io (#+ IO)]
+ ["." io (#+ IO) ("io/." Functor<IO>)]
[concurrency
["." promise (#+ Promise)]]
[host (#+ import:)]
@@ -25,80 +27,119 @@
[compiler
["." host]]]])
-(type: #export File Text)
+(type: #export Path Text)
-(type: #export Permission
- #Read
- #Write
- #Execute)
+(type: #export (Can-Open ! capability)
+ (Capability Path (! (Error (capability !)))))
-(signature: #export (System !)
- (do-template [<name>]
- [(: (-> Binary File (! (Error Any)))
- <name>)]
+(do-template [<capability> <input> <output>]
+ [(type: #export (<capability> !)
+ (Capability <input> (! (Error <output>))))]
- [append]
- [write])
+ [Can-Edit [Binary] Any]
+ [Can-Delete [] Any]
+ )
- (do-template [<name> <output>]
- [(: (-> File (! (Error <output>)))
- <name>)]
+(type: #export (Can-Query ! o)
+ (Capability [] (! (Error o))))
- [read (Dirty Binary)]
- [size Nat]
- [files (List File)]
- [last-modified Instant])
+(type: #export (Can-Modify ! i)
+ (Capability [i] (! (Error Any))))
- (do-template [<name>]
- [(: (-> File (! (Error Bit)))
+(signature: #export (File !)
+ (do-template [<name> <output>]
+ [(: (Can-Query ! <output>)
<name>)]
- [file?]
- [directory?]
+ [size Nat]
+ [last-modified Instant]
+ [can-execute? Bit]
+ [content (Dirty Binary)]
)
- (: (-> Permission File (! (Error Bit)))
- can?)
+ (: (Can-Open ! File)
+ move)
- (do-template [<name>]
- [(: (-> File (! (Error Any)))
+ (do-template [<name> <input>]
+ [(: (Can-Modify ! <input>)
<name>)]
- [make-directory]
- [delete]
+ [modify Instant]
+ [over-write Binary]
)
- (: (-> File File (! (Error Any)))
- move)
+ (: (Can-Edit !)
+ append)
+
+ (: (Can-Delete !)
+ delete)
+ )
- (: (-> Instant File (! (Error Any)))
- modify)
+(signature: #export (Directory !)
+ (: (Can-Query ! (List (File !)))
+ files)
+
+ (: (Can-Query ! (List (Directory !)))
+ directories)
+
+ (: (Can-Delete !)
+ discard))
+
+(signature: #export (System !)
+ (do-template [<name> <capability>]
+ [(: (Can-Open ! <capability>)
+ <name>)]
+
+ [file File]
+ [create-file File]
+ [directory Directory]
+ [create-directory Directory]
+ )
(: Text
separator)
)
-(def: #export (async system)
- (-> (System IO) (System Promise))
+(def: (async-file file)
+ (-> (File IO) (File Promise))
(`` (structure
(~~ (do-template [<name>]
- [(def: (<name> parameter file)
- (promise.future (:: system <name> parameter file)))]
+ [(def: <name> (|>> (:: file <name>) promise.future))]
- [append] [write]
- [can?] [move] [modify]))
+ [size] [last-modified] [can-execute?] [content]
+ [modify] [over-write]
+ [append]
+ [delete]))
- (~~ (do-template [<name>]
- [(def: <name> (|>> (:: system <name>) promise.future))]
+ (def: move (|>> (:: file move) (io/map (error/map async-file)) promise.future)))))
+
+(def: (async-directory directory)
+ (-> (Directory IO) (Directory Promise))
+ (`` (structure (~~ (do-template [<name> <async>]
+ [(def: <name> (|>> (:: directory <name>)
+ (io/map (error/map (list/map <async>)))
+ promise.future))]
+
+ [files async-file]
+ [directories async-directory]))
- [read] [size] [files] [last-modified]
- [file?] [directory?]
- [make-directory] [delete]))
+ (def: discard (|>> (:: directory discard) promise.future)))))
+
+(def: #export (async system)
+ (-> (System IO) (System Promise))
+ (`` (structure
+ (~~ (do-template [<name> <async>]
+ [(def: <name> (|>> (:: system <name>) (io/map (error/map <async>)) promise.future))]
+
+ [file async-file]
+ [create-file async-file]
+ [directory async-directory]
+ [create-directory async-directory]))
(def: separator (:: system separator)))))
(def: #export (un-nest System<!> file)
- (All [!] (-> (System !) File (Maybe [File Text])))
+ (All [!] (-> (System !) Path (Maybe [Path Text])))
(case (text.last-index-of (:: System<!> separator) file)
#.None
#.None
@@ -109,26 +150,42 @@
(#.Some [parent child]))))
(def: #export (nest System<!> [parent child])
- (All [!] (-> (System !) [File Text] File))
+ (All [!] (-> (System !) [Path Text] Path))
(format parent (:: System<!> separator) child))
(do-template [<name>]
- [(exception: #export (<name> {file File})
- (ex.report ["File" file]))]
+ [(exception: #export (<name> {file Path})
+ (ex.report ["Path" file]))]
+
+ [cannot-create-file]
+ [cannot-find-file]
+ [cannot-delete-file]
+ [cannot-create-directory]
+ [cannot-find-directory]
+ [cannot-discard-directory]
+
[cannot-read-all-data]
[not-a-directory]
- [cannot-make-directory]
- [cannot-delete]
)
-(exception: #export (cannot-move {target File} {source File})
+(exception: #export (cannot-move {target Path} {source Path})
(ex.report ["Source" source]
["Target" target]))
-(exception: #export (cannot-modify {instant Instant} {file File})
+(exception: #export (cannot-modify {instant Instant} {file Path})
(ex.report ["Instant" (%instant instant)]
- ["File" file]))
+ ["Path" file]))
+
+(template: (!delete path exception)
+ (do io.Monad<IO>
+ [outcome (java/io/File::delete (java/io/File::new path))]
+ (case outcome
+ (#error.Success #1)
+ (wrap (#error.Success []))
+
+ _
+ (io.throw exception [path]))))
(`` (for {(~~ (static host.jvm))
(as-is (import: #long java/io/File
@@ -136,7 +193,8 @@
(~~ (do-template [<name>]
[(<name> [] #io #try boolean)]
- [exists] [mkdirs] [delete]
+ [createNewFile] [mkdir]
+ [exists] [delete]
[isFile] [isDirectory]
[canRead] [canWrite] [canExecute]))
@@ -164,105 +222,137 @@
(import: java/io/FileInputStream
(new [java/io/File] #io #try))
- (structure: #export _ (System IO)
+ (structure: (File<IO> path)
+ (-> Path (File IO))
+
(do-template [<name> <flag>]
- [(def: (<name> data file)
+ [(def: (<name> data)
(do io.Monad<Process>
- [stream (FileOutputStream::new (java/io/File::new file) <flag>)
+ [stream (FileOutputStream::new (java/io/File::new path) <flag>)
_ (OutputStream::write data stream)
_ (OutputStream::flush stream)]
(AutoCloseable::close stream)))]
- [append #1]
- [write #0]
+ [over-write #0]
+ [append #1]
)
- (def: (read file)
+ (def: (content _)
(do io.Monad<Process>
- [#let [file' (java/io/File::new file)]
- size (java/io/File::length file')
+ [#let [file (java/io/File::new path)]
+ size (java/io/File::length file)
#let [data (binary.create (.nat size))]
- stream (FileInputStream::new file')
+ stream (FileInputStream::new file)
bytes-read (InputStream::read data stream)
_ (AutoCloseable::close stream)]
(if (i/= size bytes-read)
(wrap (taint data))
- (io.io (ex.throw cannot-read-all-data file)))))
-
- (def: size
- (|>> java/io/File::new
- java/io/File::length
- (:: io.Monad<Process> map .nat)))
-
- (def: (files dir)
- (do io.Monad<Process>
- [?files (java/io/File::listFiles (java/io/File::new dir))]
- (case ?files
- (#.Some files)
- (monad.map @ (|>> java/io/File::getAbsolutePath)
- (array.to-list files))
-
- #.None
- (io.throw not-a-directory dir))))
-
- (do-template [<name> <method>]
- [(def: <name> (|>> java/io/File::new <method>))]
-
- [file? java/io/File::isFile]
- [directory? java/io/File::isDirectory]
+ (io.io (ex.throw cannot-read-all-data path)))))
+
+ (def: (size _)
+ (|> path
+ java/io/File::new
+ java/io/File::length
+ (:: io.Monad<Process> map .nat)))
+
+ (def: (last-modified _)
+ (|> path
+ java/io/File::new
+ (java/io/File::lastModified)
+ (:: io.Monad<Process> map (|>> duration.from-millis instant.absolute))))
+
+ (def: (can-execute? _)
+ (|> path
+ java/io/File::new
+ java/io/File::canExecute))
+
+ (def: (move destination)
+ (do io.Monad<IO>
+ [outcome (java/io/File::renameTo (java/io/File::new destination)
+ (java/io/File::new path))]
+ (case outcome
+ (#error.Success #1)
+ (wrap (#error.Success (File<IO> destination)))
+
+ _
+ (io.throw cannot-move [destination path]))))
+
+ (def: (modify time-stamp)
+ (do io.Monad<IO>
+ [outcome (java/io/File::setLastModified (|> time-stamp instant.relative duration.to-millis)
+ (java/io/File::new path))]
+ (case outcome
+ (#error.Success #1)
+ (wrap (#error.Success []))
+
+ _
+ (io.throw cannot-modify [time-stamp path]))))
+
+ (def: (delete _)
+ (!delete path cannot-delete-file)))
+
+ (structure: (Directory<IO> path)
+ (-> Path (Directory IO))
+
+ (do-template [<name> <method> <capability>]
+ [(def: (<name> _)
+ (do io.Monad<Process>
+ [?children (java/io/File::listFiles (java/io/File::new path))]
+ (case ?children
+ (#.Some children)
+ (|> children
+ array.to-list
+ (monad.filter @ (|>> <method>))
+ (:: @ map (monad.map @ (|>> java/io/File::getAbsolutePath (:: @ map <capability>))))
+ (:: @ join))
+
+ #.None
+ (io.throw not-a-directory [path]))))]
+
+ [files java/io/File::isFile File<IO>]
+ [directories java/io/File::isDirectory Directory<IO>]
)
- (def: (can? permission file)
- (let [jvm-file (java/io/File::new file)]
- (case permission
- #Read (java/io/File::canRead jvm-file)
- #Write (java/io/File::canWrite jvm-file)
- #Execute (java/io/File::canExecute jvm-file))))
-
- (def: last-modified
- (|>> java/io/File::new
- (java/io/File::lastModified)
- (:: io.Monad<Process> map (|>> duration.from-millis instant.absolute))))
-
- (do-template [<name> <exception> <method>]
- [(def: (<name> subject)
- (do io.Monad<IO>
- [outcome (<method> (java/io/File::new subject))]
- (case outcome
- (#error.Success #1)
- (wrap (#error.Success []))
-
- _
- (io.throw <exception> [subject]))))]
-
- [make-directory cannot-make-directory java/io/File::mkdirs]
- [delete cannot-delete java/io/File::delete]
- )
+ (def: (discard _)
+ (!delete path cannot-discard-directory)))
- (do-template [<name> <exception> <method> <parameter-pre>]
- [(def: (<name> parameter subject)
+ (structure: #export _ (System IO)
+ (do-template [<name> <method> <capability> <exception>]
+ [(def: (<name> path)
(do io.Monad<IO>
- [outcome (<method> (|> parameter <parameter-pre>)
- (java/io/File::new subject))]
+ [#let [file (java/io/File::new path)]
+ outcome (<method> file)]
(case outcome
(#error.Success #1)
- (wrap (#error.Success []))
+ (wrap (#error.Success (<capability> path)))
_
- (io.throw <exception> [parameter subject]))))]
+ (wrap (ex.throw <exception> [path])))))]
- [move cannot-move java/io/File::renameTo java/io/File::new]
- [modify cannot-modify java/io/File::setLastModified (<| duration.to-millis instant.relative)]
+ [file java/io/File::isFile ..File<IO> cannot-find-file]
+ [create-file java/io/File::createNewFile ..File<IO> cannot-create-file]
+ [directory java/io/File::isDirectory ..Directory<IO> cannot-find-directory]
+ [create-directory java/io/File::mkdir ..Directory<IO> cannot-create-directory]
)
(def: separator (java/io/File::separator))
))
}))
-(def: #export (exists? Monad<!> System<!> file)
- (All [!] (-> (Monad !) (System !) File (! (Error Bit))))
- (do (error.ErrorT Monad<!>)
- [??? (:: System<!> file? file)]
- (if ???
- (wrap ???)
- (:: System<!> directory? file))))
+(def: #export (exists? Monad<!> System<!> path)
+ (All [!] (-> (Monad !) (System !) Path (! Bit)))
+ (do Monad<!>
+ [?file (:: System<!> file path)]
+ (case ?file
+ (#error.Success file)
+ (wrap true)
+
+ (#error.Error _)
+ (do Monad<!>
+ [?directory (:: System<!> directory path)]
+ (case ?directory
+ (#error.Success directory)
+ (wrap true)
+
+ (#error.Error _)
+ (wrap false))))))
diff --git a/stdlib/test/test/lux/world/file.lux b/stdlib/test/test/lux/world/file.lux
index 1332ebdfc..d87ea7fc5 100644
--- a/stdlib/test/test/lux/world/file.lux
+++ b/stdlib/test/test/lux/world/file.lux
@@ -11,15 +11,17 @@
["." error (#+ Error)]
["." number]
["." text
- format]]
+ format]
+ [collection
+ ["." list]]]
[time
["." instant]
["." duration]]
[world
- ["@" file (#+ File)]
+ ["@" file (#+ Path File)]
["." binary (#+ Binary)]]
[math
- ["r" random]]]
+ ["r" random ("r/." Monad<Random>)]]]
lux/test
[//
["_." binary]])
@@ -27,82 +29,93 @@
(def: truncate-millis
(|>> (i// +1_000) (i/* +1_000)))
+(def: (creation-and-deletion number)
+ (-> Nat Test)
+ (r/wrap (do promise.Monad<Promise>
+ [#let [path (format "temp_file_" (%n number))]
+ result (promise.future
+ (do (error.ErrorT io.Monad<IO>)
+ [#let [check-existence! (: (IO (Error Bit))
+ (io.from-io (@.exists? io.Monad<IO> @.System<IO> path)))]
+ pre! check-existence!
+ file (:: @.System<IO> create-file path)
+ post! check-existence!
+ _ (:: file delete [])
+ remains? check-existence!]
+ (wrap (and (not pre!)
+ post!
+ (not remains?)))))]
+ (assert "Can create/delete files."
+ (error.default #0 result)))))
+
+(def: (read-and-write number data)
+ (-> Nat Binary Test)
+ (r/wrap (do promise.Monad<Promise>
+ [#let [path (format "temp_file_" (%n number))]
+ result (promise.future
+ (do (error.ErrorT io.Monad<IO>)
+ [file (:: @.System<IO> create-file path)
+ _ (:: file over-write data)
+ content (:: file content [])
+ _ (:: file delete [])]
+ (wrap (:: binary.Equivalence<Binary> = data (taint.trust content)))))]
+ (assert "Can write/read files."
+ (error.default #0 result)))))
+
(context: "File system."
(do @
[file-size (|> r.nat (:: @ map (|>> (n/% 100) (n/max 10))))
dataL (_binary.binary file-size)
dataR (_binary.binary file-size)
- last-modified (|> r.int (:: @ map (|>> (:: number.Number<Int> abs)
- truncate-millis
- duration.from-millis
- instant.absolute)))]
+ new-modified (|> r.int (:: @ map (|>> (:: number.Number<Int> abs)
+ truncate-millis
+ duration.from-millis
+ instant.absolute)))]
($_ seq
+ (creation-and-deletion 0)
+ (read-and-write 1 dataL)
(wrap (do promise.Monad<Promise>
- [#let [file "temp_file_0"]
+ [#let [path "temp_file_2"]
result (promise.future
- (do io.Monad<Process>
- [#let [check-existence! (: (IO (Error Bit))
- (@.exists? io.Monad<IO> @.System<IO> file))]
- pre! check-existence!
- _ (:: @.System<IO> write dataL file)
- post! check-existence!
- _ (:: @.System<IO> delete file)
- remains? check-existence!]
- (wrap (and (not pre!)
- post!
- (not remains?)))))]
- (assert "Can create/delete files."
- (error.default #0 result))))
- (wrap (do promise.Monad<Promise>
- [#let [file "temp_file_1"]
- result (promise.future
- (do io.Monad<Process>
- [_ (:: @.System<IO> write dataL file)
- output (:: @.System<IO> read file)
- _ (:: @.System<IO> delete file)]
- (wrap (:: binary.Equivalence<Binary> = dataL (taint.trust output)))))]
- (assert "Can write/read files."
- (error.default #0 result))))
- (wrap (do promise.Monad<Promise>
- [#let [file "temp_file_2"]
- result (promise.future
- (do io.Monad<Process>
- [_ (:: @.System<IO> write dataL file)
- read-size (:: @.System<IO> size file)
- _ (:: @.System<IO> delete file)]
+ (do (error.ErrorT io.Monad<IO>)
+ [file (:: @.System<IO> create-file path)
+ _ (:: file over-write dataL)
+ read-size (:: file size [])
+ _ (:: file delete [])]
(wrap (n/= file-size read-size))))]
(assert "Can read file size."
(error.default #0 result))))
(wrap (do promise.Monad<Promise>
- [#let [file "temp_file_3"]
+ [#let [path "temp_file_3"]
result (promise.future
- (do io.Monad<Process>
- [_ (:: @.System<IO> write dataL file)
- _ (:: @.System<IO> append dataR file)
- output (:: @.System<IO> read file)
- read-size (:: @.System<IO> size file)
- _ (:: @.System<IO> delete file)]
+ (do (error.ErrorT io.Monad<IO>)
+ [file (:: @.System<IO> create-file path)
+ _ (:: file over-write dataL)
+ _ (:: file append dataR)
+ content (:: file content [])
+ read-size (:: file size [])
+ _ (:: file delete [])]
(wrap (and (n/= (n/* 2 file-size) read-size)
(:: binary.Equivalence<Binary> =
dataL
(error.assume (binary.slice 0 (dec file-size)
- (taint.trust output))))
+ (taint.trust content))))
(:: binary.Equivalence<Binary> =
dataR
(error.assume (binary.slice file-size (dec read-size)
- (taint.trust output))))))))]
+ (taint.trust content))))))))]
(assert "Can append to files."
(error.default #0 result))))
(wrap (do promise.Monad<Promise>
- [#let [dir "temp_dir_4"]
+ [#let [path "temp_dir_4"]
result (promise.future
- (do io.Monad<Process>
+ (do (error.ErrorT io.Monad<IO>)
[#let [check-existence! (: (IO (Error Bit))
- (@.exists? io.Monad<IO> @.System<IO> dir))]
+ (io.from-io (@.exists? io.Monad<IO> @.System<IO> path)))]
pre! check-existence!
- _ (:: @.System<IO> make-directory dir)
+ dir (:: @.System<IO> create-directory path)
post! check-existence!
- _ (:: @.System<IO> delete dir)
+ _ (:: dir discard [])
remains? check-existence!]
(wrap (and (not pre!)
post!
@@ -110,79 +123,70 @@
(assert "Can create/delete directories."
(error.default #0 result))))
(wrap (do promise.Monad<Promise>
- [#let [file "temp_file_5"
- dir "temp_dir_5"]
+ [#let [file-path "temp_file_5"
+ dir-path "temp_dir_5"]
result (promise.future
- (do io.Monad<Process>
- [_ (:: @.System<IO> write dataL file)
- file-is-file (:: @.System<IO> file? file)
- file-is-directory (:: @.System<IO> directory? file)
- _ (:: @.System<IO> delete file)
- _ (:: @.System<IO> make-directory dir)
- directory-is-file (:: @.System<IO> file? dir)
- directory-is-directory (:: @.System<IO> directory? dir)
- _ (:: @.System<IO> delete dir)]
- (wrap (and file-is-file (not file-is-directory)
- (not directory-is-file) directory-is-directory))))]
- (assert "Can differentiate files from directories."
- (error.default #0 result))))
- (wrap (do promise.Monad<Promise>
- [#let [file "temp_file_6"
- dir "temp_dir_6"]
- result (promise.future
- (do io.Monad<Process>
- [_ (:: @.System<IO> make-directory dir)
- #let [file' (format dir "/" file)]
- _ (:: @.System<IO> write dataL file')
- read-size (:: @.System<IO> size file')
- _ (:: @.System<IO> delete file')
- _ (:: @.System<IO> delete dir)]
+ (do (error.ErrorT io.Monad<IO>)
+ [dir (:: @.System<IO> create-directory dir-path)
+ file (:: @.System<IO> create-file (format dir-path "/" file-path))
+ _ (:: file over-write dataL)
+ read-size (:: file size [])
+ _ (:: file delete [])
+ _ (:: dir discard [])]
(wrap (n/= file-size read-size))))]
(assert "Can create files inside of directories."
(error.default #0 result))))
(wrap (do promise.Monad<Promise>
- [#let [file "temp_file_7"
- dir "temp_dir_7"]
+ [#let [file-path "temp_file_6"
+ dir-path "temp_dir_6"
+ inner-dir-path "inner_temp_dir_6"]
result (promise.future
- (do io.Monad<Process>
- [_ (:: @.System<IO> make-directory dir)
- #let [file' (format dir "/" file)]
- _ (:: @.System<IO> write dataL file')
- children (:: @.System<IO> files dir)
- _ (:: @.System<IO> delete file')
- _ (:: @.System<IO> delete dir)]
- (wrap (case children
- (^ (list child))
- (text.ends-with? file' child)
-
- _
- #0))))]
- (assert "Can list files inside a directory."
+ (do (error.ErrorT io.Monad<IO>)
+ [dir (:: @.System<IO> create-directory dir-path)
+ pre-files (:: dir files [])
+ pre-directories (:: dir directories [])
+
+ file (:: @.System<IO> create-file (format dir-path "/" file-path))
+ inner-dir (:: @.System<IO> create-directory (format dir-path "/" inner-dir-path))
+ post-files (:: dir files [])
+ post-directories (:: dir directories [])
+
+ _ (:: file delete [])
+ _ (:: inner-dir discard [])
+ _ (:: dir discard [])]
+ (wrap (and (and (n/= 0 (list.size pre-files))
+ (n/= 0 (list.size pre-directories)))
+ (and (n/= 1 (list.size post-files))
+ (n/= 1 (list.size post-directories)))))))]
+ (assert "Can list files/directories inside a directory."
(error.default #0 result))))
(wrap (do promise.Monad<Promise>
- [#let [file "temp_file_8"]
+ [#let [path "temp_file_7"]
result (promise.future
- (do io.Monad<Process>
- [_ (:: @.System<IO> write dataL file)
- _ (:: @.System<IO> modify last-modified file)
- time-read (:: @.System<IO> last-modified file)
- _ (:: @.System<IO> delete file)]
- (wrap (:: instant.Equivalence<Instant> = last-modified time-read))))]
+ (do (error.ErrorT io.Monad<IO>)
+ [file (:: @.System<IO> create-file path)
+ _ (:: file over-write dataL)
+ _ (:: file modify new-modified)
+ old-modified (:: file last-modified [])
+ _ (:: file delete [])]
+ (wrap (:: instant.Equivalence<Instant> = new-modified old-modified))))]
(assert "Can change the time of last modification."
(error.default #0 result))))
(wrap (do promise.Monad<Promise>
- [#let [file0 (format "temp_file_9+0")
- file1 (format "temp_file_9+1")]
+ [#let [path0 (format "temp_file_8+0")
+ path1 (format "temp_file_8+1")]
result (promise.future
- (do io.Monad<Process>
- [#let [check-existence! (: (-> File (IO (Error Bit)))
- (@.exists? io.Monad<IO> @.System<IO>))]
- _ (:: @.System<IO> write dataL file0)
- pre! (check-existence! file0)
- _ (:: @.System<IO> move file1 file0)
- post! (check-existence! file0)
- confirmed? (check-existence! file1)
- _ (:: @.System<IO> delete file1)]
+ (do (error.ErrorT io.Monad<IO>)
+ [#let [check-existence! (: (-> Path (IO (Error Bit)))
+ (|>> (@.exists? io.Monad<IO> @.System<IO>) io.from-io))]
+ file0 (:: @.System<IO> create-file path0)
+ _ (:: file0 over-write dataL)
+ pre! (check-existence! path0)
+ file1 (: (IO (Error (File IO))) ## TODO: Remove :
+ (:: file0 move path1))
+ post! (check-existence! path0)
+ confirmed? (check-existence! path1)
+ _ (:: file1 delete [])]
(wrap (and pre!
(not post!)
confirmed?))))]