Add hook: HangoutsChat

hook/hangouts_chat.go

@@ -0,0 +1,32 @@
+package hook
+
+import (
+	"bytes"
+	"errors"
+	"net/http"
+
+	"github.com/lucasgomide/snitch/types"
+)
+
+type HangoutsChat struct {
+	WebhookUrl string
+}
+
+func (s HangoutsChat) CallHook(deploy []types.Deploy) error {
+	message := `"The application *` + deploy[0].App + `* has been deployed just now by ` + deploy[0].User + ` at _` + deploy[0].ConvertTimestampToRFC822() + `_"`
+
+	data := []byte(`{"text":` + message + `}`)
+	resp, err := http.Post(s.WebhookUrl, "application/json", bytes.NewReader(data))
+	if err != nil {
+		return err
+	}
+
+	if resp.StatusCode != 200 {
+		return errors.New(`HangoutsChat - response status code is ` + resp.Status)
+	}
+	return nil
+}
+
+func (s HangoutsChat) ValidatesFields() error {
+	return nil
+}

hook/hangouts_chat_test.go

@@ -0,0 +1,61 @@
+package hook
+
+import (
+	"testing"
+
+	"github.com/lucasgomide/snitch/types"
+	"gopkg.in/jarcoal/httpmock.v1"
+)
+
+var hangoutWebhookUrl = "https://hangouts.chat/123"
+
+func TestHangoutWhenNotificatedSuccessful(t *testing.T) {
+	httpmock.Activate()
+	defer httpmock.DeactivateAndReset()
+
+	httpmock.RegisterResponder("POST", hangoutWebhookUrl,
+		httpmock.NewStringResponder(200, `ok`))
+
+	hangout := &HangoutsChat{WebhookUrl: hangoutWebhookUrl}
+	var deploy []types.Deploy
+	deploy = append(deploy, types.Deploy{App: "app-sample"})
+
+	err := hangout.CallHook(deploy)
+	if err != nil {
+		t.Error(err)
+	}
+}
+
+func TestHangoutWhenResponseStatusCodeIsnt200(t *testing.T) {
+	httpmock.Activate()
+	defer httpmock.DeactivateAndReset()
+
+	httpmock.RegisterResponder("POST", hangoutWebhookUrl,
+		httpmock.NewStringResponder(400, `error`))
+
+	hangout := &HangoutsChat{WebhookUrl: hangoutWebhookUrl}
+	var deploy []types.Deploy
+	deploy = append(deploy, types.Deploy{App: "app-sample"})
+
+	err := hangout.CallHook(deploy)
+	expected := "HangoutsChat - response status code is 400"
+	if err == nil || err.Error() != expected {
+		t.Error("Expected: "+expected+", but got", err.Error())
+	}
+}
+
+func TestHangoutReturnsErrorWhenRequestFail(t *testing.T) {
+	httpmock.Activate()
+	defer httpmock.DeactivateAndReset()
+
+	httpmock.RegisterNoResponder(nil)
+
+	hangout := &HangoutsChat{WebhookUrl: hangoutWebhookUrl}
+	var deploy []types.Deploy
+	deploy = append(deploy, types.Deploy{App: "app-sample"})
+
+	err := hangout.CallHook(deploy)
+	if err == nil {
+		t.Error("The request has been failed but no error was raised")
+	}
+}

hook/hook.go

@@ -31,6 +31,8 @@ func Execute(h types.Hook, t types.Tsuru) {
 				h = &Rollbar{}
 			case "Newrelic":
 				h = &NewRelic{}
+			case "Hangout":
+				h = &HangoutsChat{}
 			default:
 				continue
 			}

testdata/config.yaml

@@ -1,5 +1,7 @@
 slack:
   webhook_url: http://dummy.sample
+hangouts_chat:
+  webhook_url: http://hangouts.chat.sample
 missing_hook:
   field: value
 rollbar:
@@ -16,4 +18,4 @@ newrelic:
   host: https://api.newrelic.com
   application_id: "01234"
   api_key: 0a0b11223344
-  revision: 0.0.1
+  revision: 0.0.1