summaryrefslogtreecommitdiff
path: root/internal/pipeline
diff options
context:
space:
mode:
Diffstat (limited to 'internal/pipeline')
-rw-r--r--internal/pipeline/put.go4
-rw-r--r--internal/pipeline/put_test.go2
2 files changed, 4 insertions, 2 deletions
diff --git a/internal/pipeline/put.go b/internal/pipeline/put.go
index 444735a..1be36f0 100644
--- a/internal/pipeline/put.go
+++ b/internal/pipeline/put.go
@@ -80,7 +80,9 @@ func DetectQueueType(dir string, conn Queuer) string {
// UploadImages uploads all files (except those which start with a ".")
// from a directory (recursively) into conn.WIPStorageId(), prefixed with
-// the given bookname and a slash
+// the given bookname and a slash. It also appends all file names with
+// sequential numbers, like 0001, to ensure they are appropriately named
+// for further processing in the pipeline.
func UploadImages(dir string, bookname string, conn Uploader) error {
files, err := ioutil.ReadDir(dir)
if err != nil {
diff --git a/internal/pipeline/put_test.go b/internal/pipeline/put_test.go
index 5fb5b43..66fa0c2 100644
--- a/internal/pipeline/put_test.go
+++ b/internal/pipeline/put_test.go
@@ -77,7 +77,7 @@ func Test_DetectQueueType(t *testing.T) {
func Test_UploadImages(t *testing.T) {
var slog StrLog
- vlog := log.New(&slog, "", 0)
+ vlog := log.New(&slog, "", 0)
var conns []connection
conns = append(conns, connection{name: "local", c: &bookpipeline.LocalConn{Logger: vlog}})