testdata_test.go

package stompws

import (
	"log"
	"net"
	"os"

	"github.com/drawdy/stomp-ws-go/senv"
)

func init() {
	if os.Getenv("STOMP_HB11LONG") != "" {
		testhbrd.testhbl = true
		testhbrd.testhbvb = true
	}
}

//=============================================================================
//= ack_test type =============================================================
//=============================================================================
type (
	terrData struct {
		proto   string
		headers Headers
		errval  Error
	}
)

//=============================================================================
//= ack_test var ==============================================================
//=============================================================================
var (
	terrList = []terrData{
		{SPL_10,
			Headers{HK_DESTINATION, "/queue/a"},
			EREQMIDACK},
		{SPL_11,
			Headers{HK_DESTINATION, "/queue/a"},
			EREQSUBACK},
		{SPL_11,
			Headers{HK_DESTINATION, "/queue/a", HK_SUBSCRIPTION, "sub11a"},
			EREQMIDACK},
		{SPL_12,
			Headers{HK_DESTINATION, "/queue/a"},
			EREQIDACK},
	}
)

//=============================================================================
//= ack_test const ============================================================
//=============================================================================
const (
// None at present.
)

//=============================================================================
//= codec_test type ===========================================================
//=============================================================================
type (
	//
	testdata struct {
		encoded string
		decoded string
	}
)

//=============================================================================
//= codec_test var ============================================================
//=============================================================================
var (
	//
	tdList = []testdata{
		{"stringa", "stringa"},
		{"stringb", "stringb"},
		{"stringc", "stringc"},
		{"stringd", "stringd"},
		{"stringe", "stringe"},
		{"stringf", "stringf"},
		{"stringg", "stringg"},
		{"stringh", "stringh"},
		{"\\\\", "\\"},
		{"\\n", "\n"},
		{"\\c", ":"},
		{"\\\\\\n\\c", "\\\n:"},
		{"\\c\\n\\\\", ":\n\\"},
		{"\\\\\\c", "\\:"},
		{"c\\cc", "c:c"},
		{"n\\nn", "n\nn"},
	}
)

//=============================================================================
//= codec_test const ==========================================================
//=============================================================================
const (
// None at present.
)

//=============================================================================
//= connbv_test type ==========================================================
//=============================================================================
type (
// None at present.
)

//=============================================================================
//= connbv_test var ===========================================================
//=============================================================================
var (
// None at present.
)

//=============================================================================
//= connbv_test const =========================================================
//=============================================================================
const (
// None at present.
)

//=============================================================================
//= conndisc_test type ========================================================
//=============================================================================
type (
	frameData struct {
		data string
		resp error
	}
	verData struct {
		ch Headers // Client headers
		sh Headers // Server headers
		e  error   // Expected error
	}
)

//=============================================================================
//= conndisc_test var =========================================================
//=============================================================================
var (
	frames = []frameData{ // Many are possible but very unlikely
		{"EBADFRM", EBADFRM},
		{"EUNKFRM\n\n\x00", EUNKFRM},
		{"ERROR\n\n\x00", nil},
		{"ERROR\n\x00", EBADFRM},
		{"ERROR\n\n", EBADFRM},
		{"ERROR\nbadconhdr\n\n\x00", EUNKHDR},
		{"ERROR\nbadcon:badmsg\n\n\x00", nil},
		{"ERROR\nbadcon:badmsg\n\nbad message\x00", nil},
		{"CONNECTED\n\n\x00", nil},
		{"CONNECTED\n\nconnbody\x00", EBDYDATA},
		{"CONNECTED\n\nconnbadbody", EBDYDATA},
		{"CONNECTED\nk1:v1\nk2:v2\n\nconnbody\x00", EBDYDATA},
		{"CONNECTED\nk1:v1\nk2:v2\n\nconnbody", EBDYDATA},
		{"CONNECTED\nk1:v1\nk2:v2\n\n\x00", nil},
	}
	verChecks = []verData{
		{Headers{HK_ACCEPT_VERSION, SPL_11}, Headers{HK_VERSION, SPL_11}, nil},
		{Headers{}, Headers{}, nil},
		{Headers{HK_ACCEPT_VERSION, "1.0,1.1,1.2"}, Headers{HK_VERSION, SPL_12}, nil},
		{Headers{HK_ACCEPT_VERSION, "1.3"}, Headers{HK_VERSION, "1.3"}, EBADVERSVR},
		{Headers{HK_ACCEPT_VERSION, "1.3"}, Headers{HK_VERSION, "1.1"}, EBADVERCLI},
		{Headers{HK_ACCEPT_VERSION, "1.0,1.1,1.2"}, Headers{}, nil},
	}
)

