From 1b1589713592ec9d8f1945e4e61cac423e3e245e Mon Sep 17 00:00:00 2001 From: Wim Date: Wed, 2 Nov 2016 16:12:43 +0100 Subject: Fix tight loop (gitter). Closes #68. --- vendor/github.com/sromku/go-gitter/faye.go | 70 ------------------------------ 1 file changed, 70 deletions(-) delete mode 100644 vendor/github.com/sromku/go-gitter/faye.go (limited to 'vendor/github.com/sromku/go-gitter/faye.go') diff --git a/vendor/github.com/sromku/go-gitter/faye.go b/vendor/github.com/sromku/go-gitter/faye.go deleted file mode 100644 index dcd3e210..00000000 --- a/vendor/github.com/sromku/go-gitter/faye.go +++ /dev/null @@ -1,70 +0,0 @@ -package gitter - -import ( - "encoding/json" - "fmt" - - "github.com/mrexodia/wray" -) - -type Faye struct { - endpoint string - Event chan Event - client *wray.FayeClient - gitter *Gitter -} - -func (gitter *Gitter) Faye(roomID string) *Faye { - wray.RegisterTransports([]wray.Transport{ - &wray.HttpTransport{ - SendHook: func(data map[string]interface{}) { - if channel, ok := data["channel"]; ok && channel == "/meta/handshake" { - data["ext"] = map[string]interface{}{"token": gitter.config.token} - } - }, - }, - }) - return &Faye{ - endpoint: "/api/v1/rooms/" + roomID + "/chatMessages", - Event: make(chan Event), - client: wray.NewFayeClient(fayeBaseURL), - gitter: gitter, - } -} - -func (faye *Faye) Listen() { - defer faye.destroy() - - faye.client.Subscribe(faye.endpoint, false, func(message wray.Message) { - dataBytes, err := json.Marshal(message.Data["model"]) - if err != nil { - fmt.Printf("JSON Marshal error: %v\n", err) - return - } - var gitterMessage Message - err = json.Unmarshal(dataBytes, &gitterMessage) - if err != nil { - fmt.Printf("JSON Unmarshal error: %v\n", err) - return - } - faye.Event <- Event{ - Data: &MessageReceived{ - Message: gitterMessage, - }, - } - }) - - //TODO: this might be needed in the future - /*go func() { - for { - faye.client.Publish("/api/v1/ping2", map[string]interface{}{"reason": "ping"}) - time.Sleep(60 * time.Second) - } - }()*/ - - faye.client.Listen() -} - -func (faye *Faye) destroy() { - close(faye.Event) -} -- cgit v1.2.3