package notify import ( "bytes" "fmt" "log" "net/http" "github.com/drone/drone/plugin/notify/email" "github.com/drone/drone/plugin/notify/github" "github.com/drone/drone/plugin/notify/irc" "github.com/drone/drone/plugin/notify/webhook" "github.com/drone/drone/shared/model" ) type Sender interface { Send(context *model.Request) error } // Notification stores the configuration details // for notifying a user, or group of users, // when their Build has completed. type Notification struct { Email *email.Email `yaml:"email,omitempty"` Webhook *webhook.Webhook `yaml:"webhook,omitempty"` Hipchat *Hipchat `yaml:"hipchat,omitempty"` Irc *irc.IRC `yaml:"irc,omitempty"` Slack *Slack `yaml:"slack,omitempty"` Gitter *Gitter `yaml:"gitter,omitempty"` Flowdock *Flowdock `yaml:"flowdock,omitempty"` GitHub github.GitHub `yaml:"--"` } func (n *Notification) Send(context *model.Request) error { // send email notifications if n.Email != nil { err := n.Email.Send(context) if err != nil { log.Println(err) } } // send webhook notifications if n.Webhook != nil { err := n.Webhook.Send(context) if err != nil { log.Println(err) } } // send hipchat notifications if n.Hipchat != nil { err := n.Hipchat.Send(context) if err != nil { log.Println(err) } } // send irc notifications if n.Irc != nil { err := n.Irc.Send(context) if err != nil { log.Println(err) } } // send slack notifications if n.Slack != nil { err := n.Slack.Send(context) if err != nil { log.Println(err) } } // send gitter notifications if n.Gitter != nil { err := n.Gitter.Send(context) if err != nil { log.Println(err) } } // send gitter notifications if n.Flowdock != nil { err := n.Flowdock.Send(context) if err != nil { log.Println(err) } } // send email notifications // TODO (bradrydzewski) need to improve this code githubStatus := new(github.GitHub) if err := githubStatus.Send(context); err != nil { log.Println(err) } return nil } func getBuildUrl(context *model.Request) string { return fmt.Sprintf("%s/%s/%s/%s/%s/%s", context.Host, context.Repo.Host, context.Repo.Owner, context.Repo.Name, context.Commit.Branch, context.Commit.Sha) } // helper fuction to sent HTTP Post requests // with JSON data as the payload. func sendJson(url string, payload []byte, headers map[string]string) { client := &http.Client{} buf := bytes.NewBuffer(payload) req, err := http.NewRequest("POST", url, buf) req.Header.Set("Content-Type", "application/json") if headers != nil { for k, v := range headers { req.Header.Add(k, v) } } resp, err := client.Do(req) if err != nil { return } resp.Body.Close() }