mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2026-01-16 18:43:10 -06:00
Code Issues Packages Projects Releases Wiki Activity

Add basic edu handling test to transaction request

Browse source
This commit is contained in:
Devon Hudson 2022-12-21 13:08:35 -07:00
parent 95f08c349d
commit 4597a5a405
No known key found for this signature in database
GPG key ID: CD06B18E77F6A628
1 changed files with 41 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

42
internal/transactionrequest_test.go
View file

@ -19,7 +19,11 @@ import (
"encoding/json"
"testing"
"github.com/matrix-org/dendrite/federationapi/producers"
rsAPI "github.com/matrix-org/dendrite/roomserver/api"
"github.com/matrix-org/dendrite/setup/config"
"github.com/matrix-org/dendrite/setup/jetstream"
"github.com/matrix-org/dendrite/setup/process"
"github.com/matrix-org/gomatrixserverlib"
"github.com/stretchr/testify/assert"
)
@ -59,10 +63,46 @@ func TestEmptyTransactionRequest(t *testing.T) {
assert.Zero(t, len(txnRes.PDUs))
}
func TestProcessTransactionRequestPDUs(t *testing.T) {
func TestProcessTransactionRequestPDU(t *testing.T) {
txn := NewTxnReq(&FakeRsAPI{}, nil, "", nil, nil, nil, false, []json.RawMessage{testData[0]}, []gomatrixserverlib.EDU{}, "", "", "")
txnRes, jsonRes := txn.ProcessTransaction(context.Background())
assert.Nil(t, jsonRes)
assert.Zero(t, len(txnRes.PDUs))
}
func TestProcessTransactionRequestPDUs(t *testing.T) {
var err error
edu := gomatrixserverlib.EDU{Type: "m.typing"}
if edu.Content, err = json.Marshal(map[string]interface{}{
"room_id": "!roomid:kaer.morhen",
"user_id": "@userid:kaer.morhen",
"typing": true,
}); err != nil {
t.Errorf("failed to marshal EDU JSON")
}
cfg := &config.Dendrite{}
cfg.Defaults(config.DefaultOpts{
Generate: true,
Monolithic: true,
})
nats := &jetstream.NATSInstance{}
js, _ := nats.Prepare(process.NewProcessContext(), &cfg.Global.JetStream)
producer := &producers.SyncAPIProducer{
JetStream: js,
TopicReceiptEvent: "OutputReceiptEvent",
TopicSendToDeviceEvent: "OutputSendToDeviceEvent",
TopicTypingEvent: "OutputTypingEvent",
TopicPresenceEvent: "OutputPresenceEvent",
TopicDeviceListUpdate: "InputDeviceListUpdate",
TopicSigningKeyUpdate: "InputSigningKeyUpdate",
Config: &cfg.FederationAPI,
UserAPI: nil,
}
txn := NewTxnReq(&FakeRsAPI{}, nil, "", nil, nil, producer, false, testData, []gomatrixserverlib.EDU{edu}, "", "", "")
txnRes, jsonRes := txn.ProcessTransaction(context.Background())
assert.Nil(t, jsonRes)
assert.Zero(t, len(txnRes.PDUs))
}