Compare commits
10 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 22a605ecda | |||
| c7dd45f4f2 | |||
| 609e688d87 | |||
| a2a4ea79a9 | |||
| c08147c362 | |||
| c99fda9839 | |||
| 587d103518 | |||
| 192a4afe6d | |||
| ee69364f2b | |||
| 6be0bd7b21 |
@@ -77,36 +77,6 @@ jobs:
|
|||||||
fileName: 'libv2ray.aar'
|
fileName: 'libv2ray.aar'
|
||||||
out-file-path: V2rayNG/app/libs/
|
out-file-path: V2rayNG/app/libs/
|
||||||
|
|
||||||
- name: Restore cached libhysteria2
|
|
||||||
id: cache-libhysteria2-restore
|
|
||||||
uses: actions/cache/restore@v4
|
|
||||||
with:
|
|
||||||
path: ${{ github.workspace }}/hysteria/libs
|
|
||||||
key: libhysteria2-${{ runner.os }}-${{ env.NDK_HOME }}-${{ hashFiles('.git/modules/hysteria/HEAD') }}-${{ hashFiles('libhysteria2.sh') }}
|
|
||||||
|
|
||||||
- name: Setup Golang
|
|
||||||
if: steps.cache-libhysteria2-restore.outputs.cache-hit != 'true'
|
|
||||||
uses: actions/setup-go@v5.4.0
|
|
||||||
with:
|
|
||||||
go-version-file: 'AndroidLibXrayLite/go.mod'
|
|
||||||
cache: false
|
|
||||||
|
|
||||||
- name: Build libhysteria2
|
|
||||||
if: steps.cache-libhysteria2-restore.outputs.cache-hit != 'true'
|
|
||||||
run: |
|
|
||||||
bash libhysteria2.sh
|
|
||||||
|
|
||||||
- name: Save libhysteria2
|
|
||||||
if: steps.cache-libhysteria2-restore.outputs.cache-hit != 'true'
|
|
||||||
uses: actions/cache/save@v4
|
|
||||||
with:
|
|
||||||
path: ${{ github.workspace }}/hysteria/libs
|
|
||||||
key: libhysteria2-${{ runner.os }}-${{ env.NDK_HOME }}-${{ hashFiles('.git/modules/hysteria/HEAD') }}-${{ hashFiles('libhysteria2.sh') }}
|
|
||||||
|
|
||||||
- name: Copy libhysteria2
|
|
||||||
run: |
|
|
||||||
cp -r ${{ github.workspace }}/hysteria/libs ${{ github.workspace }}/V2rayNG/app
|
|
||||||
|
|
||||||
- name: Setup Java
|
- name: Setup Java
|
||||||
uses: actions/setup-java@v4.7.0
|
uses: actions/setup-java@v4.7.0
|
||||||
with:
|
with:
|
||||||
|
|||||||
@@ -1,6 +1,3 @@
|
|||||||
[submodule "hysteria"]
|
|
||||||
path = hysteria
|
|
||||||
url = https://github.com/apernet/hysteria
|
|
||||||
[submodule "AndroidLibXrayLite"]
|
[submodule "AndroidLibXrayLite"]
|
||||||
path = AndroidLibXrayLite
|
path = AndroidLibXrayLite
|
||||||
url = https://github.com/2dust/AndroidLibXrayLite
|
url = https://github.com/2dust/AndroidLibXrayLite
|
||||||
|
|||||||
@@ -12,8 +12,8 @@ android {
|
|||||||
applicationId = "com.v2ray.ang"
|
applicationId = "com.v2ray.ang"
|
||||||
minSdk = 24
|
minSdk = 24
|
||||||
targetSdk = 36
|
targetSdk = 36
|
||||||
versionCode = 700
|
versionCode = 701
|
||||||
versionName = "2.0.0"
|
versionName = "2.0.1"
|
||||||
multiDexEnabled = true
|
multiDexEnabled = true
|
||||||
|
|
||||||
val abiFilterList = (properties["ABI_FILTERS"] as? String)?.split(';')
|
val abiFilterList = (properties["ABI_FILTERS"] as? String)?.split(';')
|
||||||
|
|||||||
@@ -0,0 +1,43 @@
|
|||||||
|
[
|
||||||
|
{
|
||||||
|
"remarks": "Bypass bittorrent",
|
||||||
|
"outboundTag": "direct",
|
||||||
|
"protocol": [
|
||||||
|
"bittorrent"
|
||||||
|
]
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"remarks": "Block udp443",
|
||||||
|
"outboundTag": "block",
|
||||||
|
"port": "443",
|
||||||
|
"network": "udp"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"remarks": "Direct LAN IP",
|
||||||
|
"outboundTag": "direct",
|
||||||
|
"ip": [
|
||||||
|
"geoip:private"
|
||||||
|
]
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"remarks": "Direct LAN domains",
|
||||||
|
"outboundTag": "direct",
|
||||||
|
"domain": [
|
||||||
|
"geosite:private"
|
||||||
|
]
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"remarks": "Bypass Russia domains",
|
||||||
|
"outboundTag": "direct",
|
||||||
|
"domain": [
|
||||||
|
"geosite:category-ru"
|
||||||
|
]
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"remarks": "Bypass Russia IP",
|
||||||
|
"outboundTag": "direct",
|
||||||
|
"ip": [
|
||||||
|
"geoip:ru"
|
||||||
|
]
|
||||||
|
}
|
||||||
|
]
|
||||||
@@ -9,7 +9,9 @@ object AppConfig {
|
|||||||
|
|
||||||
/** Directory names used in the app's file system. */
|
/** Directory names used in the app's file system. */
|
||||||
const val DIR_ASSETS = "assets"
|
const val DIR_ASSETS = "assets"
|
||||||
const val DIR_BACKUPS = "backups"
|
|
||||||
|
const val WEBDAV_BACKUP_DIR = "backups"
|
||||||
|
const val WEBDAV_BACKUP_FILE_NAME = "backup_ng.zip"
|
||||||
|
|
||||||
/** Legacy configuration keys. */
|
/** Legacy configuration keys. */
|
||||||
const val ANG_CONFIG = "ang_config"
|
const val ANG_CONFIG = "ang_config"
|
||||||
@@ -169,6 +171,7 @@ object AppConfig {
|
|||||||
const val TROJAN = "trojan://"
|
const val TROJAN = "trojan://"
|
||||||
const val WIREGUARD = "wireguard://"
|
const val WIREGUARD = "wireguard://"
|
||||||
const val TUIC = "tuic://"
|
const val TUIC = "tuic://"
|
||||||
|
const val HYSTERIA = "hysteria://"
|
||||||
const val HYSTERIA2 = "hysteria2://"
|
const val HYSTERIA2 = "hysteria2://"
|
||||||
const val HY2 = "hy2://"
|
const val HY2 = "hy2://"
|
||||||
|
|
||||||
|
|||||||
@@ -14,6 +14,7 @@ enum class EConfigType(val value: Int, val protocolScheme: String) {
|
|||||||
|
|
||||||
// TUIC(8, AppConfig.TUIC),
|
// TUIC(8, AppConfig.TUIC),
|
||||||
HYSTERIA2(9, AppConfig.HYSTERIA2),
|
HYSTERIA2(9, AppConfig.HYSTERIA2),
|
||||||
|
HYSTERIA(900, AppConfig.HYSTERIA),
|
||||||
HTTP(10, AppConfig.HTTP),
|
HTTP(10, AppConfig.HTTP),
|
||||||
POLICYGROUP (101, AppConfig.CUSTOM);
|
POLICYGROUP (101, AppConfig.CUSTOM);
|
||||||
|
|
||||||
|
|||||||
@@ -1,46 +0,0 @@
|
|||||||
package com.v2ray.ang.dto
|
|
||||||
|
|
||||||
data class Hysteria2Bean(
|
|
||||||
val server: String?,
|
|
||||||
val auth: String?,
|
|
||||||
val lazy: Boolean? = true,
|
|
||||||
val obfs: ObfsBean? = null,
|
|
||||||
val socks5: Socks5Bean? = null,
|
|
||||||
val http: Socks5Bean? = null,
|
|
||||||
val tls: TlsBean? = null,
|
|
||||||
val transport: TransportBean? = null,
|
|
||||||
val bandwidth: BandwidthBean? = null,
|
|
||||||
) {
|
|
||||||
data class ObfsBean(
|
|
||||||
val type: String?,
|
|
||||||
val salamander: SalamanderBean?
|
|
||||||
) {
|
|
||||||
data class SalamanderBean(
|
|
||||||
val password: String?,
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|
||||||
data class Socks5Bean(
|
|
||||||
val listen: String?,
|
|
||||||
)
|
|
||||||
|
|
||||||
data class TlsBean(
|
|
||||||
val sni: String?,
|
|
||||||
val insecure: Boolean?,
|
|
||||||
val pinSHA256: String?,
|
|
||||||
)
|
|
||||||
|
|
||||||
data class TransportBean(
|
|
||||||
val type: String?,
|
|
||||||
val udp: TransportUdpBean?
|
|
||||||
) {
|
|
||||||
data class TransportUdpBean(
|
|
||||||
val hopInterval: String?,
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|
||||||
data class BandwidthBean(
|
|
||||||
val down: String?,
|
|
||||||
val up: String?,
|
|
||||||
)
|
|
||||||
}
|
|
||||||
@@ -10,7 +10,8 @@ enum class NetworkType(val type: String) {
|
|||||||
H2("h2"),
|
H2("h2"),
|
||||||
|
|
||||||
//QUIC("quic"),
|
//QUIC("quic"),
|
||||||
GRPC("grpc");
|
GRPC("grpc"),
|
||||||
|
HYSTERIA("hysteria");
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
fun fromString(type: String?) = entries.find { it.type == type } ?: TCP
|
fun fromString(type: String?) = entries.find { it.type == type } ?: TCP
|
||||||
|
|||||||
@@ -4,7 +4,8 @@ enum class RoutingType(val fileName: String) {
|
|||||||
WHITE("custom_routing_white"),
|
WHITE("custom_routing_white"),
|
||||||
BLACK("custom_routing_black"),
|
BLACK("custom_routing_black"),
|
||||||
GLOBAL("custom_routing_global"),
|
GLOBAL("custom_routing_global"),
|
||||||
WHITE_IRAN("custom_routing_white_iran");
|
WHITE_IRAN("custom_routing_white_iran"),
|
||||||
|
WHITE_RUSSIA("custom_routing_white_russia");
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
fun fromIndex(index: Int): RoutingType {
|
fun fromIndex(index: Int): RoutingType {
|
||||||
@@ -13,6 +14,7 @@ enum class RoutingType(val fileName: String) {
|
|||||||
1 -> BLACK
|
1 -> BLACK
|
||||||
2 -> GLOBAL
|
2 -> GLOBAL
|
||||||
3 -> WHITE_IRAN
|
3 -> WHITE_IRAN
|
||||||
|
4 -> WHITE_RUSSIA
|
||||||
else -> WHITE
|
else -> WHITE
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -2,7 +2,6 @@ package com.v2ray.ang.dto
|
|||||||
|
|
||||||
import com.google.gson.annotations.SerializedName
|
import com.google.gson.annotations.SerializedName
|
||||||
import com.v2ray.ang.AppConfig
|
import com.v2ray.ang.AppConfig
|
||||||
import com.v2ray.ang.util.Utils
|
|
||||||
|
|
||||||
data class V2rayConfig(
|
data class V2rayConfig(
|
||||||
var remarks: String? = null,
|
var remarks: String? = null,
|
||||||
@@ -76,7 +75,7 @@ data class V2rayConfig(
|
|||||||
/*DNS*/
|
/*DNS*/
|
||||||
val network: String? = null,
|
val network: String? = null,
|
||||||
var address: Any? = null,
|
var address: Any? = null,
|
||||||
val port: Int? = null,
|
var port: Int? = null,
|
||||||
/*Freedom*/
|
/*Freedom*/
|
||||||
var domainStrategy: String? = null,
|
var domainStrategy: String? = null,
|
||||||
val redirect: String? = null,
|
val redirect: String? = null,
|
||||||
@@ -160,7 +159,8 @@ data class V2rayConfig(
|
|||||||
var quicSettings: QuicSettingBean? = null,
|
var quicSettings: QuicSettingBean? = null,
|
||||||
var realitySettings: TlsSettingsBean? = null,
|
var realitySettings: TlsSettingsBean? = null,
|
||||||
var grpcSettings: GrpcSettingsBean? = null,
|
var grpcSettings: GrpcSettingsBean? = null,
|
||||||
var hy2steriaSettings: Hy2steriaSettingsBean? = null,
|
var hysteriaSettings: HysteriaSettingsBean? = null,
|
||||||
|
var udpmasks: List<UdpMasksBean>? = null,
|
||||||
val dsSettings: Any? = null,
|
val dsSettings: Any? = null,
|
||||||
var sockopt: SockoptBean? = null
|
var sockopt: SockoptBean? = null
|
||||||
) {
|
) {
|
||||||
@@ -247,7 +247,8 @@ data class V2rayConfig(
|
|||||||
var dialerProxy: String? = null,
|
var dialerProxy: String? = null,
|
||||||
var domainStrategy: String? = null,
|
var domainStrategy: String? = null,
|
||||||
var happyEyeballs: HappyEyeballsBean? = null,
|
var happyEyeballs: HappyEyeballsBean? = null,
|
||||||
)
|
)
|
||||||
|
|
||||||
data class HappyEyeballsBean(
|
data class HappyEyeballsBean(
|
||||||
var prioritizeIPv6: Boolean? = null,
|
var prioritizeIPv6: Boolean? = null,
|
||||||
var maxConcurrentTry: Int? = 4,
|
var maxConcurrentTry: Int? = 4,
|
||||||
@@ -293,18 +294,27 @@ data class V2rayConfig(
|
|||||||
var health_check_timeout: Int? = null
|
var health_check_timeout: Int? = null
|
||||||
)
|
)
|
||||||
|
|
||||||
data class Hy2steriaSettingsBean(
|
data class HysteriaSettingsBean(
|
||||||
var password: String? = null,
|
var version: Int,
|
||||||
var use_udp_extension: Boolean? = true,
|
var auth: String? = null,
|
||||||
var congestion: Hy2CongestionBean? = null
|
var up: String? = null,
|
||||||
|
var down: String? = null,
|
||||||
|
var udphop: HysteriaUdpHopBean? = null
|
||||||
) {
|
) {
|
||||||
data class Hy2CongestionBean(
|
data class HysteriaUdpHopBean(
|
||||||
var type: String? = "bbr",
|
var port: String? = null,
|
||||||
var up_mbps: Int? = null,
|
var interval: Int? = null
|
||||||
var down_mbps: Int? = null,
|
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
data class UdpMasksBean(
|
||||||
|
var type: String,
|
||||||
|
var settings: UdpMasksSettingsBean? = null
|
||||||
|
) {
|
||||||
|
data class UdpMasksSettingsBean(
|
||||||
|
var password: String? = null
|
||||||
|
)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
data class MuxBean(
|
data class MuxBean(
|
||||||
@@ -323,11 +333,14 @@ data class V2rayConfig(
|
|||||||
|| protocol.equals(EConfigType.SOCKS.name, true)
|
|| protocol.equals(EConfigType.SOCKS.name, true)
|
||||||
|| protocol.equals(EConfigType.HTTP.name, true)
|
|| protocol.equals(EConfigType.HTTP.name, true)
|
||||||
|| protocol.equals(EConfigType.TROJAN.name, true)
|
|| protocol.equals(EConfigType.TROJAN.name, true)
|
||||||
|| protocol.equals(EConfigType.HYSTERIA2.name, true)
|
|
||||||
) {
|
) {
|
||||||
return settings?.servers?.first()?.address
|
return settings?.servers?.first()?.address
|
||||||
} else if (protocol.equals(EConfigType.WIREGUARD.name, true)) {
|
} else if (protocol.equals(EConfigType.WIREGUARD.name, true)) {
|
||||||
return settings?.peers?.first()?.endpoint?.substringBeforeLast(":")
|
return settings?.peers?.first()?.endpoint?.substringBeforeLast(":")
|
||||||
|
} else if (protocol.equals(EConfigType.HYSTERIA2.name, true)
|
||||||
|
|| protocol.equals(EConfigType.HYSTERIA.name, true)
|
||||||
|
) {
|
||||||
|
return settings?.address as String?
|
||||||
}
|
}
|
||||||
return null
|
return null
|
||||||
}
|
}
|
||||||
@@ -341,132 +354,14 @@ data class V2rayConfig(
|
|||||||
|| protocol.equals(EConfigType.SOCKS.name, true)
|
|| protocol.equals(EConfigType.SOCKS.name, true)
|
||||||
|| protocol.equals(EConfigType.HTTP.name, true)
|
|| protocol.equals(EConfigType.HTTP.name, true)
|
||||||
|| protocol.equals(EConfigType.TROJAN.name, true)
|
|| protocol.equals(EConfigType.TROJAN.name, true)
|
||||||
|| protocol.equals(EConfigType.HYSTERIA2.name, true)
|
|
||||||
) {
|
) {
|
||||||
return settings?.servers?.first()?.port
|
return settings?.servers?.first()?.port
|
||||||
} else if (protocol.equals(EConfigType.WIREGUARD.name, true)) {
|
} else if (protocol.equals(EConfigType.WIREGUARD.name, true)) {
|
||||||
return settings?.peers?.first()?.endpoint?.substringAfterLast(":")?.toInt()
|
return settings?.peers?.first()?.endpoint?.substringAfterLast(":")?.toInt()
|
||||||
}
|
} else if (protocol.equals(EConfigType.HYSTERIA2.name, true)
|
||||||
return null
|
|| protocol.equals(EConfigType.HYSTERIA.name, true)
|
||||||
}
|
|
||||||
|
|
||||||
fun getServerAddressAndPort(): String {
|
|
||||||
val address = getServerAddress().orEmpty()
|
|
||||||
val port = getServerPort()
|
|
||||||
return Utils.getIpv6Address(address) + ":" + port
|
|
||||||
}
|
|
||||||
|
|
||||||
fun getPassword(): String? {
|
|
||||||
if (protocol.equals(EConfigType.VMESS.name, true)
|
|
||||||
|| protocol.equals(EConfigType.VLESS.name, true)
|
|
||||||
) {
|
) {
|
||||||
return settings?.vnext?.first()?.users?.first()?.id
|
return settings?.port
|
||||||
} else if (protocol.equals(EConfigType.SHADOWSOCKS.name, true)
|
|
||||||
|| protocol.equals(EConfigType.TROJAN.name, true)
|
|
||||||
|| protocol.equals(EConfigType.HYSTERIA2.name, true)
|
|
||||||
) {
|
|
||||||
return settings?.servers?.first()?.password
|
|
||||||
} else if (protocol.equals(EConfigType.SOCKS.name, true)
|
|
||||||
|| protocol.equals(EConfigType.HTTP.name, true)
|
|
||||||
) {
|
|
||||||
return settings?.servers?.first()?.users?.first()?.pass
|
|
||||||
} else if (protocol.equals(EConfigType.WIREGUARD.name, true)) {
|
|
||||||
return settings?.secretKey
|
|
||||||
}
|
|
||||||
return null
|
|
||||||
}
|
|
||||||
|
|
||||||
fun getSecurityEncryption(): String? {
|
|
||||||
return when {
|
|
||||||
protocol.equals(EConfigType.VMESS.name, true) -> settings?.vnext?.first()?.users?.first()?.security
|
|
||||||
protocol.equals(EConfigType.VLESS.name, true) -> settings?.vnext?.first()?.users?.first()?.encryption
|
|
||||||
protocol.equals(EConfigType.SHADOWSOCKS.name, true) -> settings?.servers?.first()?.method
|
|
||||||
else -> null
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
fun getTransportSettingDetails(): List<String?>? {
|
|
||||||
if (protocol.equals(EConfigType.VMESS.name, true)
|
|
||||||
|| protocol.equals(EConfigType.VLESS.name, true)
|
|
||||||
|| protocol.equals(EConfigType.TROJAN.name, true)
|
|
||||||
|| protocol.equals(EConfigType.SHADOWSOCKS.name, true)
|
|
||||||
) {
|
|
||||||
val transport = streamSettings?.network ?: return null
|
|
||||||
return when (transport) {
|
|
||||||
NetworkType.TCP.type -> {
|
|
||||||
val tcpSetting = streamSettings?.tcpSettings ?: return null
|
|
||||||
listOf(
|
|
||||||
tcpSetting.header.type,
|
|
||||||
tcpSetting.header.request?.headers?.Host?.joinToString(",").orEmpty(),
|
|
||||||
tcpSetting.header.request?.path?.joinToString(",").orEmpty()
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|
||||||
NetworkType.KCP.type -> {
|
|
||||||
val kcpSetting = streamSettings?.kcpSettings ?: return null
|
|
||||||
listOf(
|
|
||||||
kcpSetting.header.type,
|
|
||||||
"",
|
|
||||||
kcpSetting.seed.orEmpty()
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|
||||||
NetworkType.WS.type -> {
|
|
||||||
val wsSetting = streamSettings?.wsSettings ?: return null
|
|
||||||
listOf(
|
|
||||||
"",
|
|
||||||
wsSetting.headers.Host,
|
|
||||||
wsSetting.path
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|
||||||
NetworkType.HTTP_UPGRADE.type -> {
|
|
||||||
val httpupgradeSetting = streamSettings?.httpupgradeSettings ?: return null
|
|
||||||
listOf(
|
|
||||||
"",
|
|
||||||
httpupgradeSetting.host,
|
|
||||||
httpupgradeSetting.path
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|
||||||
NetworkType.XHTTP.type -> {
|
|
||||||
val xhttpSettings = streamSettings?.xhttpSettings ?: return null
|
|
||||||
listOf(
|
|
||||||
"",
|
|
||||||
xhttpSettings.host,
|
|
||||||
xhttpSettings.path
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|
||||||
NetworkType.H2.type -> {
|
|
||||||
val h2Setting = streamSettings?.httpSettings ?: return null
|
|
||||||
listOf(
|
|
||||||
"",
|
|
||||||
h2Setting.host.joinToString(","),
|
|
||||||
h2Setting.path
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|
||||||
// "quic" -> {
|
|
||||||
// val quicSetting = streamSettings?.quicSettings ?: return null
|
|
||||||
// listOf(
|
|
||||||
// quicSetting.header.type,
|
|
||||||
// quicSetting.security,
|
|
||||||
// quicSetting.key
|
|
||||||
// )
|
|
||||||
// }
|
|
||||||
|
|
||||||
NetworkType.GRPC.type -> {
|
|
||||||
val grpcSetting = streamSettings?.grpcSettings ?: return null
|
|
||||||
listOf(
|
|
||||||
if (grpcSetting.multiMode == true) "multi" else "gun",
|
|
||||||
grpcSetting.authority.orEmpty(),
|
|
||||||
grpcSetting.serviceName
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|
||||||
else -> null
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
return null
|
return null
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -158,6 +158,8 @@ open class FmtBase {
|
|||||||
config.authority.let { if (it.isNotNullEmpty()) dicQuery["authority"] = it.orEmpty() }
|
config.authority.let { if (it.isNotNullEmpty()) dicQuery["authority"] = it.orEmpty() }
|
||||||
config.serviceName.let { if (it.isNotNullEmpty()) dicQuery["serviceName"] = it.orEmpty() }
|
config.serviceName.let { if (it.isNotNullEmpty()) dicQuery["serviceName"] = it.orEmpty() }
|
||||||
}
|
}
|
||||||
|
|
||||||
|
else -> {}
|
||||||
}
|
}
|
||||||
|
|
||||||
return dicQuery
|
return dicQuery
|
||||||
|
|||||||
@@ -1,11 +1,12 @@
|
|||||||
package com.v2ray.ang.fmt
|
package com.v2ray.ang.fmt
|
||||||
|
|
||||||
import com.v2ray.ang.AppConfig
|
import com.v2ray.ang.AppConfig
|
||||||
import com.v2ray.ang.AppConfig.LOOPBACK
|
|
||||||
import com.v2ray.ang.dto.EConfigType
|
import com.v2ray.ang.dto.EConfigType
|
||||||
import com.v2ray.ang.dto.Hysteria2Bean
|
import com.v2ray.ang.dto.NetworkType
|
||||||
import com.v2ray.ang.dto.ProfileItem
|
import com.v2ray.ang.dto.ProfileItem
|
||||||
import com.v2ray.ang.dto.V2rayConfig.OutboundBean
|
import com.v2ray.ang.dto.V2rayConfig.OutboundBean
|
||||||
|
import com.v2ray.ang.dto.V2rayConfig.OutboundBean.StreamSettingsBean
|
||||||
|
import com.v2ray.ang.dto.V2rayConfig.OutboundBean.StreamSettingsBean.UdpMasksBean.UdpMasksSettingsBean
|
||||||
import com.v2ray.ang.extension.idnHost
|
import com.v2ray.ang.extension.idnHost
|
||||||
import com.v2ray.ang.extension.isNotNullEmpty
|
import com.v2ray.ang.extension.isNotNullEmpty
|
||||||
import com.v2ray.ang.handler.MmkvManager
|
import com.v2ray.ang.handler.MmkvManager
|
||||||
@@ -30,6 +31,7 @@ object Hysteria2Fmt : FmtBase() {
|
|||||||
config.serverPort = uri.port.toString()
|
config.serverPort = uri.port.toString()
|
||||||
config.password = uri.userInfo
|
config.password = uri.userInfo
|
||||||
config.security = AppConfig.TLS
|
config.security = AppConfig.TLS
|
||||||
|
config.network = NetworkType.HYSTERIA.type
|
||||||
|
|
||||||
if (!uri.rawQuery.isNullOrEmpty()) {
|
if (!uri.rawQuery.isNullOrEmpty()) {
|
||||||
val queryParam = getQueryParam(uri)
|
val queryParam = getQueryParam(uri)
|
||||||
@@ -80,64 +82,6 @@ object Hysteria2Fmt : FmtBase() {
|
|||||||
return toUri(config, config.password, dicQuery)
|
return toUri(config, config.password, dicQuery)
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* Converts a ProfileItem object to a Hysteria2Bean object.
|
|
||||||
*
|
|
||||||
* @param config the ProfileItem object to convert
|
|
||||||
* @param socksPort the port number for the socks5 proxy
|
|
||||||
* @return the converted Hysteria2Bean object, or null if conversion fails
|
|
||||||
*/
|
|
||||||
fun toNativeConfig(config: ProfileItem, socksPort: Int): Hysteria2Bean? {
|
|
||||||
|
|
||||||
val obfs = if (config.obfsPassword.isNullOrEmpty()) null else
|
|
||||||
Hysteria2Bean.ObfsBean(
|
|
||||||
type = "salamander",
|
|
||||||
salamander = Hysteria2Bean.ObfsBean.SalamanderBean(
|
|
||||||
password = config.obfsPassword
|
|
||||||
)
|
|
||||||
)
|
|
||||||
|
|
||||||
val transport = if (config.portHopping.isNullOrEmpty()) null else
|
|
||||||
Hysteria2Bean.TransportBean(
|
|
||||||
type = "udp",
|
|
||||||
udp = Hysteria2Bean.TransportBean.TransportUdpBean(
|
|
||||||
hopInterval = (config.portHoppingInterval?.takeIf { it.isNotEmpty() } ?: "30") + "s"
|
|
||||||
)
|
|
||||||
)
|
|
||||||
|
|
||||||
val bandwidth = if (config.bandwidthDown.isNullOrEmpty() || config.bandwidthUp.isNullOrEmpty()) null else
|
|
||||||
Hysteria2Bean.BandwidthBean(
|
|
||||||
down = config.bandwidthDown,
|
|
||||||
up = config.bandwidthUp,
|
|
||||||
)
|
|
||||||
|
|
||||||
val server =
|
|
||||||
if (config.portHopping.isNullOrEmpty())
|
|
||||||
config.getServerAddressAndPort()
|
|
||||||
else
|
|
||||||
Utils.getIpv6Address(config.server) + ":" + config.portHopping
|
|
||||||
|
|
||||||
val bean = Hysteria2Bean(
|
|
||||||
server = server,
|
|
||||||
auth = config.password,
|
|
||||||
obfs = obfs,
|
|
||||||
transport = transport,
|
|
||||||
bandwidth = bandwidth,
|
|
||||||
socks5 = Hysteria2Bean.Socks5Bean(
|
|
||||||
listen = "$LOOPBACK:${socksPort}",
|
|
||||||
),
|
|
||||||
http = Hysteria2Bean.Socks5Bean(
|
|
||||||
listen = "$LOOPBACK:${socksPort}",
|
|
||||||
),
|
|
||||||
tls = Hysteria2Bean.TlsBean(
|
|
||||||
sni = config.sni ?: config.server,
|
|
||||||
insecure = config.insecure,
|
|
||||||
pinSHA256 = if (config.pinSHA256.isNullOrEmpty()) null else config.pinSHA256
|
|
||||||
)
|
|
||||||
)
|
|
||||||
return bean
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Converts a ProfileItem object to an OutboundBean object.
|
* Converts a ProfileItem object to an OutboundBean object.
|
||||||
*
|
*
|
||||||
@@ -145,7 +89,33 @@ object Hysteria2Fmt : FmtBase() {
|
|||||||
* @return the converted OutboundBean object, or null if conversion fails
|
* @return the converted OutboundBean object, or null if conversion fails
|
||||||
*/
|
*/
|
||||||
fun toOutbound(profileItem: ProfileItem): OutboundBean? {
|
fun toOutbound(profileItem: ProfileItem): OutboundBean? {
|
||||||
val outboundBean = V2rayConfigManager.createInitOutbound(EConfigType.HYSTERIA2)
|
val outboundBean = V2rayConfigManager.createInitOutbound(EConfigType.HYSTERIA2) ?: return null
|
||||||
|
profileItem.network = NetworkType.HYSTERIA.type
|
||||||
|
profileItem.alpn = "h3"
|
||||||
|
|
||||||
|
outboundBean.settings?.let { server ->
|
||||||
|
server.address = getServerAddress(profileItem)
|
||||||
|
server.port = profileItem.serverPort.orEmpty().toInt()
|
||||||
|
}
|
||||||
|
|
||||||
|
val sni = outboundBean.streamSettings?.let {
|
||||||
|
V2rayConfigManager.populateTransportSettings(it, profileItem)
|
||||||
|
}
|
||||||
|
|
||||||
|
outboundBean.streamSettings?.let {
|
||||||
|
V2rayConfigManager.populateTlsSettings(it, profileItem, sni)
|
||||||
|
}
|
||||||
|
|
||||||
|
if (profileItem.obfsPassword.isNotNullEmpty()) {
|
||||||
|
outboundBean.streamSettings?.udpmasks = mutableListOf(
|
||||||
|
StreamSettingsBean.UdpMasksBean(
|
||||||
|
type = "salamander",
|
||||||
|
settings = UdpMasksSettingsBean(
|
||||||
|
password = profileItem.obfsPassword
|
||||||
|
)
|
||||||
|
)
|
||||||
|
)
|
||||||
|
}
|
||||||
return outboundBean
|
return outboundBean
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -110,13 +110,6 @@ object AngConfigManager {
|
|||||||
if (guid == null) return -1
|
if (guid == null) return -1
|
||||||
val result = V2rayConfigManager.getV2rayConfig(context, guid)
|
val result = V2rayConfigManager.getV2rayConfig(context, guid)
|
||||||
if (result.status) {
|
if (result.status) {
|
||||||
val config = MmkvManager.decodeServerConfig(guid)
|
|
||||||
if (config?.configType == EConfigType.HYSTERIA2) {
|
|
||||||
val socksPort = Utils.findFreePort(listOf(100 + SettingsManager.getSocksPort(), 0))
|
|
||||||
val hy2Config = Hysteria2Fmt.toNativeConfig(config, socksPort)
|
|
||||||
Utils.setClipboard(context, JsonUtil.toJsonPretty(hy2Config) + "\n" + result.content)
|
|
||||||
return 0
|
|
||||||
}
|
|
||||||
Utils.setClipboard(context, result.content)
|
Utils.setClipboard(context, result.content)
|
||||||
} else {
|
} else {
|
||||||
return -1
|
return -1
|
||||||
@@ -149,6 +142,7 @@ object AngConfigManager {
|
|||||||
EConfigType.WIREGUARD -> WireguardFmt.toUri(config)
|
EConfigType.WIREGUARD -> WireguardFmt.toUri(config)
|
||||||
EConfigType.HYSTERIA2 -> Hysteria2Fmt.toUri(config)
|
EConfigType.HYSTERIA2 -> Hysteria2Fmt.toUri(config)
|
||||||
EConfigType.POLICYGROUP -> ""
|
EConfigType.POLICYGROUP -> ""
|
||||||
|
else -> {}
|
||||||
}
|
}
|
||||||
} catch (e: Exception) {
|
} catch (e: Exception) {
|
||||||
Log.e(AppConfig.TAG, "Failed to share config for GUID: $guid", e)
|
Log.e(AppConfig.TAG, "Failed to share config for GUID: $guid", e)
|
||||||
|
|||||||
@@ -1,141 +0,0 @@
|
|||||||
package com.v2ray.ang.handler
|
|
||||||
|
|
||||||
import android.content.Context
|
|
||||||
import android.os.SystemClock
|
|
||||||
import android.util.Log
|
|
||||||
import com.v2ray.ang.AppConfig
|
|
||||||
import com.v2ray.ang.dto.EConfigType
|
|
||||||
import com.v2ray.ang.dto.ProfileItem
|
|
||||||
import com.v2ray.ang.fmt.Hysteria2Fmt
|
|
||||||
import com.v2ray.ang.service.ProcessService
|
|
||||||
import com.v2ray.ang.util.JsonUtil
|
|
||||||
import com.v2ray.ang.util.Utils
|
|
||||||
import java.io.File
|
|
||||||
|
|
||||||
object PluginServiceManager {
|
|
||||||
private const val HYSTERIA2 = "libhysteria2.so"
|
|
||||||
|
|
||||||
private val procService: ProcessService by lazy {
|
|
||||||
ProcessService()
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Run the plugin based on the provided configuration.
|
|
||||||
*
|
|
||||||
* @param context The context to use.
|
|
||||||
* @param config The profile configuration.
|
|
||||||
* @param socksPort The port information.
|
|
||||||
*/
|
|
||||||
fun runPlugin(context: Context, config: ProfileItem?, socksPort: Int?) {
|
|
||||||
Log.i(AppConfig.TAG, "Starting plugin execution")
|
|
||||||
|
|
||||||
if (config == null) {
|
|
||||||
Log.w(AppConfig.TAG, "Cannot run plugin: config is null")
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
try {
|
|
||||||
if (config.configType == EConfigType.HYSTERIA2) {
|
|
||||||
if (socksPort == null) {
|
|
||||||
Log.w(AppConfig.TAG, "Cannot run plugin: socksPort is null")
|
|
||||||
return
|
|
||||||
}
|
|
||||||
Log.i(AppConfig.TAG, "Running Hysteria2 plugin")
|
|
||||||
val configFile = genConfigHy2(context, config, socksPort) ?: return
|
|
||||||
val cmd = genCmdHy2(context, configFile)
|
|
||||||
|
|
||||||
procService.runProcess(context, cmd)
|
|
||||||
}
|
|
||||||
} catch (e: Exception) {
|
|
||||||
Log.e(AppConfig.TAG, "Error running plugin", e)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Stop the running plugin.
|
|
||||||
*/
|
|
||||||
fun stopPlugin() {
|
|
||||||
stopHy2()
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Perform a real ping using Hysteria2.
|
|
||||||
*
|
|
||||||
* @param context The context to use.
|
|
||||||
* @param config The profile configuration.
|
|
||||||
* @return The ping delay in milliseconds, or -1 if it fails.
|
|
||||||
*/
|
|
||||||
fun realPingHy2(context: Context, config: ProfileItem?): Long {
|
|
||||||
Log.i(AppConfig.TAG, "realPingHy2")
|
|
||||||
val retFailure = -1L
|
|
||||||
|
|
||||||
if (config?.configType?.equals(EConfigType.HYSTERIA2) == true) {
|
|
||||||
val socksPort = Utils.findFreePort(listOf(0))
|
|
||||||
val configFile = genConfigHy2(context, config, socksPort) ?: return retFailure
|
|
||||||
val cmd = genCmdHy2(context, configFile)
|
|
||||||
|
|
||||||
val proc = ProcessService()
|
|
||||||
proc.runProcess(context, cmd)
|
|
||||||
Thread.sleep(1000L)
|
|
||||||
val delay = SpeedtestManager.testConnection(context, socksPort)
|
|
||||||
proc.stopProcess()
|
|
||||||
|
|
||||||
return delay.first
|
|
||||||
}
|
|
||||||
return retFailure
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Generate the configuration file for Hysteria2.
|
|
||||||
*
|
|
||||||
* @param context The context to use.
|
|
||||||
* @param config The profile configuration.
|
|
||||||
* @param socksPort The port information.
|
|
||||||
* @return The generated configuration file.
|
|
||||||
*/
|
|
||||||
private fun genConfigHy2(context: Context, config: ProfileItem, socksPort: Int): File? {
|
|
||||||
Log.i(AppConfig.TAG, "runPlugin $HYSTERIA2")
|
|
||||||
|
|
||||||
val hy2Config = Hysteria2Fmt.toNativeConfig(config, socksPort) ?: return null
|
|
||||||
|
|
||||||
val configFile = File(context.noBackupFilesDir, "hy2_${SystemClock.elapsedRealtime()}.json")
|
|
||||||
Log.i(AppConfig.TAG, "runPlugin ${configFile.absolutePath}")
|
|
||||||
|
|
||||||
configFile.parentFile?.mkdirs()
|
|
||||||
configFile.writeText(JsonUtil.toJson(hy2Config))
|
|
||||||
Log.i(AppConfig.TAG, JsonUtil.toJson(hy2Config))
|
|
||||||
|
|
||||||
return configFile
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Generate the command to run Hysteria2.
|
|
||||||
*
|
|
||||||
* @param context The context to use.
|
|
||||||
* @param configFile The configuration file.
|
|
||||||
* @return The command to run Hysteria2.
|
|
||||||
*/
|
|
||||||
private fun genCmdHy2(context: Context, configFile: File): MutableList<String> {
|
|
||||||
return mutableListOf(
|
|
||||||
File(context.applicationInfo.nativeLibraryDir, HYSTERIA2).absolutePath,
|
|
||||||
"--disable-update-check",
|
|
||||||
"--config",
|
|
||||||
configFile.absolutePath,
|
|
||||||
"--log-level",
|
|
||||||
"warn",
|
|
||||||
"client"
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Stop the Hysteria2 process.
|
|
||||||
*/
|
|
||||||
private fun stopHy2() {
|
|
||||||
try {
|
|
||||||
Log.i(AppConfig.TAG, "$HYSTERIA2 destroy")
|
|
||||||
procService.stopProcess()
|
|
||||||
} catch (e: Exception) {
|
|
||||||
Log.e(AppConfig.TAG, "Failed to stop Hysteria2 process", e)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -168,7 +168,6 @@ object V2RayServiceManager {
|
|||||||
NotificationManager.showNotification(currentConfig)
|
NotificationManager.showNotification(currentConfig)
|
||||||
NotificationManager.startSpeedNotification(currentConfig)
|
NotificationManager.startSpeedNotification(currentConfig)
|
||||||
|
|
||||||
PluginServiceManager.runPlugin(service, config, result.socksPort)
|
|
||||||
} catch (e: Exception) {
|
} catch (e: Exception) {
|
||||||
Log.e(AppConfig.TAG, "Failed to startup service", e)
|
Log.e(AppConfig.TAG, "Failed to startup service", e)
|
||||||
return false
|
return false
|
||||||
@@ -202,7 +201,6 @@ object V2RayServiceManager {
|
|||||||
} catch (e: Exception) {
|
} catch (e: Exception) {
|
||||||
Log.e(AppConfig.TAG, "Failed to unregister broadcast receiver", e)
|
Log.e(AppConfig.TAG, "Failed to unregister broadcast receiver", e)
|
||||||
}
|
}
|
||||||
PluginServiceManager.stopPlugin()
|
|
||||||
|
|
||||||
return true
|
return true
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -16,6 +16,7 @@ import com.v2ray.ang.dto.V2rayConfig.OutboundBean.StreamSettingsBean
|
|||||||
import com.v2ray.ang.dto.V2rayConfig.RoutingBean.RulesBean
|
import com.v2ray.ang.dto.V2rayConfig.RoutingBean.RulesBean
|
||||||
import com.v2ray.ang.extension.isNotNullEmpty
|
import com.v2ray.ang.extension.isNotNullEmpty
|
||||||
import com.v2ray.ang.fmt.HttpFmt
|
import com.v2ray.ang.fmt.HttpFmt
|
||||||
|
import com.v2ray.ang.fmt.Hysteria2Fmt
|
||||||
import com.v2ray.ang.fmt.ShadowsocksFmt
|
import com.v2ray.ang.fmt.ShadowsocksFmt
|
||||||
import com.v2ray.ang.fmt.SocksFmt
|
import com.v2ray.ang.fmt.SocksFmt
|
||||||
import com.v2ray.ang.fmt.TrojanFmt
|
import com.v2ray.ang.fmt.TrojanFmt
|
||||||
@@ -160,12 +161,8 @@ object V2rayConfigManager {
|
|||||||
|
|
||||||
getInbounds(v2rayConfig)
|
getInbounds(v2rayConfig)
|
||||||
|
|
||||||
if (config.configType == EConfigType.HYSTERIA2) {
|
getOutbounds(v2rayConfig, config) ?: return result
|
||||||
result.socksPort = getPlusOutbounds(v2rayConfig, config) ?: return result
|
getMoreOutbounds(v2rayConfig, config.subscriptionId)
|
||||||
} else {
|
|
||||||
getOutbounds(v2rayConfig, config) ?: return result
|
|
||||||
getMoreOutbounds(v2rayConfig, config.subscriptionId)
|
|
||||||
}
|
|
||||||
|
|
||||||
getRouting(v2rayConfig)
|
getRouting(v2rayConfig)
|
||||||
|
|
||||||
@@ -196,7 +193,6 @@ object V2rayConfigManager {
|
|||||||
val validConfigs = configList.asSequence().filter { it.server.isNotNullEmpty() }
|
val validConfigs = configList.asSequence().filter { it.server.isNotNullEmpty() }
|
||||||
.filter { !Utils.isPureIpAddress(it.server!!) || Utils.isValidUrl(it.server!!) }
|
.filter { !Utils.isPureIpAddress(it.server!!) || Utils.isValidUrl(it.server!!) }
|
||||||
.filter { it.configType != EConfigType.CUSTOM }
|
.filter { it.configType != EConfigType.CUSTOM }
|
||||||
.filter { it.configType != EConfigType.HYSTERIA2 }
|
|
||||||
.filter { it.configType != EConfigType.POLICYGROUP }
|
.filter { it.configType != EConfigType.POLICYGROUP }
|
||||||
.toList()
|
.toList()
|
||||||
|
|
||||||
@@ -270,12 +266,8 @@ object V2rayConfigManager {
|
|||||||
|
|
||||||
val v2rayConfig = initV2rayConfig(context) ?: return result
|
val v2rayConfig = initV2rayConfig(context) ?: return result
|
||||||
|
|
||||||
if (config.configType == EConfigType.HYSTERIA2) {
|
getOutbounds(v2rayConfig, config) ?: return result
|
||||||
result.socksPort = getPlusOutbounds(v2rayConfig, config) ?: return result
|
getMoreOutbounds(v2rayConfig, config.subscriptionId)
|
||||||
} else {
|
|
||||||
getOutbounds(v2rayConfig, config) ?: return result
|
|
||||||
getMoreOutbounds(v2rayConfig, config.subscriptionId)
|
|
||||||
}
|
|
||||||
|
|
||||||
v2rayConfig.log.loglevel = MmkvManager.decodeSettingsString(AppConfig.PREF_LOGLEVEL) ?: "warning"
|
v2rayConfig.log.loglevel = MmkvManager.decodeSettingsString(AppConfig.PREF_LOGLEVEL) ?: "warning"
|
||||||
v2rayConfig.inbounds.clear()
|
v2rayConfig.inbounds.clear()
|
||||||
@@ -667,44 +659,6 @@ object V2rayConfigManager {
|
|||||||
return true
|
return true
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* Configures special outbound settings for Hysteria2 protocol.
|
|
||||||
*
|
|
||||||
* Creates a SOCKS outbound connection on a free port for protocols requiring special handling.
|
|
||||||
*
|
|
||||||
* @param v2rayConfig The V2ray configuration object to be modified
|
|
||||||
* @param config The profile item containing connection details
|
|
||||||
* @return The port number for the SOCKS connection, or null if there was an error
|
|
||||||
*/
|
|
||||||
private fun getPlusOutbounds(v2rayConfig: V2rayConfig, config: ProfileItem): Int? {
|
|
||||||
try {
|
|
||||||
val socksPort = Utils.findFreePort(listOf(100 + SettingsManager.getSocksPort(), 0))
|
|
||||||
|
|
||||||
val outboundNew = OutboundBean(
|
|
||||||
mux = null,
|
|
||||||
protocol = EConfigType.SOCKS.name.lowercase(),
|
|
||||||
settings = OutSettingsBean(
|
|
||||||
servers = listOf(
|
|
||||||
OutSettingsBean.ServersBean(
|
|
||||||
address = AppConfig.LOOPBACK,
|
|
||||||
port = socksPort
|
|
||||||
)
|
|
||||||
)
|
|
||||||
)
|
|
||||||
)
|
|
||||||
if (v2rayConfig.outbounds.isNotEmpty()) {
|
|
||||||
v2rayConfig.outbounds[0] = outboundNew
|
|
||||||
} else {
|
|
||||||
v2rayConfig.outbounds.add(outboundNew)
|
|
||||||
}
|
|
||||||
|
|
||||||
return socksPort
|
|
||||||
} catch (e: Exception) {
|
|
||||||
Log.e(AppConfig.TAG, "Failed to configure plusOutbound", e)
|
|
||||||
return null
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Configures additional outbound connections for proxy chaining.
|
* Configures additional outbound connections for proxy chaining.
|
||||||
*
|
*
|
||||||
@@ -1046,9 +1000,10 @@ object V2rayConfigManager {
|
|||||||
EConfigType.VLESS -> VlessFmt.toOutbound(profileItem)
|
EConfigType.VLESS -> VlessFmt.toOutbound(profileItem)
|
||||||
EConfigType.TROJAN -> TrojanFmt.toOutbound(profileItem)
|
EConfigType.TROJAN -> TrojanFmt.toOutbound(profileItem)
|
||||||
EConfigType.WIREGUARD -> WireguardFmt.toOutbound(profileItem)
|
EConfigType.WIREGUARD -> WireguardFmt.toOutbound(profileItem)
|
||||||
EConfigType.HYSTERIA2 -> null
|
EConfigType.HYSTERIA2 -> Hysteria2Fmt.toOutbound(profileItem)
|
||||||
EConfigType.HTTP -> HttpFmt.toOutbound(profileItem)
|
EConfigType.HTTP -> HttpFmt.toOutbound(profileItem)
|
||||||
EConfigType.POLICYGROUP -> null
|
EConfigType.POLICYGROUP -> null
|
||||||
|
else -> null
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -1079,8 +1034,7 @@ object V2rayConfigManager {
|
|||||||
EConfigType.SHADOWSOCKS,
|
EConfigType.SHADOWSOCKS,
|
||||||
EConfigType.SOCKS,
|
EConfigType.SOCKS,
|
||||||
EConfigType.HTTP,
|
EConfigType.HTTP,
|
||||||
EConfigType.TROJAN,
|
EConfigType.TROJAN ->
|
||||||
EConfigType.HYSTERIA2 ->
|
|
||||||
return OutboundBean(
|
return OutboundBean(
|
||||||
protocol = configType.name.lowercase(),
|
protocol = configType.name.lowercase(),
|
||||||
settings = OutSettingsBean(
|
settings = OutSettingsBean(
|
||||||
@@ -1098,6 +1052,16 @@ object V2rayConfigManager {
|
|||||||
)
|
)
|
||||||
)
|
)
|
||||||
|
|
||||||
|
EConfigType.HYSTERIA,
|
||||||
|
EConfigType.HYSTERIA2 ->
|
||||||
|
return OutboundBean(
|
||||||
|
protocol = EConfigType.HYSTERIA.name.lowercase(),
|
||||||
|
settings = OutSettingsBean(
|
||||||
|
servers = null
|
||||||
|
),
|
||||||
|
streamSettings = StreamSettingsBean()
|
||||||
|
)
|
||||||
|
|
||||||
EConfigType.CUSTOM -> null
|
EConfigType.CUSTOM -> null
|
||||||
EConfigType.POLICYGROUP -> null
|
EConfigType.POLICYGROUP -> null
|
||||||
}
|
}
|
||||||
@@ -1127,7 +1091,7 @@ object V2rayConfigManager {
|
|||||||
val xhttpExtra = profileItem.xhttpExtra
|
val xhttpExtra = profileItem.xhttpExtra
|
||||||
|
|
||||||
var sni: String? = null
|
var sni: String? = null
|
||||||
streamSettings.network = if (transport.isEmpty()) NetworkType.TCP.type else transport
|
streamSettings.network = transport.ifEmpty { NetworkType.TCP.type }
|
||||||
when (streamSettings.network) {
|
when (streamSettings.network) {
|
||||||
NetworkType.TCP.type -> {
|
NetworkType.TCP.type -> {
|
||||||
val tcpSetting = StreamSettingsBean.TcpSettingsBean()
|
val tcpSetting = StreamSettingsBean.TcpSettingsBean()
|
||||||
@@ -1216,6 +1180,23 @@ object V2rayConfigManager {
|
|||||||
sni = authority
|
sni = authority
|
||||||
streamSettings.grpcSettings = grpcSetting
|
streamSettings.grpcSettings = grpcSetting
|
||||||
}
|
}
|
||||||
|
|
||||||
|
NetworkType.HYSTERIA.type -> {
|
||||||
|
val hysteriaSetting = StreamSettingsBean.HysteriaSettingsBean(
|
||||||
|
version = 2,
|
||||||
|
auth = profileItem.password.orEmpty(),
|
||||||
|
up = profileItem.bandwidthUp?.ifEmpty { "0" }.orEmpty(),
|
||||||
|
down = profileItem.bandwidthDown?.ifEmpty { "0" }.orEmpty(),
|
||||||
|
udphop = null
|
||||||
|
)
|
||||||
|
if (profileItem.portHopping.isNotNullEmpty()) {
|
||||||
|
hysteriaSetting.udphop = StreamSettingsBean.HysteriaSettingsBean.HysteriaUdpHopBean(
|
||||||
|
port = profileItem.portHopping,
|
||||||
|
interval = profileItem.portHoppingInterval?.ifEmpty { "30" }.orEmpty().toInt()
|
||||||
|
)
|
||||||
|
}
|
||||||
|
streamSettings.hysteriaSettings = hysteriaSetting
|
||||||
|
}
|
||||||
}
|
}
|
||||||
return sni
|
return sni
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -35,18 +35,18 @@ object WebDavManager {
|
|||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Upload a local file to a remote relative path under the configured remoteBasePath.
|
* Upload a local file to a remote file name under the configured remoteBasePath.
|
||||||
* The provided `remoteRelativePath` should be relative (e.g. "backup_ng.zip").
|
* The provided `remoteFileName` should be a file name (e.g. "backup_ng.zip").
|
||||||
* The method will attempt to create parent directories via MKCOL before PUT.
|
* The method will attempt to create parent directories via MKCOL before PUT.
|
||||||
*
|
*
|
||||||
* @param localFile File to upload.
|
* @param localFile File to upload.
|
||||||
* @param remoteRelativePath Remote path relative to configured remoteBasePath.
|
* @param remoteFileName Remote file name relative to configured remoteBasePath.
|
||||||
* @return true if upload succeeded (HTTP 2xx), false otherwise.
|
* @return true if upload succeeded (HTTP 2xx), false otherwise.
|
||||||
*/
|
*/
|
||||||
suspend fun uploadFile(localFile: File, remoteRelativePath: String): Boolean = withContext(Dispatchers.IO) {
|
suspend fun uploadFile(localFile: File, remoteFileName: String): Boolean = withContext(Dispatchers.IO) {
|
||||||
|
val remote = buildRemoteUrl(remoteFileName)
|
||||||
try {
|
try {
|
||||||
val cl = client ?: return@withContext false
|
val cl = client ?: return@withContext false
|
||||||
val remote = buildRemoteUrl(remoteRelativePath)
|
|
||||||
|
|
||||||
// Ensure parent directories exist
|
// Ensure parent directories exist
|
||||||
val dirPath = remote.substringBeforeLast('/')
|
val dirPath = remote.substringBeforeLast('/')
|
||||||
@@ -67,14 +67,14 @@ object WebDavManager {
|
|||||||
cl.newCall(req).execute().use { resp ->
|
cl.newCall(req).execute().use { resp ->
|
||||||
val success = resp.isSuccessful
|
val success = resp.isSuccessful
|
||||||
if (success) {
|
if (success) {
|
||||||
Log.i(AppConfig.TAG, "WebDAV upload success: $remoteRelativePath")
|
Log.i(AppConfig.TAG, "WebDAV upload success: $remote")
|
||||||
} else {
|
} else {
|
||||||
Log.e(AppConfig.TAG, "WebDAV upload failed: $remoteRelativePath (HTTP ${resp.code})")
|
Log.e(AppConfig.TAG, "WebDAV upload failed: $remote (HTTP ${resp.code})")
|
||||||
}
|
}
|
||||||
return@withContext success
|
return@withContext success
|
||||||
}
|
}
|
||||||
} catch (e: Exception) {
|
} catch (e: Exception) {
|
||||||
Log.e(AppConfig.TAG, "WebDAV upload exception: $remoteRelativePath", e)
|
Log.e(AppConfig.TAG, "WebDAV upload exception: $remote", e)
|
||||||
return@withContext false
|
return@withContext false
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -82,18 +82,18 @@ object WebDavManager {
|
|||||||
/**
|
/**
|
||||||
* Download a remote file (relative to configured remoteBasePath) into a local file.
|
* Download a remote file (relative to configured remoteBasePath) into a local file.
|
||||||
*
|
*
|
||||||
* @param remoteRelativePath Remote path relative to configured remoteBasePath.
|
* @param remoteFileName Remote file name relative to configured remoteBasePath.
|
||||||
* @param destFile Local destination file to write to.
|
* @param destFile Local destination file to write to.
|
||||||
* @return true if download and write succeeded, false otherwise.
|
* @return true if download and write succeeded, false otherwise.
|
||||||
*/
|
*/
|
||||||
suspend fun downloadFile(remoteRelativePath: String, destFile: File): Boolean = withContext(Dispatchers.IO) {
|
suspend fun downloadFile(remoteFileName: String, destFile: File): Boolean = withContext(Dispatchers.IO) {
|
||||||
|
val remote = buildRemoteUrl(remoteFileName)
|
||||||
try {
|
try {
|
||||||
val cl = client ?: return@withContext false
|
val cl = client ?: return@withContext false
|
||||||
val remote = buildRemoteUrl(remoteRelativePath)
|
|
||||||
val req = applyAuth(Request.Builder().url(remote).get()).build()
|
val req = applyAuth(Request.Builder().url(remote).get()).build()
|
||||||
cl.newCall(req).execute().use { resp ->
|
cl.newCall(req).execute().use { resp ->
|
||||||
if (!resp.isSuccessful) {
|
if (!resp.isSuccessful) {
|
||||||
Log.e(AppConfig.TAG, "WebDAV download failed: $remoteRelativePath (HTTP ${resp.code})")
|
Log.e(AppConfig.TAG, "WebDAV download failed: $remote (HTTP ${resp.code})")
|
||||||
return@withContext false
|
return@withContext false
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -104,29 +104,31 @@ object WebDavManager {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
Log.i(AppConfig.TAG, "WebDAV download success: $remoteRelativePath")
|
Log.i(AppConfig.TAG, "WebDAV download success: $remote")
|
||||||
return@withContext true
|
return@withContext true
|
||||||
}
|
}
|
||||||
} catch (e: Exception) {
|
} catch (e: Exception) {
|
||||||
Log.e(AppConfig.TAG, "WebDAV download exception: $remoteRelativePath", e)
|
Log.e(AppConfig.TAG, "WebDAV download exception: $remote", e)
|
||||||
return@withContext false
|
return@withContext false
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Build a full remote URL by combining the configured base URL, the configured
|
* Build a full remote URL by combining the configured base URL, the configured
|
||||||
* remote base path and a relative path provided by the caller.
|
* remote base path and a file name provided by the caller.
|
||||||
*
|
*
|
||||||
* Example: baseUrl="https://example.com/remote.php/dav", remoteBasePath="backups",
|
* Example: baseUrl="https://example.com/remote.php/dav", remoteBasePath="backups",
|
||||||
* remoteRelativePath="backup_ng.zip" => "https://example.com/remote.php/dav/backups/backup_ng.zip"
|
* remoteFileName="backup_ng.zip" => "https://example.com/remote.php/dav/backups/backup_ng.zip"
|
||||||
*
|
*
|
||||||
* @param remoteRelativePath A path relative to the configured remoteBasePath (no leading slash required).
|
* @param remoteFileName A file name relative to the configured remoteBasePath (no leading slash required).
|
||||||
* @return Full URL string used for HTTP operations.
|
* @return Full URL string used for HTTP operations.
|
||||||
*/
|
*/
|
||||||
private fun buildRemoteUrl(remoteRelativePath: String): String {
|
private fun buildRemoteUrl(remoteFileName: String): String {
|
||||||
val base = cfg?.baseUrl?.trimEnd('/') ?: ""
|
val base = cfg?.baseUrl?.trimEnd('/') ?: ""
|
||||||
val basePath = cfg?.remoteBasePath?.trim('/') ?: ""
|
// Use configured remoteBasePath when not empty; otherwise fallback to AppConfig.WEBDAV_BACKUP_DIR
|
||||||
val rel = remoteRelativePath.trimStart('/')
|
val basePathConfigured = cfg?.remoteBasePath?.trim('/')?.takeIf { it.isNotEmpty() }
|
||||||
|
val basePath = basePathConfigured ?: AppConfig.WEBDAV_BACKUP_DIR
|
||||||
|
val rel = remoteFileName.trimStart('/')
|
||||||
return if (basePath.isEmpty()) "$base/$rel" else "$base/$basePath/$rel"
|
return if (basePath.isEmpty()) "$base/$rel" else "$base/$basePath/$rel"
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -170,7 +172,7 @@ object WebDavManager {
|
|||||||
Log.w(AppConfig.TAG, "WebDAV MKCOL $mkUrl returned ${resp.code}")
|
Log.w(AppConfig.TAG, "WebDAV MKCOL $mkUrl returned ${resp.code}")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
} catch (ignored: Exception) {
|
} catch (_: Exception) {
|
||||||
// best-effort, continue
|
// best-effort, continue
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,32 +0,0 @@
|
|||||||
/******************************************************************************
|
|
||||||
* *
|
|
||||||
* Copyright (C) 2021 by nekohasekai <contact-sagernet@sekai.icu> *
|
|
||||||
* Copyright (C) 2021 by Max Lv <max.c.lv@gmail.com> *
|
|
||||||
* Copyright (C) 2021 by Mygod Studio <contact-shadowsocks-android@mygod.be> *
|
|
||||||
* *
|
|
||||||
* This program is free software: you can redistribute it and/or modify *
|
|
||||||
* it under the terms of the GNU General Public License as published by *
|
|
||||||
* the Free Software Foundation, either version 3 of the License, or *
|
|
||||||
* (at your option) any later version. *
|
|
||||||
* *
|
|
||||||
* This program is distributed in the hope that it will be useful, *
|
|
||||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of *
|
|
||||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
|
|
||||||
* GNU General Public License for more details. *
|
|
||||||
* *
|
|
||||||
* You should have received a copy of the GNU General Public License *
|
|
||||||
* along with this program. If not, see <http://www.gnu.org/licenses/>. *
|
|
||||||
* *
|
|
||||||
******************************************************************************/
|
|
||||||
|
|
||||||
package com.v2ray.ang.plugin
|
|
||||||
|
|
||||||
import android.content.pm.ResolveInfo
|
|
||||||
|
|
||||||
class NativePlugin(resolveInfo: ResolveInfo) : ResolvedPlugin(resolveInfo) {
|
|
||||||
init {
|
|
||||||
check(resolveInfo.providerInfo != null)
|
|
||||||
}
|
|
||||||
|
|
||||||
override val componentInfo get() = resolveInfo.providerInfo!!
|
|
||||||
}
|
|
||||||
@@ -1,43 +0,0 @@
|
|||||||
/******************************************************************************
|
|
||||||
* *
|
|
||||||
* Copyright (C) 2021 by nekohasekai <contact-sagernet@sekai.icu> *
|
|
||||||
* Copyright (C) 2021 by Max Lv <max.c.lv@gmail.com> *
|
|
||||||
* Copyright (C) 2021 by Mygod Studio <contact-shadowsocks-android@mygod.be> *
|
|
||||||
* *
|
|
||||||
* This program is free software: you can redistribute it and/or modify *
|
|
||||||
* it under the terms of the GNU General Public License as published by *
|
|
||||||
* the Free Software Foundation, either version 3 of the License, or *
|
|
||||||
* (at your option) any later version. *
|
|
||||||
* *
|
|
||||||
* This program is distributed in the hope that it will be useful, *
|
|
||||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of *
|
|
||||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
|
|
||||||
* GNU General Public License for more details. *
|
|
||||||
* *
|
|
||||||
* You should have received a copy of the GNU General Public License *
|
|
||||||
* along with this program. If not, see <http://www.gnu.org/licenses/>. *
|
|
||||||
* *
|
|
||||||
******************************************************************************/
|
|
||||||
|
|
||||||
package com.v2ray.ang.plugin
|
|
||||||
|
|
||||||
import android.graphics.drawable.Drawable
|
|
||||||
|
|
||||||
abstract class Plugin {
|
|
||||||
abstract val id: String
|
|
||||||
abstract val label: CharSequence
|
|
||||||
abstract val version: Int
|
|
||||||
abstract val versionName: String
|
|
||||||
open val icon: Drawable? get() = null
|
|
||||||
open val defaultConfig: String? get() = null
|
|
||||||
open val packageName: String get() = ""
|
|
||||||
open val directBootAware: Boolean get() = true
|
|
||||||
|
|
||||||
override fun equals(other: Any?): Boolean {
|
|
||||||
if (this === other) return true
|
|
||||||
if (javaClass != other?.javaClass) return false
|
|
||||||
return id == (other as Plugin).id
|
|
||||||
}
|
|
||||||
|
|
||||||
override fun hashCode() = id.hashCode()
|
|
||||||
}
|
|
||||||
@@ -1,33 +0,0 @@
|
|||||||
/******************************************************************************
|
|
||||||
* *
|
|
||||||
* Copyright (C) 2021 by nekohasekai <contact-sagernet@sekai.icu> *
|
|
||||||
* *
|
|
||||||
* This program is free software: you can redistribute it and/or modify *
|
|
||||||
* it under the terms of the GNU General Public License as published by *
|
|
||||||
* the Free Software Foundation, either version 3 of the License, or *
|
|
||||||
* (at your option) any later version. *
|
|
||||||
* *
|
|
||||||
* This program is distributed in the hope that it will be useful, *
|
|
||||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of *
|
|
||||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
|
|
||||||
* GNU General Public License for more details. *
|
|
||||||
* *
|
|
||||||
* You should have received a copy of the GNU General Public License *
|
|
||||||
* along with this program. If not, see <http://www.gnu.org/licenses/>. *
|
|
||||||
* *
|
|
||||||
******************************************************************************/
|
|
||||||
|
|
||||||
package com.v2ray.ang.plugin
|
|
||||||
|
|
||||||
object PluginContract {
|
|
||||||
|
|
||||||
const val ACTION_NATIVE_PLUGIN = "io.nekohasekai.sagernet.plugin.ACTION_NATIVE_PLUGIN"
|
|
||||||
const val EXTRA_ENTRY = "io.nekohasekai.sagernet.plugin.EXTRA_ENTRY"
|
|
||||||
const val METADATA_KEY_ID = "io.nekohasekai.sagernet.plugin.id"
|
|
||||||
const val METADATA_KEY_EXECUTABLE_PATH = "io.nekohasekai.sagernet.plugin.executable_path"
|
|
||||||
const val METHOD_GET_EXECUTABLE = "sagernet:getExecutable"
|
|
||||||
|
|
||||||
const val COLUMN_PATH = "path"
|
|
||||||
const val COLUMN_MODE = "mode"
|
|
||||||
const val SCHEME = "plugin"
|
|
||||||
}
|
|
||||||
@@ -1,54 +0,0 @@
|
|||||||
/******************************************************************************
|
|
||||||
* *
|
|
||||||
* Copyright (C) 2021 by nekohasekai <contact-sagernet@sekai.icu> *
|
|
||||||
* Copyright (C) 2021 by Max Lv <max.c.lv@gmail.com> *
|
|
||||||
* Copyright (C) 2021 by Mygod Studio <contact-shadowsocks-android@mygod.be> *
|
|
||||||
* *
|
|
||||||
* This program is free software: you can redistribute it and/or modify *
|
|
||||||
* it under the terms of the GNU General Public License as published by *
|
|
||||||
* the Free Software Foundation, either version 3 of the License, or *
|
|
||||||
* (at your option) any later version. *
|
|
||||||
* *
|
|
||||||
* This program is distributed in the hope that it will be useful, *
|
|
||||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of *
|
|
||||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
|
|
||||||
* GNU General Public License for more details. *
|
|
||||||
* *
|
|
||||||
* You should have received a copy of the GNU General Public License *
|
|
||||||
* along with this program. If not, see <http://www.gnu.org/licenses/>. *
|
|
||||||
* *
|
|
||||||
******************************************************************************/
|
|
||||||
|
|
||||||
package com.v2ray.ang.plugin
|
|
||||||
|
|
||||||
import android.content.Intent
|
|
||||||
import android.content.pm.PackageManager
|
|
||||||
import com.v2ray.ang.AngApplication
|
|
||||||
|
|
||||||
class PluginList : ArrayList<Plugin>() {
|
|
||||||
init {
|
|
||||||
addAll(
|
|
||||||
AngApplication.application.packageManager.queryIntentContentProviders(
|
|
||||||
Intent(PluginContract.ACTION_NATIVE_PLUGIN), PackageManager.GET_META_DATA
|
|
||||||
)
|
|
||||||
.filter { it.providerInfo.exported }.map { NativePlugin(it) })
|
|
||||||
}
|
|
||||||
|
|
||||||
val lookup = mutableMapOf<String, Plugin>().apply {
|
|
||||||
for (plugin in this@PluginList.toList()) {
|
|
||||||
fun check(old: Plugin?) {
|
|
||||||
if (old != null && old != plugin) {
|
|
||||||
this@PluginList.remove(old)
|
|
||||||
}
|
|
||||||
/* if (old != null && old !== plugin) {
|
|
||||||
val packages = this@PluginList.filter { it.id == plugin.id }
|
|
||||||
.joinToString { it.packageName }
|
|
||||||
val message = "Conflicting plugins found from: $packages"
|
|
||||||
Toast.makeText(SagerNet.application, message, Toast.LENGTH_LONG).show()
|
|
||||||
throw IllegalStateException(message)
|
|
||||||
}*/
|
|
||||||
}
|
|
||||||
check(put(plugin.id, plugin))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -1,232 +0,0 @@
|
|||||||
/******************************************************************************
|
|
||||||
* *
|
|
||||||
* Copyright (C) 2021 by nekohasekai <contact-AngApplication@sekai.icu> *
|
|
||||||
* Copyright (C) 2021 by Max Lv <max.c.lv@gmail.com> *
|
|
||||||
* Copyright (C) 2021 by Mygod Studio <contact-shadowsocks-android@mygod.be> *
|
|
||||||
* *
|
|
||||||
* This program is free software: you can redistribute it and/or modify *
|
|
||||||
* it under the terms of the GNU General Public License as published by *
|
|
||||||
* the Free Software Foundation, either version 3 of the License, or *
|
|
||||||
* (at your option) any later version. *
|
|
||||||
* *
|
|
||||||
* This program is distributed in the hope that it will be useful, *
|
|
||||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of *
|
|
||||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
|
|
||||||
* GNU General Public License for more details. *
|
|
||||||
* *
|
|
||||||
* You should have received a copy of the GNU General Public License *
|
|
||||||
* along with this program. If not, see <http://www.gnu.org/licenses/>. *
|
|
||||||
* *
|
|
||||||
******************************************************************************/
|
|
||||||
|
|
||||||
package com.v2ray.ang.plugin
|
|
||||||
|
|
||||||
import android.annotation.SuppressLint
|
|
||||||
import android.content.BroadcastReceiver
|
|
||||||
import android.content.ContentResolver
|
|
||||||
import android.content.Intent
|
|
||||||
import android.content.pm.ComponentInfo
|
|
||||||
import android.content.pm.PackageManager
|
|
||||||
import android.content.pm.ProviderInfo
|
|
||||||
import android.database.Cursor
|
|
||||||
import android.net.Uri
|
|
||||||
import android.os.Build
|
|
||||||
import android.system.Os
|
|
||||||
import androidx.core.os.bundleOf
|
|
||||||
import com.v2ray.ang.AngApplication
|
|
||||||
import com.v2ray.ang.extension.listenForPackageChanges
|
|
||||||
import com.v2ray.ang.extension.toast
|
|
||||||
import com.v2ray.ang.plugin.PluginContract.METADATA_KEY_ID
|
|
||||||
import java.io.File
|
|
||||||
import java.io.FileNotFoundException
|
|
||||||
|
|
||||||
object PluginManager {
|
|
||||||
|
|
||||||
class PluginNotFoundException(val plugin: String) : FileNotFoundException(plugin)
|
|
||||||
|
|
||||||
private var receiver: BroadcastReceiver? = null
|
|
||||||
private var cachedPlugins: PluginList? = null
|
|
||||||
fun fetchPlugins() = synchronized(this) {
|
|
||||||
if (receiver == null) receiver = AngApplication.application.listenForPackageChanges {
|
|
||||||
synchronized(this) {
|
|
||||||
receiver = null
|
|
||||||
cachedPlugins = null
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (cachedPlugins == null) cachedPlugins = PluginList()
|
|
||||||
cachedPlugins!!
|
|
||||||
}
|
|
||||||
|
|
||||||
private fun buildUri(id: String, authority: String) = Uri.Builder()
|
|
||||||
.scheme(PluginContract.SCHEME)
|
|
||||||
.authority(authority)
|
|
||||||
.path("/$id")
|
|
||||||
.build()
|
|
||||||
|
|
||||||
data class InitResult(
|
|
||||||
val path: String,
|
|
||||||
)
|
|
||||||
|
|
||||||
@Throws(Throwable::class)
|
|
||||||
fun init(pluginId: String): InitResult? {
|
|
||||||
if (pluginId.isEmpty()) return null
|
|
||||||
var throwable: Throwable? = null
|
|
||||||
|
|
||||||
try {
|
|
||||||
val result = initNative(pluginId)
|
|
||||||
if (result != null) return result
|
|
||||||
} catch (t: Throwable) {
|
|
||||||
if (throwable == null) throwable = t //Logs.w(t)
|
|
||||||
}
|
|
||||||
|
|
||||||
throw throwable ?: PluginNotFoundException(pluginId)
|
|
||||||
}
|
|
||||||
|
|
||||||
private fun initNative(pluginId: String): InitResult? {
|
|
||||||
var flags = PackageManager.GET_META_DATA
|
|
||||||
if (Build.VERSION.SDK_INT >= 24) {
|
|
||||||
flags =
|
|
||||||
flags or PackageManager.MATCH_DIRECT_BOOT_UNAWARE or PackageManager.MATCH_DIRECT_BOOT_AWARE
|
|
||||||
}
|
|
||||||
var providers = AngApplication.application.packageManager.queryIntentContentProviders(
|
|
||||||
Intent(PluginContract.ACTION_NATIVE_PLUGIN, buildUri(pluginId, "com.github.dyhkwong.AngApplication")), flags
|
|
||||||
)
|
|
||||||
.filter { it.providerInfo.exported }
|
|
||||||
if (providers.isEmpty()) {
|
|
||||||
providers = AngApplication.application.packageManager.queryIntentContentProviders(
|
|
||||||
Intent(PluginContract.ACTION_NATIVE_PLUGIN, buildUri(pluginId, "io.nekohasekai.AngApplication")), flags
|
|
||||||
)
|
|
||||||
.filter { it.providerInfo.exported }
|
|
||||||
}
|
|
||||||
if (providers.isEmpty()) {
|
|
||||||
providers = AngApplication.application.packageManager.queryIntentContentProviders(
|
|
||||||
Intent(PluginContract.ACTION_NATIVE_PLUGIN, buildUri(pluginId, "moe.matsuri.lite")), flags
|
|
||||||
)
|
|
||||||
.filter { it.providerInfo.exported }
|
|
||||||
}
|
|
||||||
if (providers.isEmpty()) {
|
|
||||||
providers = AngApplication.application.packageManager.queryIntentContentProviders(
|
|
||||||
Intent(PluginContract.ACTION_NATIVE_PLUGIN, buildUri(pluginId, "fr.husi")), flags
|
|
||||||
)
|
|
||||||
.filter { it.providerInfo.exported }
|
|
||||||
}
|
|
||||||
if (providers.isEmpty()) {
|
|
||||||
providers = AngApplication.application.packageManager.queryIntentContentProviders(
|
|
||||||
Intent(PluginContract.ACTION_NATIVE_PLUGIN), PackageManager.GET_META_DATA
|
|
||||||
).filter {
|
|
||||||
it.providerInfo.exported &&
|
|
||||||
it.providerInfo.metaData.containsKey(METADATA_KEY_ID) &&
|
|
||||||
it.providerInfo.metaData.getString(METADATA_KEY_ID) == pluginId
|
|
||||||
}
|
|
||||||
if (providers.size > 1) {
|
|
||||||
providers = listOf(providers[0]) // What if there is more than one?
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (providers.isEmpty()) return null
|
|
||||||
if (providers.size > 1) {
|
|
||||||
val message =
|
|
||||||
"Conflicting plugins found from: ${providers.joinToString { it.providerInfo.packageName }}"
|
|
||||||
AngApplication.application.toast(message)
|
|
||||||
throw IllegalStateException(message)
|
|
||||||
}
|
|
||||||
val provider = providers.single().providerInfo
|
|
||||||
var failure: Throwable? = null
|
|
||||||
try {
|
|
||||||
initNativeFaster(provider)?.also { return InitResult(it) }
|
|
||||||
} catch (t: Throwable) {
|
|
||||||
// Logs.w("Initializing native plugin faster mode failed")
|
|
||||||
failure = t
|
|
||||||
}
|
|
||||||
|
|
||||||
val uri = Uri.Builder().apply {
|
|
||||||
scheme(ContentResolver.SCHEME_CONTENT)
|
|
||||||
authority(provider.authority)
|
|
||||||
}.build()
|
|
||||||
try {
|
|
||||||
return initNativeFast(
|
|
||||||
AngApplication.application.contentResolver,
|
|
||||||
pluginId,
|
|
||||||
uri
|
|
||||||
)?.let { InitResult(it) }
|
|
||||||
} catch (t: Throwable) {
|
|
||||||
// Logs.w("Initializing native plugin fast mode failed")
|
|
||||||
failure?.also { t.addSuppressed(it) }
|
|
||||||
failure = t
|
|
||||||
}
|
|
||||||
|
|
||||||
try {
|
|
||||||
return initNativeSlow(
|
|
||||||
AngApplication.application.contentResolver,
|
|
||||||
pluginId,
|
|
||||||
uri
|
|
||||||
)?.let { InitResult(it) }
|
|
||||||
} catch (t: Throwable) {
|
|
||||||
failure.also { t.addSuppressed(it) }
|
|
||||||
throw t
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private fun initNativeFaster(provider: ProviderInfo): String? {
|
|
||||||
return provider.loadString(PluginContract.METADATA_KEY_EXECUTABLE_PATH)
|
|
||||||
?.let { relativePath ->
|
|
||||||
File(provider.applicationInfo.nativeLibraryDir).resolve(relativePath).apply {
|
|
||||||
check(canExecute())
|
|
||||||
}.absolutePath
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private fun initNativeFast(cr: ContentResolver, pluginId: String, uri: Uri): String? {
|
|
||||||
return cr.call(uri, PluginContract.METHOD_GET_EXECUTABLE, null, bundleOf())
|
|
||||||
?.getString(PluginContract.EXTRA_ENTRY)?.also {
|
|
||||||
check(File(it).canExecute())
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@SuppressLint("Recycle")
|
|
||||||
private fun initNativeSlow(cr: ContentResolver, pluginId: String, uri: Uri): String? {
|
|
||||||
var initialized = false
|
|
||||||
fun entryNotFound(): Nothing =
|
|
||||||
throw IndexOutOfBoundsException("Plugin entry binary not found")
|
|
||||||
|
|
||||||
val pluginDir = File(AngApplication.application.noBackupFilesDir, "plugin")
|
|
||||||
(cr.query(
|
|
||||||
uri,
|
|
||||||
arrayOf(PluginContract.COLUMN_PATH, PluginContract.COLUMN_MODE),
|
|
||||||
null,
|
|
||||||
null,
|
|
||||||
null
|
|
||||||
)
|
|
||||||
?: return null).use { cursor ->
|
|
||||||
if (!cursor.moveToFirst()) entryNotFound()
|
|
||||||
pluginDir.deleteRecursively()
|
|
||||||
if (!pluginDir.mkdirs()) throw FileNotFoundException("Unable to create plugin directory")
|
|
||||||
val pluginDirPath = pluginDir.absolutePath + '/'
|
|
||||||
do {
|
|
||||||
val path = cursor.getString(0)
|
|
||||||
val file = File(pluginDir, path)
|
|
||||||
check(file.absolutePath.startsWith(pluginDirPath))
|
|
||||||
cr.openInputStream(uri.buildUpon().path(path).build())!!.use { inStream ->
|
|
||||||
file.outputStream().use { outStream -> inStream.copyTo(outStream) }
|
|
||||||
}
|
|
||||||
Os.chmod(
|
|
||||||
file.absolutePath, when (cursor.getType(1)) {
|
|
||||||
Cursor.FIELD_TYPE_INTEGER -> cursor.getInt(1)
|
|
||||||
Cursor.FIELD_TYPE_STRING -> cursor.getString(1).toInt(8)
|
|
||||||
else -> throw IllegalArgumentException("File mode should be of type int")
|
|
||||||
}
|
|
||||||
)
|
|
||||||
if (path == pluginId) initialized = true
|
|
||||||
} while (cursor.moveToNext())
|
|
||||||
}
|
|
||||||
if (!initialized) entryNotFound()
|
|
||||||
return File(pluginDir, pluginId).absolutePath
|
|
||||||
}
|
|
||||||
|
|
||||||
fun ComponentInfo.loadString(key: String) = when (val value = metaData.getString(key)) {
|
|
||||||
is String -> value
|
|
||||||
// is Int -> AngApplication.application.packageManager.getResourcesForApplication(applicationInfo)
|
|
||||||
// .getString(value)
|
|
||||||
|
|
||||||
null -> null
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -1,51 +0,0 @@
|
|||||||
/******************************************************************************
|
|
||||||
* *
|
|
||||||
* Copyright (C) 2021 by nekohasekai <contact-sagernet@sekai.icu> *
|
|
||||||
* Copyright (C) 2021 by Max Lv <max.c.lv@gmail.com> *
|
|
||||||
* Copyright (C) 2021 by Mygod Studio <contact-shadowsocks-android@mygod.be> *
|
|
||||||
* *
|
|
||||||
* This program is free software: you can redistribute it and/or modify *
|
|
||||||
* it under the terms of the GNU General Public License as published by *
|
|
||||||
* the Free Software Foundation, either version 3 of the License, or *
|
|
||||||
* (at your option) any later version. *
|
|
||||||
* *
|
|
||||||
* This program is distributed in the hope that it will be useful, *
|
|
||||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of *
|
|
||||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
|
|
||||||
* GNU General Public License for more details. *
|
|
||||||
* *
|
|
||||||
* You should have received a copy of the GNU General Public License *
|
|
||||||
* along with this program. If not, see <http://www.gnu.org/licenses/>. *
|
|
||||||
* *
|
|
||||||
******************************************************************************/
|
|
||||||
|
|
||||||
package com.v2ray.ang.plugin
|
|
||||||
|
|
||||||
import android.content.pm.ComponentInfo
|
|
||||||
import android.content.pm.PackageManager
|
|
||||||
import android.content.pm.ResolveInfo
|
|
||||||
import android.graphics.drawable.Drawable
|
|
||||||
import android.os.Build
|
|
||||||
import com.v2ray.ang.AngApplication
|
|
||||||
import com.v2ray.ang.plugin.PluginManager.loadString
|
|
||||||
|
|
||||||
abstract class ResolvedPlugin(protected val resolveInfo: ResolveInfo) : Plugin() {
|
|
||||||
protected abstract val componentInfo: ComponentInfo
|
|
||||||
|
|
||||||
override val id by lazy { componentInfo.loadString(PluginContract.METADATA_KEY_ID)!! }
|
|
||||||
override val version by lazy {
|
|
||||||
getPackageInfo(componentInfo.packageName).versionCode
|
|
||||||
}
|
|
||||||
override val versionName: String by lazy {
|
|
||||||
getPackageInfo(componentInfo.packageName).versionName!!
|
|
||||||
}
|
|
||||||
override val label: CharSequence get() = resolveInfo.loadLabel(AngApplication.application.packageManager)
|
|
||||||
override val icon: Drawable get() = resolveInfo.loadIcon(AngApplication.application.packageManager)
|
|
||||||
override val packageName: String get() = componentInfo.packageName
|
|
||||||
override val directBootAware get() = Build.VERSION.SDK_INT < 24 || componentInfo.directBootAware
|
|
||||||
|
|
||||||
fun getPackageInfo(packageName: String) = AngApplication.application.packageManager.getPackageInfo(
|
|
||||||
packageName, if (Build.VERSION.SDK_INT >= 28) PackageManager.GET_SIGNING_CERTIFICATES
|
|
||||||
else @Suppress("DEPRECATION") PackageManager.GET_SIGNATURES
|
|
||||||
)!!
|
|
||||||
}
|
|
||||||
@@ -7,10 +7,7 @@ import com.v2ray.ang.AppConfig
|
|||||||
import com.v2ray.ang.AppConfig.MSG_MEASURE_CONFIG
|
import com.v2ray.ang.AppConfig.MSG_MEASURE_CONFIG
|
||||||
import com.v2ray.ang.AppConfig.MSG_MEASURE_CONFIG_CANCEL
|
import com.v2ray.ang.AppConfig.MSG_MEASURE_CONFIG_CANCEL
|
||||||
import com.v2ray.ang.AppConfig.MSG_MEASURE_CONFIG_SUCCESS
|
import com.v2ray.ang.AppConfig.MSG_MEASURE_CONFIG_SUCCESS
|
||||||
import com.v2ray.ang.dto.EConfigType
|
|
||||||
import com.v2ray.ang.extension.serializable
|
import com.v2ray.ang.extension.serializable
|
||||||
import com.v2ray.ang.handler.MmkvManager
|
|
||||||
import com.v2ray.ang.handler.PluginServiceManager
|
|
||||||
import com.v2ray.ang.handler.SettingsManager
|
import com.v2ray.ang.handler.SettingsManager
|
||||||
import com.v2ray.ang.handler.V2RayNativeManager
|
import com.v2ray.ang.handler.V2RayNativeManager
|
||||||
import com.v2ray.ang.handler.V2rayConfigManager
|
import com.v2ray.ang.handler.V2rayConfigManager
|
||||||
@@ -18,18 +15,18 @@ import com.v2ray.ang.util.MessageUtil
|
|||||||
import kotlinx.coroutines.CancellationException
|
import kotlinx.coroutines.CancellationException
|
||||||
import kotlinx.coroutines.CoroutineName
|
import kotlinx.coroutines.CoroutineName
|
||||||
import kotlinx.coroutines.CoroutineScope
|
import kotlinx.coroutines.CoroutineScope
|
||||||
import kotlinx.coroutines.Dispatchers
|
|
||||||
import kotlinx.coroutines.SupervisorJob
|
import kotlinx.coroutines.SupervisorJob
|
||||||
|
import kotlinx.coroutines.asCoroutineDispatcher
|
||||||
import kotlinx.coroutines.cancelChildren
|
import kotlinx.coroutines.cancelChildren
|
||||||
import kotlinx.coroutines.joinAll
|
import kotlinx.coroutines.joinAll
|
||||||
import kotlinx.coroutines.launch
|
import kotlinx.coroutines.launch
|
||||||
|
import java.util.concurrent.Executors
|
||||||
import java.util.concurrent.atomic.AtomicInteger
|
import java.util.concurrent.atomic.AtomicInteger
|
||||||
|
|
||||||
class V2RayTestService : Service() {
|
class V2RayTestService : Service() {
|
||||||
private val realTestJob = SupervisorJob()
|
private val realTestJob = SupervisorJob()
|
||||||
private val realDispatcher = Dispatchers.IO.limitedParallelism(
|
private val cpu = Runtime.getRuntime().availableProcessors().coerceAtLeast(1)
|
||||||
Runtime.getRuntime().availableProcessors() * 3
|
private val realDispatcher = Executors.newFixedThreadPool((cpu * 2)).asCoroutineDispatcher()
|
||||||
)
|
|
||||||
private val realTestScope = CoroutineScope(
|
private val realTestScope = CoroutineScope(
|
||||||
realTestJob + realDispatcher + CoroutineName("RealTest")
|
realTestJob + realDispatcher + CoroutineName("RealTest")
|
||||||
)
|
)
|
||||||
@@ -61,6 +58,7 @@ class V2RayTestService : Service() {
|
|||||||
override fun onDestroy() {
|
override fun onDestroy() {
|
||||||
super.onDestroy()
|
super.onDestroy()
|
||||||
realTestJob.cancel()
|
realTestJob.cancel()
|
||||||
|
realDispatcher.close()
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -129,16 +127,10 @@ class V2RayTestService : Service() {
|
|||||||
private fun startRealPing(guid: String): Long {
|
private fun startRealPing(guid: String): Long {
|
||||||
val retFailure = -1L
|
val retFailure = -1L
|
||||||
|
|
||||||
val config = MmkvManager.decodeServerConfig(guid) ?: return retFailure
|
val configResult = V2rayConfigManager.getV2rayConfig4Speedtest(this, guid)
|
||||||
if (config.configType == EConfigType.HYSTERIA2) {
|
if (!configResult.status) {
|
||||||
val delay = PluginServiceManager.realPingHy2(this, config)
|
return retFailure
|
||||||
return delay
|
|
||||||
} else {
|
|
||||||
val configResult = V2rayConfigManager.getV2rayConfig4Speedtest(this, guid)
|
|
||||||
if (!configResult.status) {
|
|
||||||
return retFailure
|
|
||||||
}
|
|
||||||
return V2RayNativeManager.measureOutboundDelay(configResult.content, SettingsManager.getDelayTestUrl())
|
|
||||||
}
|
}
|
||||||
|
return V2RayNativeManager.measureOutboundDelay(configResult.content, SettingsManager.getDelayTestUrl())
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -14,6 +14,7 @@ import androidx.core.content.FileProvider
|
|||||||
import androidx.lifecycle.lifecycleScope
|
import androidx.lifecycle.lifecycleScope
|
||||||
import com.tencent.mmkv.MMKV
|
import com.tencent.mmkv.MMKV
|
||||||
import com.v2ray.ang.AppConfig
|
import com.v2ray.ang.AppConfig
|
||||||
|
import com.v2ray.ang.AppConfig.WEBDAV_BACKUP_FILE_NAME
|
||||||
import com.v2ray.ang.BuildConfig
|
import com.v2ray.ang.BuildConfig
|
||||||
import com.v2ray.ang.R
|
import com.v2ray.ang.R
|
||||||
import com.v2ray.ang.databinding.ActivityBackupBinding
|
import com.v2ray.ang.databinding.ActivityBackupBinding
|
||||||
@@ -40,10 +41,6 @@ class BackupActivity : BaseActivity() {
|
|||||||
resources.getStringArray(R.array.config_backup_options)
|
resources.getStringArray(R.array.config_backup_options)
|
||||||
}
|
}
|
||||||
|
|
||||||
companion object {
|
|
||||||
private const val BACKUP_FILE_NAME = "backup_ng.zip"
|
|
||||||
}
|
|
||||||
|
|
||||||
private val requestPermissionLauncher =
|
private val requestPermissionLauncher =
|
||||||
registerForActivityResult(ActivityResultContracts.RequestPermission()) { isGranted ->
|
registerForActivityResult(ActivityResultContracts.RequestPermission()) { isGranted ->
|
||||||
if (isGranted) {
|
if (isGranted) {
|
||||||
@@ -263,7 +260,7 @@ class BackupActivity : BaseActivity() {
|
|||||||
WebDavManager.init(saved)
|
WebDavManager.init(saved)
|
||||||
|
|
||||||
val ok = try {
|
val ok = try {
|
||||||
WebDavManager.uploadFile(tempFile, BACKUP_FILE_NAME)
|
WebDavManager.uploadFile(tempFile, WEBDAV_BACKUP_FILE_NAME)
|
||||||
} catch (e: Exception) {
|
} catch (e: Exception) {
|
||||||
Log.e(AppConfig.TAG, "WebDAV upload error", e)
|
Log.e(AppConfig.TAG, "WebDAV upload error", e)
|
||||||
false
|
false
|
||||||
@@ -303,7 +300,7 @@ class BackupActivity : BaseActivity() {
|
|||||||
try {
|
try {
|
||||||
target = File(cacheDir, "download_${System.currentTimeMillis()}.zip")
|
target = File(cacheDir, "download_${System.currentTimeMillis()}.zip")
|
||||||
WebDavManager.init(saved)
|
WebDavManager.init(saved)
|
||||||
val ok = WebDavManager.downloadFile(BACKUP_FILE_NAME, target)
|
val ok = WebDavManager.downloadFile(WEBDAV_BACKUP_FILE_NAME, target)
|
||||||
if (!ok) {
|
if (!ok) {
|
||||||
withContext(Dispatchers.Main) {
|
withContext(Dispatchers.Main) {
|
||||||
toastError(R.string.toast_failure)
|
toastError(R.string.toast_failure)
|
||||||
@@ -351,7 +348,7 @@ class BackupActivity : BaseActivity() {
|
|||||||
val url = dialogBinding.etWebdavUrl.text.toString().trim()
|
val url = dialogBinding.etWebdavUrl.text.toString().trim()
|
||||||
val user = dialogBinding.etWebdavUser.text.toString().trim().ifEmpty { null }
|
val user = dialogBinding.etWebdavUser.text.toString().trim().ifEmpty { null }
|
||||||
val pass = dialogBinding.etWebdavPass.text.toString()
|
val pass = dialogBinding.etWebdavPass.text.toString()
|
||||||
val remotePath = dialogBinding.etWebdavRemotePath.text.toString().trim().ifEmpty { "/" }
|
val remotePath = dialogBinding.etWebdavRemotePath.text.toString().trim().ifEmpty { AppConfig.WEBDAV_BACKUP_DIR }
|
||||||
val cfg = WebDavConfig(baseUrl = url, username = user, password = pass, remoteBasePath = remotePath)
|
val cfg = WebDavConfig(baseUrl = url, username = user, password = pass, remoteBasePath = remotePath)
|
||||||
MmkvManager.encodeWebDavConfig(cfg)
|
MmkvManager.encodeWebDavConfig(cfg)
|
||||||
toastSuccess(R.string.toast_success)
|
toastSuccess(R.string.toast_success)
|
||||||
|
|||||||
@@ -280,22 +280,22 @@ class MainRecyclerAdapter(val activity: MainActivity) : RecyclerView.Adapter<Mai
|
|||||||
* @param position The position in the list
|
* @param position The position in the list
|
||||||
*/
|
*/
|
||||||
private fun removeServer(guid: String, position: Int) {
|
private fun removeServer(guid: String, position: Int) {
|
||||||
if (guid != MmkvManager.getSelectServer()) {
|
if (guid == MmkvManager.getSelectServer()) {
|
||||||
if (MmkvManager.decodeSettingsBool(AppConfig.PREF_CONFIRM_REMOVE)) {
|
|
||||||
AlertDialog.Builder(mActivity).setMessage(R.string.del_config_comfirm)
|
|
||||||
.setPositiveButton(android.R.string.ok) { _, _ ->
|
|
||||||
removeServerSub(guid, position)
|
|
||||||
}
|
|
||||||
.setNegativeButton(android.R.string.cancel) { _, _ ->
|
|
||||||
//do noting
|
|
||||||
}
|
|
||||||
.show()
|
|
||||||
} else {
|
|
||||||
removeServerSub(guid, position)
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
application.toast(R.string.toast_action_not_allowed)
|
application.toast(R.string.toast_action_not_allowed)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (MmkvManager.decodeSettingsBool(AppConfig.PREF_CONFIRM_REMOVE)) {
|
||||||
|
AlertDialog.Builder(mActivity).setMessage(R.string.del_config_comfirm)
|
||||||
|
.setPositiveButton(android.R.string.ok) { _, _ ->
|
||||||
|
removeServerSub(guid, position)
|
||||||
|
}
|
||||||
|
.setNegativeButton(android.R.string.cancel) { _, _ ->
|
||||||
|
//do noting
|
||||||
|
}
|
||||||
|
.show()
|
||||||
|
} else {
|
||||||
|
removeServerSub(guid, position)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -305,8 +305,12 @@ class MainRecyclerAdapter(val activity: MainActivity) : RecyclerView.Adapter<Mai
|
|||||||
*/
|
*/
|
||||||
private fun removeServerSub(guid: String, position: Int) {
|
private fun removeServerSub(guid: String, position: Int) {
|
||||||
mActivity.mainViewModel.removeServer(guid)
|
mActivity.mainViewModel.removeServer(guid)
|
||||||
notifyItemRemoved(position)
|
val idx = data.indexOfFirst { it.guid == guid }
|
||||||
notifyItemRangeChanged(position, data.size)
|
if (idx >= 0) {
|
||||||
|
data.removeAt(idx)
|
||||||
|
notifyItemRemoved(idx)
|
||||||
|
notifyItemRangeChanged(idx, data.size - idx)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|||||||
@@ -13,6 +13,7 @@ import androidx.activity.result.contract.ActivityResultContracts
|
|||||||
import androidx.core.content.ContextCompat
|
import androidx.core.content.ContextCompat
|
||||||
import com.v2ray.ang.AppConfig
|
import com.v2ray.ang.AppConfig
|
||||||
import com.v2ray.ang.R
|
import com.v2ray.ang.R
|
||||||
|
import com.v2ray.ang.databinding.ActivityNoneBinding
|
||||||
import com.v2ray.ang.extension.toast
|
import com.v2ray.ang.extension.toast
|
||||||
import com.v2ray.ang.handler.MmkvManager
|
import com.v2ray.ang.handler.MmkvManager
|
||||||
import com.v2ray.ang.util.QRCodeDecoder
|
import com.v2ray.ang.util.QRCodeDecoder
|
||||||
@@ -21,7 +22,7 @@ import io.github.g00fy2.quickie.ScanCustomCode
|
|||||||
import io.github.g00fy2.quickie.config.ScannerConfig
|
import io.github.g00fy2.quickie.config.ScannerConfig
|
||||||
|
|
||||||
class ScannerActivity : BaseActivity() {
|
class ScannerActivity : BaseActivity() {
|
||||||
|
private val binding by lazy { ActivityNoneBinding.inflate(layoutInflater) }
|
||||||
|
|
||||||
private val scanQrCode = registerForActivityResult(ScanCustomCode(), ::handleResult)
|
private val scanQrCode = registerForActivityResult(ScanCustomCode(), ::handleResult)
|
||||||
private val chooseFile = registerForActivityResult(ActivityResultContracts.StartActivityForResult()) {
|
private val chooseFile = registerForActivityResult(ActivityResultContracts.StartActivityForResult()) {
|
||||||
@@ -59,6 +60,8 @@ class ScannerActivity : BaseActivity() {
|
|||||||
public override fun onCreate(savedInstanceState: Bundle?) {
|
public override fun onCreate(savedInstanceState: Bundle?) {
|
||||||
super.onCreate(savedInstanceState)
|
super.onCreate(savedInstanceState)
|
||||||
|
|
||||||
|
setContentViewWithToolbar(binding.root, showHomeAsUp = true, title = getString(R.string.menu_item_import_config_qrcode))
|
||||||
|
|
||||||
if (MmkvManager.decodeSettingsBool(AppConfig.PREF_START_SCAN_IMMEDIATE)) {
|
if (MmkvManager.decodeSettingsBool(AppConfig.PREF_START_SCAN_IMMEDIATE)) {
|
||||||
launchScan()
|
launchScan()
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -154,6 +154,7 @@ class ServerActivity : BaseActivity() {
|
|||||||
EConfigType.WIREGUARD -> R.layout.activity_server_wireguard
|
EConfigType.WIREGUARD -> R.layout.activity_server_wireguard
|
||||||
EConfigType.HYSTERIA2 -> R.layout.activity_server_hysteria2
|
EConfigType.HYSTERIA2 -> R.layout.activity_server_hysteria2
|
||||||
EConfigType.POLICYGROUP -> null
|
EConfigType.POLICYGROUP -> null
|
||||||
|
else -> null
|
||||||
} ?: return
|
} ?: return
|
||||||
setContentViewWithToolbar(layoutId, showHomeAsUp = true, title = (config?.configType ?: createConfigType).toString())
|
setContentViewWithToolbar(layoutId, showHomeAsUp = true, title = (config?.configType ?: createConfigType).toString())
|
||||||
|
|
||||||
|
|||||||
@@ -375,24 +375,6 @@ object Utils {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* Get the path to the backup directory.
|
|
||||||
*
|
|
||||||
* @param context The context to use.
|
|
||||||
* @return The path to the backup directory.
|
|
||||||
*/
|
|
||||||
fun backupPath(context: Context?): String {
|
|
||||||
if (context == null) return ""
|
|
||||||
|
|
||||||
return try {
|
|
||||||
context.getExternalFilesDir(AppConfig.DIR_BACKUPS)?.absolutePath
|
|
||||||
?: context.getDir(AppConfig.DIR_BACKUPS, 0).absolutePath
|
|
||||||
} catch (e: Exception) {
|
|
||||||
Log.e(AppConfig.TAG, "Failed to get backup path", e)
|
|
||||||
""
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Get the device ID for XUDP base key.
|
* Get the device ID for XUDP base key.
|
||||||
*
|
*
|
||||||
|
|||||||
@@ -388,6 +388,7 @@
|
|||||||
<item>চায়না ব্ল্যাকলিস্ট</item>
|
<item>চায়না ব্ল্যাকলিস্ট</item>
|
||||||
<item>গ্লোবাল</item>
|
<item>গ্লোবাল</item>
|
||||||
<item>ইরান হোয়াইটলিস্ট</item>
|
<item>ইরান হোয়াইটলিস্ট</item>
|
||||||
|
<item>রাশিয়া হোয়াইটলিস্ট</item>
|
||||||
</string-array>
|
</string-array>
|
||||||
|
|
||||||
<string-array name="vpn_bypass_lan">
|
<string-array name="vpn_bypass_lan">
|
||||||
|
|||||||
@@ -398,6 +398,7 @@
|
|||||||
<item>نومگه شه چین</item>
|
<item>نومگه شه چین</item>
|
||||||
<item>جهۊوی (Global)</item>
|
<item>جهۊوی (Global)</item>
|
||||||
<item>نومگه اسبؽڌ ایران</item>
|
<item>نومگه اسبؽڌ ایران</item>
|
||||||
|
<item>Russia Whitelist</item>
|
||||||
</string-array>
|
</string-array>
|
||||||
|
|
||||||
<string-array name="vpn_bypass_lan">
|
<string-array name="vpn_bypass_lan">
|
||||||
|
|||||||
@@ -397,6 +397,7 @@
|
|||||||
<item>لیست سیاه چین</item>
|
<item>لیست سیاه چین</item>
|
||||||
<item>جهانی(GLOBAL)</item>
|
<item>جهانی(GLOBAL)</item>
|
||||||
<item>ایران</item>
|
<item>ایران</item>
|
||||||
|
<item>لیست سفید روسیه</item>
|
||||||
</string-array>
|
</string-array>
|
||||||
|
|
||||||
<string-array name="vpn_bypass_lan">
|
<string-array name="vpn_bypass_lan">
|
||||||
|
|||||||
@@ -397,6 +397,7 @@
|
|||||||
<item>Чёрный список Китая</item>
|
<item>Чёрный список Китая</item>
|
||||||
<item>Общие</item>
|
<item>Общие</item>
|
||||||
<item>Белый список Ирана</item>
|
<item>Белый список Ирана</item>
|
||||||
|
<item>Белый список России</item>
|
||||||
</string-array>
|
</string-array>
|
||||||
|
|
||||||
<string-array name="vpn_bypass_lan">
|
<string-array name="vpn_bypass_lan">
|
||||||
|
|||||||
@@ -389,6 +389,7 @@
|
|||||||
<item>黑名单 (Blacklist)</item>
|
<item>黑名单 (Blacklist)</item>
|
||||||
<item>全局 (Global)</item>
|
<item>全局 (Global)</item>
|
||||||
<item>伊朗 (Iran)</item>
|
<item>伊朗 (Iran)</item>
|
||||||
|
<item>俄罗斯白名单 (Russia Whitelist)</item>
|
||||||
</string-array>
|
</string-array>
|
||||||
|
|
||||||
<string-array name="vpn_bypass_lan">
|
<string-array name="vpn_bypass_lan">
|
||||||
|
|||||||
@@ -389,6 +389,7 @@
|
|||||||
<item>黑名單 (Blacklist)</item>
|
<item>黑名單 (Blacklist)</item>
|
||||||
<item>全域 (Global)</item>
|
<item>全域 (Global)</item>
|
||||||
<item>伊朗 (Iran)</item>
|
<item>伊朗 (Iran)</item>
|
||||||
|
<item>俄羅斯白名單 (Russia Whitelist)</item>
|
||||||
</string-array>
|
</string-array>
|
||||||
|
|
||||||
<string-array name="vpn_bypass_lan">
|
<string-array name="vpn_bypass_lan">
|
||||||
|
|||||||
@@ -401,6 +401,7 @@
|
|||||||
<item>China Blacklist</item>
|
<item>China Blacklist</item>
|
||||||
<item>Global</item>
|
<item>Global</item>
|
||||||
<item>Iran Whitelist</item>
|
<item>Iran Whitelist</item>
|
||||||
|
<item>Russia Whitelist</item>
|
||||||
</string-array>
|
</string-array>
|
||||||
|
|
||||||
<string-array name="vpn_bypass_lan">
|
<string-array name="vpn_bypass_lan">
|
||||||
|
|||||||
-1
Submodule hysteria deleted from 44a5643535
@@ -1,20 +0,0 @@
|
|||||||
#!/bin/bash
|
|
||||||
|
|
||||||
targets=(
|
|
||||||
"aarch64-linux-android24 arm64 arm64-v8a"
|
|
||||||
"armv7a-linux-androideabi24 arm armeabi-v7a"
|
|
||||||
"x86_64-linux-android24 amd64 x86_64"
|
|
||||||
"i686-linux-android24 386 x86"
|
|
||||||
)
|
|
||||||
|
|
||||||
cd "hysteria" || exit
|
|
||||||
|
|
||||||
for target in "${targets[@]}"; do
|
|
||||||
IFS=' ' read -r ndk_target goarch abi <<< "$target"
|
|
||||||
|
|
||||||
echo "Building for ${abi} with ${ndk_target} (${goarch})"
|
|
||||||
|
|
||||||
CC="${NDK_HOME}/toolchains/llvm/prebuilt/linux-x86_64/bin/${ndk_target}-clang" CGO_ENABLED=1 GOOS=android GOARCH=$goarch go build -o libs/$abi/libhysteria2.so -trimpath -ldflags "-s -w -buildid=" -buildvcs=false ./app
|
|
||||||
|
|
||||||
echo "Built libhysteria2.so for ${abi}"
|
|
||||||
done
|
|
||||||
Reference in New Issue
Block a user