mirror of
https://github.com/pion/stun.git
synced 2025-09-27 04:05:57 +08:00
106 lines
2.2 KiB
Go
106 lines
2.2 KiB
Go
package stun
|
|
|
|
import (
|
|
"bytes"
|
|
"encoding/hex"
|
|
"testing"
|
|
)
|
|
|
|
func TestMessageIntegrity_AddTo_Simple(t *testing.T) {
|
|
i := NewLongTermIntegrity("user", "realm", "pass")
|
|
expected, err := hex.DecodeString("8493fbc53ba582fb4c044c456bdc40eb")
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
if !bytes.Equal(expected, i) {
|
|
t.Error(&IntegrityErr{
|
|
Expected: expected,
|
|
Actual: i,
|
|
})
|
|
}
|
|
t.Run("Check", func(t *testing.T) {
|
|
m := new(Message)
|
|
m.WriteHeader()
|
|
if err := i.AddTo(m); err != nil {
|
|
t.Error(err)
|
|
}
|
|
NewSoftware("software").AddTo(m)
|
|
m.WriteHeader()
|
|
dM := new(Message)
|
|
dM.Raw = m.Raw
|
|
if err := dM.Decode(); err != nil {
|
|
t.Error(err)
|
|
}
|
|
if err := i.Check(dM); err != nil {
|
|
t.Error(err)
|
|
}
|
|
dM.Raw[24] += 12 // HMAC now invalid
|
|
if err, ok := i.Check(dM).(*IntegrityErr); !ok {
|
|
t.Error(err, "should be *IntegrityErr")
|
|
}
|
|
})
|
|
}
|
|
|
|
func TestMessageIntegrityWithFingerprint(t *testing.T) {
|
|
m := new(Message)
|
|
m.TransactionID = [transactionIDSize]byte{1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11}
|
|
m.WriteHeader()
|
|
NewSoftware("software").AddTo(m)
|
|
i := NewShortTermIntegrity("pwd")
|
|
if err := i.AddTo(m); err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
if err := Fingerprint.AddTo(m); err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
if err := i.Check(m); err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
}
|
|
|
|
func TestMessageIntegrity(t *testing.T) {
|
|
m := new(Message)
|
|
//NewSoftware("software")
|
|
i := NewShortTermIntegrity("password")
|
|
m.WriteHeader()
|
|
if err := i.AddTo(m); err != nil {
|
|
t.Error(err)
|
|
}
|
|
_, err := m.Get(AttrMessageIntegrity)
|
|
if err != nil {
|
|
t.Error(err)
|
|
}
|
|
}
|
|
|
|
func BenchmarkMessageIntegrity_AddTo(b *testing.B) {
|
|
m := new(Message)
|
|
integrity := NewShortTermIntegrity("password")
|
|
m.WriteHeader()
|
|
b.ReportAllocs()
|
|
b.SetBytes(int64(len(m.Raw)))
|
|
for i := 0; i < b.N; i++ {
|
|
m.WriteHeader()
|
|
if err := integrity.AddTo(m); err != nil {
|
|
b.Error(err)
|
|
}
|
|
m.Reset()
|
|
}
|
|
}
|
|
func BenchmarkMessageIntegrity_Check(b *testing.B) {
|
|
m := new(Message)
|
|
NewSoftware("software").AddTo(m)
|
|
integrity := NewShortTermIntegrity("password")
|
|
b.ReportAllocs()
|
|
m.WriteHeader()
|
|
b.SetBytes(int64(len(m.Raw)))
|
|
if err := integrity.AddTo(m); err != nil {
|
|
b.Error(err)
|
|
}
|
|
m.WriteLength()
|
|
for i := 0; i < b.N; i++ {
|
|
if err := integrity.Check(m); err != nil {
|
|
b.Fatal(err)
|
|
}
|
|
}
|
|
}
|