reencode_test.go

package ais

import (
	"bufio"
	"bytes"
	"fmt"
	"log"
	"os"
	"testing"
)

func binToString(bin []byte) string {
	var out string
	for _, m := range bin {
		if m > 0 {
			out += "1"
		} else {
			out += "0"
		}
	}
	return out
}

func tryFile(t *testing.T, x *Codec, msgID int) {
	f, err := os.Open(fmt.Sprintf("testmsg/%d.msg", msgID))
	if err != nil {
		t.Error("Failed to open file", msgID)
		return
	}
	defer f.Close()

	r := bufio.NewReader(f)
	for index := 0; true; index++ {
		line, err := r.ReadString('\n')
		if err != nil {
			break
		}

		line = line[:len(line)-2]
		source := []byte(line)

		/* Convert ascii '0' and '1' to real 0 and 1 */
		for i := 0; i < len(source); i++ {
			source[i] -= '0'
		}

		/* Decode the packet */
		decoded := x.DecodePacket(source)
		if decoded == nil {
			/* Failed to decode... */
			t.Error("Could not decode", msgID, index)
			continue
		}

		encoded := x.EncodePacket(decoded)

		/* Check if the bitstream is identical */
		if len(encoded) < len(source) {
			/* Output is too short */
			t.Error("Output too short", msgID, index, len(encoded), len(source))
			continue
		}

		if !bytes.Equal(encoded[:len(source)], source) {
			t.Error("Bitstream does not match", msgID, index, binToString(source), binToString(encoded[:len(source)]))
			t.Errorf("%+v", decoded)

		}
	}
}

func TestReEncode(t *testing.T) {
	x := CodecNew(false, false)

	/* Convenience conversion disabled to avoid float inaccuracies */
	x.FloatWithoutConversion = true

	/* Test all message types */
	for i := 1; i <= 27; i++ {
		log.Println("Working on message type", i)
		tryFile(t, x, i)
	}
}

func checkFloat(a float64, b float64) bool {
	diff := a - b
	if diff < 0 {
		diff = -diff
	}

	return diff < 0.002
}

func TestFloatReEncoder(t *testing.T) {
	x := CodecNew(true, true)
	x.DecoderCheckFixedValues = true

	packet := PositionReport{
		Valid:     true,
		Longitude: 12.345,
		Latitude:  1.2345,
		Cog:       123.2,
	}
	packet.Header = Header{
		MessageID: 2,
		UserID:    1337}

	encoded := x.EncodePacket(packet)
	if encoded == nil {
		t.Error("Failed to encode position report")
		return
	}

	switch newPacket := x.DecodePacket(encoded).(type) {
	case PositionReport:
		if !checkFloat(float64(packet.Latitude), float64(newPacket.Latitude)) ||
			!checkFloat(float64(packet.Longitude), float64(newPacket.Longitude)) ||
			!checkFloat(float64(packet.Cog), float64(newPacket.Cog)) {
			t.Error("Packet has a floating point error")
		}
	default:
		t.Error("Packet was returned as a different type")
	}

	packet2 := LongRangeAisBroadcastMessage{
		Valid:     true,
		Longitude: 12.345,
		Latitude:  1.2345,
	}
	packet2.Header = Header{
		MessageID: 27,
		UserID:    1337}

	encoded2 := x.EncodePacket(packet2)
	if encoded2 == nil {
		t.Error("Failed to encode position report")
		return
	}

	switch newPacket := x.DecodePacket(encoded2).(type) {
	case LongRangeAisBroadcastMessage:
		if !checkFloat(float64(packet.Latitude), float64(newPacket.Latitude)) ||
			!checkFloat(float64(packet.Longitude), float64(newPacket.Longitude)) {
			t.Error("Packet has a floating point error")
		}
	default:
		t.Error("Packet was returned as a different type")
	}
}

func testInterfacecInternal(p Packet, t *testing.T) (bool, int, uint32) {
	x := CodecNew(false, false)

	encoded := x.EncodePacket(p)
	if encoded == nil {
		t.Error("Failed to encode packet")
	}

	decoded := x.DecodePacket(encoded)
	if decoded.GetHeader().MessageID != p.GetHeader().MessageID {
		t.Error("GetHeader failed")
	}

	switch newPacket := decoded.(type) {
	case HasCommunicationState:
		return true, newPacket.IsItdma(), newPacket.GetState()
	default:
		return false, 0, 0
	}
}

