Function TestResolverService_GetSecret

plugin/resolver_test.go:51–86

(t *testing.T)

}

func TestResolverService_GetSecret(t *testing.T) {
	t.Parallel()
	tests := []struct {
		name string
		test func(t *testing.T)
	}{
		{
			name: "does not resolve secrets before setup completed",
			test: func(t *testing.T) {
				m := &mockHandler{}
				s := &resolverService{handler: m}
				_, err := s.GetSecrets(t.Context(), newGetSecretRequest(mockSecretPattern))
				assert.ErrorContains(t, err, "registration incomplete (timeout ")
				assert.Equal(t, 0, m.getSecretCalled)
			},
		},
		{
			name: "returns secret value",
			test: func(t *testing.T) {
				m := &mockHandler{}
				done := make(chan struct{})
				close(done)
				s := &resolverService{handler: m, setupCompleted: done, registrationTimeout: 10 * time.Second}
				resp, err := s.GetSecrets(t.Context(), newGetSecretRequest(mockSecretPattern))
				assert.NoError(t, err)
				assert.Equal(t, resp, mockResponse)
				assert.Equal(t, 1, m.getSecretCalled)
			},
		},
	}
	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			tt.test(t)
		})
	}
}

func newGetSecretRequest(pattern secrets.Pattern) *connect.Request[resolverv1.GetSecretsRequest] {
	return connect.NewRequest(resolverv1.GetSecretsRequest_builder{