Function mustCreateTransaction

federationapi/routing/send_test.go:186–198

(rsAPI api.FederationRoomserverAPI, fedClient txnFederationClient, pdus []json.RawMessage)

}

func mustCreateTransaction(rsAPI api.FederationRoomserverAPI, fedClient txnFederationClient, pdus []json.RawMessage) *txnReq {
	t := &txnReq{
		rsAPI:      rsAPI,
		keys:       &test.NopJSONVerifier{},
		federation: fedClient,
		roomsMu:    internal.NewMutexByRoom(),
	}
	t.PDUs = pdus
	t.Origin = testOrigin
	t.TransactionID = gomatrixserverlib.TransactionID(fmt.Sprintf("%d", time.Now().UnixNano()))
	t.Destination = testDestination
	return t
}

func mustProcessTransaction(t *testing.T, txn *txnReq, pdusWithErrors []string) {
	res, err := txn.processTransaction(context.Background())