mirror of
https://dev.narayana.im/narayana/telegabber.git
synced 2026-08-05 04:07:07 +00:00
Return last page for any queries that specify RSM before
This commit is contained in:
parent
bfb1786a42
commit
f2867a7fc3
1 changed files with 5 additions and 1 deletions
|
|
@ -2330,6 +2330,10 @@ func handleSetQueryMAM(s xmpp.Sender, iq *stanza.IQ, query extensions.MAMQuery)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if rsmBefore != 0 && rsmAfter == 0 {
|
||||||
|
rsmLastPage = true
|
||||||
|
}
|
||||||
|
|
||||||
if rsmLimit == 0 && !justCount {
|
if rsmLimit == 0 && !justCount {
|
||||||
rsmLimit = 100
|
rsmLimit = 100
|
||||||
}
|
}
|
||||||
|
|
@ -2353,7 +2357,7 @@ func handleSetQueryMAM(s xmpp.Sender, iq *stanza.IQ, query extensions.MAMQuery)
|
||||||
quotaTs := time.Now().AddDate(0, 0, -int(gateway.MAMThreshold))
|
quotaTs := time.Now().AddDate(0, 0, -int(gateway.MAMThreshold))
|
||||||
var beyond, complete bool
|
var beyond, complete bool
|
||||||
canBeComplete := true
|
canBeComplete := true
|
||||||
fromStart := true
|
fromStart := !rsmLastPage
|
||||||
var overallyFirstMessageId, overallyLastMessageId int64
|
var overallyFirstMessageId, overallyLastMessageId int64
|
||||||
|
|
||||||
reverse := query.GetFlipPage() != nil
|
reverse := query.GetFlipPage() != nil
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue