Phase 4: CLI router exposing app functions as commands

app/src/main/java/io/github/abrarul/modularai/cli/Cli.kt

@@ -0,0 +1,150 @@
+package io.github.abrarul.modularai.cli
+
+import android.content.Context
+import io.github.abrarul.modularai.bridge.TermuxBridge
+import io.github.abrarul.modularai.engine.CloudBackend
+import io.github.abrarul.modularai.engine.LlamaEngine
+import io.github.abrarul.modularai.i18n.LocaleManager
+import io.github.abrarul.modularai.model.DeviceProfiler
+import io.github.abrarul.modularai.model.ModelDownloader
+import io.github.abrarul.modularai.model.Source
+import io.github.abrarul.modularai.plugin.PluginHost
+import io.github.abrarul.modularai.proot.Proot
+import io.github.abrarul.modularai.security.SecretStore
+import io.github.abrarul.modularai.security.Vault
+import io.github.abrarul.modularai.update.Installer
+import io.github.abrarul.modularai.update.Updater
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.withContext
+import java.io.File
+
+object Config {
+    const val LOCALES_URL = "https://huggingface.co/Abrarul8541/ModularAI-Terminal/resolve/main/locales"
+    const val UPDATE_URL = "https://huggingface.co/Abrarul8541/ModularAI-Terminal/resolve/main/update.json"
+}
+
+/** Process-wide engine so a loaded model survives screen changes. */
+object Runtime {
+    val engine by lazy { LlamaEngine() }
+}
+
+class Cli(private val ctx: Context) {
+    private val prefs = ctx.getSharedPreferences("cli", Context.MODE_PRIVATE)
+    private val secrets = SecretStore(ctx)
+    private val proot = Proot(ctx)
+    private val plugins = PluginHost(ctx)
+    val locale = LocaleManager(ctx, Config.LOCALES_URL)
+
+    private fun modelsDir() = File(prefs.getString("models_dir", null) ?: File(ctx.getExternalFilesDir(null) ?: ctx.filesDir, "models").path)
+    private fun dl() = ModelDownloader(modelsDir())
+    private fun model(name: String) = File(modelsDir(), name).takeIf { it.exists() } ?: error("No such model: $name (see: models)")
+
+    suspend fun exec(line: String, out: (String) -> Unit) {
+        val a = line.trim().split(Regex("\\s+"))
+        val rest = { n: Int -> a.drop(n).joinToString(" ") }
+        try {
+            when (a[0]) {
+                "" -> {}
+                "help" -> out(HELP)
+                "hw" -> {
+                    val p = withContext(Dispatchers.Default) { DeviceProfiler.scan(ctx) }
+                    val r = DeviceProfiler.recommend(p)
+                    out("SoC ${p.soc} | ${p.abi} | ${p.cores} cores | Vulkan ${p.vulkan}")
+                    out("RAM ${p.totalRamMb} MB (free ${p.availRamMb}) | free storage ${p.freeStorageMb} MB | disk ${"%.0f".format(p.storageMBps)} MB/s")
+                    out("Tier ${p.tier.label} (${p.tier.sizes}) -> up to ~${"%.1f".format(r.maxParamsB)}B, ${r.quant}, ctx ${r.contextTokens}, est ${r.estTokensPerSec} tok/s")
+                }
+                "models" -> dl().list().ifEmpty { out("(none) dir: ${modelsDir()}"); emptyList() }
+                    .forEach { out("%-48s %6d MB".format(it.name, it.length() / 1_048_576)) }
+                "pull" -> {
+                    val src = when (a.getOrNull(1)) {
+                        "hf" -> Source.HuggingFace(a[2], a[3])
+                        "ollama" -> Source.Ollama(a[2], a.getOrElse(3) { "latest" })
+                        "url" -> Source.Url(a[2])
+                        else -> error("pull hf <repo> <file> | pull ollama <name> [tag] | pull url <url>")
+                    }
+                    var last = -1
+                    val f = dl().download(src) { d, t ->
+                        val pct = if (t > 0) (d * 100 / t).toInt() / 5 * 5 else 0
+                        if (pct != last) { last = pct; out("  $pct%  ${d / 1_048_576}/${t / 1_048_576} MB") }
+                    }
+                    out("Saved ${f.name}")
+                }
+                "rm" -> out(if (dl().remove(model(a[1]))) "Removed" else "Failed")
+                "wipe-models" -> { dl().wipeAll(); out("All models removed") }
+                "mount" -> { prefs.edit().putString("models_dir", a[1]).apply(); File(a[1]).mkdirs(); out("Models dir: ${a[1]}") }
+                "unmount" -> { prefs.edit().remove("models_dir").apply(); out("Models dir reset to default") }
+                "load" -> withContext(Dispatchers.Default) {
+                    val f = model(a[1])
+                    val ctxLen = a.getOrNull(2)?.toInt() ?: DeviceProfiler.recommend(DeviceProfiler.scan(ctx)).contextTokens
+                    Runtime.engine.load(f.path, ctxLen)
+                    out("Loaded ${f.name} (ctx $ctxLen)")
+                }
+                "unload" -> { Runtime.engine.unload(); out("Unloaded") }
+                "run" -> withContext(Dispatchers.Default) {
+                    Runtime.engine.generate(rest(1), 512) { out(it); true }
+                }
+                "key" -> { secrets.put(a[2], a[3]); out("Key stored (encrypted) for ${a[2]}") }
+                "cloud" -> withContext(Dispatchers.IO) {
+                    val key = secrets.get(a[1]) ?: error("No key. Run: key set ${a[1]} <value>")
+                    CloudBackend(a[1], key, a[2]).generate(rest(3), 1024) { out(it); true }
+                }
+                "lang" -> {
+                    if (a.getOrNull(1) == "reset") { locale.reset(); out("Language: en") }
+                    else if (a.getOrNull(1) == "purge") { locale.purgeAll(); out("Locale cache cleared") }
+                    else { locale.apply(a[1]); out(locale.t("greeting", "Language applied: ${a[1]}")) }
+                }
+                "plugins" -> plugins.installed().ifEmpty { out("(none)"); emptyList() }
+                    .forEach { out("${it.id} v${it.version} perms=${it.permissions} granted=${plugins.isGranted(it)}") }
+                "plugin" -> when (a[1]) {
+                    "grant" -> plugins.installed().first { it.id == a[2] }.let { plugins.grant(it.id, it.permissions); out("Granted ${it.permissions}") }
+                    "rm" -> plugins.installed().first { it.id == a[2] }.let { plugins.remove(it); out("Removed") }
+                    else -> error("plugin grant <id> | plugin rm <id>")
+                }
+                "update" -> withContext(Dispatchers.IO) {
+                    val u = Updater(Config.UPDATE_URL, ctx.cacheDir)
+                    val info = u.check()
+                    if (info == null) out("Up to date") else {
+                        out("Downloading ${info.versionName}")
+                        Installer.install(ctx, u.download(info)); out("Installer opened")
+                    }
+                }
+                "proot" -> when (a.getOrNull(1)) {
+                    "install" -> proot.installAlpine(out)
+                    "remove" -> { proot.remove(); out("Rootfs removed") }
+                    "status" -> out("binary=${proot.binaryAvailable} rootfs=${proot.installed}")
+                    else -> withContext(Dispatchers.IO) { proot.exec(rest(1), out) }
+                }
+                "termux" -> if (TermuxBridge.isInstalled(ctx)) { TermuxBridge.run(ctx, rest(1)); out("Sent to Termux (background)") } else out("Termux is not installed")
+                "su" -> out(TermuxBridge.su(rest(1)) ?: "su unavailable or denied")
+                "vault" -> if (a.getOrNull(1) == "wipe") {
+                    secrets.wipe(); Vault.destroy(); out("Vault key destroyed. Encrypted notes and keys are now unreadable.")
+                } else error("vault wipe")
+                else -> withContext(Dispatchers.IO) { shell(line, out) } // raw Android shell
+            }
+        } catch (e: Exception) {
+            out("error: ${e.message ?: e.javaClass.simpleName}")
+        }
+    }
+
+    private fun shell(cmd: String, out: (String) -> Unit) {
+        val p = ProcessBuilder("/system/bin/sh", "-c", cmd).directory(ctx.filesDir).redirectErrorStream(true).start()
+        p.inputStream.bufferedReader().forEachLine(out)
+        p.waitFor()
+    }
+
+    companion object {
+        const val HELP = """hw                          device profile + recommendation
+models | pull hf <repo> <file> | pull ollama <name> [tag] | pull url <url>
+rm <file> | wipe-models | mount <dir> | unmount
+load <file> [ctx] | run <prompt> | unload
+key set <openai|deepseek|anthropic> <key>   (stored encrypted)
+cloud <provider> <model> <prompt>
+lang <code> | lang reset | lang purge
+plugins | plugin grant <id> | plugin rm <id>
+update                      check, verify and install update
+proot install | proot status | proot <cmd>   (Linux rootfs)
+termux <cmd> | su <cmd>
+vault wipe
+<anything else>             runs in the Android shell"""
+    }
+}