1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
|
package main
import (
"bufio"
"flag"
"fmt"
"log"
"os"
"path/filepath"
"strings"
"rescribe.xyz/bookpipeline"
)
const usage = `Usage: getpipelinebook [-a] [-pdf] [-png] [-v] bookname
Downloads the pipeline results for a book.
By default this downloads the best hOCR version for each page, the
binarised and (if available) colour PDF, and the best, conf and
graph.png analysis files.
`
// null writer to enable non-verbose logging to be discarded
type NullWriter bool
func (w NullWriter) Write(p []byte) (n int, err error) {
return len(p), nil
}
type Pipeliner interface {
Init() error
ListObjects(bucket string, prefix string) ([]string, error)
Download(bucket string, key string, fn string) error
Upload(bucket string, key string, path string) error
CheckQueue(url string, timeout int64) (bookpipeline.Qmsg, error)
AddToQueue(url string, msg string) error
DelFromQueue(url string, handle string) error
WIPStorageId() string
}
func getpdfs(conn Pipeliner, l *log.Logger, bookname string) {
for _, suffix := range []string { ".colour.pdf", ".binarised.pdf" } {
fn := filepath.Join(bookname, bookname + suffix)
l.Println("Downloading PDF", fn)
err := conn.Download(conn.WIPStorageId(), fn, fn)
if err != nil {
log.Printf("Failed to download %s: %s\n", fn, err)
}
}
}
func main() {
all := flag.Bool("a", false, "Get all files for book")
pdf := flag.Bool("pdf", false, "Only download PDFs")
png := flag.Bool("png", false, "Only download best binarised png files")
verbose := flag.Bool("v", false, "Verbose")
flag.Usage = func() {
fmt.Fprintf(flag.CommandLine.Output(), usage)
flag.PrintDefaults()
}
flag.Parse()
if flag.NArg() < 1 {
flag.Usage()
return
}
var verboselog *log.Logger
if *verbose {
verboselog = log.New(os.Stdout, "", log.LstdFlags)
} else {
var n NullWriter
verboselog = log.New(n, "", log.LstdFlags)
}
var conn Pipeliner
conn = &bookpipeline.AwsConn{Region: "eu-west-2", Logger: verboselog}
verboselog.Println("Setting up AWS session")
err := conn.Init()
if err != nil {
log.Fatalln("Error setting up cloud connection:", err)
}
verboselog.Println("Finished setting up AWS session")
bookname := flag.Arg(0)
err = os.MkdirAll(bookname, 0755)
if err != nil {
log.Fatalln("Failed to create directory", bookname, err)
}
if *all {
verboselog.Println("Downloading all files for", bookname)
objs, err := conn.ListObjects(conn.WIPStorageId(), bookname)
if err != nil {
log.Fatalln("Failed to get list of files for book", bookname, err)
}
for _, i := range objs {
verboselog.Println("Downloading", i)
err = conn.Download(conn.WIPStorageId(), i, i)
if err != nil {
log.Fatalln("Failed to download file", i, err)
}
}
return
}
if *pdf {
getpdfs(conn, verboselog, bookname)
return
}
verboselog.Println("Downloading best file")
fn := filepath.Join(bookname, "best")
err = conn.Download(conn.WIPStorageId(), fn, fn)
if err != nil {
log.Fatalln("Failed to download 'best' file", err)
}
f, err := os.Open(fn)
if err != nil {
log.Fatalln("Failed to open best file", err)
}
defer f.Close()
if *png {
verboselog.Println("Downloading png files")
s := bufio.NewScanner(f)
for s.Scan() {
txtfn := filepath.Join(bookname, s.Text())
fn = strings.Replace(txtfn, ".hocr", ".png", 1)
verboselog.Println("Downloading file", fn)
err = conn.Download(conn.WIPStorageId(), fn, fn)
if err != nil {
log.Fatalln("Failed to download file", fn, err)
}
}
return
}
verboselog.Println("Downloading HOCR files")
s := bufio.NewScanner(f)
for s.Scan() {
fn = filepath.Join(bookname, s.Text())
verboselog.Println("Downloading file", fn)
err = conn.Download(conn.WIPStorageId(), fn, fn)
if err != nil {
log.Fatalln("Failed to download file", fn, err)
}
}
verboselog.Println("Downloading PDF files")
getpdfs(conn, verboselog, bookname)
verboselog.Println("Downloading analysis files")
for _, a := range []string{"conf", "graph.png"} {
fn = filepath.Join(bookname, a)
verboselog.Println("Downloading file", fn)
err = conn.Download(conn.WIPStorageId(), fn, fn)
if err != nil {
log.Fatalln("Failed to download file", fn, err)
}
}
}
|
