package com.github.libretube

import android.Manifest
import android.app.NotificationManager
import android.content.ContentResolver
import android.content.Context
import android.content.DialogInterface
import android.content.Intent
import android.content.SharedPreferences
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.github.libretube.dialogs.LoginDialog
import com.github.libretube.util.RetrofitInstance
import com.google.android.material.color.DynamicColors
import com.google.android.material.dialog.MaterialAlertDialogBuilder
import java.io.IOException
import java.io.InputStream
import java.util.zip.ZipEntry
import java.util.zip.ZipInputStream
import org.json.JSONObject
import org.json.JSONTokener
import retrofit2.HttpException

private var isCurrentViewMainSettings = true
private var requireMainActivityRestart = false

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 {
                requireMainActivityRestart = true
                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)
                requireMainActivityRestart = true
                true
            }

            val accentColor = findPreference<Preference>("accent_color")
            accentColor?.setOnPreferenceChangeListener { _, _ ->
                requireMainActivityRestart = true
                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 gridColumns = findPreference<ListPreference>("grid")
            gridColumns?.setOnPreferenceChangeListener { _, _ ->
                requireMainActivityRestart = true
                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)
            if (requireMainActivityRestart) {
                requireMainActivityRestart = false
                // kill player notification
                val nManager = this.getSystemService(NOTIFICATION_SERVICE) as NotificationManager
                nManager.cancelAll()
                restartMainActivity(this)
                finishAffinity()
            } else {
                super.onBackPressed()
            }
            finishAndRemoveTask()
        } else {
            isCurrentViewMainSettings = true
            supportFragmentManager
                .beginTransaction()
                .replace(R.id.settings, SettingsFragment())
                .commit()
        }
    }
}