Skip to content

Commit c34c074

Browse files
rahul-lohrarahul-lohra
committed
refactor(core): extract incoming call coordinator
1 parent f4510e2 commit c34c074

4 files changed

Lines changed: 207 additions & 76 deletions

File tree

‎stream-video-android-core/src/main/kotlin/io/getstream/video/android/core/notifications/internal/service/IncomingCallRequest.kt‎

Lines changed: 31 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,31 @@
1+
/*
2+
* Copyright (c) 2014-2026 Stream.io Inc. All rights reserved.
3+
*
4+
* Licensed under the Stream License;
5+
* you may not use this file except in compliance with the License.
6+
* You may obtain a copy of the License at
7+
*
8+
* https://github.com/GetStream/stream-video-android/blob/main/LICENSE
9+
*
10+
* Unless required by applicable law or agreed to in writing, software
11+
* distributed under the License is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
* See the License for the specific language governing permissions and
14+
* limitations under the License.
15+
*/
16+
17+
package io.getstream.video.android.core.notifications.internal.service
18+
19+
import android.app.Notification
20+
import io.getstream.video.android.core.StreamVideo
21+
import io.getstream.video.android.model.StreamCallId
22+
23+
internal data class IncomingCallRequest(
24+
val callId: StreamCallId,
25+
val callDisplayName: String?,
26+
val callServiceConfiguration: CallServiceConfig,
27+
val isVideo: Boolean,
28+
val payload: Map<String, Any?>,
29+
val streamVideo: StreamVideo,
30+
val notification: Notification?,
31+
)

‎stream-video-android-core/src/main/kotlin/io/getstream/video/android/core/notifications/internal/service/ServiceLauncher.kt‎