//=============================================================================
//= conndisc_test const =======================================================
//=============================================================================
const (
// None at present.
)

//=============================================================================
//= data_test type ============================================================
//=============================================================================
type (
// None at present.
)

//=============================================================================
//= data_test var =============================================================
//=============================================================================
var (
	suptests = []supdata{
		{SPL_10, true},
		{SPL_11, true},
		{SPL_12, true},
		{"1.3", false},
		{"2.0", false},
		{"2.1", false},
	}
)

//=============================================================================
//= data_test const ===========================================================
//=============================================================================
const (
// None at present.
)

//=============================================================================
//= hb_test type ==============================================================
//=============================================================================
type (
	hbrundata struct {
		testhbl  bool // Run long heartbeat tests
		testhbvb bool // Verbose long heartbeat tests
	}
)

//=============================================================================
//= hb_test var ===============================================================
//=============================================================================
var (
	testhbrd = hbrundata{
		testhbl:  false,
		testhbvb: false,
	}
)

//=============================================================================
//= hb_test const =============================================================
//=============================================================================
const (
	//
	hbs = 45 // Wait time (secs)
)

//=============================================================================
//= headers_test type =========================================================
//=============================================================================
type (
// None at present.
)

//=============================================================================
//= headers_test var ==========================================================
//=============================================================================
var (
// None at present.
)

//=============================================================================
//= headers_test const ========================================================
//=============================================================================
const (
// None at present.
)

//=============================================================================
//= logger_test type ==========================================================
//=============================================================================
type (
// None at present.
)

//=============================================================================
//= logger_test var ===========================================================
//=============================================================================
var (
// None at present.
)

//=============================================================================
//= logger_test const =========================================================
//=============================================================================
const (
	testlgslt = 750
)

//=============================================================================
//= misc_test type ============================================================
//=============================================================================
type (
// None at present.
)

//=============================================================================
//= misc_test var =============================================================
//=============================================================================
var (
// None at present.
)

//=============================================================================
//= misc_test const ===========================================================
//=============================================================================
const (
// None at present.
)

//=============================================================================
//= nack_test type ============================================================
//=============================================================================
type (
	nackData struct {
		proto   string
		headers Headers
		errval  Error
	}
)

//=============================================================================
//= nack_test var =============================================================
//=============================================================================
var (
	nackList = []nackData{
		{SPL_10,
			Headers{HK_DESTINATION, "/queue/a"},
			EBADVERNAK},
		{SPL_11,
			Headers{HK_DESTINATION, "/queue/a"},
			EREQSUBNAK},
		{SPL_11,
			Headers{HK_DESTINATION, "/queue/a", HK_SUBSCRIPTION, "sub11a"},
			EREQMIDNAK},
		{SPL_12,
			Headers{HK_DESTINATION, "/queue/a"},
			EREQIDNAK},
	}
)

//=============================================================================
//= nack_test const ===========================================================
//=============================================================================
const (
// None at present.
)

//=============================================================================
//= send_test type ============================================================
//=============================================================================
type (
// None at present.
)

//=============================================================================
//= send_test var =============================================================
//=============================================================================
var (
// None at present.
)

//=============================================================================
//= send_test const ===========================================================
//=============================================================================
const (
// None at present.
)

// send_test END
// sendbytes_test BEGIN

//=============================================================================
//= sendbytes_test type =======================================================
//=============================================================================
type (
// None at present.
)

//=============================================================================
//= sendbytes_test var ========================================================
//=============================================================================
var (
// None at present.
)