func TestInterfaceAccess(t *testing.T) {

	packet := MultiSlotBinaryMessage{
		Valid: true,
	}
	packet.Header = Header{MessageID: 26}
	packet.CommunicationStateIsItdma = true
	packet.CommunicationState = 0x1234

	a, b, c := testInterfacecInternal(packet, t)
	if !a {
		t.Error("Comm state not found")
	}
	if b != 1 || c != 0x1234 {
		t.Error("Comm state decoding error", b, c)
	}

	packet.CommunicationStateIsItdma = false
	packet.CommunicationState = 0xCAFE

	a, b, c = testInterfacecInternal(packet, t)
	if !a {
		t.Error("Comm state not found")
	}
	if b != 0 || c != 0xCAFE {
		t.Error("Comm state decoding error", b, c)
	}

	packet2 := PositionReport{
		Valid: true,
	}
	packet2.Header = Header{MessageID: 1}
	packet2.CommunicationState = 0x4321
	a, b, c = testInterfacecInternal(packet2, t)
	if !a {
		t.Error("Comm state not found")
	}
	if b != -1 || c != 0x4321 {
		t.Error("Comm state decoding error", b, c)
	}
}

func testEmptyArray(t *testing.T, slotValid bool) bool {
	x := CodecNew(true, true)

	packet := BinaryAcknowledge{
		Valid: true,
	}
	packet.Header = Header{
		MessageID: 7,
		UserID:    1337}
	packet.Destinations[0].Valid = true

	encoded := x.EncodePacket(packet)
	if encoded == nil {
		t.Error("Failed to encode BinaryAcknowledge")
		return false
	}

	/* Truncate message to remove the payload */
	if !slotValid {
		encoded = encoded[:40]
	}

	decoded := x.DecodePacket(encoded)
	if decoded == nil {
		return false
	}

	switch decoded.(type) {
	case BinaryAcknowledge:
		return true
	default:
		t.Error("Packet was returned as a different type")
		return false
	}
}

func TestEmptyPayloadInArrayMessages(t *testing.T) {

	if testEmptyArray(t, false) {
		t.Error("Could decode empty acknowledge")
	}

	if !testEmptyArray(t, true) {
		t.Error("Could not decode non-empty acknowledge")
	}
}

func testValidateFailCorrupt(t *testing.T, corruptSpare bool, packetType bool) bool {
	x := CodecNew(true, true)
	x.DecoderCheckFixedValues = true

	if !packetType {
		packet := StaticDataReport{
			Valid:      true,
			PartNumber: true,
		}
		packet.Header = Header{
			MessageID: 24,
			UserID:    1337}
		packet.ReportB.Valid = true

		encoded := x.EncodePacket(packet)
		if encoded == nil {
			t.Error("Failed to encode StaticDataReport")
			return false
		}

		if corruptSpare {
			encoded[167] = 1
		}

		decoded := x.DecodePacket(encoded)
		if decoded == nil {
			return false
		}
	} else {

		packet2 := Interrogation{
			Valid: true,
		}
		packet2.Header = Header{
			MessageID: 15,
			UserID:    1337}

		packet2.Station1Msg1.Valid = true
		packet2.Station2.Valid = true
		packet2.Station2.MessageID = 2

		encoded2 := x.EncodePacket(packet2)
		if encoded2 == nil {
			t.Error("Failed to encode Interrogation")
			return false
		}

		if corruptSpare {
			encoded2[88] = 1
		}

		decoded2 := x.DecodePacket(encoded2)
		if decoded2 == nil {
			return false
		}

	}
	return true
}

func TestValidateFailCorrupt(t *testing.T) {
	if testValidateFailCorrupt(t, true, false) {
		t.Error("Could decode corrupted packet")
	}

	if !testValidateFailCorrupt(t, false, false) {
		t.Error("Could not decode non-corrupt packet")
	}

	if testValidateFailCorrupt(t, true, true) {
		t.Error("Could decode corrupted packet")
	}

	if !testValidateFailCorrupt(t, false, true) {
		t.Error("Could not decode non-corrupt packet")
	}
}