Skip to content

Commit

Permalink
Rearrange CallService methods (#1093)
Browse files Browse the repository at this point in the history
  • Loading branch information
@liviu-timar
liviu-timar authored May 22, 2024
1 parent 8ed78a3 commit bfe7f3d
Showing 1 changed file with 118 additions and 119 deletions.
237 changes: 118 additions & 119 deletions ...main/kotlin/io/getstream/video/android/core/notifications/internal/service/CallService.kt
View file
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,6 @@ import io.getstream.video.android.model.StreamCallId
import io.getstream.video.android.model.streamCallDisplayName
import io.getstream.video.android.model.streamCallId
import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.DelicateCoroutinesApi
import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.cancel
import kotlinx.coroutines.launch
Expand Down Expand Up @@ -165,55 +164,6 @@ internal class CallService : Service() {
}
}

override fun onTimeout(startId: Int) {
super.onTimeout(startId)
logger.w { "Timeout received from the system, service will stop." }
stopService()
}

override fun onTaskRemoved(rootIntent: Intent?) {
super.onTaskRemoved(rootIntent)

endCall()
stopService()
}

private fun endCall() {
callId?.let { callId ->
StreamVideo.instanceOrNull()?.let { streamVideo ->
val call = streamVideo.call(callId.type, callId.id)
val ringingState = call.state.ringingState.value

if (ringingState is RingingState.Outgoing) {
// If I'm calling, end the call for everyone
serviceScope.launch {
call.reject()
logger.i { "[onTaskRemoved] Ended outgoing call for all users." }
}
} else if (ringingState is RingingState.Incoming) {
// If I'm receiving a call...
val memberCount = call.state.members.value.size
logger.i { "[onTaskRemoved] Total members: $memberCount" }
if (memberCount == 2) {
// ...and I'm the only one being called, end the call for both users
serviceScope.launch {
call.reject()
logger.i { "[onTaskRemoved] Ended incoming call for both users." }
}
} else {
// ...and there are other users other than me and the caller, end the call just for me
call.leave()
logger.i { "[onTaskRemoved] Ended incoming call for me." }
}
} else {
// If I'm in an ongoing call, end the call for me
call.leave()
logger.i { "[onTaskRemoved] Ended ongoing call for me." }
}
}
}
}

override fun onStartCommand(intent: Intent?, flags: Int, startId: Int): Int {
val trigger = intent?.getStringExtra(TRIGGER_KEY)
val streamVideo = StreamVideo.instanceOrNull() as? StreamVideoImpl
Expand Down Expand Up @@ -343,6 +293,53 @@ internal class CallService : Service() {
}
}

@SuppressLint("MissingPermission")
private fun showIncomingCall(notification: Notification, notificationId: Int) {
if (callId == null) { // If there isn't another call in progress (callId is set in onStartCommand())
startForeground(
notificationId,
notification,
) // The service was started with startForegroundService() (from companion object), so we need to call startForeground().
} else {
NotificationManagerCompat // Else, we show a simple notification (the service was already started as a foreground service).
.from(this)
.notify(notificationId, notification)
}
}

private fun removeIncomingCall(notificationId: Int) {
NotificationManagerCompat.from(this).cancel(notificationId)

if (callId == null) {
stopService()
}
}

private fun initializeCallAndSocket(
streamVideo: StreamVideo,
callId: StreamCallId,
) {
// Update call
serviceScope.launch {
val call = streamVideo.call(callId.type, callId.id)
val update = call.get()
if (update.isFailure) {
update.errorOrNull()?.let {
logger.e { it.message }
} ?: let {
logger.e { "Failed to update call." }
}
stopService() // Failed to update call
return@launch
}
}

// Monitor coordinator socket
serviceScope.launch {
streamVideo.connectIfNotAlreadyConnected()
}
}

private fun updateRingingCall(
streamVideo: StreamVideo,
callId: StreamCallId,
Expand Down Expand Up @@ -483,59 +480,87 @@ internal class CallService : Service() {
}
}