//=============================================================================
//= sendbytes_test const ======================================================
//=============================================================================
const (
// None at present.
)

//=============================================================================
//= sub_test type =============================================================
//=============================================================================
type (
	subNoHeaderData struct {
		proto string
		exe   error
	}

	subNoIDData struct {
		proto string
		subh  Headers
		exe   error
	}

	subPlainData struct {
		proto  string
		subh   Headers
		unsubh Headers
		exe1   error
		exe2   error
	}

	subTwiceData struct {
		proto string
		subh  Headers
		exe1  error
		exe2  error
	}

	subAckData struct {
		proto string
		subh  Headers
		exe   error
	}
)

//=============================================================================
//= sub_test var ==============================================================
//=============================================================================
var (
	subNoHeaderDataList = []subNoHeaderData{
		{SPL_10, EREQDSTSUB},
		{SPL_11, EREQDSTSUB},
		{SPL_12, EREQDSTSUB},
	}
	subNoIDDataList = []subNoIDData{
		{SPL_10,
			Headers{HK_DESTINATION, "/queue/subNoIDTest.10"},
			nil},
		{SPL_11,
			Headers{HK_DESTINATION, "/queue/subNoIDTest.11"},
			nil},
		{SPL_12,
			Headers{HK_DESTINATION, "/queue/subNoIDTest.12"},
			nil},
	}
	subPlainDataList = []subPlainData{
		{SPL_10,
			Headers{HK_DESTINATION, "/queue/subPlainTest.10",
				HK_ID, "subPlainTest.10"},
			Headers{HK_DESTINATION, "/queue/subPlainTest.10",
				HK_ID, "subPlainTest.10"},
			nil, nil},
		{SPL_11,
			Headers{HK_DESTINATION, "/queue/subPlainTest.11",
				HK_ID, "subPlainTest.11"},
			Headers{HK_DESTINATION, "/queue/subPlainTest.11",
				HK_ID, "subPlainTest.11"},
			nil, nil},
		{SPL_12,
			Headers{HK_DESTINATION, "/queue/subPlainTest.12",
				HK_ID, "subPlainTest.11"},
			Headers{HK_DESTINATION, "/queue/subPlainTest.12",
				HK_ID, "subPlainTest.11"},
			nil, nil},
	}

	subTwiceDataList = []subTwiceData{
		{SPL_10,
			Headers{HK_DESTINATION, "/queue/subTwiceTest.10",
				HK_ID, "subTwiceTest.10"},
			nil, EDUPSID},
		{SPL_11,
			Headers{HK_DESTINATION, "/queue/subTwiceTest.11",
				HK_ID, "subTwiceTest.11"},
			nil, EDUPSID},
		{SPL_12,
			Headers{HK_DESTINATION, "/queue/subTwiceTest.12",
				HK_ID, "subTwiceTest.11"},
			nil, EDUPSID},
	}

	subAckDataList = []subAckData{
		// 1.0
		{SPL_10,
			Headers{HK_DESTINATION, "/queue/subAckTest.10.1"},
			nil},
		{SPL_10,
			Headers{HK_DESTINATION, "/queue/subAckTest.10.2",
				HK_ACK, AckModeAuto},
			nil},
		{SPL_10,
			Headers{HK_DESTINATION, "/queue/subAckTest.10.3",
				HK_ACK, AckModeClient},
			nil},
		{SPL_10,
			Headers{HK_DESTINATION, "/queue/subAckTest.10.3",
				HK_ACK, AckModeClientIndividual},
			ESBADAM},
		{SPL_10,
			Headers{HK_DESTINATION, "/queue/subAckTest.10.4",
				HK_ACK, badam},
			ESBADAM},
		// 1.1
		{SPL_11,
			Headers{HK_DESTINATION, "/queue/subAckTest.11.1"},
			nil},
		{SPL_11,
			Headers{HK_DESTINATION, "/queue/subAckTest.11.2",
				HK_ACK, AckModeAuto},
			nil},
		{SPL_11,
			Headers{HK_DESTINATION, "/queue/subAckTest.11.3",
				HK_ACK, AckModeClient},
			nil},
		{SPL_11,
			Headers{HK_DESTINATION, "/queue/subAckTest.11.4",
				HK_ACK, AckModeClientIndividual},
			nil},
		{SPL_11,
			Headers{HK_DESTINATION, "/queue/subAckTest.11.5",
				HK_ACK, badam},
			ESBADAM},
		// 1.2
		{SPL_12,
			Headers{HK_DESTINATION, "/queue/subAckTest.12.1"},
			nil},
		{SPL_12,
			Headers{HK_DESTINATION, "/queue/subAckTest.12.2",
				HK_ACK, AckModeAuto},
			nil},
		{SPL_12,
			Headers{HK_DESTINATION, "/queue/subAckTest.12.3",
				HK_ACK, AckModeClient},
			nil},
		{SPL_12,
			Headers{HK_DESTINATION, "/queue/subAckTest.12.4",
				HK_ACK, AckModeClientIndividual},
			nil},
		{SPL_12,
			Headers{HK_DESTINATION, "/queue/subAckTest.12.5",
				HK_ACK, badam},
			ESBADAM},
	}
)

