sync: Expose GetFile and GetFileContent functions
This commit is contained in:
parent
d24b1c5d4d
commit
560110ba5e
6 changed files with 21 additions and 21 deletions
|
|
@ -95,8 +95,8 @@ func getFileSize(i Importer, URI string) (size int64, err error) {
|
|||
return size, fmt.Errorf("%q: no such file or directory", URI)
|
||||
}
|
||||
|
||||
// getFile helps to manage huge file transfert by concatenating splitted (with split(1)) files.
|
||||
func getFile(i Importer, URI string, writer *bufio.Writer) error {
|
||||
// GetFile helps to manage huge file transfert by concatenating splitted (with split(1)) files.
|
||||
func GetFile(i Importer, URI string, writer *bufio.Writer) error {
|
||||
// Import file if it exists
|
||||
if i.exists(URI) {
|
||||
return i.getFile(URI, writer)
|
||||
|
|
@ -130,11 +130,11 @@ func getFile(i Importer, URI string, writer *bufio.Writer) error {
|
|||
return fmt.Errorf("%q: no such file or directory", URI)
|
||||
}
|
||||
|
||||
// getFileContent retrieves the content of the given text file.
|
||||
func getFileContent(i Importer, URI string) (string, error) {
|
||||
// GetFileContent retrieves the content of the given text file.
|
||||
func GetFileContent(i Importer, URI string) (string, error) {
|
||||
cnt := bytes.Buffer{}
|
||||
|
||||
if err := getFile(i, URI, bufio.NewWriter(io.Writer(&cnt))); err != nil {
|
||||
if err := GetFile(i, URI, bufio.NewWriter(io.Writer(&cnt))); err != nil {
|
||||
return "", err
|
||||
} else {
|
||||
// Ensure we read UTF-8 content.
|
||||
|
|
@ -181,7 +181,7 @@ func ImportFile(i Importer, URI string, next func(string, string) (interface{},
|
|||
} else {
|
||||
defer fdto.Close()
|
||||
writer := bufio.NewWriter(fdto)
|
||||
if err := getFile(i, URI, writer); err != nil {
|
||||
if err := GetFile(i, URI, writer); err != nil {
|
||||
os.Remove(dest)
|
||||
return nil, err
|
||||
}
|
||||
|
|
|
|||
Reference in a new issue