/* This Source Code Form is subject to the terms of the Mozilla Public
 * License, v. 2.0. If a copy of the MPL was not distributed with this
 * file, You can obtain one at http://mozilla.org/MPL/2.0/. */

package mozilla.components.browser.session.storage

import android.content.Context
import android.util.AtomicFile
import androidx.annotation.CheckResult
import androidx.annotation.VisibleForTesting
import androidx.annotation.WorkerThread
import mozilla.components.browser.session.storage.serialize.BrowserStateReader
import mozilla.components.browser.session.storage.serialize.BrowserStateWriter
import mozilla.components.browser.state.selector.normalTabs
import mozilla.components.browser.state.selector.selectedTab
import mozilla.components.browser.state.state.BrowserState
import mozilla.components.browser.state.state.recover.RecoverableTab
import mozilla.components.browser.state.store.BrowserStore
import mozilla.components.concept.base.crash.CrashReporting
import mozilla.components.concept.engine.Engine
import mozilla.components.support.base.log.logger.Logger
import java.io.File
import java.util.Locale
import java.util.concurrent.TimeUnit

private const val STORE_FILE_NAME_FORMAT = "mozilla_components_session_storage_%s.json"

private val sessionFileLock = Any()

/**
 * Session storage for (partially) persisting the state of [BrowserStore] to disk.
 */
class SessionStorage(
    private val context: Context,
    private val engine: Engine,
    private val crashReporting: CrashReporting? = null
) : AutoSave.Storage {
    private val logger = Logger("SessionStorage")
    private val stateWriter = BrowserStateWriter()
    private val stateReader = BrowserStateReader()

    /**
     * Reads the saved state from disk. Returns null if no state was found on disk or if reading the file failed.
     *
     * @param predicate an optional predicate applied to each tab to determine if it should be restored.
     */
    @WorkerThread
    fun restore(predicate: (RecoverableTab) -> Boolean = { true }): RecoverableBrowserState? {
        synchronized(sessionFileLock) {
            val file = getFileForEngine(context, engine)
            return stateReader.read(engine, file, predicate)
        }
    }

    /**
     * Clears the state saved on disk.
     */
    @WorkerThread
    fun clear() {
        removeSnapshotFromDisk(context, engine)
    }

    /**
     * Saves the given state to disk.
     */
    @WorkerThread
    override fun save(state: BrowserState): Boolean {
        if (state.normalTabs.isEmpty()) {
            clear()
            return true
        }

        val stateToPersist = if (state.selectedTabId != null && state.selectedTab == null) {
            // Needs investigation to figure out and prevent cause:
            // https://github.com/mozilla-mobile/android-components/issues/8417
            logger.error("Selected tab ID set, but tab with matching ID not found. Clearing selection.")
            state.copy(selectedTabId = null)
        } else {
            state
        }

        return synchronized(sessionFileLock) {
            try {
                val file = getFileForEngine(context, engine)
                stateWriter.write(stateToPersist, file)
            } catch (e: OutOfMemoryError) {
                crashReporting?.submitCaughtException(e)
                logger.error("Failed to save state to disk due to OutOfMemoryError", e)
                false
            }
        }
    }

    /**
     * Starts configuring automatic saving of the state.
     */
    @CheckResult
    fun autoSave(
        store: BrowserStore,
        interval: Long = AutoSave.DEFAULT_INTERVAL_MILLISECONDS,
        unit: TimeUnit = TimeUnit.MILLISECONDS
    ): AutoSave {
        return AutoSave(store, this, unit.toMillis(interval))
    }
}

private fun removeSnapshotFromDisk(context: Context, engine: Engine) {
    synchronized(sessionFileLock) {
        getFileForEngine(context, engine)
            .delete()
    }
}

@VisibleForTesting(otherwise = VisibleForTesting.PRIVATE)
internal fun getFileForEngine(context: Context, engine: Engine): AtomicFile {
    return AtomicFile(
        File(
            context.filesDir,
            String.format(STORE_FILE_NAME_FORMAT, engine.name())
                .lowercase(Locale.ROOT)
        )
    )
}
