204 lines
10 KiB
Kotlin
204 lines
10 KiB
Kotlin
|
package im.cwtch.flwtch
|
||
|
|
|
||
|
|
import SplashView
|
||
|
|
import android.content.BroadcastReceiver
|
||
|
|
import android.content.Context
|
||
|
|
import android.content.Intent
|
||
|
|
import android.content.IntentFilter
|
||
|
|
import androidx.annotation.NonNull
|
||
|
|
import android.content.pm.PackageManager
|
||
|
|
import android.util.Log
|
||
|
|
import android.view.Window
|
||
|
|
import androidx.lifecycle.Observer
|
||
|
|
import androidx.localbroadcastmanager.content.LocalBroadcastManager
|
||
|
|
import androidx.work.*
|
||
|
|
|
||
|
|
import io.flutter.embedding.android.SplashScreen
|
||
|
|
import io.flutter.embedding.android.FlutterActivity
|
||
|
|
import io.flutter.embedding.engine.FlutterEngine
|
||
|
|
import io.flutter.plugin.common.MethodChannel
|
||
|
|
import io.flutter.plugin.common.MethodCall
|
||
|
|
import io.flutter.plugin.common.MethodChannel.Result
|
||
|
|
|
||
|
|
import org.json.JSONObject
|
||
|
|
import java.util.concurrent.TimeUnit
|
||
|
|
|
||
|
|
class MainActivity: FlutterActivity() {
|
||
|
|
override fun provideSplashScreen(): SplashScreen? = SplashView()
|
||
|
|
|
||
|
|
// Channel to get app info
|
||
|
|
private val CHANNEL_APP_INFO = "test.flutter.dev/applicationInfo"
|
||
|
|
private val CALL_APP_INFO = "getNativeLibDir"
|
||
|
|
|
||
|
|
// Channel to get cwtch api calls on
|
||
|
|
private val CHANNEL_CWTCH = "cwtch"
|
||
|
|
|
||
|
|
// Channel to send eventbus events on
|
||
|
|
private val CWTCH_EVENTBUS = "test.flutter.dev/eventBus"
|
||
|
|
|
||
|
|
// Channel to trigger contactview when an external notification is clicked
|
||
|
|
private val CHANNEL_NOTIF_CLICK = "im.cwtch.flwtch/notificationClickHandler"
|
||
|
|
|
||
|
|
// WorkManager tag applied to all Start() infinite coroutines
|
||
|
|
val WORKER_TAG = "cwtchEventBusWorker"
|
||
|
|
|
||
|
|
private var myReceiver: MyBroadcastReceiver? = null
|
||
|
|
private var methodChan: MethodChannel? = null
|
||
|
|
|
||
|
|
override fun onNewIntent(intent: Intent) {
|
||
|
|
super.onNewIntent(intent)
|
||
|
|
if (methodChan == null || intent.extras == null) return
|
||
|
|
if (!intent.extras!!.containsKey("ProfileOnion") || !intent.extras!!.containsKey("RemotePeer")) {
|
||
|
|
Log.i("onNewIntent", "got intent with no onions")
|
||
|
|
return
|
||
|
|
}
|
||
|
|
val profile = intent.extras!!.getString("ProfileOnion")
|
||
|
|
val handle = intent.extras!!.getString("RemotePeer")
|
||
|
|
val mappo = mapOf("ProfileOnion" to profile, "RemotePeer" to handle)
|
||
|
|
val j = JSONObject(mappo)
|
||
|
|
methodChan!!.invokeMethod("NotificationClicked", j.toString())
|
||
|
|
}
|
||
|
|
|
||
|
|
override fun configureFlutterEngine(@NonNull flutterEngine: FlutterEngine) {
|
||
|
|
super.configureFlutterEngine(flutterEngine)
|
||
|
|
// Note: this methods are invoked on the main thread.
|
||
|
|
//note to self: ask someone if this does anything ^ea
|
||
|
|
requestWindowFeature(Window.FEATURE_NO_TITLE)
|
||
|
|
MethodChannel(flutterEngine.dartExecutor.binaryMessenger, CHANNEL_APP_INFO).setMethodCallHandler { call, result -> handleAppInfo(call, result) }
|
||
|
|
MethodChannel(flutterEngine.dartExecutor.binaryMessenger, CHANNEL_CWTCH).setMethodCallHandler { call, result -> handleCwtch(call, result) }
|
||
|
|
methodChan = MethodChannel(flutterEngine.dartExecutor.binaryMessenger, CHANNEL_NOTIF_CLICK)
|
||
|
|
}
|
||
|
|
|
||
|
|
private fun handleAppInfo(@NonNull call: MethodCall, @NonNull result: Result) {
|
||
|
|
when (call.method) {
|
||
|
|
CALL_APP_INFO -> result.success(getNativeLibDir())
|
||
|
|
?: result.error("Unavailable", "nativeLibDir not available", null);
|
||
|
|
else -> result.notImplemented()
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
private fun getNativeLibDir(): String {
|
||
|
|
val ainfo = this.applicationContext.packageManager.getApplicationInfo(
|
||
|
|
"im.cwtch.flwtch", // Must be app name
|
||
|
|
PackageManager.GET_SHARED_LIBRARY_FILES)
|
||
|
|
return ainfo.nativeLibraryDir
|
||
|
|
}
|
||
|
|
|
||
|
|
// receives messages from the ForegroundService (which provides, ironically enough, the backend)
|
||
|
|
private fun handleCwtch(@NonNull call: MethodCall, @NonNull result: Result) {
|
||
|
|
var method = call.method
|
||
|
|
val argmap: Map<String, String> = call.arguments as Map<String, String>
|
||
|
|
|
||
|
|
// the frontend calls Start every time it fires up, but we don't want to *actually* call Cwtch.Start()
|
||
|
|
// in case the ForegroundService is still running. in both cases, however, we *do* want to re-register
|
||
|
|
// the eventbus listener.
|
||
|
|
if (call.method == "Start") {
|
||
|
|
val uniqueTag = argmap["torPath"] ?: "nullEventBus"
|
||
|
|
|
||
|
|
// note: because the ForegroundService is specified as UniquePeriodicWork, it can't actually get
|
||
|
|
// accidentally duplicated. however, we still need to manually check if it's running or not, so
|
||
|
|
// that we can divert this method call to ReconnectCwtchForeground instead if so.
|
||
|
|
val works = WorkManager.getInstance(this).getWorkInfosByTag(WORKER_TAG).get()
|
||
|
|
for (workInfo in works) {
|
||
|
|
Log.i("handleCwtch:WorkManager", "$workInfo")
|
||
|
|
if (!workInfo.tags.contains(uniqueTag)) {
|
||
|
|
Log.i("handleCwtch:WorkManager", "canceling ${workInfo.id} bc tags don't include $uniqueTag")
|
||
|
|
WorkManager.getInstance(this).cancelWorkById(workInfo.id)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
WorkManager.getInstance(this).pruneWork()
|
||
|
|
|
||
|
|
Log.i("MainActivity.kt", "Start() launching foregroundservice")
|
||
|
|
// this is where the eventbus ForegroundService gets launched. WorkManager should keep it alive after this
|
||
|
|
val data: Data = Data.Builder().putString(FlwtchWorker.KEY_METHOD, call.method).putString(FlwtchWorker.KEY_ARGS, JSONObject(argmap).toString()).build()
|
||
|
|
// 15 minutes is the shortest interval you can request
|
||
|
|
val workRequest = PeriodicWorkRequestBuilder<FlwtchWorker>(15, TimeUnit.MINUTES).setInputData(data).addTag(WORKER_TAG).addTag(uniqueTag).build()
|
||
|
|
WorkManager.getInstance(this).enqueueUniquePeriodicWork("req_$uniqueTag", ExistingPeriodicWorkPolicy.REPLACE, workRequest)
|
||
|
|
return
|
||
|
|
}
|
||
|
|
|
||
|
|
// ...otherwise fallthru to a normal ffi method call (and return the result using the result callback)
|
||
|
|
val data: Data = Data.Builder().putString(FlwtchWorker.KEY_METHOD, method).putString(FlwtchWorker.KEY_ARGS, JSONObject(argmap).toString()).build()
|
||
|
|
val workRequest = OneTimeWorkRequestBuilder<FlwtchWorker>().setInputData(data).build()
|
||
|
|
WorkManager.getInstance(this).enqueue(workRequest)
|
||
|
|
WorkManager.getInstance(applicationContext).getWorkInfoByIdLiveData(workRequest.id).observe(
|
||
|
|
this, Observer { workInfo ->
|
||
|
|
if (workInfo.state == WorkInfo.State.SUCCEEDED) {
|
||
|
|
val res = workInfo.outputData.keyValueMap.toString()
|
||
|
|
result.success(workInfo.outputData.getString("result"))
|
||
|
|
}
|
||
|
|
}
|
||
|
|
)
|
||
|
|
}
|
||
|
|
|
||
|
|
// using onresume/onstop for broadcastreceiver because of extended discussion on https://stackoverflow.com/questions/7439041/how-to-unregister-broadcastreceiver
|
||
|
|
override fun onResume() {
|
||
|
|
super.onResume()
|
||
|
|
Log.i("MainActivity.kt", "onResume")
|
||
|
|
if (myReceiver == null) {
|
||
|
|
Log.i("MainActivity.kt", "onResume registering local broadcast receiver / event bus forwarder")
|
||
|
|
val mc = MethodChannel(flutterEngine?.dartExecutor?.binaryMessenger, CWTCH_EVENTBUS)
|
||
|
|
val filter = IntentFilter("im.cwtch.flwtch.broadcast.SERVICE_EVENT_BUS")
|
||
|
|
myReceiver = MyBroadcastReceiver(mc)
|
||
|
|
LocalBroadcastManager.getInstance(applicationContext).registerReceiver(myReceiver!!, filter)
|
||
|
|
}
|
||
|
|
|
||
|
|
// ReconnectCwtchForeground which will resync counters and settings...
|
||
|
|
// We need to do this here because after a "pause" flutter is still running
|
||
|
|
// but we might have lost sync with the background process...
|
||
|
|
Log.i("MainActivity.kt", "Call ReconnectCwtchForeground")
|
||
|
|
val data: Data = Data.Builder().putString(FlwtchWorker.KEY_METHOD, "ReconnectCwtchForeground").putString(FlwtchWorker.KEY_ARGS, "{}").build()
|
||
|
|
val workRequest = OneTimeWorkRequestBuilder<FlwtchWorker>().setInputData(data).build()
|
||
|
|
WorkManager.getInstance(applicationContext).enqueue(workRequest)
|
||
|
|
}
|
||
|
|
|
||
|
|
override fun onStop() {
|
||
|
|
super.onStop()
|
||
|
|
Log.i("MainActivity.kt", "onStop")
|
||
|
|
if (myReceiver != null) {
|
||
|
|
LocalBroadcastManager.getInstance(applicationContext).unregisterReceiver(myReceiver!!);
|
||
|
|
myReceiver = null;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
override fun onDestroy() {
|
||
|
|
super.onDestroy()
|
||
|
|
Log.i("MainActivity.kt", "onDestroy - cancelling all WORKER_TAG and pruning old work")
|
||
|
|
WorkManager.getInstance(this).cancelAllWorkByTag(WORKER_TAG)
|
||
|
|
WorkManager.getInstance(this).pruneWork()
|
||
|
|
}
|
||
|
|
|
||
|
|
// source: https://web.archive.org/web/20210203022531/https://stackoverflow.com/questions/41928803/how-to-parse-json-in-kotlin/50468095
|
||
|
|
// for reference:
|
||
|
|
//
|
||
|
|
// class Response(json: String) : JSONObject(json) {
|
||
|
|
// val type: String? = this.optString("type")
|
||
|
|
// val data = this.optJSONArray("data")
|
||
|
|
// ?.let { 0.until(it.length()).map { i -> it.optJSONObject(i) } } // returns an array of JSONObject
|
||
|
|
// ?.map { Foo(it.toString()) } // transforms each JSONObject of the array into Foo
|
||
|
|
// }
|
||
|
|
//
|
||
|
|
// class Foo(json: String) : JSONObject(json) {
|
||
|
|
// val id = this.optInt("id")
|
||
|
|
// val title: String? = this.optString("title")
|
||
|
|
// }
|
||
|
|
class AppbusEvent(json: String) : JSONObject(json) {
|
||
|
|
val EventType = this.optString("EventType")
|
||
|
|
val EventID = this.optString("EventID")
|
||
|
|
val Data = this.optString("Data")
|
||
|
|
}
|
||
|
|
|
||
|
|
// MainActivity.MyBroadcastReceiver receives events from the Cwtch service via im.cwtch.flwtch.broadcast.SERVICE_EVENT_BUS Android local broadcast intents
|
||
|
|
// then it forwards them to the flutter ui engine using the CWTCH_EVENTBUS methodchannel
|
||
|
|
class MyBroadcastReceiver(mc: MethodChannel) : BroadcastReceiver() {
|
||
|
|
val eventBus: MethodChannel = mc
|
||
|
|
|
||
|
|
override fun onReceive(context: Context, intent: Intent) {
|
||
|
|
val evtType = intent.getStringExtra("EventType") ?: ""
|
||
|
|
val evtData = intent.getStringExtra("Data") ?: ""
|
||
|
|
//val evtID = intent.getStringExtra("EventID") ?: ""//todo?
|
||
|
|
eventBus.invokeMethod(evtType, evtData)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|