From b4902d4edb27baf59b21747117d93db4e0e4e96c Mon Sep 17 00:00:00 2001
From: Tulir Asokan <tulir@maunium.net>
Date: Wed, 21 Mar 2018 20:01:52 +0200
Subject: Clear push rules when clearing cache and listen to push rule updates

---
 matrix/ext/pushrules.go | 16 ++++++++++++++++
 matrix/matrix.go        | 12 +++++++++++-
 matrix/sync.go          |  3 +++
 3 files changed, 30 insertions(+), 1 deletion(-)

(limited to 'matrix')

diff --git a/matrix/ext/pushrules.go b/matrix/ext/pushrules.go
index c156873..ccccbb0 100644
--- a/matrix/ext/pushrules.go
+++ b/matrix/ext/pushrules.go
@@ -26,6 +26,22 @@ func GetScopedPushRules(client *gomatrix.Client, scope string) (resp *PushRulese
 	return
 }
 
+func EventToPushRules(event *gomatrix.Event) (*PushRuleset, error) {
+	content, _ := event.Content["global"]
+	raw, err := json.Marshal(content)
+	if err != nil {
+		return nil, err
+	}
+
+	ruleset := &PushRuleset{}
+	err = json.Unmarshal(raw, ruleset)
+	if err != nil {
+		return nil, err
+	}
+
+	return ruleset, nil
+}
+
 type PushRuleset struct {
 	Override  PushRuleArray
 	Content   PushRuleArray
diff --git a/matrix/matrix.go b/matrix/matrix.go
index 4ec6d96..6ab922c 100644
--- a/matrix/matrix.go
+++ b/matrix/matrix.go
@@ -121,6 +121,7 @@ func (c *Container) Client() *gomatrix.Client {
 }
 
 func (c *Container) UpdatePushRules() {
+	debug.Print("Updating push rules...")
 	resp, err := gomx_ext.GetPushRules(c.client)
 	if err != nil {
 		debug.Print("Failed to fetch push rules:", err)
@@ -162,10 +163,10 @@ func (c *Container) OnLogin() {
 	syncer.OnEventType("m.room.message", c.HandleMessage)
 	syncer.OnEventType("m.room.member", c.HandleMembership)
 	syncer.OnEventType("m.typing", c.HandleTyping)
+	syncer.OnEventType("m.push_rules", c.HandlePushRules)
 	c.client.Syncer = syncer
 
 	c.UpdateRoomList()
-	c.UpdatePushRules()
 }
 
 func (c *Container) Start() {
@@ -221,6 +222,15 @@ func (c *Container) HandleMessage(evt *gomatrix.Event) {
 	}
 }
 
+func (c *Container) HandlePushRules(evt *gomatrix.Event) {
+	debug.Print("Received updated push rules")
+	var err error
+	c.config.Session.PushRules, err = gomx_ext.EventToPushRules(evt)
+	if err != nil {
+		debug.Print("Failed to convert event to push rules:", err)
+	}
+}
+
 func (c *Container) HandleMembership(evt *gomatrix.Event) {
 	const Hour = 1 * 60 * 60 * 1000
 	if evt.Unsigned.Age > Hour {
diff --git a/matrix/sync.go b/matrix/sync.go
index ab5d047..9eeb87a 100644
--- a/matrix/sync.go
+++ b/matrix/sync.go
@@ -41,6 +41,9 @@ func (s *GomuksSyncer) ProcessResponse(res *gomatrix.RespSync, since string) (er
 	for _, event := range res.Presence.Events {
 		s.notifyListeners(event)
 	}
+	for _, event := range res.AccountData.Events {
+		s.notifyListeners(event)
+	}
 	for roomID, roomData := range res.Rooms.Join {
 		room := s.Session.GetRoom(roomID)
 		for _, event := range roomData.State.Events {
-- 
cgit v1.2.3