mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2026-01-03 04:03:09 -06:00
Code Issues Packages Projects Releases Wiki Activity

Add new presence stream

Browse source
This commit is contained in:
S7evinK 2022-03-31 08:12:27 +02:00
parent 9f2019475f
commit 2e90610cce
1 changed files with 7 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
setup/jetstream/streams.go
View file

@ -25,6 +25,8 @@ var (
OutputReceiptEvent = "OutputReceiptEvent" OutputReceiptEvent = "OutputReceiptEvent"
OutputStreamEvent = "OutputStreamEvent" OutputStreamEvent = "OutputStreamEvent"
OutputReadUpdate = "OutputReadUpdate" OutputReadUpdate = "OutputReadUpdate"
RequestPresence = "GetPresence"
OutputPresenceEvent = "OutputPresenceEvent"
) )
var safeCharacters = regexp.MustCompile("[^A-Za-z0-9$]+") var safeCharacters = regexp.MustCompile("[^A-Za-z0-9$]+")
@ -89,4 +91,9 @@ var streams = []*nats.StreamConfig{
Retention: nats.InterestPolicy, Retention: nats.InterestPolicy,
Storage: nats.FileStorage, Storage: nats.FileStorage,
}, },
{
Name: OutputPresenceEvent,
Retention: nats.InterestPolicy,
Storage: nats.FileStorage,
},
} }