74 lines
3.0 KiB
Kotlin
74 lines
3.0 KiB
Kotlin
package be.mygod.vpnhotspot.client
|
|
|
|
import android.text.SpannableStringBuilder
|
|
import android.text.Spanned
|
|
import android.text.format.Formatter
|
|
import android.text.style.StrikethroughSpan
|
|
import androidx.databinding.BaseObservable
|
|
import androidx.databinding.Bindable
|
|
import androidx.recyclerview.widget.DiffUtil
|
|
import be.mygod.vpnhotspot.App.Companion.app
|
|
import be.mygod.vpnhotspot.R
|
|
import be.mygod.vpnhotspot.net.InetAddressComparator
|
|
import be.mygod.vpnhotspot.net.monitor.IpNeighbour
|
|
import be.mygod.vpnhotspot.net.TetherType
|
|
import be.mygod.vpnhotspot.room.AppDatabase
|
|
import be.mygod.vpnhotspot.room.lookup
|
|
import be.mygod.vpnhotspot.room.macToLong
|
|
import be.mygod.vpnhotspot.util.onEmpty
|
|
import java.net.InetAddress
|
|
import java.util.Objects
|
|
import java.util.TreeMap
|
|
|
|
abstract class Client : BaseObservable() {
|
|
companion object DiffCallback : DiffUtil.ItemCallback<Client>() {
|
|
override fun areItemsTheSame(oldItem: Client, newItem: Client) =
|
|
oldItem.iface == newItem.iface && oldItem.mac == newItem.mac
|
|
override fun areContentsTheSame(oldItem: Client, newItem: Client) = oldItem == newItem
|
|
}
|
|
|
|
abstract val iface: String
|
|
abstract val mac: String
|
|
private val macIface get() = "$mac%$iface"
|
|
val ip = TreeMap<InetAddress, IpNeighbour.State>(InetAddressComparator)
|
|
val record by lazy { AppDatabase.instance.clientRecordDao.lookup(mac.macToLong()) }
|
|
var sendRate = -1L
|
|
var receiveRate = -1L
|
|
|
|
open val icon get() = TetherType.ofInterface(iface).icon
|
|
val title: CharSequence get() {
|
|
val result = SpannableStringBuilder(record.nickname.onEmpty(macIface))
|
|
if (record.blocked) result.setSpan(StrikethroughSpan(), 0, result.length, Spanned.SPAN_INCLUSIVE_INCLUSIVE)
|
|
return result
|
|
}
|
|
val description: String @Bindable get() {
|
|
val result = StringBuilder(if (record.nickname.isEmpty()) "" else "$macIface\n")
|
|
ip.entries.forEach { (ip, state) ->
|
|
result.appendln(app.getString(when (state) {
|
|
IpNeighbour.State.INCOMPLETE -> R.string.connected_state_incomplete
|
|
IpNeighbour.State.VALID -> R.string.connected_state_valid
|
|
IpNeighbour.State.FAILED -> R.string.connected_state_failed
|
|
else -> throw IllegalStateException("Invalid IpNeighbour.State: $state")
|
|
}, ip.hostAddress))
|
|
}
|
|
if (sendRate >= 0 && receiveRate >= 0) result.appendln(
|
|
"▲ ${Formatter.formatFileSize(app, sendRate)}/s\t\t▼ ${Formatter.formatFileSize(app, receiveRate)}/s")
|
|
return result.toString().trimEnd()
|
|
}
|
|
|
|
override fun equals(other: Any?): Boolean {
|
|
if (this === other) return true
|
|
if (javaClass != other?.javaClass) return false
|
|
|
|
other as Client
|
|
|
|
if (iface != other.iface) return false
|
|
if (mac != other.mac) return false
|
|
if (ip != other.ip) return false
|
|
if (record != other.record) return false
|
|
|
|
return true
|
|
}
|
|
override fun hashCode() = Objects.hash(iface, mac, ip, record)
|
|
}
|