mirror of https://github.com/NekoX-Dev/NekoX.git
518 lines
15 KiB
Kotlin
518 lines
15 KiB
Kotlin
package tw.nekomimi.nekogram.utils
|
|
|
|
import android.Manifest
|
|
import android.app.Activity
|
|
import android.content.ClipboardManager
|
|
import android.content.Context
|
|
import android.content.ContextWrapper
|
|
import android.content.Intent
|
|
import android.content.pm.PackageManager
|
|
import android.graphics.Bitmap
|
|
import android.os.Build
|
|
import android.os.Environment
|
|
import android.util.Base64
|
|
import android.view.Gravity
|
|
import android.widget.ImageView
|
|
import android.widget.LinearLayout
|
|
import android.widget.Toast
|
|
import com.google.zxing.*
|
|
import com.google.zxing.common.GlobalHistogramBinarizer
|
|
import com.google.zxing.qrcode.QRCodeReader
|
|
import com.google.zxing.qrcode.QRCodeWriter
|
|
import com.v2ray.ang.V2RayConfig.SSR_PROTOCOL
|
|
import com.v2ray.ang.V2RayConfig.SS_PROTOCOL
|
|
import com.v2ray.ang.V2RayConfig.VMESS1_PROTOCOL
|
|
import com.v2ray.ang.V2RayConfig.VMESS_PROTOCOL
|
|
import okhttp3.HttpUrl.Companion.toHttpUrlOrNull
|
|
import org.telegram.messenger.*
|
|
import org.telegram.messenger.browser.Browser
|
|
import org.telegram.ui.ActionBar.BottomSheet
|
|
import java.io.File
|
|
import java.net.NetworkInterface
|
|
import java.util.*
|
|
import kotlin.collections.HashMap
|
|
|
|
object ProxyUtil {
|
|
|
|
@JvmStatic
|
|
fun isVPNEnabled(): Boolean {
|
|
|
|
val networkList = mutableListOf<String>()
|
|
|
|
runCatching {
|
|
|
|
Collections.list(NetworkInterface.getNetworkInterfaces()).forEach {
|
|
|
|
if (it.isUp) networkList.add(it.name)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return networkList.contains("tun0")
|
|
|
|
}
|
|
|
|
@JvmStatic
|
|
fun parseProxies(_text: String): MutableList<String> {
|
|
|
|
val text = runCatching {
|
|
|
|
String(Base64.decode(_text, Base64.NO_PADDING))
|
|
|
|
}.recover {
|
|
|
|
_text
|
|
|
|
}.getOrThrow()
|
|
|
|
val proxies = mutableListOf<String>()
|
|
|
|
text.split('\n').map { it.split(" ") }.forEach {
|
|
|
|
it.forEach { line ->
|
|
|
|
if (line.startsWith("tg://proxy") ||
|
|
line.startsWith("tg://socks") ||
|
|
line.startsWith("https://t.me/proxy") ||
|
|
line.startsWith("https://t.me/socks") ||
|
|
line.startsWith(VMESS_PROTOCOL) ||
|
|
line.startsWith(VMESS1_PROTOCOL) ||
|
|
line.startsWith(SS_PROTOCOL) ||
|
|
line.startsWith(SSR_PROTOCOL) /*||
|
|
line.startsWith(RB_PROTOCOL)*/) {
|
|
|
|
runCatching { proxies.add(SharedConfig.parseProxyInfo(line).toUrl()) }
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if (proxies.isEmpty()) error("no proxy link found")
|
|
|
|
return proxies
|
|
|
|
}
|
|
|
|
@JvmStatic
|
|
fun importFromClipboard(ctx: Activity) {
|
|
|
|
var text = (ApplicationLoader.applicationContext.getSystemService(Context.CLIPBOARD_SERVICE) as ClipboardManager).primaryClip?.getItemAt(0)?.text?.toString()
|
|
|
|
val proxies = mutableListOf<SharedConfig.ProxyInfo>()
|
|
|
|
var error = false
|
|
|
|
text?.trim()?.split('\n')?.map { it.split(" ") }?.forEach {
|
|
|
|
it.forEach { line ->
|
|
|
|
if (line.startsWith("tg://proxy") ||
|
|
line.startsWith("tg://socks") ||
|
|
line.startsWith("https://t.me/proxy") ||
|
|
line.startsWith("https://t.me/socks") ||
|
|
line.startsWith(VMESS_PROTOCOL) ||
|
|
line.startsWith(VMESS1_PROTOCOL) ||
|
|
line.startsWith(SS_PROTOCOL) ||
|
|
line.startsWith(SSR_PROTOCOL) /*||
|
|
line.startsWith(RB_PROTOCOL)*/) {
|
|
|
|
runCatching { proxies.add(SharedConfig.parseProxyInfo(line)) }.onFailure {
|
|
|
|
error = true
|
|
|
|
AlertUtil.showToast(LocaleController.getString("BrokenLink", R.string.BrokenLink) + ": ${it.message ?: it.javaClass.simpleName}")
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
runCatching {
|
|
|
|
if (proxies.isNullOrEmpty() && !error) {
|
|
|
|
String(Base64.decode(text, Base64.NO_PADDING)).trim().split('\n').map { it.split(" ") }.forEach { str ->
|
|
|
|
str.forEach { line ->
|
|
|
|
if (line.startsWith("tg://proxy") ||
|
|
line.startsWith("tg://socks") ||
|
|
line.startsWith("https://t.me/proxy") ||
|
|
line.startsWith("https://t.me/socks") ||
|
|
line.startsWith(VMESS_PROTOCOL) ||
|
|
line.startsWith(VMESS1_PROTOCOL) ||
|
|
line.startsWith(SS_PROTOCOL) ||
|
|
line.startsWith(SSR_PROTOCOL) /*||
|
|
line.startsWith(RB_PROTOCOL)*/) {
|
|
|
|
runCatching { proxies.add(SharedConfig.parseProxyInfo(line)) }.onFailure {
|
|
|
|
error = true
|
|
|
|
AlertUtil.showToast(LocaleController.getString("BrokenLink", R.string.BrokenLink) + ": ${it.message ?: it.javaClass.simpleName}")
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if (proxies.isNullOrEmpty()) {
|
|
|
|
if (!error) AlertUtil.showToast(LocaleController.getString("BrokenLink", R.string.BrokenLink))
|
|
|
|
return
|
|
|
|
} else if (!error) {
|
|
|
|
AlertUtil.showSimpleAlert(ctx, LocaleController.getString("ImportedProxies", R.string.ImportedProxies) + "\n\n" + proxies.joinToString("\n") { it.title })
|
|
|
|
}
|
|
|
|
proxies.forEach {
|
|
|
|
SharedConfig.addProxy(it)
|
|
|
|
}
|
|
|
|
UIUtil.runOnUIThread {
|
|
|
|
NotificationCenter.getGlobalInstance().postNotificationName(NotificationCenter.proxySettingsChanged)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
@JvmStatic
|
|
fun importProxy(ctx: Context, link: String): Boolean {
|
|
|
|
runCatching {
|
|
|
|
if (link.startsWith(VMESS_PROTOCOL) || link.startsWith(VMESS1_PROTOCOL)) {
|
|
|
|
AndroidUtilities.showVmessAlert(ctx, SharedConfig.VmessProxy(link))
|
|
|
|
} else if (link.startsWith(SS_PROTOCOL)) {
|
|
|
|
AndroidUtilities.showShadowsocksAlert(ctx, SharedConfig.ShadowsocksProxy(link))
|
|
|
|
} else if (link.startsWith(SSR_PROTOCOL)) {
|
|
|
|
AndroidUtilities.showShadowsocksRAlert(ctx, SharedConfig.ShadowsocksRProxy(link))
|
|
|
|
} else {
|
|
|
|
val url = link.replace("tg://", "https://t.me/").toHttpUrlOrNull()!!
|
|
|
|
AndroidUtilities.showProxyAlert(ctx,
|
|
url.queryParameter("server"),
|
|
url.queryParameter("port"),
|
|
url.queryParameter("user"),
|
|
url.queryParameter("pass"),
|
|
url.queryParameter("secret"),
|
|
url.fragment)
|
|
|
|
|
|
}
|
|
|
|
return true
|
|
|
|
}.onFailure {
|
|
|
|
FileLog.e(it)
|
|
|
|
if (BuildVars.LOGS_ENABLED) {
|
|
|
|
AlertUtil.showSimpleAlert(ctx, it)
|
|
|
|
} else {
|
|
|
|
AlertUtil.showToast("${LocaleController.getString("BrokenLink", R.string.BrokenLink)}: ${it.message}")
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return false
|
|
|
|
}
|
|
|
|
@JvmStatic
|
|
fun importInBackground(link: String): SharedConfig.ProxyInfo {
|
|
|
|
val info = runCatching {
|
|
|
|
if (link.startsWith(VMESS_PROTOCOL) || link.startsWith(VMESS1_PROTOCOL)) {
|
|
|
|
SharedConfig.VmessProxy(link)
|
|
|
|
} else if (link.startsWith(SS_PROTOCOL)) {
|
|
|
|
if (Build.VERSION.SDK_INT < Build.VERSION_CODES.LOLLIPOP) {
|
|
|
|
error(LocaleController.getString("MinApi21Required", R.string.MinApi21Required))
|
|
|
|
}
|
|
|
|
SharedConfig.ShadowsocksProxy(link)
|
|
|
|
} else if (link.startsWith(SSR_PROTOCOL)) {
|
|
|
|
if (Build.VERSION.SDK_INT < Build.VERSION_CODES.LOLLIPOP) {
|
|
|
|
error(LocaleController.getString("MinApi21Required", R.string.MinApi21Required))
|
|
|
|
}
|
|
|
|
SharedConfig.ShadowsocksRProxy(link)
|
|
|
|
} else {
|
|
|
|
SharedConfig.ProxyInfo.fromUrl(link)
|
|
|
|
}
|
|
|
|
}.getOrThrow()
|
|
|
|
if (!(SharedConfig.addProxy(info) === info)) {
|
|
|
|
error("already exists")
|
|
|
|
}
|
|
|
|
return info
|
|
|
|
}
|
|
|
|
@JvmStatic
|
|
fun shareProxy(ctx: Activity, info: SharedConfig.ProxyInfo, type: Int) {
|
|
|
|
val url = info.toUrl();
|
|
|
|
if (type == 1) {
|
|
|
|
AndroidUtilities.addToClipboard(url)
|
|
|
|
Toast.makeText(ctx, LocaleController.getString("LinkCopied", R.string.LinkCopied), Toast.LENGTH_LONG).show()
|
|
|
|
} else if (type == 0) {
|
|
|
|
val shareIntent = Intent(Intent.ACTION_SEND)
|
|
|
|
shareIntent.type = "text/plain"
|
|
|
|
shareIntent.putExtra(Intent.EXTRA_TEXT, url)
|
|
|
|
val chooserIntent = Intent.createChooser(shareIntent, LocaleController.getString("ShareLink", R.string.ShareLink))
|
|
|
|
chooserIntent.flags = Intent.FLAG_ACTIVITY_NEW_TASK
|
|
|
|
ctx.startActivity(chooserIntent)
|
|
|
|
} else {
|
|
|
|
showQrDialog(ctx, url)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
@JvmStatic
|
|
fun getOwnerActivity(ctx: Context): Activity {
|
|
|
|
if (ctx is Activity) return ctx
|
|
|
|
if (ctx is ContextWrapper) return getOwnerActivity(ctx.baseContext)
|
|
|
|
error("unable cast ${ctx.javaClass.name} to activity")
|
|
|
|
}
|
|
|
|
@JvmStatic
|
|
fun showQrDialog(ctx: Context, text: String) {
|
|
|
|
val code = createQRCode(text)
|
|
|
|
ctx.setTheme(R.style.Theme_TMessages)
|
|
|
|
android.app.AlertDialog.Builder(ctx).setView(LinearLayout(ctx).apply {
|
|
|
|
addView(LinearLayout(ctx).apply {
|
|
|
|
gravity = Gravity.CENTER
|
|
|
|
val width = AndroidUtilities.dp(330f)
|
|
|
|
addView(ImageView(ctx).apply {
|
|
|
|
setImageBitmap(code)
|
|
|
|
scaleType = ImageView.ScaleType.FIT_XY
|
|
|
|
setOnLongClickListener {
|
|
|
|
BottomSheet.Builder(ctx).setItems(arrayOf(
|
|
|
|
LocaleController.getString("SaveToGallery", R.string.SaveToGallery),
|
|
LocaleController.getString("Cancel", R.string.Cancel)
|
|
|
|
), intArrayOf(
|
|
|
|
R.drawable.baseline_image_24,
|
|
R.drawable.baseline_cancel_24
|
|
|
|
)) { _, i ->
|
|
|
|
if (i == 0) {
|
|
|
|
if (Build.VERSION.SDK_INT >= 23 && ctx.checkSelfPermission(Manifest.permission.WRITE_EXTERNAL_STORAGE) != PackageManager.PERMISSION_GRANTED) {
|
|
|
|
getOwnerActivity(ctx).requestPermissions(arrayOf(Manifest.permission.WRITE_EXTERNAL_STORAGE), 4)
|
|
|
|
return@setItems
|
|
|
|
}
|
|
|
|
val saveTo = File(Environment.getExternalStorageDirectory(), "${Environment.DIRECTORY_PICTURES}/share_${text.hashCode()}.jpg")
|
|
|
|
saveTo.parentFile?.mkdirs()
|
|
|
|
runCatching {
|
|
|
|
saveTo.createNewFile()
|
|
|
|
saveTo.outputStream().use {
|
|
|
|
code?.compress(Bitmap.CompressFormat.JPEG, 100, it);
|
|
|
|
}
|
|
|
|
AndroidUtilities.addMediaToGallery(saveTo.path)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}.show()
|
|
|
|
return@setOnLongClickListener true
|
|
|
|
}
|
|
|
|
}, LinearLayout.LayoutParams(width, width))
|
|
|
|
}, LinearLayout.LayoutParams(-1, -1).apply {
|
|
|
|
gravity = Gravity.CENTER
|
|
|
|
})
|
|
|
|
}).show()
|
|
|
|
}
|
|
|
|
fun createQRCode(text: String, size: Int = 800): Bitmap? {
|
|
try {
|
|
val hints = HashMap<EncodeHintType, Any>()
|
|
hints[EncodeHintType.CHARACTER_SET] = "utf-8"
|
|
//hints[EncodeHintType.ERROR_CORRECTION] = ErrorCorrectionLevel.H
|
|
val bitMatrix = QRCodeWriter().encode(text, BarcodeFormat.QR_CODE, size, size, hints)
|
|
val pixels = IntArray(size * size)
|
|
for (y in 0 until size) {
|
|
for (x in 0 until size) {
|
|
if (bitMatrix.get(x, y)) {
|
|
pixels[y * size + x] = 0xff000000.toInt()
|
|
} else {
|
|
pixels[y * size + x] = 0xffffffff.toInt()
|
|
}
|
|
}
|
|
}
|
|
val bitmap = Bitmap.createBitmap(size, size, Bitmap.Config.ARGB_8888)
|
|
bitmap.setPixels(pixels, 0, size, 0, 0, size, size)
|
|
return bitmap
|
|
} catch (e: WriterException) {
|
|
e.printStackTrace()
|
|
return null
|
|
}
|
|
}
|
|
|
|
val qrReader = QRCodeReader()
|
|
|
|
@JvmStatic
|
|
fun tryReadQR(ctx: Activity, bitmap: Bitmap) {
|
|
|
|
val intArray = IntArray(bitmap.getWidth() * bitmap.getHeight())
|
|
bitmap.getPixels(intArray, 0, bitmap.getWidth(), 0, 0, bitmap.getWidth(), bitmap.getHeight())
|
|
val source = RGBLuminanceSource(bitmap.getWidth(), bitmap.getHeight(), intArray)
|
|
|
|
try {
|
|
|
|
val result = qrReader.decode(BinaryBitmap(GlobalHistogramBinarizer(source)))
|
|
|
|
if (result == null || result.text.isBlank()) {
|
|
|
|
AlertUtil.showToast(LocaleController.getString("NoQrFound", R.string.NoQrFound))
|
|
|
|
} else {
|
|
|
|
showLinkAlert(ctx, result.text)
|
|
|
|
}
|
|
|
|
} catch (ex: NoSuchMethodError) {
|
|
|
|
AlertUtil.showSimpleAlert(ctx, "很抱歉, 這是一個已知的問題, 但您現在無法掃碼, 因爲您正在使用糟糕的Android系統, 直到 Google Zxing 為您的設備做出優化.")
|
|
|
|
}
|
|
|
|
}
|
|
|
|
@JvmStatic
|
|
fun showLinkAlert(ctx: Activity, text: String) {
|
|
|
|
val builder = BottomSheet.Builder(ctx)
|
|
|
|
var isUrl = false
|
|
|
|
runCatching {
|
|
text.toHttpUrlOrNull()!!
|
|
if (Browser.isInternalUrl(text, booleanArrayOf(false))) {
|
|
Browser.openUrl(ctx, text)
|
|
return
|
|
}
|
|
isUrl = true
|
|
}
|
|
|
|
builder.setTitle(text)
|
|
|
|
builder.setItems(arrayOf(
|
|
if (isUrl) LocaleController.getString("Open", R.string.OpenUrlTitle) else null,
|
|
LocaleController.getString("Copy", R.string.Copy),
|
|
LocaleController.getString("Cancel", R.string.Cancel)
|
|
)) { _, i ->
|
|
if (i == 0) {
|
|
Browser.openUrl(ctx, text)
|
|
} else if (i == 1) {
|
|
AndroidUtilities.addToClipboard(text)
|
|
Toast.makeText(ApplicationLoader.applicationContext, LocaleController.getString("LinkCopied", R.string.LinkCopied), Toast.LENGTH_LONG).show()
|
|
}
|
|
}
|
|
|
|
builder.show()
|
|
|
|
}
|
|
|
|
}
|