Function TestJoinServerRace

pkg/interop/client_test.go:688–864

(t *testing.T)

}

func TestJoinServerRace(t *testing.T) { //nolint:paralleltest
	for _, tc := range []struct { //nolint:paralleltest
		Name              string
		NewServers        func(*assertions.Assertion) []*httptest.Server
		NetID             types.NetID
		Request           *ttnpb.JoinRequest
		ResponseAssertion func(*assertions.Assertion, *ttnpb.JoinResponse) bool
		ErrorAssertion    func(*assertions.Assertion, error) bool
	}{
		{
			Name: "Slowest server successful",
			NewServers: func(a *assertions.Assertion) []*httptest.Server {
				return []*httptest.Server{
					newTLSServer(9183, http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
						time.Sleep(test.Delay << 4)
						test.Must[any](nil, json.NewEncoder(w).Encode(map[string]any{
							"ProtocolVersion": "1.0",
							"TransactionID":   0,
							"MessageType":     "JoinAns",
							"ReceiverToken":   "01",
							"SenderID":        "70B3D57ED0000000",
							"ReceiverID":      "42FFFF",
							"PHYPayload":      "204D675073BB4153B23653EFA82C1F3A49E19C2A8696C9A34BF492674779E4BEFA",
							"Result": map[string]any{
								"ResultCode": "Success",
							},
							"Lifetime": 0,
							"NwkSKey": map[string]any{
								"KEKLabel": "ns:42ffff",
								"AESKey":   "EB56FE6681999F25D548CFEDD4A6528B331BB5ADE1CAF17F",
							},
							"AppSKey": map[string]any{
								"KEKLabel": "as:010042",
								"AESKey":   "2A195CC93CA54AD82CFB36C83D91450F3D2D523556F13E69",
							},
							"SessionKeyID": "016BFA7BAD4756346A674981E75CDBDC",
						}))
					})),
					newTLSServer(9184, http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
						test.Must[any](nil, json.NewEncoder(w).Encode(map[string]any{
							"ProtocolVersion": "1.0",
							"TransactionID":   0.0,
							"MessageType":     "JoinAns",
							"SenderID":        "EC656E0000000001",
							"ReceiverID":      "42FFFF",
							"Result": map[string]any{
								"ResultCode": "MICFailed",
							},
						}))
					})),
				}
			},
			NetID: types.NetID{0x42, 0xff, 0xff},
			Request: &ttnpb.JoinRequest{
				SelectedMacVersion: ttnpb.MACVersion_MAC_V1_0_3,
				DevAddr:            types.DevAddr{0x01, 0x02, 0x03, 0x04}.Bytes(),
				RxDelay:            ttnpb.RxDelay_RX_DELAY_5,
				DownlinkSettings:   &ttnpb.DLSettings{},