No places.

README.md

@@ -21,8 +21,7 @@ absolute mount points are not stored, and path separators are always `/`.
 ## FLAC 48 kHz manager
 
 The command keeps a FLAC directory tree at a maximum sample rate of 48 kHz.
-Files above the configured threshold are converted in place through a Racket
+Files above the configured threshold are converted synchronously by the batch process. The conversion path uses `racket-audio/audio-encoder` dynamically, so the
-place. The conversion path uses `racket-audio/audio-encoder` dynamically, so the
 package can still compile on systems where the native audio libraries are not
 installed yet.
 

flac2opus-manager.rkt

@@ -168,7 +168,9 @@
           (summary-inc s 'removed)))))
 
 (define (find-source-files source-dir)
-  (filter (lambda (p) (not (manager-admin-relpath? (source-relpath-string source-dir p))))
+  (filter (lambda (p)
+            (and (not (manager-temp-path? p))
+                 (not (manager-admin-relpath? (source-relpath-string source-dir p)))))
           (directory-file-paths source-dir)))
 
 (define (manage-flac2opus-tree source-directory target-directory

private/convert-place.rkt

@@ -1,9 +1,7 @@
 #lang racket/base
 
 (require racket/file
-         racket/path
+         racket/path)
-         racket/place
-         "util.rkt")
 
 (provide convert-flac-to-target-in-place)
 
@@ -12,35 +10,34 @@
   (define name-str (path->string name))
   (build-path base (format ".~a.tmp-~a.flac" name-str (current-inexact-milliseconds))))
 
-(define (settings->alist max-sample-rate compression-level)
+(define (settings->hash max-sample-rate compression-level)
+  (make-immutable-hash
    (list (cons 'target-sample-rate max-sample-rate)
-        (cons 'compression-level compression-level)))
+         (cons 'compression-level compression-level))))
 
-(define (convert-flac-to-target-in-place input-path max-sample-rate compression-level)
+(define (delete-file/quiet path)
+  (with-handlers ([exn:fail? (lambda (_) #f)])
+    (when (file-exists? path) (delete-file path))))
+
+(define (convert-flac-to-target-in-place input-path max-sample-rate compression-level
+                                         #:progress-callback [progress-callback #f])
   (define tmp-path (temp-output-path input-path))
-  (define worker
-    (place ch
-      (define msg (place-channel-get ch))
-      (define in-file (list-ref msg 0))
-      (define out-file (list-ref msg 1))
-      (define settings (list-ref msg 2))
-      (with-handlers ([exn:fail?
-                       (lambda (e)
-                         (place-channel-put ch (list 'error (exn-message e))))])
   (define audio-encode (dynamic-require 'racket-audio/audio-encoder 'audio-encode))
-        (define result (audio-encode in-file out-file (make-immutable-hash settings)
+  (with-handlers ([exn:break?
-                                     #:encoder 'flac
+                   (lambda (e)
-                                     #:copy-tags? #t))
+                     (delete-file/quiet tmp-path)
-        (place-channel-put ch (list 'ok result)))))
+                     (raise e))]
-  (place-channel-put worker (list (path->string input-path)
+                  [exn:fail?
+                   (lambda (e)
+                     (delete-file/quiet tmp-path)
+                     (error 'convert-flac-to-target-in-place
+                            "conversion failed for ~a: ~a" input-path (exn-message e)))])
+    (define result
+      (audio-encode (path->string input-path)
                     (path->string tmp-path)
-                                  (settings->alist max-sample-rate compression-level)))
+                    (settings->hash max-sample-rate compression-level)
-  (define response (place-channel-get worker))
+                    #:encoder 'flac
-  (cond [(and (pair? response) (eq? (car response) 'ok))
+                    #:copy-tags? #t
+                    #:progress-callback progress-callback))
     (rename-file-or-directory tmp-path input-path #t)
-         (cadr response)]
+    result))
-        [else
-         (when (file-exists? tmp-path) (delete-file tmp-path))
-         (error 'convert-flac-to-target-in-place "conversion failed for ~a: ~a"
-                input-path
-                (if (and (pair? response) (pair? (cdr response))) (cadr response) response))]))

private/opus-convert-place.rkt

@@ -3,7 +3,6 @@
 (require racket/file
          racket/list
          racket/path
-         racket/place
          racket/string
          "util.rkt")
 
@@ -84,28 +83,34 @@
        (tags-save! tags)))
    #:mode 'read-write))
 
-(define (convert-flac-to-opus input-path output-path kbps)
+(define (delete-file/quiet path)
+  (with-handlers ([exn:fail? (lambda (_) #f)])
+    (when (file-exists? path) (delete-file path))))
+
+(define (convert-flac-to-opus input-path output-path kbps
+                              #:progress-callback [progress-callback #f])
   (define tmp-path (temp-output-path output-path))
   (ensure-parent-directory! tmp-path)
-  (define worker
+  (with-handlers ([exn:break?
-    (place ch
+                   (lambda (e)
-      (define msg (place-channel-get ch))
+                     (delete-file/quiet tmp-path)
-      (define in-file (list-ref msg 0))
+                     (raise e))]
-      (define out-file (list-ref msg 1))
+                  [exn:fail?
-      (define kbps (list-ref msg 2))
+                   (lambda (e)
-      (with-handlers ([exn:fail? (lambda (e) (place-channel-put ch (list 'error (exn-message e))))])
+                     (delete-file/quiet tmp-path)
-        (define-values (settings properties picture) (source-tags->settings in-file kbps))
+                     (error 'convert-flac-to-opus
+                            "conversion failed for ~a: ~a" input-path (exn-message e)))])
+    (define-values (settings properties picture)
+      (source-tags->settings (path->string input-path) kbps))
     (define audio-encode (dynamic-require 'racket-audio/audio-encoder 'audio-encode))
-        (define result (audio-encode in-file out-file settings #:encoder 'opus #:copy-tags? #f))
+    (define result
-        (copy-all-tag-properties! out-file properties picture)
+      (audio-encode (path->string input-path)
-        (place-channel-put ch (list 'ok result)))))
+                    (path->string tmp-path)
-  (place-channel-put worker (list (path->string input-path) (path->string tmp-path) kbps))
+                    settings
-  (define response (place-channel-get worker))
+                    #:encoder 'opus
-  (cond [(and (pair? response) (eq? (car response) 'ok))
+                    #:copy-tags? #f
+                    #:progress-callback progress-callback))
+    (copy-all-tag-properties! (path->string tmp-path) properties picture)
     (ensure-parent-directory! output-path)
     (rename-file-or-directory tmp-path output-path #t)
-         (cadr response)]
+    result))
-        [else
-         (when (file-exists? tmp-path) (delete-file tmp-path))
-         (error 'convert-flac-to-opus "conversion failed for ~a: ~a" input-path
-                (if (and (pair? response) (pair? (cdr response))) (cadr response) response))]))

private/scan.rkt

@@ -36,4 +36,5 @@
             [else acc]))))
 
 (define (find-flac-files base-dir)
-  (sort-paths (filter flac-path? (find-regular-files base-dir))))
+  (sort-paths (filter (lambda (p) (and (flac-path? p) (not (manager-temp-path? p))))
+                      (find-regular-files base-dir))))

private/util.rkt

@@ -17,6 +17,7 @@
          filesystem-path
          flac-path?
          opus-path?
+         manager-temp-path?
          directory-file-paths
          replace-path-extension
          ensure-parent-directory!
@@ -112,6 +113,16 @@
 (define (file-exists?/quiet p)
   (with-handlers ([exn:fail? (lambda (_) #f)]) (file-exists? p)))
 
+(define (path-file-name-string p)
+  (let-values ([(base name dir?) (split-path p)])
+    (and (path? name) (path->string name))))
+
+(define (manager-temp-path? p)
+  (define name (path-file-name-string p))
+  (and name
+       (string-prefix? name ".")
+       (regexp-match? #rx"\\.tmp-[0-9.]+\\.(flac|opus)$" name)))
+
 (define (flac-path? p)
   (and (file-exists?/quiet p) (extension-ci=? p ".flac")))
 

scribblings/audio-library-manager.scrbl

@@ -24,8 +24,7 @@ so it can share the same database with the 48 kHz manager.
 @section{FLAC 48 kHz manager}
 
 The tool @filepath{flac-48khz-manager.rkt} keeps a FLAC tree at a maximum sample
-rate of 48 kHz. Files with a higher sample rate are converted in place through a
+rate of 48 kHz. Files with a higher sample rate are converted synchronously by the batch process. The conversion path uses
-worker place. The conversion path uses
 @racketmodname[racket-audio/audio-encoder] dynamically, so the manager module can
 still be compiled on systems where the native audio libraries are not available.