Function TestServer

pkg/basicstation/cups/server_test.go:180–617

(t *testing.T)

)

func TestServer(t *testing.T) { //nolint:gocyclo
	t.Parallel()
	tlsServer := httptest.NewTLSServer(http.HandlerFunc(http.NotFound))
	t.Cleanup(func() {
		tlsServer.Close()
	})
	tlsServerURL, _ := url.Parse(tlsServer.URL)

	cupsURI := (&url.URL{Scheme: "https", Host: tlsServerURL.Host}).String()
	lnsURI := (&url.URL{Scheme: "wss", Host: tlsServerURL.Host}).String()

	var kv config.KeyVault //nolint:gosimple

	mockGateway := func(hasLNSSecret, redirectCUPS, updateCUPSCreds bool) *ttnpb.Gateway {
		secret := &ttnpb.Secret{
			KeyId: "test-key",
			Value: []byte("KEYCONTENTS"),
		}
		gtw := ttnpb.Gateway{
			Ids: &ttnpb.GatewayIdentifiers{
				GatewayId: "test-gateway",
				Eui:       mockGatewayEUI.Bytes(),
			},
			Attributes: map[string]string{
				cupsStationAttribute: "2.0.0(minihub/debug) 2018-12-06 09:30:35",
				cupsModelAttribute:   "minihub",
				cupsPackageAttribute: "2.0.0",
			},
			GatewayServerAddress: lnsURI,
		}
		if hasLNSSecret {
			gtw.LbsLnsSecret = secret
		}
		if redirectCUPS {
			gtw.TargetCupsUri = cupsURI
			gtw.TargetCupsKey = secret
		}
		if updateCUPSCreds {
			gtw.TargetCupsKey = secret
		}
		return &gtw
	}

	for _, tt := range []struct {
		Name           string
		StoreSetup     func(*mockGatewayClient)
		Options        []Option
		RequestSetup   func(*http.Request)
		SetContext     func(ctx context.Context) context.Context
		AssertError    func(error) bool
		AssertStore    func(*assertions.Assertion, *mockGatewayClient)
		AssertResponse func(*assertions.Assertion, *httptest.ResponseRecorder)
	}{
		{
			Name: "No Auth",
			StoreSetup: func(c *mockGatewayClient) {
				c.res.Get = mockGateway(false, false, false)
				c.res.GetIdentifiersForEUI = c.res.Get.GetIds()