srctree

import javax.inject.Inject

import javax.inject.Singleton

import kotlin.concurrent.schedule

import kotlinx.coroutines.launch

import ltd.evilcorp.atox.settings.Settings

import ltd.evilcorp.core.vo.UserStatus

 

@Singleton

class AutoAway @Inject constructor(

private val settings: Settings,

private val userManager: UserManager,

private val tox: Tox

 

Log.i(TAG, "In background, scheduling away")

awayTimer.schedule(settings.autoAwaySeconds * 1_000) {

if (tox.getStatus() != UserStatus.None) return@launch

Log.i(TAG, "Setting away")

userManager.setStatus(UserStatus.Away)

 

 

import dagger.Module

import dagger.Provides

import ltd.evilcorp.atox.tox.BootstrapNodeRegistryImpl

import ltd.evilcorp.domain.tox.BootstrapNodeRegistry

 

class AppModule {

@Provides

fun provideBootstrapNodeRegistry(nodeRegistry: BootstrapNodeRegistryImpl): BootstrapNodeRegistry = nodeRegistry

}

 

import java.nio.charset.StandardCharsets

import javax.inject.Inject

import javax.inject.Singleton

import kotlinx.coroutines.Dispatchers

import kotlinx.coroutines.launch

import ltd.evilcorp.atox.R

import ltd.evilcorp.atox.settings.BootstrapNodeSource

 

@Singleton

class BootstrapNodeRegistryImpl @Inject constructor(

private val context: Context,

private val parser: BootstrapNodeJsonParser,

private val settings: Settings,

}

 

override fun reset() {

val str = if (settings.bootstrapNodeSource == BootstrapNodeSource.BuiltIn) {

context.resources.openRawResource(R.raw.nodes).use {

val bytes = ByteArray(it.available())

 

import androidx.lifecycle.asLiveData

import javax.inject.Inject

import kotlinx.coroutines.CoroutineScope

import kotlinx.coroutines.flow.first

import kotlinx.coroutines.launch

import ltd.evilcorp.atox.ui.NotificationHelper

import ltd.evilcorp.domain.tox.PublicKey

 

class CallViewModel @Inject constructor(

private val callManager: CallManager,

private val notificationHelper: NotificationHelper,

private val contactManager: ContactManager,

private var publicKey = PublicKey("")

 

val contact: LiveData<Contact> by lazy {

 

fun startCall() {

callManager.startCall(publicKey)

}

 

callManager.endCall(publicKey)

notificationHelper.dismissCallNotification(publicKey)

}

 

import javax.inject.Inject

import kotlinx.coroutines.CoroutineScope

import kotlinx.coroutines.Dispatchers

import kotlinx.coroutines.flow.collect

import kotlinx.coroutines.flow.combine

import kotlinx.coroutines.flow.take

private val fileTransferManager: FileTransferManager,

private val notificationHelper: NotificationHelper,

private val resolver: ContentResolver,

private var publicKey = PublicKey("")

private var sentTyping = false

 

 

fun send(message: String, type: MessageType) = chatManager.sendMessage(publicKey, message, type)

 

chatManager.clearHistory(publicKey)

fileTransferManager.deleteAll(publicKey)

}

}

}

 

fileTransferManager.accept(id)

}

 

fileTransferManager.reject(id)

}

 

fileTransferManager.create(publicKey, file)

}

 

if (msg.type == MessageType.FileTransfer) {

fileTransferManager.delete(msg.correlationId)

}

chatManager.deleteMessage(msg.id)

}

 

fileTransferManager.get(id).take(1).collect { ft ->

launch(Dispatchers.IO) {

try {

 

import javax.inject.Inject

import kotlinx.coroutines.CoroutineScope

import kotlinx.coroutines.Dispatchers

import kotlinx.coroutines.launch

import kotlinx.coroutines.withContext

import ltd.evilcorp.atox.R

import ltd.evilcorp.domain.tox.testToxSave

 

class ContactListViewModel @Inject constructor(

private val context: Context,

private val resolver: ContentResolver,

private val chatManager: ChatManager,

private val tox: Tox,

private val toxStarter: ToxStarter,

userManager: UserManager

val publicKey by lazy { tox.publicKey }

 

val user: LiveData<User> by lazy { userManager.get(publicKey).asLiveData() }

fun deleteContact(publicKey: PublicKey) {

contactManager.delete(publicKey)

chatManager.clearHistory(publicKey)

fileTransferManager.deleteAll(publicKey)

}

}

 

// Export the save.

resolver.openFileDescriptor(uri, "w")!!.use { fd ->

FileOutputStream(fd.fileDescriptor).use { out ->

 

import androidx.fragment.app.viewModels

import androidx.navigation.fragment.findNavController

import java.lang.NumberFormatException

import kotlinx.coroutines.Dispatchers

import kotlinx.coroutines.launch

import kotlinx.coroutines.withContext

import ltd.evilcorp.atox.BuildConfig

 

class SettingsFragment : BaseFragment<FragmentSettingsBinding>(FragmentSettingsBinding::inflate) {

private val vm: SettingsViewModel by viewModels { vmFactory }

private val blockBackCallback = object : OnBackPressedCallback(false) {

override fun handleOnBackPressed() {

Toast.makeText(requireContext(), getString(R.string.warn_proxy_broken), Toast.LENGTH_LONG).show()

}

 

private val importNodesLauncher = registerForActivityResult(ActivityResultContracts.OpenDocument()) { uri ->

if (uri != null && vm.validateNodeJson(uri)) {

if (vm.importNodeJson(uri)) {

vm.setBootstrapNodeSource(BootstrapNodeSource.UserProvided)