deblan-mirror/mautrix-go
1
0
Fork 0
mirror of https://mau.dev/mautrix/go.git synced 2026-03-14 14:25:53 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

bridgev2/simplevent: add pre/post handle support to EventMeta
Some checks are pending
Go / Lint (latest) (push) Waiting to run
Details
Go / Build (old, libolm) (push) Waiting to run
Details
Go / Build (latest, libolm) (push) Waiting to run
Details
Go / Build (old, goolm) (push) Waiting to run
Details
Go / Build (latest, goolm) (push) Waiting to run
Details

Browse source
This commit is contained in:
Tulir Asokan 2024-11-06 14:50:41 +01:00
commit 5967fe7b0f
1 changed files with 14 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

14
bridgev2/simplevent/meta.go
View file

@ -7,6 +7,7 @@
package simplevent
import (
"context"
"time"
"github.com/rs/zerolog"
@ -25,6 +26,9 @@ type EventMeta struct {
CreatePortal bool
Timestamp time.Time
StreamOrder int64
PreHandleFunc func(context.Context, *bridgev2.Portal)
PostHandleFunc func(context.Context, *bridgev2.Portal)
}
var (
@ -33,6 +37,8 @@ var (
_ bridgev2.RemoteEventThatMayCreatePortal = (*EventMeta)(nil)
_ bridgev2.RemoteEventWithTimestamp = (*EventMeta)(nil)
_ bridgev2.RemoteEventWithStreamOrder = (*EventMeta)(nil)
_ bridgev2.RemotePreHandler = (*EventMeta)(nil)
_ bridgev2.RemotePostHandler = (*EventMeta)(nil)
)
func (evt *EventMeta) AddLogContext(c zerolog.Context) zerolog.Context {
@ -73,6 +79,14 @@ func (evt *EventMeta) ShouldCreatePortal() bool {
return evt.CreatePortal
}
func (evt *EventMeta) PreHandle(ctx context.Context, portal *bridgev2.Portal) {
evt.PreHandleFunc(ctx, portal)
}
func (evt *EventMeta) PostHandle(ctx context.Context, portal *bridgev2.Portal) {
evt.PostHandleFunc(ctx, portal)
}
func (evt EventMeta) WithType(t bridgev2.RemoteEventType) EventMeta {
evt.Type = t
return evt