@OptIn(DelicateCoroutinesApi::class)
private fun initializeCallAndSocket(
streamVideo: StreamVideo,
callId: StreamCallId,
) {
// Update call
serviceScope.launch {
val call = streamVideo.call(callId.type, callId.id)
val update = call.get()
if (update.isFailure) {
update.errorOrNull()?.let {
logger.e { it.message }
} ?: let {
logger.e { "Failed to update call." }
}
stopService() // Failed to update call
return@launch
private fun registerToggleCameraBroadcastReceiver() {
if (!isToggleCameraBroadcastReceiverRegistered) {
try {
registerReceiver(
toggleCameraBroadcastReceiver,
IntentFilter().apply {
addAction(Intent.ACTION_SCREEN_ON)
addAction(Intent.ACTION_SCREEN_OFF)
addAction(Intent.ACTION_USER_PRESENT)
},
)
isToggleCameraBroadcastReceiverRegistered = true
} catch (e: Exception) {
logger.d { "Unable to register ToggleCameraBroadcastReceiver." }
}
}
}

// Monitor coordinator socket
serviceScope.launch {
streamVideo.connectIfNotAlreadyConnected()
private fun unregisterToggleCameraBroadcastReceiver() {
if (isToggleCameraBroadcastReceiverRegistered) {
try {
unregisterReceiver(toggleCameraBroadcastReceiver)
isToggleCameraBroadcastReceiverRegistered = false
} catch (e: Exception) {
logger.d { "Unable to unregister ToggleCameraBroadcastReceiver." }
}
}
}

override fun onDestroy() {
override fun onTimeout(startId: Int) {
super.onTimeout(startId)
logger.w { "Timeout received from the system, service will stop." }
stopService()
super.onDestroy()
}

// This service does not return a Binder
override fun onBind(intent: Intent?): IBinder? = null
override fun onTaskRemoved(rootIntent: Intent?) {
super.onTaskRemoved(rootIntent)

// Internal logic
@SuppressLint("MissingPermission")
private fun showIncomingCall(notification: Notification, notificationId: Int) {
if (callId == null) { // If there isn't another call in progress (callId is set in onStartCommand())
startForeground(
notificationId,
notification,
) // The service was started with startForegroundService() (from companion object), so we need to call startForeground().
} else {
NotificationManagerCompat // Else, we show a simple notification (the service was already started as a foreground service).
.from(this)
.notify(notificationId, notification)
}
endCall()
stopService()
}

private fun removeIncomingCall(notificationId: Int) {
NotificationManagerCompat.from(this).cancel(notificationId)
private fun endCall() {
callId?.let { callId ->
StreamVideo.instanceOrNull()?.let { streamVideo ->
val call = streamVideo.call(callId.type, callId.id)
val ringingState = call.state.ringingState.value

if (ringingState is RingingState.Outgoing) {
// If I'm calling, end the call for everyone
serviceScope.launch {
call.reject()
logger.i { "[onTaskRemoved] Ended outgoing call for all users." }
}
} else if (ringingState is RingingState.Incoming) {
// If I'm receiving a call...
val memberCount = call.state.members.value.size
logger.i { "[onTaskRemoved] Total members: $memberCount" }
if (memberCount == 2) {
// ...and I'm the only one being called, end the call for both users
serviceScope.launch {
call.reject()
logger.i { "[onTaskRemoved] Ended incoming call for both users." }
}
} else {
// ...and there are other users other than me and the caller, end the call just for me
call.leave()
logger.i { "[onTaskRemoved] Ended incoming call for me." }
}
} else {
// If I'm in an ongoing call, end the call for me
call.leave()
logger.i { "[onTaskRemoved] Ended ongoing call for me." }
}
}
}
}

if (callId == null) stopService()
override fun onDestroy() {
stopService()
super.onDestroy()
}

/**
Expand Down Expand Up @@ -568,37 +593,11 @@ internal class CallService : Service() {
stopSelf()
}

private fun registerToggleCameraBroadcastReceiver() {
if (!isToggleCameraBroadcastReceiverRegistered) {
try {
registerReceiver(
toggleCameraBroadcastReceiver,
IntentFilter().apply {
addAction(Intent.ACTION_SCREEN_ON)
addAction(Intent.ACTION_SCREEN_OFF)
addAction(Intent.ACTION_USER_PRESENT)
},
)
isToggleCameraBroadcastReceiverRegistered = true
} catch (e: Exception) {
logger.d { "Unable to register ToggleCameraBroadcastReceiver." }
}
}
}

private fun unregisterToggleCameraBroadcastReceiver() {
if (isToggleCameraBroadcastReceiverRegistered) {
try {
unregisterReceiver(toggleCameraBroadcastReceiver)
isToggleCameraBroadcastReceiverRegistered = false
} catch (e: Exception) {
logger.d { "Unable to unregister ToggleCameraBroadcastReceiver." }
}
}
}

private fun clearMediaPlayer() {
mediaPlayer?.release()
mediaPlayer = null
}

// This service does not return a Binder
override fun onBind(intent: Intent?): IBinder? = null
}

0 comments on commit bfe7f3d

Please sign in to comment.