diff options
| author | Kegsay <kegan@matrix.org> | 2020-12-04 14:11:01 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-12-04 14:11:01 +0000 |
| commit | b507312d4cf9d35b5d4eaaa01a7f74d095b825f8 (patch) | |
| tree | 2812bd7453da07a3c2850fb0b27a740c950af212 /roomserver/internal/input/input.go | |
| parent | c052edafdd765d821f9732add4f5d33962ba5ba4 (diff) | |
MSC2836 threading: part 2 (#1596)
* Update GMSL
* Add MSC2836EventRelationships to fedsender
* Call MSC2836EventRelationships in reqCtx
* auth remote servers
* Extract room ID and servers from previous events; refactor a bit
* initial cut of federated threading
* Use the right client/fed struct in the response
* Add QueryAuthChain for use with MSC2836
* Add auth chain to federated response
* Fix pointers
* under CI: more logging and enable mscs, nil fix
* Handle direction: up
* Actually send message events to the roomserver..
* Add children and children_hash to unsigned, with tests
* Add logic for exploring threads and tracking children; missing storage functions
* Implement storage functions for children
* Add fetchUnknownEvent
* Do federated hits for include_children if we have unexplored children
* Use /ev_rel rather than /event as the former includes child metadata
* Remove cross-room threading impl
* Enable MSC2836 in the p2p demo
* Namespace mscs db
* Enable msc2836 for ygg
Co-authored-by: Neil Alexander <neilalexander@users.noreply.github.com>
Diffstat (limited to 'roomserver/internal/input/input.go')
| -rw-r--r-- | roomserver/internal/input/input.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/roomserver/internal/input/input.go b/roomserver/internal/input/input.go index 79dc2fe1..2bed0c7f 100644 --- a/roomserver/internal/input/input.go +++ b/roomserver/internal/input/input.go @@ -62,10 +62,10 @@ func (w *inputWorker) start() { for { select { case task := <-w.input: - hooks.Run(hooks.KindNewEventReceived, &task.event.Event) + hooks.Run(hooks.KindNewEventReceived, task.event.Event) _, task.err = w.r.processRoomEvent(task.ctx, task.event) if task.err == nil { - hooks.Run(hooks.KindNewEventPersisted, &task.event.Event) + hooks.Run(hooks.KindNewEventPersisted, task.event.Event) } task.wg.Done() case <-time.After(time.Second * 5): |