package github import ( "context" "fmt" "strconv" "sync" "github.com/google/go-github/github" "github.com/pkg/errors" "github.com/strongdm/comply/internal/model" "golang.org/x/oauth2" ) const ( cfgToken = "token" cfgUsername = "username" cfgRepo = "repo" ) var prompts = map[string]string{ cfgToken: "GitHub Token", cfgUsername: "GitHub Username", cfgRepo: "GitHub Repository", } // Prompts are human-readable configuration element names func (g *githubPlugin) Prompts() map[string]string { return prompts } // Register causes the Github plugin to register itself func Register() { model.Register(model.GitHub, &githubPlugin{}) } type githubPlugin struct { token string username string reponame string clientMu sync.Mutex client *github.Client } func (g *githubPlugin) api() *github.Client { g.clientMu.Lock() defer g.clientMu.Unlock() if g.client == nil { ts := oauth2.StaticTokenSource( &oauth2.Token{AccessToken: g.token}, ) // get go-github client gh := github.NewClient(oauth2.NewClient(context.Background(), ts)) g.client = gh } return g.client } func (g *githubPlugin) Get(ID string) (*model.Ticket, error) { return nil, nil } func (g *githubPlugin) Configured() bool { return g.username != "" && g.reponame != "" && g.token != "" } func (g *githubPlugin) Links() model.TicketLinks { links := model.TicketLinks{} links.AuditAll = fmt.Sprintf("https://github.com/%s/%s/issues?q=is%3Aissue+is%3Aopen+label%3Acomply+label%3Aaudit", g.username, g.reponame) links.AuditOpen = fmt.Sprintf("https://github.com/%s/%s/issues?q=is%3Aissue+is%3Aopen+label%3Acomply+label%3Aaudit", g.username, g.reponame) links.ProcedureAll = fmt.Sprintf("https://github.com/%s/%s/issues?q=is%3Aissue+label%3Acomply+label%3Aprocedure", g.username, g.reponame) links.ProcedureOpen = fmt.Sprintf("https://github.com/%s/%s/issues?q=is%3Aissue+is%3Aopen+label%3Acomply+label%3Aprocedure", g.username, g.reponame) return links } func (g *githubPlugin) Configure(cfg map[string]interface{}) error { var err error if g.token, err = getCfg(cfg, cfgToken); err != nil { return err } if g.username, err = getCfg(cfg, cfgUsername); err != nil { return err } if g.reponame, err = getCfg(cfg, cfgRepo); err != nil { return err } return nil } func getCfg(cfg map[string]interface{}, k string) (string, error) { v, ok := cfg[k] if !ok { return "", errors.New("Missing key: " + k) } vS, ok := v.(string) if !ok { return "", errors.New("Malformatted key: " + k) } return vS, nil } func (g *githubPlugin) FindOpen() ([]*model.Ticket, error) { issues, _, err := g.api().Issues.ListByRepo(context.Background(), g.username, g.reponame, &github.IssueListByRepoOptions{ State: "open", }) if err != nil { return nil, errors.Wrap(err, "error during FindOpen") } return toTickets(issues), nil } func (g *githubPlugin) FindByTag(name, value string) ([]*model.Ticket, error) { panic("not implemented") } func (g *githubPlugin) FindByTagName(name string) ([]*model.Ticket, error) { issues, _, err := g.api().Issues.ListByRepo(context.Background(), g.username, g.reponame, &github.IssueListByRepoOptions{ State: "all", Labels: []string{name}, }) if err != nil { return nil, errors.Wrap(err, "error during FindOpen") } return toTickets(issues), nil } func (g *githubPlugin) LinkFor(t *model.Ticket) string { // return fmt.Sprintf("https://github.com/strongdm/comply/issues/%s", t.ID) panic("not implemented") } func (g *githubPlugin) Create(ticket *model.Ticket, labels []string) error { _, _, err := g.api().Issues.Create(context.Background(), g.username, g.reponame, &github.IssueRequest{ Title: &ticket.Name, Body: &ticket.Body, Labels: &labels, }) return err } func toTickets(issues []*github.Issue) []*model.Ticket { var tickets []*model.Ticket for _, i := range issues { tickets = append(tickets, toTicket(i)) } return tickets } func toTicket(i *github.Issue) *model.Ticket { t := &model.Ticket{Attributes: make(map[string]interface{})} t.ID = strconv.Itoa(*i.Number) t.Name = ss(i.Title) t.Body = ss(i.Body) t.CreatedAt = i.CreatedAt t.State = toState(ss(i.State)) for _, l := range i.Labels { if l.Name != nil { t.SetBool(*l.Name) } } return t } func toState(state string) model.TicketState { switch state { case "closed": return model.Closed } return model.Open } func ss(s *string) string { if s == nil { return "" } return *s }