Skip to content
Snippets Groups Projects
Commit d245fcb5 authored by ale's avatar ale
Browse files

Do not call os.Open directly but use FileStorage.Open

parent e26a7a72
No related branches found
No related tags found
No related merge requests found
...@@ -4,7 +4,6 @@ import ( ...@@ -4,7 +4,6 @@ import (
"encoding/xml" "encoding/xml"
"errors" "errors"
"io" "io"
"os"
"path/filepath" "path/filepath"
"strings" "strings"
) )
...@@ -67,8 +66,8 @@ func opfParse(r io.Reader) (*Metadata, error) { ...@@ -67,8 +66,8 @@ func opfParse(r io.Reader) (*Metadata, error) {
return opf.Meta.ToMetadata(), nil return opf.Meta.ToMetadata(), nil
} }
func opfOpen(path string) (*Metadata, error) { func opfOpen(storage *FileStorage, path string) (*Metadata, error) {
file, err := os.Open(path) file, err := storage.Open(path)
if err != nil { if err != nil {
return nil, err return nil, err
} }
...@@ -88,7 +87,7 @@ func (p *opfProvider) Lookup(storage *FileStorage, path, filetype string) (*Meta ...@@ -88,7 +87,7 @@ func (p *opfProvider) Lookup(storage *FileStorage, path, filetype string) (*Meta
replaceExt(path, ".opf"), replaceExt(path, ".opf"),
} }
for _, opfpath := range paths { for _, opfpath := range paths {
if m, err := opfOpen(storage.Abs(opfpath)); err == nil { if m, err := opfOpen(storage, opfpath); err == nil {
return m, err return m, err
} }
} }
......
...@@ -9,7 +9,6 @@ import ( ...@@ -9,7 +9,6 @@ import (
"mime/multipart" "mime/multipart"
"net/http" "net/http"
"net/url" "net/url"
"os"
"path/filepath" "path/filepath"
"strings" "strings"
"sync" "sync"
...@@ -91,8 +90,8 @@ func (r *remoteServer) DiffRequest(diffreq *diffRequest) (*diffResponse, error) ...@@ -91,8 +90,8 @@ func (r *remoteServer) DiffRequest(diffreq *diffRequest) (*diffResponse, error)
return &diffresp, nil return &diffresp, nil
} }
func addFilePart(w *multipart.Writer, varname, filename, mimeFilename string) error { func addFilePart(w *multipart.Writer, varname string, storage *FileStorage, filename, mimeFilename string) error {
file, err := os.Open(filename) file, err := storage.Open(filename)
if err != nil { if err != nil {
return err return err
} }
...@@ -128,14 +127,14 @@ func (r *remoteServer) SendBook(book *Book, storage *FileStorage, files []*File) ...@@ -128,14 +127,14 @@ func (r *remoteServer) SendBook(book *Book, storage *FileStorage, files []*File)
for i, f := range files { for i, f := range files {
varname := fmt.Sprintf("book%d", i) varname := fmt.Sprintf("book%d", i)
filename := fmt.Sprintf("%d%s", book.Id, f.FileType) filename := fmt.Sprintf("%d%s", book.Id, f.FileType)
if err := addFilePart(w, varname, storage.Abs(f.Path), filename); err != nil { if err := addFilePart(w, varname, storage, f.Path, filename); err != nil {
w.Close() w.Close()
return err return err
} }
} }
if book.CoverPath != "" { if book.CoverPath != "" {
if err := addFilePart(w, "cover", storage.Abs(book.CoverPath), "cover.jpg"); err != nil { if err := addFilePart(w, "cover", storage, book.CoverPath, "cover.jpg"); err != nil {
w.Close() w.Close()
return err return err
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment