dkforest

A forum and chat platform (onion)
git clone https://git.dasho.dev/n0tr1v/dkforest.git
Log | Files | Refs | LICENSE

commit 9c1883e95958e93ddc0cb45c7d502f22b2165ef6
parent cefdd2788dedc398dd4cae09424cd7002e84bc10
Author: n0tr1v <n0tr1v@protonmail.com>
Date:   Mon, 29 May 2023 02:36:07 -0700

cleanup

Diffstat:
Mpkg/web/handlers/handlers.go | 5+++--
1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/pkg/web/handlers/handlers.go b/pkg/web/handlers/handlers.go @@ -5094,14 +5094,15 @@ func ChatStreamMessagesHandler(c echo.Context) error { send("<div>" + v1.RenderMessages(authUser, data, csrf, nullUsername) + "</div>") c.Response().Flush() + // Create a subscriber and topics to listen to selfRefreshTopic := "refresh_" + string(authUser.Username) readMarkerTopic := "readmarker_" + authUser.ID.String() - authorizedChannels := []string{ + authorizedTopics := []string{ "refresh", selfRefreshTopic, readMarkerTopic, "room_" + room.ID.String()} - sub := database.MsgPubSub.Subscribe(authorizedChannels) + sub := database.MsgPubSub.Subscribe(authorizedTopics) defer sub.Close() readMarkerRev := 0