Merge branch 'dev' into 'master'

import dagger.Provides

import dagger.multibindings.IntoMap

import io.reactivex.disposables.CompositeDisposable

import javax.inject.Named

@Module

class MainActivityModule {

    @ActivityScope

    fun provideCompositeDiposableLifecycle(): CompositeDisposable = CompositeDisposable()

    @Provides

    @Named("threadId")

    fun provideThreadId(activity: MainActivity): Long = activity.intent.extras?.getLong("threadId")

            ?: 0L

    @Provides

    @IntoMap

    @ViewModelKey(MainViewModel::class)

import com.moez.QKSMS.common.base.QkViewModel

import com.moez.QKSMS.common.util.BillingManager

import com.moez.QKSMS.extensions.mapNotNull

import com.moez.QKSMS.interactor.DeleteConversations

import com.moez.QKSMS.interactor.MarkAllSeen

import com.moez.QKSMS.interactor.MarkArchived

import com.moez.QKSMS.interactor.MarkPinned

import com.moez.QKSMS.interactor.MarkRead

import com.moez.QKSMS.interactor.MarkUnarchived

import com.moez.QKSMS.interactor.MarkUnpinned

import com.moez.QKSMS.interactor.MarkUnread

import com.moez.QKSMS.interactor.MigratePreferences

import com.moez.QKSMS.interactor.SyncMessages

import com.moez.QKSMS.interactor.*

import com.moez.QKSMS.listener.ContactAddedListener

import com.moez.QKSMS.manager.ChangelogManager

import com.moez.QKSMS.manager.PermissionManager

import java.util.*

import java.util.concurrent.TimeUnit

import javax.inject.Inject

import javax.inject.Named

class MainViewModel @Inject constructor(

        @Named("threadId") private val threadId: Long,

        markAllSeen: MarkAllSeen,

        migratePreferences: MigratePreferences,

        syncRepository: SyncRepository,

        private val conversationRepo: ConversationRepository,

        private val deleteConversations: DeleteConversations,

        private val markArchived: MarkArchived,

        private val markBlocked: MarkBlocked,

        private val markPinned: MarkPinned,

        private val markRead: MarkRead,

        private val markUnarchived: MarkUnarchived,

        private val navigator: Navigator,

        private val permissionManager: PermissionManager,

        private val prefs: Preferences,

    private val syncMessages: SyncMessages

        private val syncMessages: SyncMessages,

        private val syncContacts: ContactSync

) : QkViewModel<MainView, MainState>(MainState(page = Inbox(data = conversationRepo.getConversations()))) {

    init {

                }

                .autoDisposable(view.scope())

                .subscribe()

        if (threadId == 0L) {

            syncContacts.execute(Unit)

        }

    }

}