Compare commits

..

No commits in common. "master" and "v0.0.3" have entirely different histories.

3 changed files with 17 additions and 54 deletions

View File

@ -1,4 +1,2 @@
# download # download

View File

@ -7,7 +7,6 @@ import (
"io" "io"
"net/http" "net/http"
"os" "os"
"strings"
"github.com/tanaikech/go-getfilelist" "github.com/tanaikech/go-getfilelist"
"google.golang.org/api/drive/v3" "google.golang.org/api/drive/v3"
@ -46,23 +45,18 @@ func NewGoogleDrive(apiKey string) (*GoogleDrive, error) {
return &ggdrive, nil return &ggdrive, nil
} }
func (g GoogleDrive) GetFilesByFolderID(folderID string, mimeType []string) ([]GoogleDriveFile, error) { func (g GoogleDrive) GetFilesByFolderID(folderID string) ([]GoogleDriveFile, error) {
var ( var (
result = make([]GoogleDriveFile, 0) result = make([]GoogleDriveFile, 0)
) )
chain := getfilelist.Folder(folderID).Fields("files(id,name)") res, err := getfilelist.Folder(folderID).Fields("files(name,id)").Do(g.svc)
if len(mimeType) > 0 {
chain.MimeType(mimeType)
}
res, err := chain.Do(g.svc)
if err != nil { if err != nil {
err := fmt.Errorf("error when fetch folder %s: %s", folderID, err.Error()) err := fmt.Errorf("error when fetch folder %s: %s", folderID, err.Error())
return result, err return result, err
} }
// if there is more than 1 sub folder // if there is more than 1 subfolder
if len(res.FileList) != 1 { if len(res.FileList) != 1 {
err := fmt.Errorf("folder %s have more than 1 subfolder", folderID) err := fmt.Errorf("folder %s have more than 1 subfolder", folderID)
return result, err return result, err
@ -85,52 +79,36 @@ func (g GoogleDrive) GetFilesByFolderID(folderID string, mimeType []string) ([]G
return result, nil return result, nil
} }
// DownloadByFileID download file into specific path func (g GoogleDrive) DownloadByFileID(id, name, location string) (err error) {
func (g GoogleDrive) DownloadByFileID(id, path string) (filename string, err error) { fmt.Printf("[google drive] start download file %s \n", name)
// trim "/" in the end of path defer fmt.Printf("[google drive] done download file %s \n", name)
path = strings.TrimSuffix(path, "/")
// prepare url
url := fmt.Sprintf("https://drive.google.com/uc?export=download&id=%s", id) url := fmt.Sprintf("https://drive.google.com/uc?export=download&id=%s", id)
// Create the file
out, err := os.Create(location)
if err != nil {
return err
}
defer out.Close()
// Get the data // Get the data
resp, err := http.Get(url) resp, err := http.Get(url)
if err != nil { if err != nil {
return "", err return err
} }
defer resp.Body.Close() defer resp.Body.Close()
// Check server response // Check server response
if resp.StatusCode != http.StatusOK { if resp.StatusCode != http.StatusOK {
return "", fmt.Errorf("bad status: %s", resp.Status) return fmt.Errorf("bad status: %s", resp.Status)
} }
// get file name
filename = getFileNameFromHeaderContentDisposition(resp.Header.Get("Content-Disposition"))
// return err if not found
if filename == "" {
return "", errors.New("file is not existed or is in private mode, please check again")
}
// assign location with field name
location := fmt.Sprintf("%s/%s", path, filename)
// Create the file
out, err := os.Create(location)
if err != nil {
return "", err
}
defer out.Close()
fmt.Printf("[google drive] start download file %s with id %s \n", filename, id)
defer fmt.Printf("[google drive] done download file %s with id %s \n", filename, id)
// Writer the body to file // Writer the body to file
_, err = io.Copy(out, resp.Body) _, err = io.Copy(out, resp.Body)
if err != nil { if err != nil {
return "", err return err
} }
return filename, nil return nil
} }

13
util.go
View File

@ -1,13 +0,0 @@
package download
import (
"mime"
)
func getFileNameFromHeaderContentDisposition(value string) string {
disposition, params, err := mime.ParseMediaType(value)
if err != nil || disposition != "attachment" {
return ""
}
return params["filename"]
}