/* * Copyright (C) 2025 The Android Open Source Project * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package com.android.tv.settings.connectivity.thread import android.net.thread.ThreadNetworkController import android.net.thread.ThreadNetworkException import android.os.Bundle import android.os.CountDownTimer import android.os.OutcomeReceiver import android.util.Log import android.view.LayoutInflater import android.view.View import android.view.ViewGroup import android.widget.TextView import androidx.fragment.app.Fragment import androidx.lifecycle.ViewModelProvider import com.android.tv.settings.R import com.android.tv.settings.connectivity.util.State import com.android.tv.settings.connectivity.util.StateMachine import com.android.tv.settings.connectivity.util.ThreadNetworkHelper import com.android.tv.twopanelsettings.QrCodeView import java.time.Duration import java.time.Instant class ShareQRCodeState(private val activity: ShareThreadNetworkActivity) : State { private var fragment : Fragment = ShareQRCodeFragment() private val stateMachine = ViewModelProvider(activity)[StateMachine::class.java] override fun processForward() { fragment = ShareQRCodeFragment() activity.onFragmentChange(fragment, true) } override fun processBackward() { fragment = ShareQRCodeFragment() stateMachine.back() } override fun getFragment(): Fragment = fragment class ShareQRCodeFragment : Fragment() { private lateinit var stateMachine: StateMachine private lateinit var threadNetworkHelper: ThreadNetworkHelper private var timeoutMinutes : Int = 0 private lateinit var qrCodeView: QrCodeView private lateinit var qrCodeString: TextView private lateinit var qrCodeCountdown: TextView private var ephemeralKey: String? = null private var ephemeralKeyExpiry: Instant? = null private var countDownTimer: CountDownTimer? = null private var activatingEphemeralMode : Boolean = false private val onStateChangeListener = object : ThreadNetworkHelper.OnStateChangeListener { override fun onEphemeralKeyStateChanged( state: Int, key: String?, expiry: Instant? ) { ephemeralKey = key ephemeralKeyExpiry = expiry when (state) { ThreadNetworkController.EPHEMERAL_KEY_ENABLED -> { updateQrCode(key!!) val remaining = Duration.between(Instant.now(), expiry) countDownTimer?.cancel() if (remaining.isNegative) { qrCodeCountdown.text = "" } else { val minutes = remaining.toMinutes() val seconds = remaining.minusMinutes(minutes).seconds qrCodeCountdown.text = getString( R.string.share_thread_network_countdown, minutes, seconds ) countDownTimer = object : CountDownTimer(remaining.toMillis(), 1000) { override fun onTick(millisUntilFinished: Long) { val remaining = Duration.ofMillis(millisUntilFinished) val minutes = remaining.toMinutes() val seconds = remaining.minusMinutes(minutes).seconds qrCodeCountdown.text = getString( R.string.share_thread_network_countdown, minutes, seconds ) } override fun onFinish() { maybeReactivateEphemeralKey() } }.start() } } ThreadNetworkController.EPHEMERAL_KEY_IN_USE -> { stateMachine.listener.onComplete( this@ShareQRCodeFragment, StateMachine.RESULT_SUCCESS) } ThreadNetworkController.EPHEMERAL_KEY_DISABLED -> { maybeReactivateEphemeralKey() } } } } override fun onCreate(savedInstanceState: Bundle?) { super.onCreate(savedInstanceState) stateMachine = ViewModelProvider(requireActivity())[StateMachine::class.java] threadNetworkHelper = ThreadNetworkHelper.getInstance(requireContext()) timeoutMinutes = resources.getInteger( R.integer.share_thread_network_key_validity_minutes) } override fun onCreateView( inflater: LayoutInflater, container: ViewGroup?, savedInstanceState: Bundle? ): View? { val view = inflater.inflate(R.layout.share_thread_network_qr_code, container, false) qrCodeView = view.findViewById(R.id.setup_qrcode_view) qrCodeString = view.findViewById(R.id.thread_qr_code_string) qrCodeCountdown = view.findViewById(R.id.thread_qr_code_countdown) return view } override fun onViewCreated(view: View, savedInstanceState: Bundle?) { val description = view.requireViewById(R.id.setup_qrcode_description) description.text = getString(R.string.share_thread_description, timeoutMinutes) threadNetworkHelper.setOnStateChangeListener(onStateChangeListener) threadNetworkHelper.registerStateCallback() activateEphemeralKey() } override fun onDestroyView() { super.onDestroyView() countDownTimer?.cancel() threadNetworkHelper.setOnStateChangeListener(null) threadNetworkHelper.unregisterStateCallback() deactivateEphemeralKey() } private fun deactivateEphemeralKey() { threadNetworkHelper.deactivateEphimeralKeyCode( object : OutcomeReceiver { override fun onResult(result: Void?) {} override fun onError(error: ThreadNetworkException) {} }) } private fun maybeReactivateEphemeralKey() { if (activatingEphemeralMode ) { return } if (resources.getBoolean(R.bool.config_share_thread_network_key_refreshes)) { activateEphemeralKey() } else { stateMachine.listener?.onComplete(this@ShareQRCodeFragment, StateMachine.RESULT_TIMEOUT) } } private fun activateEphemeralKey() { // Deactivate first because otherwise we can get already activated error. qrCodeView.setData(null) qrCodeString.text = "" qrCodeCountdown.text = "" ephemeralKey = null ephemeralKeyExpiry = null activatingEphemeralMode = true; threadNetworkHelper.activateEphimeralKeyMode( Duration.ofMinutes(timeoutMinutes.toLong()), object : OutcomeReceiver { override fun onResult(result: Void?) { activatingEphemeralMode = false Log.i(TAG, "Ephemeral mode activated") } override fun onError(e : ThreadNetworkException) { activatingEphemeralMode = false Log.e(TAG, "Failed to activate ephemeral mode", e) stateMachine.listener?.onComplete(this@ShareQRCodeFragment, StateMachine.RESULT_FAILURE) } } ) } private fun updateQrCode(key: String) { qrCodeView.setData(key) qrCodeString.text = key.chunked(3).joinToString("-") } } companion object { const val TAG = "ThreadShareQRCode" } }