//=============================================================================
//= sub_test const ============================================================
//=============================================================================
const (
// None at present.
)

//=============================================================================
//= suppress_test type ========================================================
//=============================================================================
type (
// None at present.
)

//=============================================================================
//= suppress_test var =========================================================
//=============================================================================
var (
	tsclData = []struct {
		ba     []uint8
		wanted string
	}{
		{
			[]uint8{0x61, 0x62, 0x63, 0x64, 0x65, 0x66},
			"abcdef",
		},
		{
			[]uint8{0x61, 0x62, 0x63, 0x00, 0x64, 0x65, 0x66},
			"abc",
		},
		{
			[]uint8{0x64, 0x65, 0x66, 0x00},
			"def",
		},
		{
			[]uint8{0x00, 0x64, 0x65, 0x66, 0x00},
			"",
		},
	}
	tsctData = []struct {
		body       string
		doSuppress bool
		wanted     bool
	}{
		{
			"some data",
			true,
			false,
		},
		{
			"other data",
			false,
			true,
		},
	}
)

//=============================================================================
//= suppress_test const =======================================================
//=============================================================================
const (
// None at present.
)

//=============================================================================
//= testdata_test type ========================================================
//=============================================================================
type (
	//
	sendRecvCodecData struct {
		sid string
		sk  []string          // send keys
		sv  []string          // send values
		rv  map[string]string // expected receive value
	}
	supdata struct {
		v string // version
		s bool   // is supported
	}
)

//=============================================================================
//= testdata_test var =========================================================
//=============================================================================
var (
	srcdList10 = []sendRecvCodecData{
		{sid: "sub10a",
			sk: []string{"keya"},
			sv: []string{"valuea"},
			rv: map[string]string{"keya": "valuea"}},
		{sid: "sub10b",
			sk: []string{"key:one"},
			sv: []string{"value:a"},
			rv: map[string]string{"key": "one:value:a"}},
		{sid: "sub10c",
			sk: []string{"key"},
			sv: []string{"valuec"},
			rv: map[string]string{"key": "valuec"}},
	}

	srcdList1p = []sendRecvCodecData{
		{sid: "sub1xa",
			sk: []string{"keya"},
			sv: []string{"valuea"},
			rv: map[string]string{"keya": "valuea"}},
		{sid: "sub1xb",
			sk: []string{"key:one", "key/ntwo", "key:three/naaa\\bbb"},
			sv: []string{"value\\one", "value:two\\back:slash", "value\\three:aaa/nbbb"},
			rv: map[string]string{"key:one": "value\\one",
				"key/ntwo":            "value:two\\back:slash",
				"key:three/naaa\\bbb": "value\\three:aaa/nbbb"}},
	}

	srcdmap = map[string][]sendRecvCodecData{SPL_10: srcdList10,
		SPL_11: srcdList1p,
		SPL_12: srcdList1p}
)

//=============================================================================
//= testdata_test const =======================================================
//=============================================================================
const (
// None at present.
)

