-
Notifications
You must be signed in to change notification settings - Fork 88
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
210d01c
commit f8a72e8
Showing
20 changed files
with
263 additions
and
78 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
213 changes: 213 additions & 0 deletions
213
core/src/main/java/com/github/shadowsocks/bg/V2RayProxyService.kt
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,213 @@ | ||
| package com.github.shadowsocks.bg | ||
| import SpeedUpVPN.VpnEncrypt | ||
| import android.app.Service | ||
| import android.content.Intent | ||
| import android.content.IntentFilter | ||
| import android.os.Build | ||
| import android.os.ParcelFileDescriptor | ||
| import android.os.StrictMode | ||
| import android.util.Log | ||
| import com.github.shadowsocks.BootReceiver | ||
| import com.github.shadowsocks.Core.defaultDPreference | ||
| import com.github.shadowsocks.core.R | ||
| import com.github.shadowsocks.database.AppConfig | ||
| import com.github.shadowsocks.database.Profile | ||
| import com.github.shadowsocks.database.ProfileManager | ||
| import com.github.shadowsocks.preference.DataStore | ||
| import com.github.shadowsocks.utils.Action | ||
| import com.github.shadowsocks.utils.packagePath | ||
| import com.github.shadowsocks.utils.printLog | ||
| import com.github.shadowsocks.utils.readableMessage | ||
| import go.Seq | ||
| import kotlinx.coroutines.* | ||
| import libv2ray.Libv2ray | ||
| import libv2ray.V2RayVPNServiceSupportsSet | ||
| import java.net.UnknownHostException | ||
|
|
||
| class V2RayProxyService : Service() , BaseService.Interface { | ||
| //for BaseService.Interface start | ||
| override val data = BaseService.Data(this) | ||
| override val tag: String get() = "SSV2Service" | ||
| override fun createNotification(profileName: String): ServiceNotification = | ||
| ServiceNotification(this, profileName, "service-v2proxy", true) | ||
| override fun onBind(intent: Intent) = super.onBind(intent) | ||
| //for BaseService.Interface stop | ||
|
|
||
| private val v2rayPoint = Libv2ray.newV2RayPoint(V2RayCallback()) | ||
| private lateinit var configContent: String | ||
| private lateinit var mInterface: ParcelFileDescriptor | ||
| private var listeningForDefaultNetwork = false | ||
| lateinit var activeProfile: Profile | ||
| override fun onCreate() { | ||
| super.onCreate() | ||
| val policy = StrictMode.ThreadPolicy.Builder().permitAll().build() | ||
| StrictMode.setThreadPolicy(policy) | ||
| v2rayPoint.packageName = packagePath(applicationContext) | ||
| Seq.setContext(applicationContext) | ||
| } | ||
|
|
||
| override fun onStartCommand(intent: Intent?, flags: Int, startId: Int): Int { | ||
| data.connectingJob = GlobalScope.launch(Dispatchers.Main) { | ||
| try { | ||
| activeProfile = ProfileManager.getProfile(DataStore.profileId)!! | ||
| val proxy = V2ProxyInstance(v2rayPoint,activeProfile,activeProfile.route) | ||
| data.proxy = proxy | ||
| ProfileManager.genStoreV2rayConfig(activeProfile) | ||
| startV2ray() | ||
| } catch (_: CancellationException) { | ||
| // if the job was cancelled, it is canceller's responsibility to call stopRunner | ||
| } catch (_: UnknownHostException) { | ||
| stopRunner(false, getString(R.string.invalid_server)) | ||
| } catch (exc: Throwable) { | ||
| if (exc is BaseService.ExpectedException) exc.printStackTrace() else printLog(exc) | ||
| stopRunner(false, "${getString(R.string.service_failed)}: ${exc.readableMessage}") | ||
| } finally { | ||
| data.connectingJob = null | ||
| } | ||
| } | ||
| return START_NOT_STICKY | ||
| stopRunner() | ||
| return Service.START_NOT_STICKY | ||
| } | ||
|
|
||
| override fun onLowMemory() { | ||
| stopV2Ray() | ||
| super.onLowMemory() | ||
| } | ||
|
|
||
| override fun onDestroy() { | ||
| super.onDestroy() | ||
| data.binder.close() | ||
| //android.os.Process.killProcess(android.os.Process.myPid()) | ||
| } | ||
|
|
||
| fun shutdown() { | ||
| stopV2Ray(true) | ||
| } | ||
|
|
||
| private fun startV2ray() { | ||
| if (!v2rayPoint.isRunning) { | ||
| val broadname="$packageName.SERVICE" | ||
| if (!data.closeReceiverRegistered) { | ||
| registerReceiver(data.closeReceiver, IntentFilter().apply { | ||
| addAction(Action.RELOAD) | ||
| addAction(Intent.ACTION_SHUTDOWN) | ||
| addAction(Action.CLOSE) | ||
| }, broadname, null) | ||
| data.closeReceiverRegistered = true | ||
| } | ||
| data.notification = createNotification(activeProfile.formattedName) | ||
| data.changeState(BaseService.State.Connecting) | ||
|
|
||
| configContent = defaultDPreference.getPrefString(AppConfig.PREF_CURR_CONFIG, "") | ||
| v2rayPoint.configureFileContent = configContent | ||
| v2rayPoint.enableLocalDNS = VpnEncrypt.enableLocalDns | ||
| v2rayPoint.forwardIpv6 = activeProfile.ipv6 | ||
| v2rayPoint.domainName = defaultDPreference.getPrefString(AppConfig.PREF_CURR_CONFIG_DOMAIN, "") | ||
|
|
||
| try { | ||
| v2rayPoint.runLoop() | ||
| } catch (e: Exception) { | ||
| Log.d(packageName, e.toString()) | ||
| } | ||
|
|
||
| if (v2rayPoint.isRunning) { | ||
| data.changeState(BaseService.State.Connected) | ||
| } else { | ||
| //MessageUtil.sendMsg2UI(this, AppConfig.MSG_STATE_START_FAILURE, "") | ||
| //cancelNotification() | ||
| } | ||
| } | ||
| else{ | ||
| Log.e("startV2ray","v2rayPoint isRunning already.") | ||
| } | ||
| } | ||
| override fun stopRunner(restart: Boolean , msg: String? ) { | ||
| Log.e("v2stopRunner",msg.toString()) | ||
| if (data.state == BaseService.State.Stopping) return | ||
| // channge the state | ||
| data.changeState(BaseService.State.Stopping) | ||
| GlobalScope.launch(Dispatchers.Main.immediate) { | ||
| data.connectingJob?.cancelAndJoin() // ensure stop connecting first | ||
| // clean up receivers | ||
| val data = data | ||
| if (data.closeReceiverRegistered) { | ||
| unregisterReceiver(data.closeReceiver) | ||
| data.closeReceiverRegistered = false | ||
| } | ||
| data.notification?.destroy() | ||
| data.notification = null | ||
| stopV2Ray() | ||
| val ids = listOfNotNull(data.proxy, data.udpFallback).map { | ||
| it.shutdown(this) | ||
| it.profile.id | ||
| } | ||
| data.binder.trafficPersisted(ids) | ||
| data.proxy = null | ||
| data.udpFallback = null | ||
| // change the state | ||
| data.changeState(BaseService.State.Stopped, msg) | ||
|
|
||
| // stop the service if nothing has bound to it | ||
| if (restart) startRunner() else { | ||
| BootReceiver.enabled = false | ||
| stopSelf() | ||
| } | ||
| } | ||
| } | ||
| private fun stopV2Ray(isForced: Boolean = true) { | ||
| if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.P) { | ||
| if (listeningForDefaultNetwork) { | ||
| listeningForDefaultNetwork = false | ||
| } | ||
| } | ||
| if (v2rayPoint.isRunning) { | ||
| try { | ||
| v2rayPoint.stopLoop() | ||
| } catch (e: Exception) { | ||
| Log.d(packageName, e.toString()) | ||
| } | ||
| } | ||
|
|
||
| if (isForced) { | ||
| //stopSelf has to be called ahead of mInterface.close(). otherwise v2ray core cannot be stooped | ||
| //It's strage but true. | ||
| //This can be verified by putting stopself() behind and call stopLoop and startLoop | ||
| //in a row for several times. You will find that later created v2ray core report port in use | ||
| //which means the first v2ray core somehow failed to stop and release the port. | ||
| stopSelf() | ||
| } | ||
| } | ||
|
|
||
| private inner class V2RayCallback : V2RayVPNServiceSupportsSet { | ||
| override fun shutdown(): Long { | ||
| // called by go | ||
| // shutdown the whole vpn service | ||
| try { | ||
| this@V2RayProxyService.shutdown() | ||
| return 0 | ||
| } catch (e: Exception) { | ||
| Log.d(packageName, e.toString()) | ||
| return -1 | ||
| } | ||
| } | ||
|
|
||
| override fun prepare(): Long { | ||
| return 0 | ||
| } | ||
|
|
||
| override fun protect(l: Long) = 1.toLong() | ||
|
|
||
| override fun onEmitStatus(l: Long, s: String?): Long { | ||
| return 0 | ||
| } | ||
|
|
||
| override fun setup(s: String): Long { | ||
| return 0 | ||
| } | ||
| override fun sendFd(): Long { | ||
| return 0 | ||
| } | ||
| } | ||
| } | ||
|
|
Oops, something went wrong.