Compare commits
No commits in common. "master" and "v0.0.3" have entirely different histories.
|
@ -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
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue