@@ -12,8 +12,8 @@ import misk.moshi.adapter
12
12
import retrofit2.Retrofit
13
13
import retrofit2.adapter.guava.GuavaCallAdapterFactory
14
14
import retrofit2.converter.wire.WireConverterFactory
15
- import wisp .client.EnvoyClientEndpointProvider
16
- import wisp .client.HttpClientEnvoyConfig
15
+ import misk .client.EnvoyClientEndpointProvider
16
+ import misk .client.HttpClientEnvoyConfig
17
17
18
18
@Singleton
19
19
class EnvoyCallbackConnectorProvider @Inject constructor(
@@ -22,7 +22,7 @@ class EnvoyCallbackConnectorProvider @Inject constructor(
22
22
private val moshi : Moshi ,
23
23
) : BackfilaCallbackConnectorProvider {
24
24
@com.google.inject.Inject (optional = true )
25
- var envoyClientEndpointProvider: EnvoyClientEndpointProvider ? = null
25
+ private lateinit var envoyClientEndpointProvider: EnvoyClientEndpointProvider
26
26
27
27
override fun validateExtraData (connectorExtraData : String? ) {
28
28
connectorExtraData?.let {
@@ -54,13 +54,7 @@ class EnvoyCallbackConnectorProvider @Inject constructor(
54
54
app = serviceName,
55
55
env = env,
56
56
)
57
-
58
- val baseUrl = if (envoyClientEndpointProvider != null ) {
59
- URL (envoyClientEndpointProvider!! .url(envoyConfig))
60
- } else {
61
- // Fallback: construct a basic URL when EnvoyClientEndpointProvider is not available
62
- URL (" http://localhost:8080/" )
63
- }
57
+ val baseUrl = URL (envoyClientEndpointProvider.url(envoyConfig))
64
58
val httpClientEndpointConfig = httpClientsConfig[baseUrl]
65
59
66
60
var okHttpClient = httpClientFactory.create(httpClientEndpointConfig)
0 commit comments