Lines changed: 22 additions & 76 deletions
Original file line numberDiff line numberDiff line change
@@ -36,22 +36,20 @@ import android.annotation.SuppressLint
3636
import android.app.Notification
3737
import android.content.Context
3838
import android.os.Bundle
39-
import androidx.core.app.NotificationManagerCompat
4039
import androidx.core.content.ContextCompat
4140
import androidx.core.net.toUri
4241
import io.getstream.log.taggedLogger
4342
import io.getstream.video.android.core.Call
4443
import io.getstream.video.android.core.StreamVideo
4544
import io.getstream.video.android.core.StreamVideoClient
46-
import io.getstream.video.android.core.notifications.NotificationType
4745
import io.getstream.video.android.core.notifications.internal.Throttler
4846
import io.getstream.video.android.core.notifications.internal.VideoPushDelegate.Companion.DEFAULT_CALL_TEXT
49-
import io.getstream.video.android.core.notifications.internal.service.CallService.Companion.TRIGGER_REMOVE_INCOMING_CALL
47+
import io.getstream.video.android.core.notifications.internal.service.incomingcallcoordinator.IncomingCallCoordinator
48+
import io.getstream.video.android.core.notifications.internal.service.incomingcallcoordinator.PreAndroid17IncomingCallCoordinator
5049
import io.getstream.video.android.core.notifications.internal.telecom.TelecomHelper
5150
import io.getstream.video.android.core.notifications.internal.telecom.TelecomPermissions
5251
import io.getstream.video.android.core.notifications.internal.telecom.jetpack.TelecomCall
5352
import io.getstream.video.android.core.notifications.internal.telecom.jetpack.TelecomCallAction
54-
import io.getstream.video.android.core.utils.safeCallWithResult
5553
import io.getstream.video.android.model.StreamCallId
5654
import kotlinx.coroutines.Dispatchers
5755
import kotlinx.coroutines.delay
@@ -66,6 +64,15 @@ internal class ServiceLauncher(val context: Context) {
6664
private val telecomPermissions = TelecomPermissions()
6765
private val jetpackTelecomRepositoryProvider = JetpackTelecomRepositoryProvider(context)
6866
private val throttler = Throttler()
67+
private val incomingCallCoordinator: IncomingCallCoordinator =
68+
PreAndroid17IncomingCallCoordinator(
69+
context = context,
70+
incomingCallPresenter = incomingCallPresenter,
71+
serviceIntentBuilder = serviceIntentBuilder,
72+
telecomPermissions = telecomPermissions,
73+
telecomHelper = telecomHelper,
74+
jetpackTelecomRepositoryProvider = jetpackTelecomRepositoryProvider,
75+
)
6976

7077
@SuppressLint("MissingPermission", "NewApi")
7178
fun showIncomingCall(
@@ -78,43 +85,17 @@ internal class ServiceLauncher(val context: Context) {
7885
streamVideo: StreamVideo,
7986
notification: Notification?,
8087
) {
81-
val result = incomingCallPresenter.showIncomingCall(
82-
context,
83-
callId,
84-
callDisplayName,
85-
callServiceConfiguration,
86-
notification,
88+
incomingCallCoordinator.showIncomingCall(
89+
IncomingCallRequest(
90+
callId = callId,
91+
callDisplayName = callDisplayName,
92+
callServiceConfiguration = callServiceConfiguration,
93+
isVideo = isVideo,
94+
payload = payload,
95+
streamVideo = streamVideo,
96+
notification = notification,
97+
),
8798
)
88-
logger.d { "[showIncomingCall] service start result: $result" }
89-
if (telecomPermissions.canUseTelecom(callServiceConfiguration, context)) {
90-
if (telecomHelper.canUseJetpackTelecom()) {
91-
when (result) {
92-
ShowIncomingCallResult.FG_SERVICE -> {
93-
updateIncomingCallNotification(notification, streamVideo, callId)
94-
95-
val jetpackTelecomRepository = jetpackTelecomRepositoryProvider.get(callId)
96-
97-
val appSchema = (streamVideo as StreamVideoClient).telecomConfig?.schema
98-
val addressUri = "$appSchema:${callId.id}".toUri()
99-
val formattedCallDisplayName = callDisplayName?.takeIf { it.isNotBlank() } ?: DEFAULT_CALL_TEXT
100-
101-
val call = streamVideo.call(callId.type, callId.id)
102-
103-
call.state.jetpackTelecomRepository = (jetpackTelecomRepository)
104-
105-
call.scope.launch {
106-
jetpackTelecomRepository.registerCall(
107-
formattedCallDisplayName,
108-
addressUri,
109-
true,
110-
isVideo,
111-
)
112-
}
113-
}
114-
else -> {}
115-
}
116-
}
117-
}
11899
}
119100

120101
fun showOnGoingCall(call: Call, trigger: String, streamVideo: StreamVideo) {
@@ -193,47 +174,12 @@ internal class ServiceLauncher(val context: Context) {
193174
}
194175
}
195176

196-
/**
197-
* Because we need to retrieve the notification
198-
* in [io.getstream.video.android.core.notifications.internal.telecom.connection.SuccessIncomingTelecomConnection]
199-
*/
200-
private fun updateIncomingCallNotification(
201-
notification: Notification?,
202-
streamVideo: StreamVideo,
203-
callId: StreamCallId,
204-
) {
205-
notification?.let {
206-
val notificationId = callId.getNotificationId(NotificationType.Incoming)
207-
streamVideo.call(callId.type, callId.id)
208-
.state.updateNotification(notificationId, notification)
209-
}
210-
}
211-
212177
fun removeIncomingCall(
213178
context: Context,
214179
callId: StreamCallId,
215180
config: CallServiceConfig = DefaultCallConfigurations.default,
216181
) {
217-
safeCallWithResult {
218-
context.startService(
219-
serviceIntentBuilder.buildStartIntent(
220-
context,
221-
StartServiceParam(
222-
callId,
223-
TRIGGER_REMOVE_INCOMING_CALL,
224-
callServiceConfiguration = config,
225-
),
226-
),
227-
)!!
228-
}.onError {
229-
logger.d {
230-
"[removeIncomingCall] notificationId: ${callId.getNotificationId(
231-
NotificationType.Incoming,
232-
)}"
233-
}
234-
NotificationManagerCompat.from(context)
235-
.cancel(callId.getNotificationId(NotificationType.Incoming))
236-
}
182+
incomingCallCoordinator.dismissIncomingCall(callId, config)
237183
}
238184

239185
/**

‎stream-video-android-core/src/main/kotlin/io/getstream/video/android/core/notifications/internal/service/incomingcallcoordinator/IncomingCallCoordinator.kt‎

Lines changed: 31 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,31 @@
1+
/*
2+
* Copyright (c) 2014-2026 Stream.io Inc. All rights reserved.
3+
*
4+
* Licensed under the Stream License;
5+
* you may not use this file except in compliance with the License.
6+
* You may obtain a copy of the License at
7+
*
8+
* https://github.com/GetStream/stream-video-android/blob/main/LICENSE
9+
*
10+
* Unless required by applicable law or agreed to in writing, software
11+
* distributed under the License is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
* See the License for the specific language governing permissions and
14+
* limitations under the License.
15+
*/
16+
17+
package io.getstream.video.android.core.notifications.internal.service.incomingcallcoordinator
18+
19+
import io.getstream.video.android.core.notifications.internal.service.CallServiceConfig
20+
import io.getstream.video.android.core.notifications.internal.service.IncomingCallRequest
21+
import io.getstream.video.android.model.StreamCallId
22+
23+
internal interface IncomingCallCoordinator {
24+
25+
fun showIncomingCall(request: IncomingCallRequest)
26+
27+
fun dismissIncomingCall(
28+
callId: StreamCallId,
29+
config: CallServiceConfig,
30+
)
31+
}

‎stream-video-android-core/src/main/kotlin/io/getstream/video/android/core/notifications/internal/service/incomingcallcoordinator/PreAndroid17IncomingCallCoordinator.kt‎

Lines changed: 123 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,123 @@
1+
/*
2+
* Copyright (c) 2014-2026 Stream.io Inc. All rights reserved.
3+
*
4+
* Licensed under the Stream License;
5+
* you may not use this file except in compliance with the License.
6+
* You may obtain a copy of the License at
7+
*
8+
* https://github.com/GetStream/stream-video-android/blob/main/LICENSE
9+
*
10+
* Unless required by applicable law or agreed to in writing, software
11+
* distributed under the License is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
* See the License for the specific language governing permissions and
14+
* limitations under the License.
15+
*/
16+
17+
package io.getstream.video.android.core.notifications.internal.service.incomingcallcoordinator
18+
19+
import android.annotation.SuppressLint
20+
import android.content.Context
21+
import androidx.core.app.NotificationManagerCompat
22+
import androidx.core.net.toUri
23+
import io.getstream.log.taggedLogger
24+
import io.getstream.video.android.core.StreamVideoClient
25+
import io.getstream.video.android.core.notifications.NotificationType
26+
import io.getstream.video.android.core.notifications.internal.VideoPushDelegate.Companion.DEFAULT_CALL_TEXT
27+
import io.getstream.video.android.core.notifications.internal.service.CallService.Companion.TRIGGER_REMOVE_INCOMING_CALL
28+
import io.getstream.video.android.core.notifications.internal.service.CallServiceConfig
29+
import io.getstream.video.android.core.notifications.internal.service.IncomingCallPresenter
30+
import io.getstream.video.android.core.notifications.internal.service.IncomingCallRequest
31+
import io.getstream.video.android.core.notifications.internal.service.JetpackTelecomRepositoryProvider
32+
import io.getstream.video.android.core.notifications.internal.service.ServiceIntentBuilder
33+
import io.getstream.video.android.core.notifications.internal.service.ShowIncomingCallResult
34+
import io.getstream.video.android.core.notifications.internal.service.StartServiceParam
35+
import io.getstream.video.android.core.notifications.internal.telecom.TelecomHelper
36+
import io.getstream.video.android.core.notifications.internal.telecom.TelecomPermissions
37+
import io.getstream.video.android.core.utils.safeCallWithResult
38+
import io.getstream.video.android.model.StreamCallId
39+
import kotlinx.coroutines.launch
40+
41+
/** Coordinates the existing incoming-call service and optional Telecom registration path. */
42+
internal class PreAndroid17IncomingCallCoordinator(
43+
private val context: Context,
44+
private val incomingCallPresenter: IncomingCallPresenter,
45+
private val serviceIntentBuilder: ServiceIntentBuilder,
46+
private val telecomPermissions: TelecomPermissions,
47+
private val telecomHelper: TelecomHelper,
48+
private val jetpackTelecomRepositoryProvider: JetpackTelecomRepositoryProvider,
49+
) : IncomingCallCoordinator {
50+
51+
private val logger by taggedLogger("PreAndroid17IncomingCallCoordinator")
52+
53+
@SuppressLint("MissingPermission", "NewApi")
54+
override fun showIncomingCall(request: IncomingCallRequest) {
55+
val result = incomingCallPresenter.showIncomingCall(
56+
context = context,
57+
callId = request.callId,
58+
callDisplayName = request.callDisplayName,
59+
callServiceConfiguration = request.callServiceConfiguration,
60+
notification = request.notification,
61+
)
62+
logger.d { "[showIncomingCall] service start result: $result" }
63+
64+
if (result != ShowIncomingCallResult.FG_SERVICE ||
65+
!telecomPermissions.canUseTelecom(request.callServiceConfiguration, context) ||
66+
!telecomHelper.canUseJetpackTelecom()
67+
) {
68+
return
69+
}
70+
71+
val client = request.streamVideo as StreamVideoClient
72+
updateIncomingCallNotification(request, client)
73+
val jetpackTelecomRepository = jetpackTelecomRepositoryProvider.get(request.callId)
74+
val addressUri = "${client.telecomConfig?.schema}:${request.callId.id}".toUri()
75+
val formattedCallDisplayName = request.callDisplayName
76+
?.takeIf { it.isNotBlank() }
77+
?: DEFAULT_CALL_TEXT
78+
val call = client.call(request.callId.type, request.callId.id)
79+
80+
call.state.jetpackTelecomRepository = jetpackTelecomRepository
81+
call.scope.launch {
82+
jetpackTelecomRepository.registerCall(
83+
displayName = formattedCallDisplayName,
84+
address = addressUri,
85+
isIncoming = true,
86+
isVideoCall = request.isVideo,
87+
)
88+
}
89+
}
90+
91+
override fun dismissIncomingCall(
92+
callId: StreamCallId,
93+
config: CallServiceConfig,
94+
) {
95+
safeCallWithResult {
96+
context.startService(
97+
serviceIntentBuilder.buildStartIntent(
98+
context,
99+
StartServiceParam(
100+
callId = callId,
101+
trigger = TRIGGER_REMOVE_INCOMING_CALL,
102+
callServiceConfiguration = config,
103+
),
104+
),
105+
)!!
106+
}.onError {
107+
val notificationId = callId.getNotificationId(NotificationType.Incoming)
108+
logger.d { "[dismissIncomingCall] notificationId: $notificationId" }
109+
NotificationManagerCompat.from(context).cancel(notificationId)
110+
}
111+
}
112+
113+
private fun updateIncomingCallNotification(
114+
request: IncomingCallRequest,
115+
client: StreamVideoClient,
116+
) {
117+
request.notification?.let { notification ->
118+
val notificationId = request.callId.getNotificationId(NotificationType.Incoming)
119+
client.call(request.callId.type, request.callId.id)
120+
.state.updateNotification(notificationId, notification)
121+
}
122+
}
123+
}

0 commit comments

Comments
 (0)