Fix / device change detection broken
This commit is contained in:
parent
51228a3a5c
commit
51b7a0aeae
|
@ -360,6 +360,8 @@ internal class DefaultCryptoService @Inject constructor(
|
||||||
// be called for all e2e rooms during the processing of the sync,
|
// be called for all e2e rooms during the processing of the sync,
|
||||||
// at which point we'll start tracking all the users of that room.
|
// at which point we'll start tracking all the users of that room.
|
||||||
deviceListManager.invalidateAllDeviceLists()
|
deviceListManager.invalidateAllDeviceLists()
|
||||||
|
// always track my devices?
|
||||||
|
deviceListManager.startTrackingDeviceList(listOf(userId))
|
||||||
deviceListManager.refreshOutdatedDeviceLists()
|
deviceListManager.refreshOutdatedDeviceLists()
|
||||||
} catch (failure: Throwable) {
|
} catch (failure: Throwable) {
|
||||||
Timber.e(failure, "## CRYPTO onSyncWillProcess ")
|
Timber.e(failure, "## CRYPTO onSyncWillProcess ")
|
||||||
|
|
|
@ -156,6 +156,7 @@ internal class DeviceListManager @Inject constructor(private val cryptoStore: IM
|
||||||
* @param left the user ids list which left a room
|
* @param left the user ids list which left a room
|
||||||
*/
|
*/
|
||||||
fun handleDeviceListsChanges(changed: Collection<String>, left: Collection<String>) {
|
fun handleDeviceListsChanges(changed: Collection<String>, left: Collection<String>) {
|
||||||
|
Timber.v("## CRYPTO: handleDeviceListsChanges changed:$changed / left:$left")
|
||||||
var isUpdated = false
|
var isUpdated = false
|
||||||
val deviceTrackingStatuses = cryptoStore.getDeviceTrackingStatuses().toMutableMap()
|
val deviceTrackingStatuses = cryptoStore.getDeviceTrackingStatuses().toMutableMap()
|
||||||
|
|
||||||
|
@ -483,6 +484,7 @@ internal class DeviceListManager @Inject constructor(private val cryptoStore: IM
|
||||||
* This method must be called on getEncryptingThreadHandler() thread.
|
* This method must be called on getEncryptingThreadHandler() thread.
|
||||||
*/
|
*/
|
||||||
suspend fun refreshOutdatedDeviceLists() {
|
suspend fun refreshOutdatedDeviceLists() {
|
||||||
|
Timber.v("## CRYPTO | refreshOutdatedDeviceLists()")
|
||||||
val deviceTrackingStatuses = cryptoStore.getDeviceTrackingStatuses().toMutableMap()
|
val deviceTrackingStatuses = cryptoStore.getDeviceTrackingStatuses().toMutableMap()
|
||||||
|
|
||||||
val users = deviceTrackingStatuses.keys.filterTo(mutableListOf()) { userId ->
|
val users = deviceTrackingStatuses.keys.filterTo(mutableListOf()) { userId ->
|
||||||
|
|
|
@ -49,6 +49,10 @@ internal class SyncResponseHandler @Inject constructor(@SessionDatabase private
|
||||||
val reporter = initialSyncProgressService.takeIf { isInitialSync }
|
val reporter = initialSyncProgressService.takeIf { isInitialSync }
|
||||||
|
|
||||||
measureTimeMillis {
|
measureTimeMillis {
|
||||||
|
if (!cryptoService.isStarted()) {
|
||||||
|
Timber.v("Should start cryptoService")
|
||||||
|
cryptoService.start()
|
||||||
|
}
|
||||||
cryptoService.onSyncWillProcess(isInitialSync)
|
cryptoService.onSyncWillProcess(isInitialSync)
|
||||||
}.also {
|
}.also {
|
||||||
Timber.v("Finish handling start cryptoService in $it ms")
|
Timber.v("Finish handling start cryptoService in $it ms")
|
||||||
|
|
Loading…
Reference in New Issue