]> gitweb.factorcode.org Git - factor.git/blobdiff - basis/http/download/download.factor
http.download: move download words to their own vocabulary
[factor.git] / basis / http / download / download.factor
diff --git a/basis/http/download/download.factor b/basis/http/download/download.factor
new file mode 100644 (file)
index 0000000..36d2b0e
--- /dev/null
@@ -0,0 +1,90 @@
+! Copyright (C) 2024 Doug Coleman.
+! See https://factorcode.org/license.txt for BSD license.
+USING: accessors calendar checksums combinators.short-circuit
+http.client io io.backend io.directories io.encodings.binary
+io.files io.files.info io.files.unique io.pathnames kernel math
+math.order math.parser present sequences shuffle splitting ;
+IN: http.download
+
+: file-too-old-or-not-exists? ( file duration -- ? )
+    [ ?file-info [ created>> ] ?call ]
+    [ ago ] bi*
+    over [ before? ] [ 2drop t ] if ;
+
+: delete-when-old ( file duration -- deleted? )
+    dupd file-too-old-or-not-exists? [ ?delete-file t ] [ drop f ] if ;
+
+: file-matches-checksum? ( file checksum-type bytes -- ? )
+    [ checksum-file ] dip = ;
+
+: delete-when-checksum-mismatches ( file checksum-type bytes -- deleted? )
+    dupdd file-matches-checksum? [ drop f ] [ ?delete-file t ] if ;
+
+: file-size= ( path n -- ? ) [ ?file-info [ size>> ] ?call ] dip = ;
+
+: file-zero-size? ( path -- ? ) 0 file-size= ;
+
+: delete-when-zero-size ( path -- deleted? )
+    dup file-zero-size? [ ?delete-file t ] [ drop f ] if ;
+
+: delete-when-file-size-mismatches? ( file size -- deleted? )
+    dupd file-size= [ drop f ] [ ?delete-file t ] if ;
+
+: download-name ( url -- name )
+    present file-name "?" split1 drop "/" ?tail drop ;
+
+<PRIVATE
+
+: increment-file-extension ( path -- path' )
+    dup file-extension
+    [ ?tail drop ]
+    [
+        ?string>number
+        [ 1 + number>string append ]
+        [ ".1" 3append ] if
+    ] bi ;
+
+: ?parenthesis-number ( str -- n/str ? )
+    dup { [ "(" head? ] [ ")" tail? ] } 1&&
+    [ rest but-last ?string>number ] [ f ] if ;
+
+: increment-file-name ( path -- path' )
+    [
+        file-stem " " split1-last
+        ?parenthesis-number
+        [ 1 + number>string "(" ")" surround " " glue ]
+        [ "(1)" append " " glue ] if
+    ] [
+        file-extension
+    ] bi "." glue ;
+
+: find-next-incremented-name ( path -- path' )
+    dup file-exists? [
+        increment-file-name find-next-incremented-name
+    ] when ;
+
+: next-download-name ( url -- name )
+    download-name find-next-incremented-name ;
+
+: http-write-request ( url -- )
+    <get-request> [ write ] with-http-request drop ;
+
+: download-temporary-name ( url -- prefix suffix )
+    [ "temp." ".temp" ] dip download-name prepend ;
+
+: download-file-to ( url file -- path )
+    [
+        [ download-temporary-name binary ] keep
+        '[ _ http-write-request ] with-unique-file-writer
+    ] dip [ move-file ] keep ;
+
+PRIVATE>
+
+: download-to ( url file -- path )
+    dup file-exists? [ nip ] [ download-file-to ] if ;
+
+: download-outdated-to ( url file duration -- path )
+    2dup delete-when-old [ drop download-to ] [ drop nip ] if ;
+
+: download ( url -- path )
+    dup download-name download-to ;