package com.github.libretube

import android.Manifest
import android.content.*
import android.content.pm.PackageManager
import android.net.Uri
import android.os.Build
import android.os.Bundle
import android.text.Html
import android.text.TextUtils
import android.util.Log
import android.view.View
import android.widget.Toast
import androidx.activity.result.ActivityResultLauncher
import androidx.activity.result.contract.ActivityResultContracts
import androidx.appcompat.app.AppCompatActivity
import androidx.core.app.ActivityCompat
import androidx.core.content.ContextCompat
import androidx.fragment.app.Fragment
import androidx.lifecycle.lifecycleScope
import androidx.preference.ListPreference
import androidx.preference.Preference
import androidx.preference.PreferenceFragmentCompat
import androidx.preference.PreferenceManager
import com.google.android.material.color.DynamicColors
import com.google.android.material.dialog.MaterialAlertDialogBuilder
import org.json.JSONObject
import org.json.JSONTokener
import retrofit2.HttpException
import java.io.IOException
import java.io.InputStream
import java.util.zip.ZipEntry
import java.util.zip.ZipInputStream


private var isCurrentViewMainSettings = true

class SettingsActivity :
    AppCompatActivity(),
    SharedPreferences.OnSharedPreferenceChangeListener {

    override fun onCreate(savedInstanceState: Bundle?) {
        DynamicColors.applyToActivityIfAvailable(this)
        updateAccentColor(this)
        updateThemeMode(this)

        super.onCreate(savedInstanceState)
        if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.Q) {
            overridePendingTransition(50, 50)
        }
        val view = this.findViewById<View>(android.R.id.content)
        view.alpha = 0F
        view.animate().alpha(1F).duration = 300

        setContentView(R.layout.activity_settings)
        if (savedInstanceState == null) {
            supportFragmentManager
                .beginTransaction()
                .replace(R.id.settings, SettingsFragment())
                .commit()
        }

        PreferenceManager.getDefaultSharedPreferences(this)
            .registerOnSharedPreferenceChangeListener(this)
    }

    override fun onSharedPreferenceChanged(
        sharedPreferences: SharedPreferences?,
        rootKey: String?
    ) {
    }

    class SettingsFragment : PreferenceFragmentCompat() {
        val TAG = "Settings"

        companion object {
            lateinit var getContent: ActivityResultLauncher<String>
        }

        override fun onCreate(savedInstanceState: Bundle?) {
            getContent =
                registerForActivityResult(ActivityResultContracts.GetContent()) { uri: Uri? ->
                    if (uri != null) {
                        try {
                            // Open a specific media item using ParcelFileDescriptor.
                            val resolver: ContentResolver =
                                requireActivity()
                                    .contentResolver

                            // "rw" for read-and-write;
                            // "rwt" for truncating or overwriting existing file contents.
                            // val readOnlyMode = "r"
                            // uri - I have got from onActivityResult
                            val type = resolver.getType(uri)

                            var inputStream: InputStream? = resolver.openInputStream(uri)
                            val channels = ArrayList<String>()
                            if (type == "application/json") {
                                val json = inputStream?.bufferedReader()?.readLines()?.get(0)
                                val jsonObject = JSONTokener(json).nextValue() as JSONObject
                                Log.e(TAG, jsonObject.getJSONArray("subscriptions").toString())
                                for (
                                    i in 0 until jsonObject.getJSONArray("subscriptions")
                                        .length()
                                ) {
                                    var url =
                                        jsonObject.getJSONArray("subscriptions").getJSONObject(i)
                                            .getString("url")
                                    url = url.replace("https://www.youtube.com/channel/", "")
                                    Log.e(TAG, url)
                                    channels.add(url)
                                }
                            } else {
                                if (type == "application/zip") {
                                    val zis = ZipInputStream(inputStream)
                                    var entry: ZipEntry? = zis.nextEntry
                                    while (entry != null) {
                                        if (entry.name.endsWith(".csv")) {
                                            inputStream = zis
                                            break
                                        }
                                        entry = zis.nextEntry
                                    }
                                }

                                inputStream?.bufferedReader()?.readLines()?.forEach {
                                    if (it.isNotBlank()) {
                                        val channelId = it.substringBefore(",")
                                        if (channelId.length == 24)
                                            channels.add(channelId)
                                    }
                                }
                            }
                            inputStream?.close()

                            subscribe(channels)
                        } catch (e: Exception) {
                            Log.e(TAG, e.toString())
                            Toast.makeText(
                                context,
                                R.string.error,
                                Toast.LENGTH_SHORT
                            ).show()
                        }
                    }
                }
            super.onCreate(savedInstanceState)
        }

        override fun onCreatePreferences(savedInstanceState: Bundle?, rootKey: String?) {
            setPreferencesFromResource(R.xml.settings, rootKey)
            val instance = findPreference<ListPreference>("instance")
            fetchInstance()
            instance?.setOnPreferenceChangeListener { _, newValue ->
                RetrofitInstance.url = newValue.toString()
                RetrofitInstance.lazyMgr.reset()
                val sharedPref = context?.getSharedPreferences("token", Context.MODE_PRIVATE)
                if (sharedPref?.getString("token", "") != "") {
                    with(sharedPref!!.edit()) {
                        putString("token", "")
                        apply()
                    }
                    Toast.makeText(context, R.string.loggedout, Toast.LENGTH_SHORT).show()
                }
                true
            }

            val login = findPreference<Preference>("login_register")
            login?.setOnPreferenceClickListener {

                val newFragment = LoginDialog()
                newFragment.show(childFragmentManager, "Login")
                true
            }

            val sponsorblock = findPreference<Preference>("sponsorblock")
            sponsorblock?.setOnPreferenceClickListener {
                isCurrentViewMainSettings = false
                val newFragment = SponsorBlockSettings()
                parentFragmentManager.beginTransaction()
                    .replace(R.id.settings, newFragment)
                    .commitNow()
                true
            }

            val importFromYt = findPreference<Preference>("import_from_yt")
            importFromYt?.setOnPreferenceClickListener {
                val sharedPref = context?.getSharedPreferences("token", Context.MODE_PRIVATE)
                val token = sharedPref?.getString("token", "")!!
                // check StorageAccess
                if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.R) {
                    Log.d("myz", "" + Build.VERSION.SDK_INT)
                    if (ContextCompat.checkSelfPermission(
                            this.requireContext(),
                            Manifest.permission.READ_EXTERNAL_STORAGE
                        )
                        != PackageManager.PERMISSION_GRANTED
                    ) {
                        ActivityCompat.requestPermissions(
                            this.requireActivity(),
                            arrayOf(
                                Manifest.permission.READ_EXTERNAL_STORAGE,
                                Manifest.permission.MANAGE_EXTERNAL_STORAGE
                            ),
                            1
                        ) // permission request code is just an int
                    } else if (token != "") {
                        getContent.launch("*/*")
                    } else {
                        Toast.makeText(context, R.string.login_first, Toast.LENGTH_SHORT).show()
                    }
                } else {
                    if (ActivityCompat.checkSelfPermission(
                            requireContext(),
                            Manifest.permission.READ_EXTERNAL_STORAGE
                        ) != PackageManager.PERMISSION_GRANTED ||
                        ActivityCompat.checkSelfPermission(
                                requireContext(),
                                Manifest.permission.WRITE_EXTERNAL_STORAGE
                            ) != PackageManager.PERMISSION_GRANTED
                    ) {
                        ActivityCompat.requestPermissions(
                            this.requireActivity(),
                            arrayOf(
                                Manifest.permission.READ_EXTERNAL_STORAGE,
                                Manifest.permission.WRITE_EXTERNAL_STORAGE
                            ),
                            1
                        )
                    } else if (token != "") {
                        getContent.launch("*/*")
                    } else {
                        Toast.makeText(context, R.string.login_first, Toast.LENGTH_SHORT).show()
                    }
                }
                true
            }

            val themeToggle = findPreference<ListPreference>("theme_togglee")
            themeToggle?.setOnPreferenceChangeListener { _, _ ->
                val refresh = Intent(context, SettingsActivity::class.java)
                startActivity(refresh)
                true
            }

            val accentColor = findPreference<Preference>("accent_color")
            accentColor?.setOnPreferenceChangeListener { _, _ ->
                val refresh = Intent(context, SettingsActivity::class.java)
                startActivity(refresh)
                true
            }

            val iconChange = findPreference<ListPreference>("icon_change")
            iconChange?.setOnPreferenceChangeListener { _, newValue ->
                changeIcon(requireContext(), newValue.toString())
                true
            }

            val changeLanguage = findPreference<ListPreference>("language")
            changeLanguage?.setOnPreferenceChangeListener { _, _ ->
                restartMainActivity(requireContext())
                true
            }

            val clearHistory = findPreference<Preference>("clear_history")
            clearHistory?.setOnPreferenceClickListener {
                val sharedPreferences =
                    PreferenceManager.getDefaultSharedPreferences(requireContext())
                sharedPreferences.edit().remove("search_history").commit()
                true
            }

            val about = findPreference<Preference>("about")
            about?.setOnPreferenceClickListener {
                val uri = Uri.parse("https://libre-tube.github.io/")
                val intent = Intent(Intent.ACTION_VIEW).setData(uri)
                startActivity(intent)
                true
            }

            val license = findPreference<Preference>("license")
            license?.setOnPreferenceClickListener {
                val licenseString = view?.context?.assets!!.open("gpl3.html").bufferedReader().use {
                    it.readText()
                }
                val licenseHtml = if (Build.VERSION.SDK_INT >= 24) {
                    Html.fromHtml(licenseString, 1)
                } else {
                    Html.fromHtml(licenseString)
                }
                MaterialAlertDialogBuilder(view?.context!!)
                    .setPositiveButton(
                        getString(R.string.okay),
                        DialogInterface.OnClickListener { _, _ -> }
                    )
                    .setMessage(licenseHtml)
                    .create()
                    .show()
                true
            }
        }

        private fun fetchInstance() {
            lifecycleScope.launchWhenCreated {
                val response = try {
                    RetrofitInstance.api.getInstances("https://instances.tokhmi.xyz/")
                } catch (e: IOException) {
                    println(e)
                    Log.e("settings", "IOException, you might not have internet connection")
                    return@launchWhenCreated
                } catch (e: HttpException) {
                    Log.e("settings", "HttpException, unexpected response $e")
                    return@launchWhenCreated
                } catch (e: Exception) {
                    Log.e("settings", e.toString())
                    return@launchWhenCreated
                }
                val listEntries: MutableList<String> = ArrayList()
                val listEntryValues: MutableList<String> = ArrayList()
                for (item in response) {
                    listEntries.add(item.name!!)
                    listEntryValues.add(item.api_url!!)
                }
                val entries = listEntries.toTypedArray<CharSequence>()
                val entryValues = listEntryValues.toTypedArray<CharSequence>()
                runOnUiThread {
                    val instance = findPreference<ListPreference>("instance")
                    instance?.entries = entries
                    instance?.entryValues = entryValues
                    instance?.summaryProvider =
                        Preference.SummaryProvider<ListPreference> { preference ->
                            val text = preference.entry
                            if (TextUtils.isEmpty(text)) {
                                "kavin.rocks (Official)"
                            } else {
                                text
                            }
                        }
                }
            }
        }

        private fun Fragment?.runOnUiThread(action: () -> Unit) {
            this ?: return
            if (!isAdded) return // Fragment not attached to an Activity
            activity?.runOnUiThread(action)
        }

        private fun subscribe(channels: List<String>) {
            fun run() {
                lifecycleScope.launchWhenCreated {
                    val response = try {
                        val sharedPref =
                            context?.getSharedPreferences("token", Context.MODE_PRIVATE)
                        RetrofitInstance.api.importSubscriptions(
                            false,
                            sharedPref?.getString("token", "")!!,
                            channels
                        )
                    } catch (e: IOException) {
                        Log.e(TAG, "IOException, you might not have internet connection")
                        return@launchWhenCreated
                    } catch (e: HttpException) {
                        Log.e(TAG, "HttpException, unexpected response$e")
                        return@launchWhenCreated
                    }
                    if (response.message == "ok") {
                        Toast.makeText(
                            context,
                            R.string.importsuccess,
                            Toast.LENGTH_SHORT
                        ).show()
                    }
                }
            }
            run()
        }
    }

    override fun onBackPressed() {
        if (isCurrentViewMainSettings) {
            PreferenceManager.getDefaultSharedPreferences(this)
                .unregisterOnSharedPreferenceChangeListener(this)
            restartMainActivity(this)
        } else {
            isCurrentViewMainSettings = true
            supportFragmentManager
                .beginTransaction()
                .replace(R.id.settings, SettingsFragment())
                .commit()
        }
    }
}