//=============================================================================
//= trans_test type ===========================================================
//=============================================================================
type (
	transBasicData struct {
		action string
		th     Headers
		te     error
	}
	transSendCommitData struct {
		tid string
		exe error
	}
	transSendAbortData struct {
		tid string
		exe error
	}
	transMessageOrderData struct {
		sh Headers
		se error
	}
)

//=============================================================================
//= trans_test var ============================================================
//=============================================================================
var (
	transBasicList = []transBasicData{
		{BEGIN, Headers{}, EREQTIDBEG},
		{COMMIT, Headers{}, EREQTIDCOM},
		{ABORT, Headers{}, EREQTIDABT},
		{BEGIN, Headers{HK_TRANSACTION, ""}, ETIDBEGEMT},
		{COMMIT, Headers{HK_TRANSACTION, ""}, ETIDCOMEMT},
		{ABORT, Headers{HK_TRANSACTION, ""}, ETIDABTEMT},
	}
	transSendCommitList = []transSendCommitData{
		{"trans.send.commit", nil},
	}

	transSendAbortList = []transSendAbortData{
		{"trans.send.abort", nil},
	}
	transMessageOrderList = []transMessageOrderData{
		{Headers{HK_DESTINATION, "/queue/tsrbdata.q"}, nil},
	}
)

//=============================================================================
//= trans_test const ==========================================================
//=============================================================================
const (
// None at present.
)

//=============================================================================
//= unsub_test type ===========================================================
//=============================================================================
type (
	unsubNoHeaderData struct {
		proto string
		exe   error
	}
	unsubNoIDData struct {
		proto  string
		unsubh Headers
		exe    error
	}
	unsubBoolData struct {
		proto    string
		subfirst bool
		subh     Headers
		unsubh   Headers
		exe1     error
		exe2     error
	}
)

//=============================================================================
//= unsub_test var ============================================================
//=============================================================================
var (
	unsubNoHeaderDataList = []subNoHeaderData{
		{SPL_10, EUNODSID},
		{SPL_11, EUNOSID},
		{SPL_12, EUNOSID},
	}
	unsubNoIDDataList = []subNoIDData{
		// 1.0
		{SPL_10,
			Headers{},
			EUNODSID},
		{SPL_10,
			Headers{HK_DESTINATION, "/queue/unsubIDTest.10.1"},
			EUNOSID},
		{SPL_10,
			Headers{HK_DESTINATION, "/queue/unsubIDTest.10.2",
				HK_ID, "unsubIDTest.10.2"},
			EBADSID},
		// 1.1
		{SPL_11,
			Headers{},
			EREQDIUNS},
		{SPL_11,
			Headers{HK_DESTINATION, "/queue/unsubIDTest.11.1"},
			EUNOSID},
		{SPL_11,
			Headers{HK_DESTINATION, "/queue/unsubIDTest.11.2",
				HK_ID, "unsubIDTest.11.2"},
			EUNOSID},
		// 1.2
		{SPL_12,
			Headers{},
			EUNODSID},
		{SPL_12,
			Headers{HK_DESTINATION, "/queue/unsubIDTest.12.1"},
			EUNOSID},
		{SPL_12,
			Headers{HK_DESTINATION, "/queue/unsubIDTest.12.2",
				HK_ID, "unsubIDTest.12.2"},
			EUNOSID},
	}

	// REQIDUNS = Error("id required, UNSUBSCRIBE")
	// REQDIUNS  = Error("destination required, UNSUBSCRIBE")

	unsubBoolDataList = []unsubBoolData{

		// 1.0
		{SPL_10, false, // 0
			Headers{},
			Headers{},
			EUNODSID, EUNODSID},

		{SPL_10, false,
			Headers{HK_DESTINATION, "/queue/PlainDataTest.10.1"},
			Headers{HK_DESTINATION, "/queue/PlainDataTest.10.1"},
			nil, EUNODSID},

		{SPL_10, true,
			Headers{HK_DESTINATION, "/queue/PlainDataTest.10.2"},
			Headers{HK_DESTINATION, "/queue/PlainDataTest.10.2"},
			nil, nil},

		// 1.1
		{SPL_11, false, // 3
			Headers{},
			Headers{},
			EUNOSID, EUNOSID},

		{SPL_11, false,
			Headers{HK_DESTINATION, "/queue/PlainDataTest.11.1"},
			Headers{HK_DESTINATION, "/queue/PlainDataTest.11.1"},
			EUNOSID, EUNOSID},

		{SPL_11, true,
			Headers{HK_DESTINATION, "/queue/PlainDataTest.11.2"},
			Headers{HK_DESTINATION, "/queue/PlainDataTest.11.2"},
			nil, EUNOSID},

		// 1.2
		{SPL_12, false,
			Headers{},
			Headers{},
			EUNOSID, EUNOSID},

		{SPL_12, false,
			Headers{HK_DESTINATION, "/queue/PlainDataTest.12.1"},
			Headers{HK_DESTINATION, "/queue/PlainDataTest.12.1"},
			EUNOSID, EUNOSID},

		{SPL_12, true,
			Headers{HK_DESTINATION, "/queue/PlainDataTest.10.1"},
			Headers{HK_DESTINATION, "/queue/PlainDataTest.10.1"},
			nil, EUNOSID},
	}
)

