0
0
Fork 0
mirror of https://github.com/matrix-org/dendrite synced 2024-12-15 06:13:45 +01:00

Sort resolve-state output

This commit is contained in:
Neil Alexander 2022-05-30 14:38:50 +01:00
parent 9869dc2cbe
commit fb52b6cedc
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944

View file

@ -4,7 +4,9 @@ import (
"context"
"flag"
"fmt"
"sort"
"strconv"
"strings"
"github.com/matrix-org/dendrite/internal/caching"
"github.com/matrix-org/dendrite/roomserver/storage"
@ -110,7 +112,8 @@ func main() {
}
fmt.Println("Resolving state")
resolved, err := gomatrixserverlib.ResolveConflicts(
var resolved Events
resolved, err = gomatrixserverlib.ResolveConflicts(
gomatrixserverlib.RoomVersion(*roomVersion),
events,
authEvents,
@ -120,6 +123,7 @@ func main() {
}
fmt.Println("Resolved state contains", len(resolved), "events")
sort.Sort(resolved)
filteringEventType := *filterType
count := 0
for _, event := range resolved {
@ -135,3 +139,25 @@ func main() {
fmt.Println()
fmt.Println("Returned", count, "state events after filtering")
}
type Events []*gomatrixserverlib.Event
func (e Events) Len() int {
return len(e)
}
func (e Events) Swap(i, j int) {
e[i], e[j] = e[j], e[i]
}
func (e Events) Less(i, j int) bool {
typeDelta := strings.Compare(e[i].Type(), e[j].Type())
if typeDelta < 0 {
return true
}
if typeDelta > 0 {
return false
}
stateKeyDelta := strings.Compare(*e[i].StateKey(), *e[j].StateKey())
return stateKeyDelta < 0
}