diff options
| author | Wim <wim@42.be> | 2016-11-02 16:12:43 +0100 |
|---|---|---|
| committer | Wim <wim@42.be> | 2016-11-02 16:13:22 +0100 |
| commit | 1b1589713592ec9d8f1945e4e61cac423e3e245e (patch) | |
| tree | e92e23f00375f4bb71e0dcff541bf729f47147ac /vendor/github.com/42wim/go-gitter/faye.go | |
| parent | 8e606e3cef5f36cff1a14c25fc1915ecfd30e054 (diff) | |
| download | matterbridge-msglm-1b1589713592ec9d8f1945e4e61cac423e3e245e.tar.gz matterbridge-msglm-1b1589713592ec9d8f1945e4e61cac423e3e245e.tar.bz2 matterbridge-msglm-1b1589713592ec9d8f1945e4e61cac423e3e245e.zip | |
Fix tight loop (gitter). Closes #68.
Diffstat (limited to 'vendor/github.com/42wim/go-gitter/faye.go')
| -rw-r--r-- | vendor/github.com/42wim/go-gitter/faye.go | 70 |
1 files changed, 70 insertions, 0 deletions
diff --git a/vendor/github.com/42wim/go-gitter/faye.go b/vendor/github.com/42wim/go-gitter/faye.go new file mode 100644 index 00000000..dcd3e210 --- /dev/null +++ b/vendor/github.com/42wim/go-gitter/faye.go @@ -0,0 +1,70 @@ +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)
+}
|