add missing cmd/ (#10)

Author: graphaelli

.gitignore

@@ -1,10 +1,11 @@
-.idea/
 findfolders
 listrecordings
 upload
+!*/
 zat
 zat.yml
 google.config.json
 google.creds.json
 zoom.config.json
 zoom.creds.json
+.idea/

cmd/google/findfolders/findfolders.go

@@ -0,0 +1,51 @@
+package main
+
+import (
+	"context"
+	"flag"
+	"fmt"
+	"log"
+	"os"
+	"path"
+
+	"github.com/graphaelli/zat/cmd"
+	"github.com/graphaelli/zat/google"
+)
+
+func main() {
+	andQuery := flag.String("query", "", "google drive query: https://developers.google.com/drive/api/v3/search-files")
+	cfgDir := cmd.FlagConfigDir()
+	flag.Parse()
+
+	logger := log.New(os.Stderr, "", cmd.LogFmt)
+	googleClient, err := google.NewClientFromFile(
+		logger,
+		path.Join(*cfgDir, cmd.GoogleConfigPath),
+		google.NewCredentialsManager(cmd.GoogleCredsPath).ClientOption,
+	)
+	if err != nil {
+		logger.Fatal(err)
+	}
+	query := fmt.Sprintf("mimeType='%s'", google.MimeTypeFolder)
+	if *andQuery != "" {
+		query += " and " + *andQuery
+	}
+	var pageToken string
+	for page := 1; page < 5; page++ {
+		files, err := googleClient.ListFiles(context.TODO(), query, pageToken)
+		if err != nil {
+			logger.Fatal(err)
+		}
+		for _, f := range files.Files {
+			name := f.Name
+			if len(name) >= 60 {
+				name = name[0:59] + "⋯"
+			}
+			fmt.Printf("%-60s %-33s https://drive.google.com/drive/folders/%s\n", name, f.Id, f.Id)
+		}
+		if files.NextPageToken == "" {
+			break
+		}
+		pageToken = files.NextPageToken
+	}
+}

cmd/google/upload/upload.go

@@ -0,0 +1,84 @@
+package main
+
+import (
+	"context"
+	"flag"
+	"fmt"
+	"io/ioutil"
+	"log"
+	"os"
+	"path"
+
+	"google.golang.org/api/drive/v3"
+
+	"github.com/graphaelli/zat/cmd"
+	"github.com/graphaelli/zat/google"
+)
+
+func main() {
+	cfgDir := cmd.FlagConfigDir()
+	flag.Parse()
+
+	if flag.NArg() != 2 {
+		fmt.Printf("usage: %s <src> <dst>", os.Args[0])
+		os.Exit(1)
+	}
+	logger := log.New(os.Stderr, "", cmd.LogFmt)
+
+	src, dst := flag.Arg(0), flag.Arg(1)
+	srcInfo, err := os.Stat(src)
+	if err != nil {
+		logger.Fatal(err)
+	}
+	if !srcInfo.IsDir() {
+		logger.Fatal("only directories supported")
+	}
+
+	googleClient, err := google.NewClientFromFile(
+		logger,
+		path.Join(*cfgDir, cmd.GoogleConfigPath),
+		google.NewCredentialsManager(cmd.GoogleCredsPath).ClientOption,
+	)
+	if err != nil {
+		logger.Fatal(err)
+	}
+
+	service, err := googleClient.Service(context.TODO())
+	if err != nil {
+		logger.Fatal(err)
+	}
+
+	parent, err := service.Files.Get(dst).Do()
+	if err != nil {
+		logger.Fatal(err)
+	}
+	dir, err := service.Files.Create(&drive.File{
+		Name:     srcInfo.Name(),
+		MimeType: google.MimeTypeFolder,
+		Parents:  []string{parent.Id},
+	}).Do()
+	if err != nil {
+		logger.Fatal(err)
+	}
+	logger.Printf("created folder %s - https://drive.google.com/drive/folders/%s", dir.Name, dir.Id)
+	files, err := ioutil.ReadDir(src)
+	if err != nil {
+		logger.Fatal(err)
+	}
+
+	for _, file := range files {
+		r, err := os.Open(path.Join(src, file.Name()))
+		if err != nil {
+			logger.Fatal(err)
+		}
+		up, err := service.Files.Create(&drive.File{
+			Name:    file.Name(),
+			Parents: []string{dir.Id},
+		}).Media(r).Do()
+
+		if err != nil {
+			logger.Fatal(err)
+		}
+		logger.Printf("uploaded %s to https://drive.google.com/drive/folders/%s", up.Name, dir.Id)
+	}
+}

cmd/zoom/listrecordings/listrecordings.go

@@ -0,0 +1,52 @@
+package main
+
+import (
+	"flag"
+	"fmt"
+	"log"
+	"os"
+	"path"
+	"strings"
+	"time"
+
+	"github.com/graphaelli/zat/cmd"
+	"github.com/graphaelli/zat/zoom"
+)
+
+func pluralize(c int) string {
+	if c == 1 {
+		return ""
+	}
+	return "s"
+}
+
+func main() {
+	cfgDir := cmd.FlagConfigDir()
+	since := flag.Duration("since", 168*time.Hour, "since")
+	flag.Parse()
+
+	logger := log.New(os.Stderr, "", cmd.LogFmt)
+	zoomClient, err := zoom.NewClientFromFile(
+		logger,
+		path.Join(*cfgDir, cmd.ZoomConfigPath),
+		zoom.NewCredentialsManager(cmd.ZoomCredsPath).ClientOption,
+	)
+	if err != nil {
+		logger.Fatal(err)
+	}
+	recordings, err := zoomClient.ListRecordings(time.Now().Add(-1**since), "")
+	if err != nil {
+		logger.Fatal(err)
+	}
+	logger.Printf("%d recording%s found", recordings.TotalRecords, pluralize(recordings.TotalRecords))
+	for _, meeting := range recordings.Meetings {
+		fmt.Printf("%s %d %s\n", meeting.StartTime.Format("2006-01-02"), meeting.ID, meeting.Topic)
+		for _, f := range meeting.RecordingFiles {
+			typ := f.RecordingType
+			if typ == "" {
+				typ = f.FileType
+			}
+			fmt.Printf("\t%s %s\n", strings.ToLower(typ), f.DownloadURL)
+		}
+	}
+}