test(plc4go/spi): add tests for transport instance

plc4go/spi/transports/TransportInstance_test.go

@@ -0,0 +1,363 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+package transports
+
+import (
+	"bufio"
+	"bytes"
+	"context"
+	"reflect"
+	"testing"
+)
+
+func TestNewDefaultBufferedTransportInstance(t *testing.T) {
+	type args struct {
+		defaultBufferedTransportInstanceRequirements DefaultBufferedTransportInstanceRequirements
+	}
+	tests := []struct {
+		name string
+		args args
+		want DefaultBufferedTransportInstance
+	}{
+		{
+			name: "create it",
+			want: &defaultBufferedTransportInstance{},
+		},
+	}
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			if got := NewDefaultBufferedTransportInstance(tt.args.defaultBufferedTransportInstanceRequirements); !reflect.DeepEqual(got, tt.want) {
+				t.Errorf("NewDefaultBufferedTransportInstance() = %v, want %v", got, tt.want)
+			}
+		})
+	}
+}
+
+type _Test_defaultBufferedTransportInstance_ConnectWithContext_DefaultBufferedTransportInstanceRequirements struct {
+}
+
+func (_ _Test_defaultBufferedTransportInstance_ConnectWithContext_DefaultBufferedTransportInstanceRequirements) GetReader() *bufio.Reader {
+	return nil
+}
+
+func (_ _Test_defaultBufferedTransportInstance_ConnectWithContext_DefaultBufferedTransportInstanceRequirements) Connect() error {
+	return nil
+}
+
+func Test_defaultBufferedTransportInstance_ConnectWithContext(t *testing.T) {
+	type fields struct {
+		DefaultBufferedTransportInstanceRequirements DefaultBufferedTransportInstanceRequirements
+	}
+	type args struct {
+		ctx context.Context
+	}
+	tests := []struct {
+		name    string
+		fields  fields
+		args    args
+		wantErr bool
+	}{
+		{
+			name: "connect",
+			fields: fields{
+				DefaultBufferedTransportInstanceRequirements: _Test_defaultBufferedTransportInstance_ConnectWithContext_DefaultBufferedTransportInstanceRequirements{},
+			},
+			args: args{ctx: context.Background()},
+		},
+		{
+			name: "connect canceled",
+			fields: fields{
+				DefaultBufferedTransportInstanceRequirements: _Test_defaultBufferedTransportInstance_ConnectWithContext_DefaultBufferedTransportInstanceRequirements{},
+			},
+			args: args{
+				func() context.Context {
+					ctx, cancel := context.WithCancel(context.Background())
+					cancel()
+					return ctx
+				}(),
+			},
+			wantErr: true,
+		},
+	}
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			m := &defaultBufferedTransportInstance{
+				DefaultBufferedTransportInstanceRequirements: tt.fields.DefaultBufferedTransportInstanceRequirements,
+			}
+			if err := m.ConnectWithContext(tt.args.ctx); (err != nil) != tt.wantErr {
+				t.Errorf("ConnectWithContext() error = %v, wantErr %v", err, tt.wantErr)
+			}
+		})
+	}
+}
+
+type _Test_defaultBufferedTransportInstance_FillBuffer_DefaultBufferedTransportInstanceRequirements struct {
+	reader *bufio.Reader
+}
+
+func (t _Test_defaultBufferedTransportInstance_FillBuffer_DefaultBufferedTransportInstanceRequirements) GetReader() *bufio.Reader {
+	return t.reader
+}
+
+func (_ _Test_defaultBufferedTransportInstance_FillBuffer_DefaultBufferedTransportInstanceRequirements) Connect() error {
+	return nil
+}
+
+func Test_defaultBufferedTransportInstance_FillBuffer(t *testing.T) {
+	type fields struct {
+		DefaultBufferedTransportInstanceRequirements DefaultBufferedTransportInstanceRequirements
+	}
+	type args struct {
+		until func(pos uint, currentByte byte, reader *bufio.Reader) bool
+	}
+	tests := []struct {
+		name    string
+		fields  fields
+		args    args
+		wantErr bool
+	}{
+		{
+			name: "fill it",
+			fields: fields{
+				DefaultBufferedTransportInstanceRequirements: _Test_defaultBufferedTransportInstance_FillBuffer_DefaultBufferedTransportInstanceRequirements{},
+			},
+		},
+		{
+			name: "fill it with reader",
+			fields: fields{
+				DefaultBufferedTransportInstanceRequirements: _Test_defaultBufferedTransportInstance_FillBuffer_DefaultBufferedTransportInstanceRequirements{
+					reader: bufio.NewReader(bytes.NewReader([]byte{0x0, 0x0})),
+				},
+			},
+			args: args{func(pos uint, currentByte byte, reader *bufio.Reader) bool {
+				return pos < 1
+			}},
+		},
+		{
+			name: "fill it with reader errors",
+			fields: fields{
+				DefaultBufferedTransportInstanceRequirements: _Test_defaultBufferedTransportInstance_FillBuffer_DefaultBufferedTransportInstanceRequirements{
+					reader: bufio.NewReader(bytes.NewReader([]byte{0x0, 0x0})),
+				},
+			},
+			args: args{func(pos uint, currentByte byte, reader *bufio.Reader) bool {
+				return pos < 2
+			}},
+			wantErr: true,
+		},
+	}
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			m := &defaultBufferedTransportInstance{
+				DefaultBufferedTransportInstanceRequirements: tt.fields.DefaultBufferedTransportInstanceRequirements,
+			}
+			if err := m.FillBuffer(tt.args.until); (err != nil) != tt.wantErr {
+				t.Errorf("FillBuffer() error = %v, wantErr %v", err, tt.wantErr)
+			}
+		})
+	}
+}
+
+type _Test_defaultBufferedTransportInstance_GetNumBytesAvailableInBuffer_DefaultBufferedTransportInstanceRequirements struct {
+	reader *bufio.Reader
+}
+
+func (t _Test_defaultBufferedTransportInstance_GetNumBytesAvailableInBuffer_DefaultBufferedTransportInstanceRequirements) GetReader() *bufio.Reader {
+	return t.reader
+}
+
+func (_ _Test_defaultBufferedTransportInstance_GetNumBytesAvailableInBuffer_DefaultBufferedTransportInstanceRequirements) Connect() error {
+	return nil
+}
+
+func Test_defaultBufferedTransportInstance_GetNumBytesAvailableInBuffer(t *testing.T) {
+	type fields struct {
+		DefaultBufferedTransportInstanceRequirements DefaultBufferedTransportInstanceRequirements
+	}
+	tests := []struct {
+		name    string
+		fields  fields
+		want    uint32
+		wantErr bool
+	}{
+		{
+			name: "get it without reader",
+			fields: fields{
+				DefaultBufferedTransportInstanceRequirements: _Test_defaultBufferedTransportInstance_GetNumBytesAvailableInBuffer_DefaultBufferedTransportInstanceRequirements{},
+			},
+		},
+		{
+			name: "get it with reader",
+			fields: fields{
+				DefaultBufferedTransportInstanceRequirements: _Test_defaultBufferedTransportInstance_GetNumBytesAvailableInBuffer_DefaultBufferedTransportInstanceRequirements{
+					reader: bufio.NewReader(bytes.NewReader([]byte{0x0, 0x0})),
+				},
+			},
+			want: 2,
+		},
+	}
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			m := &defaultBufferedTransportInstance{
+				DefaultBufferedTransportInstanceRequirements: tt.fields.DefaultBufferedTransportInstanceRequirements,
+			}
+			got, err := m.GetNumBytesAvailableInBuffer()
+			if (err != nil) != tt.wantErr {
+				t.Errorf("GetNumBytesAvailableInBuffer() error = %v, wantErr %v", err, tt.wantErr)
+				return
+			}
+			if got != tt.want {
+				t.Errorf("GetNumBytesAvailableInBuffer() got = %v, want %v", got, tt.want)
+			}
+		})
+	}
+}
+
+type _Test_defaultBufferedTransportInstance_PeekReadableByteser_DefaultBufferedTransportInstanceRequirements struct {
+	reader *bufio.Reader
+}
+
+func (t _Test_defaultBufferedTransportInstance_PeekReadableByteser_DefaultBufferedTransportInstanceRequirements) GetReader() *bufio.Reader {
+	return t.reader
+}
+
+func (_ _Test_defaultBufferedTransportInstance_PeekReadableByteser_DefaultBufferedTransportInstanceRequirements) Connect() error {
+	return nil
+}
+
+func Test_defaultBufferedTransportInstance_PeekReadableBytes(t *testing.T) {
+	type fields struct {
+		DefaultBufferedTransportInstanceRequirements DefaultBufferedTransportInstanceRequirements
+	}
+	type args struct {
+		numBytes uint32
+	}
+	tests := []struct {
+		name    string
+		fields  fields
+		args    args
+		want    []byte
+		wantErr bool
+	}{
+		{
+			name: "peek it without reader",
+			fields: fields{
+				DefaultBufferedTransportInstanceRequirements: _Test_defaultBufferedTransportInstance_PeekReadableByteser_DefaultBufferedTransportInstanceRequirements{},
+			},
+			wantErr: true,
+		},
+		{
+			name: "peek it with reader",
+			fields: fields{
+				DefaultBufferedTransportInstanceRequirements: _Test_defaultBufferedTransportInstance_PeekReadableByteser_DefaultBufferedTransportInstanceRequirements{
+					reader: bufio.NewReader(bytes.NewReader([]byte{0x0, 0x0})),
+				},
+			},
+			args: args{numBytes: 2},
+			want: []byte{0x0, 0x0},
+		},
+	}
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			m := &defaultBufferedTransportInstance{
+				DefaultBufferedTransportInstanceRequirements: tt.fields.DefaultBufferedTransportInstanceRequirements,
+			}
+			got, err := m.PeekReadableBytes(tt.args.numBytes)
+			if (err != nil) != tt.wantErr {
+				t.Errorf("PeekReadableBytes() error = %v, wantErr %v", err, tt.wantErr)
+				return
+			}
+			if !reflect.DeepEqual(got, tt.want) {
+				t.Errorf("PeekReadableBytes() got = %v, want %v", got, tt.want)
+			}
+		})
+	}
+}
+
+type _Test_defaultBufferedTransportInstance_Read_DefaultBufferedTransportInstanceRequirements struct {
+	reader *bufio.Reader
+}
+
+func (t _Test_defaultBufferedTransportInstance_Read_DefaultBufferedTransportInstanceRequirements) GetReader() *bufio.Reader {
+	return t.reader
+}
+
+func (_ _Test_defaultBufferedTransportInstance_Read_DefaultBufferedTransportInstanceRequirements) Connect() error {
+	return nil
+}
+
+func Test_defaultBufferedTransportInstance_Read(t *testing.T) {
+	type fields struct {
+		DefaultBufferedTransportInstanceRequirements DefaultBufferedTransportInstanceRequirements
+	}
+	type args struct {
+		numBytes uint32
+	}
+	tests := []struct {
+		name    string
+		fields  fields
+		args    args
+		want    []byte
+		wantErr bool
+	}{
+		{
+			name: "read it without reader",
+			fields: fields{
+				DefaultBufferedTransportInstanceRequirements: _Test_defaultBufferedTransportInstance_Read_DefaultBufferedTransportInstanceRequirements{},
+			},
+			wantErr: true,
+		},
+		{
+			name: "read it with reader",
+			fields: fields{
+				DefaultBufferedTransportInstanceRequirements: _Test_defaultBufferedTransportInstance_Read_DefaultBufferedTransportInstanceRequirements{
+					reader: bufio.NewReader(bytes.NewReader([]byte{0x0, 0x0})),
+				},
+			},
+			args: args{numBytes: 2},
+			want: []byte{0x0, 0x0},
+		},
+		{
+			name: "read it with reader errors",
+			fields: fields{
+				DefaultBufferedTransportInstanceRequirements: _Test_defaultBufferedTransportInstance_Read_DefaultBufferedTransportInstanceRequirements{
+					reader: bufio.NewReader(bytes.NewReader([]byte{0x0})),
+				},
+			},
+			args:    args{numBytes: 2},
+			wantErr: true,
+		},
+	}
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			m := &defaultBufferedTransportInstance{
+				DefaultBufferedTransportInstanceRequirements: tt.fields.DefaultBufferedTransportInstanceRequirements,
+			}
+			got, err := m.Read(tt.args.numBytes)
+			if (err != nil) != tt.wantErr {
+				t.Errorf("Read() error = %v, wantErr %v", err, tt.wantErr)
+				return
+			}
+			if !reflect.DeepEqual(got, tt.want) {
+				t.Errorf("Read() got = %v, want %v", got, tt.want)
+			}
+		})
+	}
+}

plc4go/spi/transports/pcap/Transport.go

@@ -192,7 +192,7 @@ func (m *TransportInstance) IsConnected() bool {
 }
 
 func (m *TransportInstance) Write(_ []byte) error {
-	panic("Write to pcap not supported")
+	return errors.New("Write to pcap not supported")
 }
 
 func (m *TransportInstance) GetReader() *bufio.Reader {