summaryrefslogtreecommitdiff
path: root/internal
diff options
context:
space:
mode:
authorNick White <git@njw.name>2021-11-23 11:01:17 +0000
committerNick White <git@njw.name>2021-11-23 11:01:17 +0000
commitecc7e3e9e49d58c9bc22784a96279c4d5ba814a2 (patch)
tree9576b315dab658cdaaa8de19f500a6a344b0c10d /internal
parentd4e90332b1ac2d2cd06ad2fe1c0fcdfc0b690e99 (diff)
gofmt, plus update documentation of recently changed pipeline.UploadImages
Diffstat (limited to 'internal')
-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}})