Improved file-not-found handling (#1508)

This commit is contained in:
John Kerl 2024-02-26 00:12:31 -05:00 committed by GitHub
parent 3201f9c675
commit aff4b9f32d
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
43 changed files with 85 additions and 61 deletions

View file

@ -65,8 +65,9 @@ func (reader *RecordReaderCSV) Read(
)
if err != nil {
errorChannel <- err
} else {
reader.processHandle(handle, "(stdin)", &context, readerChannel, errorChannel, downstreamDoneChannel)
}
reader.processHandle(handle, "(stdin)", &context, readerChannel, errorChannel, downstreamDoneChannel)
} else {
for _, filename := range filenames {
handle, err := lib.OpenFileForRead(

View file

@ -94,16 +94,16 @@ func (reader *RecordReaderCSVLite) Read(
)
if err != nil {
errorChannel <- err
return
} else {
reader.processHandle(
handle,
"(stdin)",
&context,
readerChannel,
errorChannel,
downstreamDoneChannel,
)
}
reader.processHandle(
handle,
"(stdin)",
&context,
readerChannel,
errorChannel,
downstreamDoneChannel,
)
} else {
for _, filename := range filenames {
handle, err := lib.OpenFileForRead(
@ -114,17 +114,17 @@ func (reader *RecordReaderCSVLite) Read(
)
if err != nil {
errorChannel <- err
return
} else {
reader.processHandle(
handle,
filename,
&context,
readerChannel,
errorChannel,
downstreamDoneChannel,
)
handle.Close()
}
reader.processHandle(
handle,
filename,
&context,
readerChannel,
errorChannel,
downstreamDoneChannel,
)
handle.Close()
}
}
}

View file

@ -68,8 +68,9 @@ func (reader *RecordReaderDKVPNIDX) Read(
)
if err != nil {
errorChannel <- err
} else {
reader.processHandle(handle, "(stdin)", &context, readerChannel, errorChannel, downstreamDoneChannel)
}
reader.processHandle(handle, "(stdin)", &context, readerChannel, errorChannel, downstreamDoneChannel)
} else {
for _, filename := range filenames {
handle, err := lib.OpenFileForRead(

View file

@ -45,8 +45,9 @@ func (reader *RecordReaderJSON) Read(
)
if err != nil {
errorChannel <- err
} else {
reader.processHandle(handle, "(stdin)", &context, readerChannel, errorChannel, downstreamDoneChannel)
}
reader.processHandle(handle, "(stdin)", &context, readerChannel, errorChannel, downstreamDoneChannel)
} else {
for _, filename := range filenames {
handle, err := lib.OpenFileForRead(

View file

@ -98,16 +98,16 @@ func (reader *RecordReaderPprintBarredOrMarkdown) Read(
)
if err != nil {
errorChannel <- err
return
} else {
reader.processHandle(
handle,
"(stdin)",
&context,
readerChannel,
errorChannel,
downstreamDoneChannel,
)
}
reader.processHandle(
handle,
"(stdin)",
&context,
readerChannel,
errorChannel,
downstreamDoneChannel,
)
} else {
for _, filename := range filenames {
handle, err := lib.OpenFileForRead(
@ -118,17 +118,17 @@ func (reader *RecordReaderPprintBarredOrMarkdown) Read(
)
if err != nil {
errorChannel <- err
return
} else {
reader.processHandle(
handle,
filename,
&context,
readerChannel,
errorChannel,
downstreamDoneChannel,
)
handle.Close()
}
reader.processHandle(
handle,
filename,
&context,
readerChannel,
errorChannel,
downstreamDoneChannel,
)
handle.Close()
}
}
}

View file

@ -76,16 +76,16 @@ func (reader *RecordReaderTSV) Read(
)
if err != nil {
errorChannel <- err
return
} else {
reader.processHandle(
handle,
"(stdin)",
&context,
readerChannel,
errorChannel,
downstreamDoneChannel,
)
}
reader.processHandle(
handle,
"(stdin)",
&context,
readerChannel,
errorChannel,
downstreamDoneChannel,
)
} else {
for _, filename := range filenames {
handle, err := lib.OpenFileForRead(
@ -96,17 +96,17 @@ func (reader *RecordReaderTSV) Read(
)
if err != nil {
errorChannel <- err
return
} else {
reader.processHandle(
handle,
filename,
&context,
readerChannel,
errorChannel,
downstreamDoneChannel,
)
handle.Close()
}
reader.processHandle(
handle,
filename,
&context,
readerChannel,
errorChannel,
downstreamDoneChannel,
)
handle.Close()
}
}
}

View file

@ -71,8 +71,9 @@ func (reader *RecordReaderXTAB) Read(
)
if err != nil {
errorChannel <- err
} else {
reader.processHandle(handle, "(stdin)", &context, readerChannel, errorChannel, downstreamDoneChannel)
}
reader.processHandle(handle, "(stdin)", &context, readerChannel, errorChannel, downstreamDoneChannel)
} else {
for _, filename := range filenames {
handle, err := lib.OpenFileForRead(

View file

@ -0,0 +1 @@
mlr --csv cat /nonesuch/nope/never

View file

@ -0,0 +1 @@
mlr: open /nonesuch/nope/never: no such file or directory.

View file

@ -0,0 +1 @@
mlr --dkvp cat /nonesuch/nope/never

View file

@ -0,0 +1 @@
mlr: open /nonesuch/nope/never: no such file or directory.

View file

@ -0,0 +1 @@
mlr --imd cat /nonesuch/nope/never

View file

@ -0,0 +1 @@
mlr: open /nonesuch/nope/never: no such file or directory.

View file

@ -0,0 +1 @@
mlr --json cat /nonesuch/nope/never

View file

@ -0,0 +1 @@
mlr: open /nonesuch/nope/never: no such file or directory.

View file

@ -0,0 +1,2 @@
[
]

View file

@ -0,0 +1 @@
mlr --jsonl cat /nonesuch/nope/never

View file

@ -0,0 +1 @@
mlr: open /nonesuch/nope/never: no such file or directory.

View file

@ -0,0 +1 @@
mlr --nidx cat /nonesuch/nope/never

View file

@ -0,0 +1 @@
mlr: open /nonesuch/nope/never: no such file or directory.

View file

@ -0,0 +1 @@
mlr --pprint cat /nonesuch/nope/never

View file

@ -0,0 +1 @@
mlr: open /nonesuch/nope/never: no such file or directory.

View file

@ -0,0 +1 @@
mlr --tsv cat /nonesuch/nope/never

View file

@ -0,0 +1 @@
mlr: open /nonesuch/nope/never: no such file or directory.

View file

@ -0,0 +1 @@
mlr --xtab cat /nonesuch/nope/never

View file

@ -0,0 +1 @@
mlr: open /nonesuch/nope/never: no such file or directory.