Mirrors/gomuks
1
0
Fork 1
mirror of https://github.com/tulir/gomuks.git synced 2025-04-20 10:33:41 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

hicli/pushrules: add todo for saving mute flag in rooms

Browse source
This commit is contained in:
Tulir Asokan 2024-10-19 02:05:17 +03:00
parent 957f3eb5aa
commit d3decc5255
3 changed files with 16 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
pkg/hicli/hicli.go
View file

@ -226,16 +226,6 @@ func (h *HiClient) Sync() {
} }
} }
func (h *HiClient) LoadPushRules(ctx context.Context) {
rules, err := h.Client.GetPushRules(ctx)
if err != nil {
zerolog.Ctx(ctx).Err(err).Msg("Failed to load push rules")
return
}
h.PushRules.Store(rules)
zerolog.Ctx(ctx).Debug().Msg("Updated push rules from fetch")
}
func (h *HiClient) Stop() { func (h *HiClient) Stop() {
h.Client.StopSync() h.Client.StopSync()
if fn := h.stopSync.Swap(nil); fn != nil { if fn := h.stopSync.Swap(nil); fn != nil {

15
pkg/hicli/pushrules.go
View file

@ -109,3 +109,18 @@ func (h *HiClient) evaluatePushRules(ctx context.Context, llSummary *mautrix.Laz
} }
return baseType return baseType
} }
func (h *HiClient) LoadPushRules(ctx context.Context) {
rules, err := h.Client.GetPushRules(ctx)
if err != nil {
zerolog.Ctx(ctx).Err(err).Msg("Failed to load push rules")
return
}
h.receiveNewPushRules(ctx, rules)
zerolog.Ctx(ctx).Debug().Msg("Updated push rules from fetch")
}
func (h *HiClient) receiveNewPushRules(ctx context.Context, rules *pushrules.PushRuleset) {
h.PushRules.Store(rules)
// TODO set mute flag in rooms
}

2
pkg/hicli/sync.go
View file

@ -109,7 +109,7 @@ func (h *HiClient) processSyncResponse(ctx context.Context, resp *mautrix.RespSy
if err != nil && !errors.Is(err, event.ErrContentAlreadyParsed) { if err != nil && !errors.Is(err, event.ErrContentAlreadyParsed) {
zerolog.Ctx(ctx).Warn().Err(err).Msg("Failed to parse push rules in sync") zerolog.Ctx(ctx).Warn().Err(err).Msg("Failed to parse push rules in sync")
} else if pushRules, ok := evt.Content.Parsed.(*pushrules.EventContent); ok { } else if pushRules, ok := evt.Content.Parsed.(*pushrules.EventContent); ok {
h.PushRules.Store(pushRules.Ruleset) h.receiveNewPushRules(ctx, pushRules.Ruleset)
zerolog.Ctx(ctx).Debug().Msg("Updated push rules from sync") zerolog.Ctx(ctx).Debug().Msg("Updated push rules from sync")
} }
} }