refactor from mgfetch into commits

cmd/mgfetch/mgfetch.go

@@ -1,149 +1,22 @@
 package main
 
 import (
-	"errors"
 	"fmt"
-	"os"
-	"regexp"
 	"time"
 
 	git "github.com/go-git/go-git/v5"
-	"github.com/go-git/go-git/v5/plumbing/object"
 
-	"github.com/taigrr/gico/types"
-	"github.com/taigrr/mg/parse"
+	"github.com/taigrr/gico/commits"
 )
 
 type Repo git.Repository
 
 func main() {
 	year := time.Now().Year() - 1
-	yearLength := 365
-	if year%4 == 0 {
-		yearLength++
-	}
-	gfreq := make(types.YearFreq, yearLength)
-	mrconf, err := parse.LoadMRConfig()
+	authors := []string{"Groot"}
+	gfreq, err := commits.GlobalFrequency(year, authors)
 	if err != nil {
 		panic(err)
 	}
-	paths := mrconf.GetRepoPaths()
-	for _, p := range paths {
-		repo, err := OpenRepo(p)
-		if err != nil {
-			panic(err)
-		}
-		commits, err := repo.GetCommitSetForYear(year)
-		if err != nil {
-			panic(err)
-		}
-		commits, err = commits.FilterByAuthorRegex([]string{"Groot"})
-		if err != nil {
-			panic(err)
-		}
-		freq := commits.ToYearFreq()
-		gfreq = gfreq.Merge(freq)
-	}
 	fmt.Print(gfreq.String())
 }
-
-func OpenRepo(directory string) (Repo, error) {
-	if s, err := os.Stat(directory); err != nil {
-		return Repo{}, err
-	} else {
-		if !s.IsDir() {
-			return Repo{}, errors.New("received path to non-directory for git repo")
-		}
-	}
-	r, err := git.PlainOpenWithOptions(directory, &(git.PlainOpenOptions{DetectDotGit: true}))
-	return Repo(*r), err
-}
-
-type CommitSet struct {
-	Commits []types.Commit
-	Year    int
-}
-
-func (cs CommitSet) ToYearFreq() types.YearFreq {
-	year := cs.Year
-	yearLength := 365
-	if year%4 == 0 {
-		yearLength++
-	}
-	freq := make([]int, yearLength)
-	data := types.NewDataSet()
-	for _, commit := range cs.Commits {
-		ts := commit.TimeStamp
-		roundedTS := ts.Round(time.Hour * 24)
-		wd, ok := data[roundedTS]
-		if !ok {
-			wd = types.WorkDay{}
-			wd.Commits = []types.Commit{}
-		}
-		wd.Commits = append(wd.Commits, commit)
-		wd.Count++
-		wd.Day = roundedTS
-		data[roundedTS] = wd
-	}
-	for k, v := range data {
-		if k.Year() != year {
-			continue
-		}
-		// this is equivalent to adding len(commits) to the freq total, but
-		// it's a stub for later when we do more here
-		for range v.Commits {
-			freq[k.YearDay()-1]++
-		}
-	}
-	return freq
-}
-
-func (cs CommitSet) FilterByAuthorRegex(authors []string) (CommitSet, error) {
-	regSet := [](*regexp.Regexp){}
-	for _, a := range authors {
-		r, err := regexp.Compile(a)
-		if err != nil {
-			return CommitSet{}, err
-		}
-		regSet = append(regSet, r)
-	}
-	newCS := CommitSet{Year: cs.Year}
-	for _, commit := range cs.Commits {
-		for _, r := range regSet {
-			if r.MatchString(commit.Author) {
-				newCS.Commits = append(newCS.Commits, commit)
-				break
-			}
-		}
-	}
-	return newCS, nil
-}
-
-func (repo Repo) GetCommitSetForYear(year int) (CommitSet, error) {
-	yearLength := 365
-	if year%4 == 0 {
-		yearLength++
-	}
-	cs := CommitSet{}
-	commits := []types.Commit{}
-	r := git.Repository(repo)
-	ref, err := r.Head()
-	if err != nil {
-		return cs, err
-	}
-	cIter, err := r.Log(&git.LogOptions{From: ref.Hash()})
-	if err != nil {
-		return cs, err
-	}
-	err = cIter.ForEach(func(c *object.Commit) error {
-		ts := c.Author.When
-		commit := types.Commit{Author: c.Author.Name, Message: c.Message, TimeStamp: ts}
-		if commit.TimeStamp.Year() == year {
-			commits = append(commits, commit)
-		}
-		return nil
-	})
-	cs.Commits = commits
-	cs.Year = year
-	return cs, nil
-}