Merge pull request #10 from techlover10/master

Implement repo sync command + fix cookie redaction

Author: timperrett

src/github.com/verizon/nelson/log_filter.go

@@ -22,7 +22,7 @@ import (
 	"regexp"
 )
 
-var sanitizer = regexp.MustCompile("nelson.session=(.*)")
+var sanitizer = regexp.MustCompile("\"Cookie: nelson.session=(.*)\"")
 
 type FilteredLog struct {
 	logger gorequest.Logger
@@ -38,7 +38,7 @@ func (f FilteredLog) SetPrefix(s string) {
 
 func (f FilteredLog) Printf(format string, v ...interface{}) {
 	s := fmt.Sprintf(format, v)
-	f.logger.Println(sanitizer.ReplaceAllString(s, "nelson.session=<redacted>"))
+	f.logger.Println(sanitizer.ReplaceAllString(s, "\"Cookie: nelson.session=<redacted>\""))
 }
 
 func (f FilteredLog) Println(v ...interface{}) {

src/github.com/verizon/nelson/main.go

@@ -155,6 +155,22 @@ func main() {
 			Aliases: []string{"repo"},
 			Usage:   "Commands for enabling and disabling project repositories",
 			Subcommands: []cli.Command{
+				{
+					Name:  "sync",
+					Usage: "Synchronize the available repositories with GitHub",
+					Action: func(c *cli.Context) error {
+						pi.Start()
+						cfg := LoadDefaultConfigOrExit(http)
+						e := SyncRepos(http, cfg)
+						pi.Stop()
+						if e != nil {
+							fmt.Println(e)
+							return cli.NewExitError("Unable to synchronize repositories.", 1)
+						}
+						fmt.Println("Successfully synchronized repositories.")
+						return nil
+					},
+				},
 				{
 					Name:  "list",
 					Usage: "List enabled/disabled statuses for project repositories",

src/github.com/verizon/nelson/repo.go

@@ -50,6 +50,21 @@ type RepoSummary struct {
 	Access     string    `json:"access"`
 }
 
+func SyncRepos(http *gorequest.SuperAgent, cfg *Config) []error {
+	uri := cfg.Endpoint + "/v1/profile/sync"
+	r, _, errs := AugmentRequest(http.Post(uri), cfg).EndBytes()
+
+	if errs != nil {
+		return errs
+	}
+
+	if r.StatusCode/100 != 2 {
+		errs = append(errs, errors.New("Unexpected response from Nelson server"))
+		return errs
+	}
+	return nil
+}
+
 func ListRepos(owner string, http *gorequest.SuperAgent, cfg *Config) (list []RepoSummary, err []error) {
 	uri := cfg.Endpoint + "/v1/repos?owner=" + owner
 	r, body, errs := AugmentRequest(http.Get(uri), cfg).EndBytes()