mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-06 22:43:10 -06:00
Code Issues Packages Projects Releases Wiki Activity

♻️ Milliseconds instead of seconds for MR.

Browse source
This commit is contained in:
Daniel Aloni 2023-04-11 13:36:35 +03:00
parent beeb0ca8f5
commit 941f65d388
5 changed files with 7 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
syncapi/consumers/multiroomdata.go
View file

@ -95,7 +95,7 @@ func (s *OutputMultiRoomDataConsumer) onMessage(ctx context.Context, msgs []*nat
rooms, err := s.db.SelectMultiRoomVisibilityRooms(ctx, mrd.SelectMultiRoomVisibilityRoomsParams{ rooms, err := s.db.SelectMultiRoomVisibilityRooms(ctx, mrd.SelectMultiRoomVisibilityRoomsParams{
UserID: userID, UserID: userID,
ExpireTs: time.Now().Unix(), ExpireTs: time.Now().UnixMilli(),
}) })
if err != nil { if err != nil {
sentry.CaptureException(err) sentry.CaptureException(err)

2
syncapi/storage/mrd/types.go
View file

@ -2,5 +2,5 @@ package mrd
type StateEvent struct { type StateEvent struct {
Hidden bool `json:"hidden"` Hidden bool `json:"hidden"`
ExpireTs int `json:"expire_ts"` ExpireTs int64 `json:"expire_ts"`
} }

2
syncapi/storage/shared/storage_consumer.go
View file

@ -655,7 +655,7 @@ func (d *Database) UpdateMultiRoomVisibility(ctx context.Context, event *gomatri
UserID: event.Sender(), UserID: event.Sender(),
Type: event.Type(), Type: event.Type(),
RoomID: event.RoomID(), RoomID: event.RoomID(),
ExpireTs: int64(mrdEv.ExpireTs), ExpireTs: mrdEv.ExpireTs,
}) })
if err != nil { if err != nil {
return fmt.Errorf("insert multiroom visibility failed: %w", err) return fmt.Errorf("insert multiroom visibility failed: %w", err)

2
syncapi/syncapi.go
View file

@ -56,7 +56,7 @@ func AddPublicRoutes(
go func() { go func() {
var affected int64 var affected int64
for { for {
affected, err = mrq.DeleteMultiRoomVisibilityByExpireTS(context.Background(), time.Now().Unix()) affected, err = mrq.DeleteMultiRoomVisibilityByExpireTS(context.Background(), time.Now().UnixMilli())
if err != nil { if err != nil {
logrus.WithError(err).Error("failed to expire multiroom visibility") logrus.WithError(err).Error("failed to expire multiroom visibility")
} }

4
syncapi/types/multiroom_test.go
View file

@ -14,8 +14,8 @@ func TestMarshallMultiRoom(t *testing.T) {
"@3:example.com": map[string]MultiRoomData{ "@3:example.com": map[string]MultiRoomData{
"location": { "location": {
Content: MultiRoomContent(`{"foo":"bar"}`), Content: MultiRoomContent(`{"foo":"bar"}`),
OriginServerTs: 123, OriginServerTs: 1234567890000,
}}}) }}})
is.NoErr(err) is.NoErr(err)
is.Equal(m, []byte(`{"@3:example.com":{"location":{"content":{"foo":"bar"},"origin_server_ts":123}}}`)) is.Equal(m, []byte(`{"@3:example.com":{"location":{"content":{"foo":"bar"},"origin_server_ts":1234567890000}}}`))
} }