Skip to content
Snippets Groups Projects
Commit 55c1c89f authored by Taras's avatar Taras
Browse files

Move knock into room service

parent 3266332c
No related branches found
No related tags found
No related merge requests found
......@@ -293,4 +293,7 @@ interface RoomService {
* This is useful for refreshing summary content with encrypted messages after receiving new room keys.
*/
fun refreshJoinedRoomSummaryPreviews(roomId: String?)
//Ask permission to join the room.
suspend fun knock(roomId: String, reason: String? = null)
}
......@@ -95,7 +95,4 @@ interface MembershipService {
@Deprecated("Use remove instead", ReplaceWith("remove(userId, reason)"))
suspend fun kick(userId: String, reason: String? = null) = remove(userId, reason)
//Ask permission to join the room.
suspend fun knock(userId: String, reason: String? = null)
}
......@@ -51,6 +51,7 @@ import org.matrix.android.sdk.internal.session.room.delete.DeleteLocalRoomTask
import org.matrix.android.sdk.internal.session.room.membership.RoomChangeMembershipStateDataSource
import org.matrix.android.sdk.internal.session.room.membership.RoomMemberHelper
import org.matrix.android.sdk.internal.session.room.membership.joining.JoinRoomTask
import org.matrix.android.sdk.internal.session.room.membership.joining.KnockTask
import org.matrix.android.sdk.internal.session.room.membership.leaving.LeaveRoomTask
import org.matrix.android.sdk.internal.session.room.peeking.PeekRoomTask
import org.matrix.android.sdk.internal.session.room.peeking.ResolveRoomStateTask
......@@ -77,8 +78,9 @@ internal class DefaultRoomService @Inject constructor(
private val roomSummaryDataSource: RoomSummaryDataSource,
private val roomChangeMembershipStateDataSource: RoomChangeMembershipStateDataSource,
private val leaveRoomTask: LeaveRoomTask,
private val roomSummaryUpdater: RoomSummaryUpdater
) : RoomService {
private val roomSummaryUpdater: RoomSummaryUpdater,
private val knockTask: KnockTask
) : RoomService {
override suspend fun createRoom(createRoomParams: CreateRoomParams): String {
return createRoomTask.executeRetry(createRoomParams, 3)
......@@ -262,4 +264,8 @@ internal class DefaultRoomService @Inject constructor(
}
return roomSummaryDataSource.getAllRoomSummaryChildOfLive(spaceId, memberships)
}
override suspend fun knock(roomId: String, reason: String?) {
knockTask.execute(KnockTask.Params(roomId, reason))
}
}
......@@ -55,7 +55,6 @@ internal class DefaultMembershipService @AssistedInject constructor(
private val inviteTask: InviteTask,
private val inviteThreePidTask: InviteThreePidTask,
private val membershipAdminTask: MembershipAdminTask,
private val knockTask: KnockTask,
private val roomDataSource: RoomDataSource,
private val cryptoService: CryptoService,
@UserId
......@@ -166,9 +165,4 @@ internal class DefaultMembershipService @AssistedInject constructor(
val params = InviteThreePidTask.Params(roomId, threePid)
return inviteThreePidTask.execute(params)
}
override suspend fun knock(userId: String, reason: String?) {
val params = KnockTask.Params(roomId, reason)
knockTask.execute(params)
}
}
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment