srctree

import dagger.Component

import dagger.Module

import dagger.Provides

import kotlinx.coroutines.CoroutineScope

import kotlinx.coroutines.Dispatchers

import ltd.evilcorp.atox.di.AndroidModule

import org.hamcrest.core.AllOf.allOf

import org.junit.Rule

import org.junit.runner.RunWith

 

class InjectedActivityTestRule<T : Activity>(

activityClass: Class<T>,

 

 

import androidx.test.ext.junit.runners.AndroidJUnit4

import androidx.test.platform.app.InstrumentationRegistry

import kotlin.test.Test

 

@RunWith(AndroidJUnit4::class)

class AvatarFactoryTest {

 

import android.widget.Toast

import androidx.core.app.RemoteInput

import im.tox.tox4j.av.exceptions.ToxavAnswerException

import kotlinx.coroutines.CoroutineScope

import kotlinx.coroutines.Dispatchers

import kotlinx.coroutines.flow.firstOrNull

import ltd.evilcorp.domain.feature.ContactManager

import ltd.evilcorp.domain.tox.PublicKey

import ltd.evilcorp.domain.tox.Tox

 

const val KEY_TEXT_REPLY = "key_text_reply"

const val KEY_CONTACT_PK = "key_contact_pk"

 

package ltd.evilcorp.atox

 

import android.util.Log

import kotlinx.coroutines.CoroutineScope

import kotlinx.coroutines.launch

import ltd.evilcorp.atox.settings.Settings

import ltd.evilcorp.core.vo.UserStatus

import ltd.evilcorp.domain.feature.UserManager

import ltd.evilcorp.domain.tox.Tox

 

private const val TAG = "AutoAway"

 

 

import androidx.core.app.NotificationCompat

import androidx.core.app.NotificationManagerCompat

import androidx.navigation.NavDeepLinkBuilder

import ltd.evilcorp.atox.tox.ToxStarter

import ltd.evilcorp.domain.tox.ToxSaveStatus

 

private const val ENCRYPTED = "aTox profile encrypted"

 

 

import coil.ImageLoader

import coil.decode.GifDecoder

import coil.decode.ImageDecoderDecoder

import ltd.evilcorp.atox.di.ViewModelFactory

import ltd.evilcorp.atox.settings.Settings

import ltd.evilcorp.atox.ui.contactlist.ARG_SHARE

 

private const val TAG = "MainActivity"

private const val SCHEME = "tox:"

 

import androidx.lifecycle.LifecycleService

import androidx.lifecycle.flowWithLifecycle

import androidx.lifecycle.lifecycleScope

import kotlinx.coroutines.Dispatchers

import kotlinx.coroutines.flow.filter

import kotlinx.coroutines.flow.filterNotNull

import ltd.evilcorp.domain.feature.FriendRequestManager

import ltd.evilcorp.domain.tox.Tox

import ltd.evilcorp.domain.tox.ToxSaveStatus

 

private const val TAG = "ToxService"

private const val NOTIFICATION_ID = 1984

 

import android.content.Context

import dagger.BindsInstance

import dagger.Component

import ltd.evilcorp.atox.ActionReceiver

import ltd.evilcorp.atox.BootReceiver

import ltd.evilcorp.atox.MainActivity

import ltd.evilcorp.atox.ToxService

 

@Singleton

@Component(

 

import androidx.room.Room

import dagger.Module

import dagger.Provides

import ltd.evilcorp.core.db.ALL_MIGRATIONS

import ltd.evilcorp.core.db.ContactDao

import ltd.evilcorp.core.db.Database

import ltd.evilcorp.core.db.FriendRequestDao

import ltd.evilcorp.core.db.MessageDao

import ltd.evilcorp.core.db.UserDao

 

@Suppress("unused")

@Module

 

import dagger.MapKey

import dagger.Module

import dagger.multibindings.IntoMap

import ltd.evilcorp.atox.ui.addcontact.AddContactViewModel

import ltd.evilcorp.atox.ui.call.CallViewModel

import ltd.evilcorp.atox.ui.chat.ChatViewModel

import ltd.evilcorp.atox.ui.friendrequest.FriendRequestViewModel

import ltd.evilcorp.atox.ui.settings.SettingsViewModel

import ltd.evilcorp.atox.ui.userprofile.UserProfileViewModel

 

@MustBeDocumented

@Target(

 

import androidx.appcompat.app.AppCompatDelegate

import androidx.core.content.edit

import androidx.preference.PreferenceManager

import ltd.evilcorp.atox.BootReceiver

import ltd.evilcorp.domain.tox.ProxyType

 

enum class FtAutoAccept {

None,

 

 

import android.content.Context

import android.widget.Toast

import kotlinx.coroutines.CoroutineScope

import kotlinx.coroutines.Dispatchers

import kotlinx.coroutines.launch

import ltd.evilcorp.domain.tox.BootstrapNode

import ltd.evilcorp.domain.tox.BootstrapNodeJsonParser

import ltd.evilcorp.domain.tox.BootstrapNodeRegistry

 

@Singleton

class BootstrapNodeRegistryImpl @Inject constructor(

 

import android.util.Log

import im.tox.tox4j.av.enums.ToxavFriendCallState

import im.tox.tox4j.core.enums.ToxFileControl

import kotlinx.coroutines.CoroutineScope

import kotlinx.coroutines.Dispatchers

import kotlinx.coroutines.flow.firstOrNull

import ltd.evilcorp.domain.tox.ToxAvEventListener

import ltd.evilcorp.domain.tox.ToxEventListener

import ltd.evilcorp.domain.tox.toMessageType

 

private const val TAG = "EventListenerCallbacks"

 

}

 

videoReceiveFrameHandler = { pk,

Log.v(

TAG,

"videoReceiveFrame ${pk.fingerprint()}" +

 

import android.util.Log

import im.tox.tox4j.core.exceptions.ToxNewException

import im.tox.tox4j.crypto.exceptions.ToxDecryptionException

import ltd.evilcorp.atox.ToxService

import ltd.evilcorp.atox.settings.Settings

import ltd.evilcorp.domain.feature.FileTransferManager

import ltd.evilcorp.domain.tox.ToxEventListener

import ltd.evilcorp.domain.tox.ToxSaveStatus

import ltd.evilcorp.domain.tox.testToxSave

 

private const val TAG = "ToxStarter"

 

 

import android.graphics.Rect

import android.graphics.RectF

import android.graphics.Typeface

import kotlin.math.abs

 

internal object AvatarFactory {

 

 

import androidx.core.content.res.use

import androidx.core.view.doOnPreDraw

import com.google.android.material.imageview.ShapeableImageView

import ltd.evilcorp.atox.R

import ltd.evilcorp.core.vo.ConnectionStatus

import ltd.evilcorp.core.vo.Contact

import ltd.evilcorp.core.vo.UserStatus

 

private const val STATUS_INDICATOR_SIZE_RATIO_WITH_AVATAR = 12f / 50

 

 

import coil.imageLoader

import coil.request.ImageRequest

import coil.transform.CircleCropTransformation

import ltd.evilcorp.atox.Action

import ltd.evilcorp.atox.ActionReceiver

import ltd.evilcorp.atox.KEY_ACTION

import ltd.evilcorp.core.vo.FriendRequest

import ltd.evilcorp.core.vo.UserStatus

import ltd.evilcorp.domain.tox.PublicKey

 

private const val MESSAGE = "aTox messages"

private const val FRIEND_REQUEST = "aTox friend requests"

 

import android.graphics.drawable.TransitionDrawable

import android.os.Bundle

import android.view.Window

import ltd.evilcorp.atox.R

import ltd.evilcorp.atox.databinding.DialogStatusBinding

import ltd.evilcorp.core.vo.UserStatus

import ltd.evilcorp.domain.feature.UserManager

 

private const val TRANSITION_TIME = 250

 

 

import androidx.lifecycle.LiveData

import androidx.lifecycle.ViewModel

import androidx.lifecycle.asLiveData

import kotlinx.coroutines.CoroutineScope

import kotlinx.coroutines.launch

import ltd.evilcorp.atox.tox.ToxStarter

import ltd.evilcorp.domain.tox.Tox

import ltd.evilcorp.domain.tox.ToxID

import ltd.evilcorp.domain.tox.ToxSaveStatus

 

class AddContactViewModel @Inject constructor(

private val scope: CoroutineScope,

 

import androidx.lifecycle.LiveData

import androidx.lifecycle.ViewModel

import androidx.lifecycle.asLiveData

import kotlinx.coroutines.CoroutineScope

import kotlinx.coroutines.flow.first

import kotlinx.coroutines.launch

import ltd.evilcorp.domain.feature.CallManager

import ltd.evilcorp.domain.feature.ContactManager

import ltd.evilcorp.domain.tox.PublicKey

 

class CallViewModel @Inject constructor(

private val scope: CoroutineScope,

 

import android.widget.TextView

import coil.load

import coil.size.Precision

import ltd.evilcorp.atox.R

import ltd.evilcorp.core.vo.FileTransfer

import ltd.evilcorp.core.vo.Message

import ltd.evilcorp.core.vo.isComplete

import ltd.evilcorp.core.vo.isRejected

import ltd.evilcorp.core.vo.isStarted

 

private const val TAG = "ChatAdapter"

private const val IMAGE_TO_SCREEN_RATIO = 0.75

 

import androidx.fragment.app.viewModels

import androidx.navigation.fragment.findNavController

import com.google.android.material.math.MathUtils.lerp

import ltd.evilcorp.atox.BuildConfig

import ltd.evilcorp.atox.R

import ltd.evilcorp.atox.databinding.FragmentChatBinding

import ltd.evilcorp.core.vo.isComplete

import ltd.evilcorp.domain.feature.CallState

import ltd.evilcorp.domain.tox.PublicKey

 

const val CONTACT_PUBLIC_KEY = "publicKey"

const val FOCUS_ON_MESSAGE_BOX = "focusOnMessageBox"

R.id.backup_history -> {

exportBackupLauncher.launch(

"backup-atox-${"messages" /* TODO @Akito: Put in Helper object. */}_${contactPubKey}_${

}.json",

)

true

 

import androidx.lifecycle.LiveData

import androidx.lifecycle.ViewModel

import androidx.lifecycle.asLiveData

import kotlinx.coroutines.CoroutineScope

import kotlinx.coroutines.Dispatchers

import kotlinx.coroutines.flow.combine

import ltd.evilcorp.domain.feature.ExportManager

import ltd.evilcorp.domain.feature.FileTransferManager

import ltd.evilcorp.domain.tox.PublicKey

 

private const val TAG = "ChatViewModel"

 

 

import android.widget.ImageView

import android.widget.TextView

import androidx.core.content.ContextCompat

import ltd.evilcorp.atox.R

import ltd.evilcorp.atox.databinding.ContactListViewItemBinding

import ltd.evilcorp.atox.databinding.FriendRequestItemBinding

import ltd.evilcorp.atox.ui.AvatarImageView

import ltd.evilcorp.core.vo.Contact

import ltd.evilcorp.core.vo.FriendRequest

 

enum class ContactListItemType {

FriendRequest,

 

import androidx.lifecycle.LiveData

import androidx.lifecycle.ViewModel

import androidx.lifecycle.asLiveData

import kotlinx.coroutines.CoroutineScope

import kotlinx.coroutines.Dispatchers

import kotlinx.coroutines.launch

import ltd.evilcorp.domain.tox.Tox

import ltd.evilcorp.domain.tox.ToxSaveStatus

import ltd.evilcorp.domain.tox.testToxSave

 

class ContactListViewModel @Inject constructor(

private val scope: CoroutineScope,

 

import androidx.lifecycle.LiveData

import androidx.lifecycle.ViewModel

import androidx.lifecycle.asLiveData

import ltd.evilcorp.core.vo.Contact

import ltd.evilcorp.domain.feature.ContactManager

import ltd.evilcorp.domain.tox.PublicKey

 

class ContactProfileViewModel @Inject constructor(contactManager: ContactManager) : ViewModel() {

var publicKey: PublicKey = PublicKey("")

 

import android.content.ContentResolver

import android.net.Uri

import androidx.lifecycle.ViewModel

import ltd.evilcorp.atox.tox.ToxStarter

import ltd.evilcorp.core.vo.User

import ltd.evilcorp.domain.feature.UserManager

import ltd.evilcorp.domain.tox.PublicKey

import ltd.evilcorp.domain.tox.Tox

import ltd.evilcorp.domain.tox.ToxSaveStatus

 

class CreateProfileViewModel @Inject constructor(

private val resolver: ContentResolver,

 

import androidx.lifecycle.LiveData

import androidx.lifecycle.ViewModel

import androidx.lifecycle.asLiveData

import kotlinx.coroutines.CoroutineScope

import kotlinx.coroutines.launch

import ltd.evilcorp.core.repository.MessageRepository

import ltd.evilcorp.core.vo.Sender

import ltd.evilcorp.domain.feature.FriendRequestManager

import ltd.evilcorp.domain.tox.PublicKey

 

class FriendRequestViewModel @Inject constructor(

private val scope: CoroutineScope,

 

import androidx.core.widget.doAfterTextChanged

import androidx.fragment.app.viewModels

import androidx.navigation.fragment.findNavController

import kotlinx.coroutines.CoroutineScope

import kotlinx.coroutines.Dispatchers

import kotlinx.coroutines.launch

import ltd.evilcorp.atox.ui.BaseFragment

import ltd.evilcorp.atox.vmFactory

import ltd.evilcorp.domain.tox.ProxyType

 

private fun Spinner.onItemSelectedListener(callback: (Int) -> Unit) {

this.onItemSelectedListener = object : AdapterView.OnItemSelectedListener {

 

import androidx.lifecycle.MutableLiveData

import androidx.lifecycle.ViewModel

import androidx.lifecycle.viewModelScope

import kotlinx.coroutines.Dispatchers

import kotlinx.coroutines.Job

import kotlinx.coroutines.delay

import ltd.evilcorp.domain.tox.Tox

import ltd.evilcorp.domain.tox.ToxSaveStatus

import ltd.evilcorp.domain.tox.testToxSave

 

private const val TOX_SHUTDOWN_POLL_DELAY_MS = 200L

 

 

import androidx.fragment.app.viewModels

import androidx.lifecycle.viewModelScope

import io.nayuki.qrcodegen.QrCode

import kotlinx.coroutines.Dispatchers

import kotlinx.coroutines.launch

import kotlinx.coroutines.withContext

import ltd.evilcorp.atox.vmFactory

import ltd.evilcorp.core.vo.UserStatus

import ltd.evilcorp.domain.tox.ToxID

 

private const val TOX_MAX_NAME_LENGTH = 128

private const val TOX_MAX_STATUS_MESSAGE_LENGTH = 1007

 

import androidx.lifecycle.LiveData

import androidx.lifecycle.ViewModel

import androidx.lifecycle.asLiveData

import ltd.evilcorp.core.vo.User

import ltd.evilcorp.core.vo.UserStatus

import ltd.evilcorp.domain.feature.UserManager

import ltd.evilcorp.domain.tox.Tox

 

class UserProfileViewModel @Inject constructor(

private val userManager: UserManager,

 

import androidx.room.Room

import androidx.test.ext.junit.runners.AndroidJUnit4

import androidx.test.platform.app.InstrumentationRegistry

import kotlinx.coroutines.ExperimentalCoroutinesApi

import kotlinx.coroutines.flow.first

import kotlinx.coroutines.test.runTest

import ltd.evilcorp.core.vo.Contact

import ltd.evilcorp.core.vo.UserStatus

import org.junit.runner.RunWith

 

@ExperimentalCoroutinesApi

@RunWith(AndroidJUnit4::class)

 

import androidx.sqlite.db.framework.FrameworkSQLiteOpenHelperFactory

import androidx.test.ext.junit.runners.AndroidJUnit4

import androidx.test.platform.app.InstrumentationRegistry

import ltd.evilcorp.core.vo.ConnectionStatus

import ltd.evilcorp.core.vo.Contact

import ltd.evilcorp.core.vo.FileKind

import ltd.evilcorp.core.vo.UserStatus

import org.junit.Rule

import org.junit.runner.RunWith

 

fun Boolean.toInt() = if (this) 1 else 0

 

 

import androidx.room.Room

import androidx.test.ext.junit.runners.AndroidJUnit4

import androidx.test.platform.app.InstrumentationRegistry

import kotlinx.coroutines.ExperimentalCoroutinesApi

import kotlinx.coroutines.flow.first

import kotlinx.coroutines.test.runTest

import ltd.evilcorp.core.vo.UserStatus

import org.junit.Test

import org.junit.runner.RunWith

 

@ExperimentalCoroutinesApi

@RunWith(AndroidJUnit4::class)

 

 

package ltd.evilcorp.core.repository

 

import kotlinx.coroutines.flow.Flow

import ltd.evilcorp.core.db.ContactDao

import ltd.evilcorp.core.vo.ConnectionStatus

import ltd.evilcorp.core.vo.Contact

import ltd.evilcorp.core.vo.UserStatus

 

@Singleton

class ContactRepository @Inject constructor(

 

 

package ltd.evilcorp.core.repository

 

import kotlinx.coroutines.flow.Flow

import ltd.evilcorp.core.db.FileTransferDao

import ltd.evilcorp.core.vo.FileTransfer

 

@Singleton

class FileTransferRepository @Inject internal constructor(

 

 

package ltd.evilcorp.core.repository

 

import kotlinx.coroutines.flow.Flow

import ltd.evilcorp.core.db.FriendRequestDao

import ltd.evilcorp.core.vo.FriendRequest

 

@Singleton

class FriendRequestRepository @Inject internal constructor(

 

 

package ltd.evilcorp.core.repository

 

import java.util.Date

import javax.inject.Inject

import javax.inject.Singleton

 

@Singleton

class MessageRepository @Inject internal constructor(

 

 

package ltd.evilcorp.core.repository

 

import kotlinx.coroutines.flow.Flow

import ltd.evilcorp.core.db.UserDao

import ltd.evilcorp.core.vo.ConnectionStatus

import ltd.evilcorp.core.vo.User

import ltd.evilcorp.core.vo.UserStatus

 

@Singleton

class UserRepository @Inject constructor(

 

 

package ltd.evilcorp.core.db

 

import ltd.evilcorp.core.vo.ConnectionStatus

import ltd.evilcorp.core.vo.MessageType

import ltd.evilcorp.core.vo.Sender

import ltd.evilcorp.core.vo.UserStatus

 

class ConvertersTest {

@Test

 

import androidx.room.Room

import androidx.test.ext.junit.runners.AndroidJUnit4

import androidx.test.platform.app.InstrumentationRegistry

import kotlinx.coroutines.ExperimentalCoroutinesApi

import kotlinx.coroutines.delay

import kotlinx.coroutines.test.TestScope

import ltd.evilcorp.core.repository.ContactRepository

import ltd.evilcorp.core.repository.UserRepository

import org.junit.runner.RunWith

 

class FakeBootstrapNodeRegistry : BootstrapNodeRegistry {

override fun get(n: Int): List<BootstrapNode> = listOf()

 

import android.util.Log

import androidx.core.content.ContextCompat

import im.tox.tox4j.av.exceptions.ToxavCallControlException

import kotlinx.coroutines.CoroutineScope

import kotlinx.coroutines.delay

import kotlinx.coroutines.flow.MutableStateFlow

import ltd.evilcorp.domain.av.AudioCapture

import ltd.evilcorp.domain.tox.PublicKey

import ltd.evilcorp.domain.tox.Tox

 

sealed class CallState {

object NotInCall : CallState()

 

 

package ltd.evilcorp.domain.feature

 

import kotlinx.coroutines.CoroutineScope

import kotlinx.coroutines.flow.first

import kotlinx.coroutines.launch

import ltd.evilcorp.domain.tox.MAX_MESSAGE_LENGTH

import ltd.evilcorp.domain.tox.PublicKey

import ltd.evilcorp.domain.tox.Tox

 

private fun String.chunked(chunkSizeInBytes: Int): MutableList<String> {

val encoder = StandardCharsets.UTF_8.newEncoder()

 

 

package ltd.evilcorp.domain.feature

 

import kotlinx.coroutines.CoroutineScope

import kotlinx.coroutines.launch

import ltd.evilcorp.core.repository.ContactRepository

import ltd.evilcorp.domain.tox.PublicKey

import ltd.evilcorp.domain.tox.Tox

import ltd.evilcorp.domain.tox.ToxID

 

class ContactManager @Inject constructor(

private val scope: CoroutineScope,

 

package ltd.evilcorp.domain.feature

 

import com.fasterxml.jackson.module.kotlin.jacksonObjectMapper

import java.text.SimpleDateFormat

import java.util.Date

import java.util.Locale

import javax.inject.Inject

 

class ExportManager @Inject constructor(

private val messageRepository: MessageRepository,

 

import android.provider.OpenableColumns

import android.util.Log

import im.tox.tox4j.core.enums.ToxFileControl

import kotlinx.coroutines.CoroutineScope

import kotlinx.coroutines.flow.collect

import kotlinx.coroutines.flow.take

import ltd.evilcorp.domain.tox.MAX_AVATAR_SIZE

import ltd.evilcorp.domain.tox.PublicKey

import ltd.evilcorp.domain.tox.Tox

 

private const val TAG = "FileTransferManager"

 

 

 

package ltd.evilcorp.domain.feature

 

import kotlinx.coroutines.CoroutineScope

import kotlinx.coroutines.flow.Flow

import kotlinx.coroutines.launch

import ltd.evilcorp.core.vo.FriendRequest

import ltd.evilcorp.domain.tox.PublicKey

import ltd.evilcorp.domain.tox.Tox

 

class FriendRequestManager @Inject constructor(

private val scope: CoroutineScope,

 

 

package ltd.evilcorp.domain.feature

 

import kotlinx.coroutines.CoroutineScope

import kotlinx.coroutines.launch

import ltd.evilcorp.core.repository.UserRepository

import ltd.evilcorp.core.vo.UserStatus

import ltd.evilcorp.domain.tox.PublicKey

import ltd.evilcorp.domain.tox.Tox

 

class UserManager @Inject constructor(

private val scope: CoroutineScope,

 

package ltd.evilcorp.domain.tox

 

import android.util.Log

import javax.inject.Inject

 

private const val TAG = "BootstrapNodeJsonParser"

 

 

import im.tox.tox4j.core.exceptions.ToxBootstrapException

import im.tox.tox4j.crypto.ToxCryptoConstants

import im.tox.tox4j.impl.jni.ToxCryptoImpl

import kotlinx.coroutines.CoroutineScope

import kotlinx.coroutines.delay

import kotlinx.coroutines.launch

import ltd.evilcorp.core.vo.FileKind

import ltd.evilcorp.core.vo.MessageType

import ltd.evilcorp.core.vo.UserStatus

 

private const val TAG = "Tox"

 

 

 

import im.tox.tox4j.av.callbacks.ToxAvEventListener

import im.tox.tox4j.av.enums.ToxavFriendCallState

import java.util.EnumSet

import javax.inject.Inject

 

typealias CallHandler = (pk: String, audioEnabled: Boolean, videoEnabled: Boolean) -> Unit

typealias CallStateHandler = (pk: String, callState: EnumSet<ToxavFriendCallState>) -> Unit

 

import im.tox.tox4j.core.enums.ToxFileControl

import im.tox.tox4j.core.enums.ToxMessageType

import im.tox.tox4j.core.enums.ToxUserStatus

import ltd.evilcorp.core.vo.ConnectionStatus

import ltd.evilcorp.core.vo.UserStatus

 

typealias FriendLosslessPacketHandler = (publicKey: String, data: ByteArray) -> Unit

typealias FileRecvControlHandler = (publicKey: String, fileNo: Int, control: ToxFileControl) -> Unit

 

import im.tox.tox4j.core.exceptions.ToxFriendCustomPacketException

import im.tox.tox4j.impl.jni.ToxAvImpl

import im.tox.tox4j.impl.jni.ToxCoreImpl

import ltd.evilcorp.core.vo.FileKind

import ltd.evilcorp.core.vo.MessageType

import ltd.evilcorp.core.vo.UserStatus

 

private const val TAG = "ToxWrapper"

 

 

import im.tox.tox4j.core.enums.ToxFileKind

import im.tox.tox4j.core.enums.ToxMessageType

import im.tox.tox4j.core.enums.ToxUserStatus

import kotlin.test.Test

import kotlin.test.assertContentEquals

import kotlin.test.assertEquals

import kotlin.test.assertNotEquals

 

private fun byteArrayOf(vararg bytes: Int) = ByteArray(bytes.size) { bytes[it].toByte() }