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

Also test reserialisation

Browse source
This commit is contained in:
Kegan Dougal 2020-07-29 14:18:13 +01:00
parent 2bde8b59a4
commit e9ef552ca0
2 changed files with 4 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
syncapi/types/types.go
View file

@ -129,7 +129,7 @@ func (t *StreamingToken) String() string {
t.syncToken.String(), t.syncToken.String(),
} }
for name, lp := range t.logs { for name, lp := range t.logs {
logStr := fmt.Sprintf("%s%d-%d", name, lp.Partition, lp.Offset) logStr := fmt.Sprintf("%s-%d-%d", name, lp.Partition, lp.Offset)
logStrings = append(logStrings, logStr) logStrings = append(logStrings, logStr)
} }
// E.g s11_22_33|dl0-134|ab1-441 // E.g s11_22_33|dl0-134|ab1-441

3
syncapi/types/types_test.go
View file

@ -46,6 +46,9 @@ func TestNewSyncTokenWithLogs(t *testing.T) {
if !reflect.DeepEqual(got, *want) { if !reflect.DeepEqual(got, *want) {
t.Errorf("%s mismatch: got %v want %v", tok, got, want) t.Errorf("%s mismatch: got %v want %v", tok, got, want)
} }
if got.String() != tok {
t.Errorf("%s reserialisation mismatch: got %s want %s", tok, got.String(), tok)
}
} }
} }