mirror of
https://github.com/matrix-org/dendrite.git
synced 2026-01-21 13:03:09 -06:00
Refactor relay perform_test for clarity
This commit is contained in:
parent
27b40621fd
commit
0e4d2593eb
|
|
@ -41,7 +41,10 @@ func (f *testFedClient) P2PGetTransactionFromRelay(
|
||||||
relayServer gomatrixserverlib.ServerName,
|
relayServer gomatrixserverlib.ServerName,
|
||||||
) (res gomatrixserverlib.RespGetRelayTransaction, err error) {
|
) (res gomatrixserverlib.RespGetRelayTransaction, err error) {
|
||||||
f.queryCount++
|
f.queryCount++
|
||||||
if !f.shouldFail {
|
if f.shouldFail {
|
||||||
|
return res, fmt.Errorf("Error")
|
||||||
|
}
|
||||||
|
|
||||||
res = gomatrixserverlib.RespGetRelayTransaction{
|
res = gomatrixserverlib.RespGetRelayTransaction{
|
||||||
Txn: gomatrixserverlib.Transaction{},
|
Txn: gomatrixserverlib.Transaction{},
|
||||||
EntryID: 0,
|
EntryID: 0,
|
||||||
|
|
@ -52,9 +55,6 @@ func (f *testFedClient) P2PGetTransactionFromRelay(
|
||||||
res.EntriesQueued = false
|
res.EntriesQueued = false
|
||||||
}
|
}
|
||||||
f.queueDepth -= 1
|
f.queueDepth -= 1
|
||||||
} else {
|
|
||||||
err = fmt.Errorf("Error")
|
|
||||||
}
|
|
||||||
|
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue