68 lines
1.8 KiB
Go
68 lines
1.8 KiB
Go
package tcp
|
|
|
|
import (
|
|
"context"
|
|
"encoding/binary"
|
|
"github.com/stretchr/testify/assert"
|
|
"github.com/stretchr/testify/require"
|
|
"mpbl3p/mocks"
|
|
"mpbl3p/proxy"
|
|
"testing"
|
|
)
|
|
|
|
func TestFlow_Consume(t *testing.T) {
|
|
testContent := []byte("A test string is the content of this packet.")
|
|
testPacket := proxy.SimplePacket(testContent)
|
|
testMac := mocks.AlmostUselessMac{}
|
|
|
|
t.Run("Length", func(t *testing.T) {
|
|
testConn := mocks.NewMockPerfectBiStreamConn(100)
|
|
|
|
flowA := NewFlowConn(testConn.SideA())
|
|
|
|
err := flowA.Consume(context.Background(), testPacket, testMac)
|
|
require.Nil(t, err)
|
|
|
|
buf := make([]byte, 100)
|
|
n, err := testConn.SideB().Read(buf)
|
|
require.Nil(t, err)
|
|
|
|
assert.Equal(t, len(testContent)+8+4+4, n)
|
|
assert.Equal(t, uint32(len(testContent)+8+4), binary.LittleEndian.Uint32(buf[:len(buf)-4]))
|
|
})
|
|
}
|
|
|
|
func TestFlow_Produce(t *testing.T) {
|
|
testContent := "A test string is the content of this packet."
|
|
testMarshalled := []byte("0000" + testContent + "00000000abcd")
|
|
binary.LittleEndian.PutUint32(testMarshalled, uint32(len(testMarshalled)-4))
|
|
|
|
testMac := mocks.AlmostUselessMac{}
|
|
|
|
t.Run("Length", func(t *testing.T) {
|
|
testConn := mocks.NewMockPerfectBiStreamConn(100)
|
|
|
|
flowA := NewFlowConn(testConn.SideA())
|
|
|
|
_, err := testConn.SideB().Write(testMarshalled)
|
|
require.Nil(t, err)
|
|
|
|
p, err := flowA.Produce(context.Background(), testMac)
|
|
require.Nil(t, err)
|
|
assert.Equal(t, len(testContent), len(p.Contents()))
|
|
})
|
|
|
|
t.Run("Value", func(t *testing.T) {
|
|
testConn := mocks.NewMockPerfectBiStreamConn(100)
|
|
|
|
flowA := NewFlowConn(testConn.SideA())
|
|
|
|
_, err := testConn.SideB().Write(testMarshalled)
|
|
require.Nil(t, err)
|
|
|
|
p, err := flowA.Produce(context.Background(), testMac)
|
|
require.Nil(t, err)
|
|
assert.Equal(t, testContent, string(p.Contents()))
|
|
})
|
|
}
|