//=============================================================================
//= unsub_test const ==========================================================
//=============================================================================
const (
// None at present.
)

//=============================================================================
//= utils_test type ===========================================================
//=============================================================================
type (
	multi_send_data struct {
		conn  *Connection // this connection
		dest  string      // queue/topic name
		mpref string      // message prefix
		count int         // number of messages
	}
)

//=============================================================================
//= utils_test var ============================================================
//=============================================================================
var (
// None at present.
)

//=============================================================================
//= utils_test const ==========================================================
//=============================================================================
const (
// None at present.
)

//=============================================================================
//= shovel_dup_headers_test type ==============================================
//=============================================================================
type (
// None at present.
)

//=============================================================================
//= shovel_dup_headers_test var ===============================================
//=============================================================================
var (
	tsdhHeaders = Headers{
		"dupkey1", "value0",
		"dupkey1", "value1",
		"dupkey1", "value2",
	}
	wantedDupeV1 = Headers{
		"dupkey1", "value1",
	}
	wantedDupeV2 = Headers{
		"dupkey1", "value2",
	}
	wantedDupeVAll = Headers{
		"dupkey1", "value1",
		"dupkey1", "value2",
	}
)

//=============================================================================
//= shovel_dup_headers_test const =============================================
//=============================================================================
const (
// None at present.
)

//=============================================================================
//= deadline_test type ========================================================
//=============================================================================
type (
// None at present.
)

//=============================================================================
//= deadline_test var =========================================================
//=============================================================================
var (
	wdleInit = false // Enabled just after init
)

//=============================================================================
//= deadline_test const =======================================================
//=============================================================================
const (
// None at present.
)

//=============================================================================
//= for use by all type =======================================================
//=============================================================================
type (
// None at present.
)

//=============================================================================
//= for use by all var ========================================================
//=============================================================================
var (
	TEST_HEADERS     = Headers{HK_LOGIN, "guest", HK_PASSCODE, "guest"}
	TEST_TDESTPREF   = "/queue/test.pref."
	TEST_TRANID      = "TransactionA"
	md               MessageData
	hv               string
	ok               bool
	empty_headers    = Headers{}
	testuser         = senv.Login()
	testpw           = senv.Passcode()
	login_headers    = Headers{HK_LOGIN, testuser, HK_PASSCODE, testpw}
	rid              = "receipt-12345"
	oneOnePlusProtos = []string{SPL_11, SPL_12}
	e                error
	n                net.Conn
	conn             *Connection
	sc               <-chan MessageData
	sp               string
	badam            = "AckModeInvalid"
	brokerid         int
	tm               = "A Test Message."
	tlg              = log.New(os.Stderr, "TLG|", log.Ldate|log.Lmicroseconds)
)

//=============================================================================
//= for use by all const ======================================================
//=============================================================================
const (
	TEST_ANYBROKER = iota
	TEST_AMQ       = iota
	TEST_RMQ       = iota
	TEST_ARTEMIS   = iota
	TEST_APOLLO    = iota
)