Feature: Headless Command (#44)

* chore: add check-types

* refactor: api package file structure update

* feat: add headless worker extension API

* feat: add HeadlessCmd to manifest schema

* feat: make each type of cmds optional in manifest

There may be more types of cmds in the future, this makes backward compatibility easier.

* feat: implement headless extension command in app

A demo cmd implemented as well.

* refactor: move api package's API server files

* refactor: reformat all

apps/desktop/src/lib/cmds/ext.ts

@@ -2,13 +2,17 @@ import { appState } from "@/stores"
 import { winExtMap } from "@/stores/winExtMap"
 import { trimSlash } from "@/utils/url"
 import { constructExtensionSupportDir } from "@kksh/api"
-import { spawnExtensionFileServer } from "@kksh/api/commands"
-import { CustomUiCmd, ExtPackageJsonExtra, TemplateUiCmd } from "@kksh/api/models"
-import { launchNewExtWindow } from "@kksh/extension"
+import { db, spawnExtensionFileServer } from "@kksh/api/commands"
+import { HeadlessWorkerExtension } from "@kksh/api/headless"
+import { CustomUiCmd, ExtPackageJsonExtra, HeadlessCmd, TemplateUiCmd } from "@kksh/api/models"
+import { constructJarvisServerAPIWithPermissions, type IApp } from "@kksh/api/ui"
+import { launchNewExtWindow, loadExtensionManifestFromDisk } from "@kksh/extension"
 import { convertFileSrc } from "@tauri-apps/api/core"
+import * as path from "@tauri-apps/api/path"
 import * as fs from "@tauri-apps/plugin-fs"
 import { platform } from "@tauri-apps/plugin-os"
 import { goto } from "$app/navigation"
+import { RPCChannel, WorkerParentIO } from "kkrpc/browser"
 
 export async function createExtSupportDir(extPath: string) {
 	const extSupportDir = await constructExtensionSupportDir(extPath)
@@ -38,6 +42,44 @@ export async function onTemplateUiCmdSelect(
 	}
 }
 
+export async function onHeadlessCmdSelect(
+	ext: ExtPackageJsonExtra,
+	cmd: HeadlessCmd,
+	{ isDev, hmr }: { isDev: boolean; hmr: boolean }
+) {
+	await createExtSupportDir(ext.extPath)
+	// load the script in Web Worker
+	const loadedExt = await loadExtensionManifestFromDisk(
+		await path.join(ext.extPath, "package.json")
+	)
+	const scriptPath = await path.join(loadedExt.extPath, cmd.main)
+	const workerScript = await fs.readTextFile(scriptPath)
+	const blob = new Blob([workerScript], { type: "application/javascript" })
+	const blobURL = URL.createObjectURL(blob)
+	const worker = new Worker(blobURL)
+	const extInfoInDB = await db.getUniqueExtensionByPath(loadedExt.extPath)
+	if (!extInfoInDB) {
+		return
+	}
+	const serverAPI: Record<string, any> = constructJarvisServerAPIWithPermissions(
+		loadedExt.kunkun.permissions,
+		loadedExt.extPath
+	)
+	serverAPI.iframeUi = undefined
+	serverAPI.workerUi = undefined
+	serverAPI.db = new db.JarvisExtDB(extInfoInDB.extId)
+	serverAPI.kv = new db.KV(extInfoInDB.extId)
+	serverAPI.app = {
+		language: () => Promise.resolve("en")
+	} satisfies IApp
+	const io = new WorkerParentIO(worker)
+	const rpc = new RPCChannel<typeof serverAPI, HeadlessWorkerExtension>(io, {
+		expose: serverAPI
+	})
+	const workerAPI = rpc.getAPI()
+	await workerAPI.load()
+}
+
 export async function onCustomUiCmdSelect(
 	ext: ExtPackageJsonExtra,
 	cmd: CustomUiCmd,

apps/desktop/src/lib/cmds/index.ts

@@ -1,7 +1,13 @@
-import { CmdTypeEnum, CustomUiCmd, ExtPackageJsonExtra, TemplateUiCmd } from "@kksh/api/models"
+import {
+	CmdTypeEnum,
+	CustomUiCmd,
+	ExtPackageJsonExtra,
+	HeadlessCmd,
+	TemplateUiCmd
+} from "@kksh/api/models"
 import type { CommandLaunchers, OnExtCmdSelect } from "@kksh/ui/types"
 import * as v from "valibot"
-import { onCustomUiCmdSelect, onTemplateUiCmdSelect } from "./ext"
+import { onCustomUiCmdSelect, onHeadlessCmdSelect, onTemplateUiCmdSelect } from "./ext"
 import { onQuickLinkSelect } from "./quick-links"
 
 const onExtCmdSelect: OnExtCmdSelect = (
@@ -16,6 +22,9 @@ const onExtCmdSelect: OnExtCmdSelect = (
 		case CmdTypeEnum.UiWorker:
 			onTemplateUiCmdSelect(ext, v.parse(TemplateUiCmd, cmd), { isDev, hmr })
 			break
+		case CmdTypeEnum.HeadlessWorker:
+			onHeadlessCmdSelect(ext, v.parse(HeadlessCmd, cmd), { isDev, hmr })
+			break
 		default:
 			console.error("Unknown command type", cmd.type)
 	}

apps/desktop/src/routes/app/+page.svelte

@@ -25,8 +25,6 @@
 	import { ArrowBigUpIcon, CircleXIcon, EllipsisVerticalIcon, RefreshCcwIcon } from "lucide-svelte"
 	import { onMount } from "svelte"
 
-	const kv = new db.KV(1)
-
 	let inputEle: HTMLInputElement | null = $state(null)
 	function onKeyDown(event: KeyboardEvent) {
 		if (event.key === "Escape") {

apps/desktop/src/routes/app/extension/ui-iframe/+page.svelte

@@ -21,7 +21,6 @@
 	import { IframeParentIO, RPCChannel } from "kkrpc/browser"
 	import { ArrowLeftIcon, MoveIcon, RefreshCcwIcon, XIcon } from "lucide-svelte"
 	import { onDestroy, onMount } from "svelte"
-	import * as v from "valibot"
 	import type { PageData } from "./$types"
 
 	let { data }: { data: PageData } = $props()

apps/desktop/src/routes/app/extension/ui-worker/+page.svelte

@@ -25,19 +25,15 @@
 		type IComponent,
 		type WorkerExtension
 	} from "@kksh/api/ui/worker"
-	import { Button } from "@kksh/svelte5"
 	import { LoadingBar } from "@kksh/ui"
 	import { Templates } from "@kksh/ui/extension"
 	import { GlobalCommandPaletteFooter } from "@kksh/ui/main"
 	import type { UnlistenFn } from "@tauri-apps/api/event"
 	import { getCurrentWebviewWindow } from "@tauri-apps/api/webviewWindow"
 	import { readTextFile } from "@tauri-apps/plugin-fs"
-	import { fetch } from "@tauri-apps/plugin-http"
 	import { debug } from "@tauri-apps/plugin-log"
 	import { goto } from "$app/navigation"
 	import { RPCChannel, WorkerParentIO } from "kkrpc/browser"
-	// import { RPCChannel, WorkerParentIO } from "kkrpc/worker"
-	import { ArrowLeftIcon } from "lucide-svelte"
 	import { onDestroy, onMount } from "svelte"
 	import * as v from "valibot"
 
@@ -282,10 +278,10 @@
 		onListItemSelected={(value: string) => {
 			workerAPI?.onListItemSelected(value)
 		}}
-		onSearchTermChange={(searchTerm) => {
+		onSearchTermChange={(searchTerm: string) => {
 			workerAPI?.onSearchTermChange(searchTerm)
 		}}
-		onHighlightedItemChanged={(value) => {
+		onHighlightedItemChanged={(value: string) => {
 			workerAPI?.onHighlightedListItemChanged(value)
 			if (listViewContent?.defaultAction) {
 				appState.setDefaultAction(listViewContent.defaultAction)
@@ -302,7 +298,7 @@
 				onDefaultActionSelected={() => {
 					workerAPI?.onEnterPressedOnSearchBar()
 				}}
-				onActionSelected={(value) => {
+				onActionSelected={(value: string) => {
 					workerAPI?.onActionSelected(value)
 				}}
 			/>

apps/desktop/src/routes/app/extension/ui-worker/+page.ts

@@ -56,7 +56,7 @@ export const load: PageLoad = async ({ url }) => {
 		sbError(404, `Extension package.json not found at ${pkgJsonPath}`)
 	}
 
-	const cmd = loadedExt.kunkun.templateUiCmds.find((cmd) => cmd.name === cmdName)
+	const cmd = loadedExt.kunkun.templateUiCmds?.find((cmd) => cmd.name === cmdName)
 	if (!cmd) {
 		sbError(404, `Command ${cmdName} not found in extension ${loadedExt.kunkun.identifier}`)
 	}

package.json

@@ -4,6 +4,7 @@
 	"scripts": {
 		"build": "turbo build",
 		"dev": "turbo dev",
+		"check-types": "turbo check-types",
 		"test": "turbo run test",
 		"prepare": "turbo run prepare",
 		"lint": "turbo lint",

packages/api/build.ts

@@ -18,3 +18,4 @@ if (!schemaFile.exists()) {
 }
 
 await $`bun patch-version.ts`
+await $`bun run check-types`

packages/api/package.json

@@ -7,6 +7,7 @@
 		"./ui": "./src/ui/index.ts",
 		"./ui/iframe": "./src/ui/iframe/index.ts",
 		"./ui/worker": "./src/ui/worker/index.ts",
+		"./headless": "./src/headless/index.ts",
 		"./models": "./src/models/index.ts",
 		"./commands": "./src/commands/index.ts",
 		"./runtime/deno": "./src/runtime/deno.ts",
@@ -22,6 +23,7 @@
 		"test": "bun test --coverage",
 		"gen:deno:types": "deno types > deno.d.ts",
 		"build:docs": "npx typedoc",
+		"check-types": "tsc --noEmit",
 		"dev": "bun --watch build.ts",
 		"build": "bun build.ts",
 		"prepare": "bun setup.ts",

packages/api/src/api/client.ts

@@ -0,0 +1,299 @@
+import type {
+	copyFile,
+	create,
+	exists,
+	lstat,
+	mkdir,
+	readDir,
+	readFile,
+	readTextFile,
+	remove,
+	rename,
+	stat,
+	truncate,
+	writeFile,
+	writeTextFile
+} from "@tauri-apps/plugin-fs"
+import type { IShell as IShell1, IPath as ITauriPath } from "tauri-api-adapter"
+import type {
+	Child,
+	ChildProcess,
+	CommandEvents,
+	hasCommand,
+	InternalSpawnOptions,
+	IOPayload,
+	likelyOnWindows,
+	OutputEvents,
+	SpawnOptions
+} from "tauri-plugin-shellx-api"
+import { EventEmitter, open as shellxOpen } from "tauri-plugin-shellx-api"
+import * as v from "valibot"
+import { KV, type JarvisExtDB } from "../commands/db"
+import type { fileSearch } from "../commands/fileSearch"
+import { type AppInfo } from "../models/apps"
+import type { LightMode, Position, Radius, ThemeColor } from "../models/styles"
+import type { DenoSysOptions } from "../permissions/schema"
+
+type PromiseWrap<T extends (...args: any[]) => any> = (
+	...args: Parameters<T>
+) => Promise<ReturnType<T>>
+
+export type IPath = ITauriPath & {
+	extensionDir: () => Promise<string>
+	extensionSupportDir: () => Promise<string>
+}
+
+export interface IPlist {
+	// build: PromiseWrap<typeof plist.build>
+	parse: (plistContent: string) => Promise<any>
+}
+
+export interface IUtils {
+	plist: IPlist
+}
+
+export interface ISystem {
+	openTrash(): Promise<void>
+	emptyTrash(): Promise<void>
+	shutdown(): Promise<void>
+	reboot(): Promise<void>
+	sleep(): Promise<void>
+	toggleSystemAppearance(): Promise<void>
+	showDesktop(): Promise<void>
+	quitAllApps(): Promise<void>
+	sleepDisplays(): Promise<void>
+	setVolume(percentage: number): Promise<void>
+	setVolumeTo0(): Promise<void>
+	setVolumeTo25(): Promise<void>
+	setVolumeTo50(): Promise<void>
+	setVolumeTo75(): Promise<void>
+	setVolumeTo100(): Promise<void>
+	turnVolumeUp(): Promise<void>
+	turnVolumeDown(): Promise<void>
+	toggleStageManager(): Promise<void>
+	toggleBluetooth(): Promise<void>
+	toggleHiddenFiles(): Promise<void>
+	ejectAllDisks(): Promise<void>
+	logoutUser(): Promise<void>
+	toggleMute(): Promise<void>
+	mute(): Promise<void>
+	unmute(): Promise<void>
+	getFrontmostApp(): Promise<AppInfo>
+	hideAllAppsExceptFrontmost(): Promise<void>
+	getSelectedFilesInFileExplorer(): Promise<string[]>
+}
+
+export type GeneralToastParams = {
+	description?: string
+	duration?: number
+	closeButton?: boolean
+	position?:
+		| "top-left"
+		| "top-right"
+		| "bottom-left"
+		| "bottom-right"
+		| "top-center"
+		| "bottom-center"
+	actionLabel?: string
+}
+
+export type GeneralToast = (
+	message: string,
+	options?: GeneralToastParams,
+	action?: () => void
+) => Promise<void>
+
+export interface IToast {
+	message: GeneralToast
+	info: GeneralToast
+	success: GeneralToast
+	warning: GeneralToast
+	error: GeneralToast
+}
+
+export interface IUiIframe {
+	// goHome: () => Promise<void>
+	goBack: () => Promise<void>
+	hideBackButton: () => Promise<void>
+	hideMoveButton: () => Promise<void>
+	hideRefreshButton: () => Promise<void>
+	/**
+	 * position can be "top-left" | "top-right" | "bottom-left" | "bottom-right" | CustomPosition
+	 * `CustomPosition` is an object with optional `top`, `right`, `bottom`, `left` properties
+	 * Each property is a number, with `rem` unit, and will be applied to css `top`, `right`, `bottom`, `left` properties
+	 * @param position "top-left" | "top-right" | "bottom-left" | "bottom-right" | CustomPosition
+	 * @example
+	 * ```ts
+	 * ui.showBackButton({ top: 2, left: 2 })
+	 * ui.showBackButton('top-right')
+	 * ```
+	 * @returns
+	 */
+	showBackButton: (position?: Position) => Promise<void>
+	/**
+	 * position can be "top-left" | "top-right" | "bottom-left" | "bottom-right" | CustomPosition
+	 * `CustomPosition` is an object with optional `top`, `right`, `bottom`, `left` properties
+	 * Each property is a number, with `rem` unit, and will be applied to css `top`, `right`, `bottom`, `left` properties
+	 * @param position "top-left" | "top-right" | "bottom-left" | "bottom-right" | CustomPosition
+	 * @example
+	 * ```ts
+	 * ui.showBackButton({ top: 2, left: 2 })
+	 * ui.showBackButton('top-right')
+	 * ```
+	 * @returns
+	 */
+	showMoveButton: (position?: Position) => Promise<void>
+	showRefreshButton: (position?: Position) => Promise<void>
+	getTheme: () => Promise<{
+		theme: ThemeColor
+		radius: Radius
+		lightMode: LightMode
+	}>
+	reloadPage: () => Promise<void>
+	startDragging: () => Promise<void>
+	toggleMaximize: () => Promise<void>
+	internalToggleMaximize: () => Promise<void>
+	setTransparentWindowBackground: (transparent: boolean) => Promise<void>
+	registerDragRegion: () => Promise<void>
+}
+
+export interface IDb {
+	add: typeof JarvisExtDB.prototype.add
+	delete: typeof JarvisExtDB.prototype.delete
+	search: typeof JarvisExtDB.prototype.search
+	retrieveAll: typeof JarvisExtDB.prototype.retrieveAll
+	retrieveAllByType: typeof JarvisExtDB.prototype.retrieveAllByType
+	deleteAll: typeof JarvisExtDB.prototype.deleteAll
+	update: typeof JarvisExtDB.prototype.update
+}
+
+export interface IKV {
+	get: typeof KV.prototype.get
+	set: typeof KV.prototype.set
+	exists: typeof KV.prototype.exists
+	delete: typeof KV.prototype.delete
+}
+
+export interface IFs {
+	readDir: typeof readDir
+	readFile: typeof readFile
+	readTextFile: typeof readTextFile
+	stat: typeof stat
+	lstat: typeof lstat
+	exists: typeof exists
+	mkdir: typeof mkdir
+	create: typeof create
+	copyFile: typeof copyFile
+	remove: typeof remove
+	rename: typeof rename
+	truncate: typeof truncate
+	writeFile: typeof writeFile
+	writeTextFile: typeof writeTextFile
+	fileSearch: typeof fileSearch
+}
+
+export interface IOpen {
+	url: (url: string) => Promise<void>
+	file: (path: string) => Promise<void>
+	folder: (path: string) => Promise<void>
+}
+
+/* -------------------------------------------------------------------------- */
+/*                                  Event API                                 */
+/* -------------------------------------------------------------------------- */
+export type DragDropPayload = {
+	paths: string[]
+	position: { x: number; y: number }
+}
+export type DragEnterPayload = DragDropPayload
+export type DragOverPayload = {
+	position: { x: number; y: number }
+}
+
+export interface IEvent {
+	/**
+	 * Get files dropped on the window
+	 */
+	onDragDrop: (callback: (payload: DragDropPayload) => void) => void
+	/**
+	 * Listen to drag enter event, when mouse drag enters the window
+	 */
+	onDragEnter: (callback: (payload: DragEnterPayload) => void) => void
+	/**
+	 * Listen to drag leave event, when mouse drag leaves the window
+	 */
+	onDragLeave: (callback: () => void) => void
+	/**
+	 * Get the position of the dragged item
+	 */
+	onDragOver: (callback: (payload: DragOverPayload) => void) => void
+	/**
+	 * Listen to window blur (defocus) event
+	 */
+	onWindowBlur: (callback: () => void) => void
+	/**
+	 * Listen to window close request event
+	 */
+	onWindowCloseRequested: (callback: () => void) => void
+	/**
+	 * Listen to window on focus event
+	 */
+	onWindowFocus: (callback: () => void) => void
+}
+
+/**
+ * https://docs.deno.com/runtime/fundamentals/security/
+ */
+export interface DenoRunConfig {
+	allowNet?: string[]
+	allowAllNet?: boolean
+	allowRead?: string[]
+	allowAllRead?: boolean
+	allowWrite?: string[]
+	allowAllWrite?: boolean
+	allowRun?: string[]
+	allowAllRun?: boolean
+	allowEnv?: string[]
+	allowAllEnv?: boolean
+	allowFfi?: string[]
+	allowAllFfi?: boolean
+	allowSys?: DenoSysOptions[]
+	allowAllSys?: boolean
+	denyNet?: string[]
+	denyAllNet?: boolean
+	denyRead?: string[]
+	denyAllRead?: boolean
+	denyWrite?: string[]
+	denyAllWrite?: boolean
+	denyRun?: string[]
+	denyAllRun?: boolean
+	denyEnv?: string[]
+	denyAllEnv?: boolean
+	denyFfi?: string[]
+	denyAllFfi?: boolean
+	denySys?: DenoSysOptions[]
+	denyAllSys?: boolean
+}
+
+export interface IApp {
+	language: () => Promise<"en" | "zh">
+}
+
+export const MacSecurityOptions = v.union([
+	v.literal("ScreenCapture"),
+	v.literal("Camera"),
+	v.literal("Microphone"),
+	v.literal("Accessibility"),
+	v.literal("AllFiles")
+])
+export type MacSecurityOptions = v.InferOutput<typeof MacSecurityOptions>
+
+export interface ISecurity {
+	mac: {
+		revealSecurityPane: (privacyOption?: MacSecurityOptions) => Promise<void>
+		resetPermission: (privacyOption: MacSecurityOptions) => Promise<void>
+		verifyFingerprint: () => Promise<boolean>
+		requestScreenCapturePermission: () => Promise<boolean>
+		checkScreenCapturePermission: () => Promise<boolean>
+	}
+}

packages/api/src/api/deno.ts

@@ -0,0 +1,2 @@
+import type { DenoSysOptions } from "../permissions/schema"
+import type { DenoRunConfig } from "./client"

packages/api/src/api/event.ts

@@ -1,5 +1,5 @@
 // import { proxy, type Remote } from "@huakunshen/comlink"
-import type { DragDropPayload, DragEnterPayload, DragOverPayload, IEvent } from "../client"
+import type { DragDropPayload, DragEnterPayload, DragOverPayload, IEvent } from "./client"
 
 // event API listens for events, event callback functions are proxied with comlink, thus I have to provide this constructor function
 export function constructEventAPI(api: IEvent): IEvent {

packages/api/src/api/iframe-ui.ts

@@ -1,6 +1,6 @@
 // import type { Remote } from "@huakunshen/comlink"
 import type { IOs } from "tauri-api-adapter/client"
-import { type IUiIframe } from "../client"
+import { type IUiIframe } from "./client"
 
 export const KK_DRAG_REGION_ATTR = "data-kunkun-drag-region"
 

packages/api/src/api/path.ts

@@ -1,6 +1,6 @@
 // import type { Remote } from "@huakunshen/comlink"
 import { BaseDirectory } from "@tauri-apps/api/path"
-import type { IPath } from "../client"
+import type { IPath } from "./client"
 
 export function constructPathAPI(api: IPath): IPath {
 	return {

packages/api/src/api/server-types.ts

@@ -1,5 +1,3 @@
-// import type { IEvent, IFs, ISystem } from "../client"
-
 import { type IShellServer as IShellServer1 } from "tauri-api-adapter"
 import type {
 	ChildProcess,
@@ -8,7 +6,7 @@ import type {
 	IOPayload,
 	SpawnOptions
 } from "tauri-plugin-shellx-api"
-import type { DenoRunConfig, IUiIframe } from "../client"
+import type { DenoRunConfig, IUiIframe } from "./client"
 
 export type IShellServer = IShellServer1 & {
 	denoExecute(

packages/api/src/api/server/deno.ts

@@ -1,8 +1,8 @@
 import { join } from "@tauri-apps/api/path"
 import { exists } from "@tauri-apps/plugin-fs"
-import { difference } from "lodash"
 import type { InternalSpawnOptions, SpawnOptions } from "tauri-plugin-shellx-api"
 import { safeParse } from "valibot"
+import { type DenoRunConfig } from "../../api/client"
 import {
 	PermissionScopeSchema,
 	ShellPermissionScopedSchema,
@@ -15,7 +15,6 @@ import {
 	pathStartsWithAlias,
 	translateScopeToPath
 } from "../../utils/path"
-import { type DenoRunConfig } from "../client"
 
 /**
  *

packages/api/src/api/server/event.ts

@@ -5,10 +5,10 @@
  * only exposes a limited set of events.
  */
 import { listen, TauriEvent } from "@tauri-apps/api/event"
+import type { DragDropPayload, DragEnterPayload, DragOverPayload, IEvent } from "../../api/client"
 import { type EventPermission } from "../../permissions"
 import { EventPermissionMap } from "../../permissions/permission-map"
 import { checkPermission } from "../../utils/permission-check"
-import type { DragDropPayload, DragEnterPayload, DragOverPayload, IEvent } from "../client"
 
 export function constructEventApi(permissions: EventPermission[]): IEvent {
 	return {

packages/api/src/api/server/fs.ts

@@ -26,6 +26,7 @@ import {
 	type TruncateOptions,
 	type WriteFileOptions
 } from "@tauri-apps/plugin-fs"
+import type { IFs } from "../../api/client"
 import { fileSearch, FileSearchParams } from "../../commands/fileSearch"
 import { FsPermissionMap } from "../../permissions/permission-map"
 import {
@@ -39,7 +40,6 @@ import {
 	matchPathAndScope,
 	verifyGeneralPathScopedPermission
 } from "../../utils/path"
-import type { IFs } from "../client"
 
 /**
  * `tauri-api-adapter` provides fs API

packages/api/src/api/server/index.ts

@@ -37,6 +37,8 @@ import {
 	type SystemInfoPermission,
 	type UpdownloadPermission
 } from "tauri-api-adapter/permissions"
+import type { IEvent, IFs, IOpen, ISecurity, ISystem, IToast, IUtils } from "../../api/client"
+import type { IUiIframeServer1 } from "../../api/server-types"
 import {
 	AllKunkunPermission,
 	type EventPermission,
@@ -48,14 +50,12 @@ import {
 	type ShellPermissionScoped,
 	type SystemPermission
 } from "../../permissions"
-import type { IEvent, IFs, IOpen, ISecurity, ISystem, IToast, IUtils } from "../client"
 // import type { IDbServer } from "./db"
 import { constructEventApi } from "./event"
 import { constructFsApi } from "./fs"
 import { constructOpenApi } from "./open"
 import { constructPathApi } from "./path"
 import { constructSecurityAPI } from "./security"
-import type { IUiIframeServer1 } from "./server-types"
 // import type { IFsServer, ISystemServer } from "./server-types"
 import { constructShellApi } from "./shell"
 import { constructSystemApi } from "./system"

packages/api/src/api/server/open.ts

@@ -2,6 +2,7 @@ import { exists, stat } from "@tauri-apps/plugin-fs"
 import { minimatch } from "minimatch"
 import { open } from "tauri-plugin-shellx-api"
 import { flatten, parse, pipe, safeParse, string, url, type InferOutput } from "valibot"
+import type { IOpen } from "../../api/client"
 import type { OpenPermissionScoped } from "../../permissions"
 import {
 	combinePathAndBaseDir,
@@ -10,7 +11,6 @@ import {
 	translateScopeToPath,
 	verifyScopedPermission
 } from "../../utils/path"
-import type { IOpen } from "../client"
 
 const UrlSchema = pipe(string("A URL must be string."), url("The URL is badly formatted."))
 

packages/api/src/api/server/path.ts

@@ -1,7 +1,7 @@
 import * as path from "@tauri-apps/api/path"
 import { exists, mkdir } from "@tauri-apps/plugin-fs"
 import { constructPathApi as constructTauriPathApi } from "tauri-api-adapter"
-import type { IPath } from "../client"
+import type { IPath } from "../../api/client"
 
 export async function constructExtensionSupportDir(extPath: string) {
 	const appDataDir = await path.appDataDir()

packages/api/src/api/server/security.ts

@@ -1,9 +1,9 @@
 import { Command, open } from "tauri-plugin-shellx-api"
 import * as v from "valibot"
+import { MacSecurityOptions, type ISecurity } from "../../api/client"
 import { macSecurity } from "../../commands"
 import { SecurityPermissionMap, type SecurityPermission } from "../../permissions"
 import { checkPermission } from "../../utils/permission-check"
-import { MacSecurityOptions, type ISecurity } from "../client"
 
 export function constructSecurityAPI(permissions: SecurityPermission[]): ISecurity {
 	return {

packages/api/src/api/server/shell.ts

@@ -10,13 +10,13 @@ import {
 	type InternalSpawnOptions,
 	type IOPayload
 } from "tauri-plugin-shellx-api"
+import type { DenoRunConfig } from "../../api/client"
+import type { IShellServer } from "../../api/server-types"
 import { RECORD_EXTENSION_PROCESS_EVENT, type IRecordExtensionProcessEvent } from "../../events"
 import { ShellPermissionMap } from "../../permissions/permission-map"
 import { type ShellPermission, type ShellPermissionScoped } from "../../permissions/schema"
 import { verifyScopedPermission } from "../../utils/path"
-import type { DenoRunConfig } from "../client"
 import { translateDenoCommand, verifyDenoCmdPermission } from "./deno"
-import type { IShellServer } from "./server-types"
 
 function matchRegexArgs(args: string[], regexes: string[]): boolean {
 	if (args.length !== regexes.length) {

packages/api/src/api/server/system.ts

@@ -1,4 +1,5 @@
 import { checkPermission } from "tauri-api-adapter/permissions"
+import type { ISystem } from "../../api/client"
 import {
 	ejectAllDisks,
 	emptyTrash,
@@ -36,7 +37,6 @@ import {
 	type SystemPermission
 } from "../../permissions"
 import { SystemPermissionMap } from "../../permissions/permission-map"
-import type { ISystem } from "../client"
 
 export function constructSystemApi(permissions: SystemPermission[]): ISystem {
 	return {

packages/api/src/api/server/toast.ts

@@ -1,14 +1,5 @@
 import { toast } from "svelte-sonner"
-import type {
-	GeneralToast,
-	GeneralToastParams,
-	IDb,
-	IFs,
-	ISystem,
-	IToast,
-	IUiIframe,
-	IUiWorker
-} from "../client"
+import type { GeneralToastParams, IToast } from "../../api/client"
 
 async function constructToast(
 	fn:

packages/api/src/api/server/ui.ts

@@ -1,6 +1,6 @@
 import { invoke } from "@tauri-apps/api/core"
 import { getCurrentWindow } from "@tauri-apps/api/window"
-import type { IUiIframeServer1 } from "./server-types"
+import type { IUiIframeServer1 } from "../../api/server-types"
 
 /**
  * Other APIs will be constructed in main window as they are used to manipulate UI directly

packages/api/src/api/server/utils.ts

@@ -1,5 +1,5 @@
+import type { IUtils } from "../../api/client"
 import { plistToJson } from "../../commands/utils"
-import type { IUtils } from "../client"
 
 export function constructUtilsApi(): IUtils {
 	return {

packages/api/src/api/shell.ts

@@ -15,8 +15,8 @@ import {
 	type OutputEvents,
 	type SpawnOptions
 } from "tauri-plugin-shellx-api"
-import { type DenoRunConfig } from "../client.ts"
-import type { IShellServer } from "../server/server-types.ts"
+import { type DenoRunConfig } from "./client.ts"
+import type { IShellServer } from "./server-types.ts"
 
 export class Child {
 	/** The child process `pid`. */

packages/api/src/api/toast.ts

@@ -1,5 +1,5 @@
 // import { proxy as comlinkProxy, type Remote } from "@huakunshen/comlink"
-import type { GeneralToastParams, IToast } from "../client"
+import type { GeneralToastParams, IToast } from "./client"
 
 export function constructToastAPI(api: IToast) {
 	return {

packages/api/src/headless/ext.ts

@@ -0,0 +1,7 @@
+export abstract class HeadlessWorkerExtension {
+	/**
+	 * Load the extension. Initialize the extension.
+	 * Will be called once when the extension is first loaded.
+	 */
+	abstract load(): Promise<void>
+}

packages/api/src/headless/index.ts

@@ -0,0 +1,117 @@
+import { RPCChannel, WorkerChildIO, type DestroyableIoInterface } from "kkrpc/browser"
+import type {
+	IClipboard,
+	IDialog,
+	// IEventInternal,
+	IFetchInternal,
+	// IFs,
+	ILogger,
+	INetwork,
+	INotification,
+	IOs,
+	// IPath,
+	IShellInternal,
+	ISystemInfo,
+	IUpdownload
+} from "tauri-api-adapter"
+import { constructFetchAPI, constructUpdownloadAPI } from "tauri-api-adapter/client"
+import type {
+	IApp,
+	IDb,
+	IEvent,
+	IFs,
+	IKV,
+	IOpen,
+	IPath,
+	ISecurity,
+	ISystem,
+	IToast,
+	IUtils
+} from "../api/client"
+import { constructEventAPI } from "../api/event"
+import { constructPathAPI } from "../api/path"
+import type { IShellServer } from "../api/server-types"
+import { constructShellAPI } from "../api/shell"
+import { constructToastAPI } from "../api/toast"
+import type { HeadlessWorkerExtension } from "./ext"
+
+/* -------------------------------------------------------------------------- */
+/*                               API Interfaces                               */
+/* -------------------------------------------------------------------------- */
+export type {
+	IClipboard,
+	IDialog,
+	ILogger,
+	INetwork,
+	INotification,
+	IOs,
+	IPath,
+	// IShell,
+	ISystemInfo,
+	IUpdownload,
+	IFetch
+} from "tauri-api-adapter"
+export type { ISystem, IToast, IUiIframe, IDb, IKV, IFs, IOpen, IEvent } from "../api/client"
+export type { IShell } from "../api/shell"
+export { HeadlessWorkerExtension } from "./ext"
+/* -------------------------------------------------------------------------- */
+/*                                     RPC                                    */
+/* -------------------------------------------------------------------------- */
+/**
+ * For the APIs annotated with "inherit from tauri-api-adapter", they inherit the client API completely from tauri-api-adapter
+ * There may be server API changes for them, but the client API can be inherited
+ */
+type API = {
+	db: IDb // for kunkun
+	kv: IKV // for kunkun
+	system: ISystem // for kunkun
+	open: IOpen // for kunkun
+	clipboard: IClipboard // inherit from tauri-api-adapter
+	dialog: IDialog // inherit from tauri-api-adapter
+	fetch: IFetchInternal // inherit from tauri-api-adapter
+	event: IEvent // for kunkun, override tauri-api-adapter's event API, expose only specified event, disallow, emit and listen
+	fs: IFs // customized for kunkun, add file search API on top of tauri-api-adapter's fs API
+	log: ILogger // inherit from tauri-api-adapter
+	notification: INotification // inherit from tauri-api-adapter
+	toast: IToast // for kunkun
+	os: IOs // inherit from tauri-api-adapter
+	path: IPath // inherit from tauri-api-adapter
+	shell: IShellServer // inherit from tauri-api-adapter
+	updownload: IUpdownload // inherit from tauri-api-adapter
+	sysInfo: ISystemInfo // inherit from tauri-api-adapter
+	network: INetwork // inherit from tauri-api-adapter
+	security: ISecurity // for kunkun
+	utils: IUtils // for kunkun
+	app: IApp
+}
+const io = new WorkerChildIO()
+const rpc = new RPCChannel<{}, API, DestroyableIoInterface>(io, {})
+export const api = rpc.getAPI()
+export function expose(api: HeadlessWorkerExtension) {
+	rpc.expose(api)
+}
+
+export const event = constructEventAPI(api.event) // this is different from event api from tauri-api-adapter
+export const fetch = constructFetchAPI(api.fetch)
+export const path = constructPathAPI(api.path)
+export const shell = constructShellAPI(api.shell)
+export const toast = constructToastAPI(api.toast)
+export const updownload = constructUpdownloadAPI(api.updownload)
+export const {
+	db,
+	kv,
+	os,
+	clipboard,
+	dialog,
+	fs,
+	log,
+	notification,
+	sysInfo,
+	network,
+	system,
+	open,
+	utils,
+	app,
+	security
+} = api
+export { Child, RPCChannel, Command, DenoCommand } from "../api/shell"

packages/api/src/index.ts

@@ -4,6 +4,7 @@ export {
 	isVersionBetween,
 	isCompatible
 } from "./version"
-export { constructExtensionSupportDir } from "./ui/server/path"
+export { constructExtensionSupportDir } from "./api/server/path"
+export { constructJarvisServerAPIWithPermissions } from "./api/server"
 export * from "./constants"
-export { TauriShellStdio } from "./ui/api/shell"
+export { TauriShellStdio } from "./api/shell"

packages/api/src/models/manifest.ts

@@ -1,17 +1,5 @@
 import { FsPermissionSchema } from "tauri-api-adapter/permissions"
-import {
-	array,
-	boolean,
-	enum_,
-	literal,
-	nullable,
-	number,
-	object,
-	optional,
-	string,
-	union,
-	type InferOutput
-} from "valibot"
+import * as v from "valibot"
 import {
 	AllKunkunPermission,
 	FsPermissionScopedSchema,
@@ -29,159 +17,159 @@ export enum OSPlatformEnum {
 	windows = "windows"
 }
 
-export const OSPlatform = enum_(OSPlatformEnum)
-export type OSPlatform = InferOutput<typeof OSPlatform>
+export const OSPlatform = v.enum_(OSPlatformEnum)
+export type OSPlatform = v.InferOutput<typeof OSPlatform>
 const allPlatforms = Object.values(OSPlatformEnum)
-export const TriggerCmd = object({
-	type: union([literal("text"), literal("regex")]),
-	value: string()
+export const TriggerCmd = v.object({
+	type: v.union([v.literal("text"), v.literal("regex")]),
+	value: v.string()
 })
-export type TriggerCmd = InferOutput<typeof TriggerCmd>
+export type TriggerCmd = v.InferOutput<typeof TriggerCmd>
 export enum TitleBarStyleEnum {
 	"visible" = "visible",
 	"transparent" = "transparent",
 	"overlay" = "overlay"
 }
-export const TitleBarStyle = enum_(TitleBarStyleEnum)
+export const TitleBarStyle = v.enum_(TitleBarStyleEnum)
 // JS new WebViewWindow only accepts lowercase, while manifest loaded from Rust is capitalized. I run toLowerCase() on the value before passing it to the WebViewWindow.
 // This lowercase title bar style schema is used to validate and set the type so TypeScript won't complaint
 // export const TitleBarStyleAllLower = z.enum(["visible", "transparent", "overlay"]);
 // export type TitleBarStyleAllLower = z.infer<typeof TitleBarStyleAllLower>;
-export const WindowConfig = object({
-	center: optional(nullable(boolean())),
-	x: optional(nullable(number())),
-	y: optional(nullable(number())),
-	width: optional(nullable(number())),
-	height: optional(nullable(number())),
-	minWidth: optional(nullable(number())),
-	minHeight: optional(nullable(number())),
-	maxWidth: optional(nullable(number())),
-	maxHeight: optional(nullable(number())),
-	resizable: optional(nullable(boolean())),
-	title: optional(nullable(string())),
-	fullscreen: optional(nullable(boolean())),
-	focus: optional(nullable(boolean())),
-	transparent: optional(nullable(boolean())),
-	maximized: optional(nullable(boolean())),
-	visible: optional(nullable(boolean())),
-	decorations: optional(nullable(boolean())),
-	alwaysOnTop: optional(nullable(boolean())),
-	alwaysOnBottom: optional(nullable(boolean())),
-	contentProtected: optional(nullable(boolean())),
-	skipTaskbar: optional(nullable(boolean())),
-	shadow: optional(nullable(boolean())),
+export const WindowConfig = v.object({
+	center: v.optional(v.nullable(v.boolean())),
+	x: v.optional(v.nullable(v.number())),
+	y: v.optional(v.nullable(v.number())),
+	width: v.optional(v.nullable(v.number())),
+	height: v.optional(v.nullable(v.number())),
+	minWidth: v.optional(v.nullable(v.number())),
+	minHeight: v.optional(v.nullable(v.number())),
+	maxWidth: v.optional(v.nullable(v.number())),
+	maxHeight: v.optional(v.nullable(v.number())),
+	resizable: v.optional(v.nullable(v.boolean())),
+	title: v.optional(v.nullable(v.string())),
+	fullscreen: v.optional(v.nullable(v.boolean())),
+	focus: v.optional(v.nullable(v.boolean())),
+	transparent: v.optional(v.nullable(v.boolean())),
+	maximized: v.optional(v.nullable(v.boolean())),
+	visible: v.optional(v.nullable(v.boolean())),
+	decorations: v.optional(v.nullable(v.boolean())),
+	alwaysOnTop: v.optional(v.nullable(v.boolean())),
+	alwaysOnBottom: v.optional(v.nullable(v.boolean())),
+	contentProtected: v.optional(v.nullable(v.boolean())),
+	skipTaskbar: v.optional(v.nullable(v.boolean())),
+	shadow: v.optional(v.nullable(v.boolean())),
 	// theme: optional(nullable(union([literal("light"), literal("dark")]))), // changing theme of one window will change theme of all windows
-	titleBarStyle: optional(nullable(TitleBarStyle)),
-	hiddenTitle: optional(nullable(boolean())),
-	tabbingIdentifier: optional(nullable(string())),
-	maximizable: optional(nullable(boolean())),
-	minimizable: optional(nullable(boolean())),
-	closable: optional(nullable(boolean())),
-	parent: optional(nullable(string())),
-	visibleOnAllWorkspaces: optional(nullable(boolean()))
+	titleBarStyle: v.optional(v.nullable(TitleBarStyle)),
+	hiddenTitle: v.optional(v.nullable(v.boolean())),
+	tabbingIdentifier: v.optional(v.nullable(v.string())),
+	maximizable: v.optional(v.nullable(v.boolean())),
+	minimizable: v.optional(v.nullable(v.boolean())),
+	closable: v.optional(v.nullable(v.boolean())),
+	parent: v.optional(v.nullable(v.string())),
+	visibleOnAllWorkspaces: v.optional(v.nullable(v.boolean()))
 })
-export type WindowConfig = InferOutput<typeof WindowConfig>
-export const CustomUiCmd = object({
-	type: optional(CmdType, CmdType.enum.UiIframe),
-	main: string("HTML file to load, e.g. dist/index.html"),
-	dist: string("Dist folder to load, e.g. dist, build, out"),
-	description: optional(nullable(string("Description of the Command"), ""), ""),
-	devMain: string("URL to load in development to support live reload, e.g. http://localhost:5173/"),
-	name: string("Name of the command"),
-	window: optional(nullable(WindowConfig)),
-	cmds: array(TriggerCmd, "Commands to trigger the UI"),
-	icon: optional(Icon),
-	platforms: optional(
-		nullable(
-			array(OSPlatform, "Platforms available on. Leave empty for all platforms."),
+export type WindowConfig = v.InferOutput<typeof WindowConfig>
+export const BaseCmd = v.object({
+	main: v.string("HTML file to load, e.g. dist/index.html"),
+	description: v.optional(v.nullable(v.string("Description of the Command"), ""), ""),
+	name: v.string("Name of the command"),
+	cmds: v.array(TriggerCmd, "Commands to trigger the UI"),
+	icon: v.optional(Icon),
+	platforms: v.optional(
+		v.nullable(
+			v.array(OSPlatform, "Platforms available on. Leave empty for all platforms."),
 			allPlatforms
 		),
 		allPlatforms
 	)
 })
-export type CustomUiCmd = InferOutput<typeof CustomUiCmd>
+export const CustomUiCmd = v.object({
+	...BaseCmd.entries,
+	type: v.optional(CmdType, CmdType.enum.UiIframe),
+	dist: v.string("Dist folder to load, e.g. dist, build, out"),
+	devMain: v.string(
+		"URL to load in development to support live reload, e.g. http://localhost:5173/"
+	),
+	window: v.optional(v.nullable(WindowConfig))
+})
+export type CustomUiCmd = v.InferOutput<typeof CustomUiCmd>
 
-export const TemplateUiCmd = object({
-	type: optional(CmdType, CmdType.enum.UiWorker),
-	main: string(),
-	name: string(),
-	description: optional(nullable(string("Description of the Command"), ""), ""),
-	window: optional(nullable(WindowConfig)),
-	cmds: array(TriggerCmd),
-	icon: optional(Icon),
-	platforms: optional(
-		nullable(
-			array(OSPlatform, "Platforms available on. Leave empty for all platforms."),
-			allPlatforms
-		),
-		allPlatforms
-	)
+export const TemplateUiCmd = v.object({
+	...BaseCmd.entries,
+	type: v.optional(CmdType, CmdType.enum.UiWorker),
+	window: v.optional(v.nullable(WindowConfig))
 })
-export type TemplateUiCmd = InferOutput<typeof TemplateUiCmd>
-export const PermissionUnion = union([
+export const HeadlessCmd = v.object({
+	...BaseCmd.entries,
+	type: v.optional(CmdType, CmdType.enum.HeadlessWorker)
+})
+export type HeadlessCmd = v.InferOutput<typeof HeadlessCmd>
+export type TemplateUiCmd = v.InferOutput<typeof TemplateUiCmd>
+export const PermissionUnion = v.union([
 	KunkunManifestPermission,
 	FsPermissionScopedSchema,
 	OpenPermissionScopedSchema,
 	ShellPermissionScopedSchema
 ])
-export type PermissionUnion = InferOutput<typeof PermissionUnion>
-export const KunkunExtManifest = object({
-	name: string("Name of the extension (Human Readable)"),
-	shortDescription: string("Description of the extension (Will be displayed in store)"),
-	longDescription: string("Long description of the extension (Will be displayed in store)"),
-	identifier: string(
+export type PermissionUnion = v.InferOutput<typeof PermissionUnion>
+export const KunkunExtManifest = v.object({
+	name: v.string("Name of the extension (Human Readable)"),
+	shortDescription: v.string("Description of the extension (Will be displayed in store)"),
+	longDescription: v.string("Long description of the extension (Will be displayed in store)"),
+	identifier: v.string(
 		"Unique identifier for the extension, must be the same as extension folder name"
 	),
 	icon: Icon,
-	permissions: array(
+	permissions: v.array(
 		PermissionUnion,
 		"Permissions Declared by the extension. e.g. clipboard-all. Not declared APIs will be blocked."
 	),
-	demoImages: array(string("Demo images for the extension")),
-	customUiCmds: array(CustomUiCmd, "Custom UI Commands"),
-	templateUiCmds: array(TemplateUiCmd, "Template UI Commands")
+	demoImages: v.array(v.string("Demo images for the extension")),
+	customUiCmds: v.optional(v.array(CustomUiCmd, "Custom UI Commands")),
+	templateUiCmds: v.optional(v.array(TemplateUiCmd, "Template UI Commands")),
+	headlessCmds: v.optional(v.array(HeadlessCmd, "Headless Commands"))
 })
-export type KunkunExtManifest = InferOutput<typeof KunkunExtManifest>
+export type KunkunExtManifest = v.InferOutput<typeof KunkunExtManifest>
 
-const Person = union([
-	object({
-		name: string("GitHub Username"),
-		email: string("Email of the person"),
-		url: optional(nullable(string("URL of the person")))
+const Person = v.union([
+	v.object({
+		name: v.string("GitHub Username"),
+		email: v.string("Email of the person"),
+		url: v.optional(v.nullable(v.string("URL of the person")))
 	}),
-	string("GitHub Username")
+	v.string("GitHub Username")
 ])
 
-export const ExtPackageJson = object({
-	name: string("Package name for the extension (just a regular npm package name)"),
-	version: string("Version of the extension"),
-	author: optional(Person),
-	draft: optional(boolean("Whether the extension is a draft, draft will not be published")),
-	contributors: optional(array(Person, "Contributors of the extension")),
-	repository: optional(
-		union([
-			string("URL of the repository"),
-			object({
-				type: string("Type of the repository"),
-				url: string("URL of the repository"),
-				directory: string("Directory of the repository")
+export const ExtPackageJson = v.object({
+	name: v.string("Package name for the extension (just a regular npm package name)"),
+	version: v.string("Version of the extension"),
+	author: v.optional(Person),
+	draft: v.optional(v.boolean("Whether the extension is a draft, draft will not be published")),
+	contributors: v.optional(v.array(Person, "Contributors of the extension")),
+	repository: v.optional(
+		v.union([
+			v.string("URL of the repository"),
+			v.object({
+				type: v.string("Type of the repository"),
+				url: v.string("URL of the repository"),
+				directory: v.string("Directory of the repository")
 			})
 		])
 	),
 	kunkun: KunkunExtManifest,
-	files: array(string("Files to include in the extension. e.g. ['dist']"))
+	files: v.array(v.string("Files to include in the extension. e.g. ['dist']"))
 })
-export type ExtPackageJson = InferOutput<typeof ExtPackageJson>
+export type ExtPackageJson = v.InferOutput<typeof ExtPackageJson>
 /**
  * Extra fields for ExtPackageJson
  * e.g. path to the extension
  */
-export const ExtPackageJsonExtra = object({
+export const ExtPackageJsonExtra = v.object({
 	...ExtPackageJson.entries,
 	...{
-		extPath: string(),
-		extFolderName: string()
+		extPath: v.string(),
+		extFolderName: v.string()
 	}
 })
 
-export type ExtPackageJsonExtra = InferOutput<typeof ExtPackageJsonExtra>
+export type ExtPackageJsonExtra = v.InferOutput<typeof ExtPackageJsonExtra>

packages/api/src/permissions/permission-map.ts

@@ -1,6 +1,6 @@
 import type { IShellServer } from "tauri-api-adapter"
 // import type { IEventServer, IFsServer, ISystemServer } from "../ui/server/server-types"
-import type { IEvent, IFs, ISecurity, ISystem } from "../ui/client"
+import type { IEvent, IFs, ISecurity, ISystem } from "../api/client"
 import type {
 	EventPermission,
 	KunkunFsPermission,

packages/api/src/ui/api/deno.ts

@@ -1,2 +0,0 @@
-import type { DenoSysOptions } from "../../permissions/schema"
-import type { DenoRunConfig } from "../client"

packages/api/src/ui/client.ts

@@ -1,314 +0,0 @@
-import type {
-	copyFile,
-	create,
-	exists,
-	lstat,
-	mkdir,
-	readDir,
-	readFile,
-	readTextFile,
-	remove,
-	rename,
-	stat,
-	truncate,
-	writeFile,
-	writeTextFile
-} from "@tauri-apps/plugin-fs"
-import type { IShell as IShell1, IPath as ITauriPath } from "tauri-api-adapter"
-import type {
-	Child,
-	ChildProcess,
-	CommandEvents,
-	hasCommand,
-	InternalSpawnOptions,
-	IOPayload,
-	likelyOnWindows,
-	OutputEvents,
-	SpawnOptions
-} from "tauri-plugin-shellx-api"
-import { EventEmitter, open as shellxOpen } from "tauri-plugin-shellx-api"
-import * as v from "valibot"
-import { KV, type JarvisExtDB } from "../commands/db"
-import type { fileSearch } from "../commands/fileSearch"
-import { type AppInfo } from "../models/apps"
-import type { LightMode, Position, Radius, ThemeColor } from "../models/styles"
-import type { DenoSysOptions } from "../permissions/schema"
-import type { MarkdownSchema } from "./worker"
-import { type IComponent } from "./worker/components/interfaces"
-import type { Markdown } from "./worker/components/markdown"
-import * as FormSchema from "./worker/schema/form"
-import * as ListSchema from "./worker/schema/list"
-
-type PromiseWrap<T extends (...args: any[]) => any> = (
-	...args: Parameters<T>
-) => Promise<ReturnType<T>>
-
-export type IPath = ITauriPath & {
-	extensionDir: () => Promise<string>
-	extensionSupportDir: () => Promise<string>
-}
-
-export interface IPlist {
-	// build: PromiseWrap<typeof plist.build>
-	parse: (plistContent: string) => Promise<any>
-}
-
-export interface IUtils {
-	plist: IPlist
-}
-
-export interface ISystem {
-	openTrash(): Promise<void>
-	emptyTrash(): Promise<void>
-	shutdown(): Promise<void>
-	reboot(): Promise<void>
-	sleep(): Promise<void>
-	toggleSystemAppearance(): Promise<void>
-	showDesktop(): Promise<void>
-	quitAllApps(): Promise<void>
-	sleepDisplays(): Promise<void>
-	setVolume(percentage: number): Promise<void>
-	setVolumeTo0(): Promise<void>
-	setVolumeTo25(): Promise<void>
-	setVolumeTo50(): Promise<void>
-	setVolumeTo75(): Promise<void>
-	setVolumeTo100(): Promise<void>
-	turnVolumeUp(): Promise<void>
-	turnVolumeDown(): Promise<void>
-	toggleStageManager(): Promise<void>
-	toggleBluetooth(): Promise<void>
-	toggleHiddenFiles(): Promise<void>
-	ejectAllDisks(): Promise<void>
-	logoutUser(): Promise<void>
-	toggleMute(): Promise<void>
-	mute(): Promise<void>
-	unmute(): Promise<void>
-	getFrontmostApp(): Promise<AppInfo>
-	hideAllAppsExceptFrontmost(): Promise<void>
-	getSelectedFilesInFileExplorer(): Promise<string[]>
-}
-
-export type GeneralToastParams = {
-	description?: string
-	duration?: number
-	closeButton?: boolean
-	position?:
-		| "top-left"
-		| "top-right"
-		| "bottom-left"
-		| "bottom-right"
-		| "top-center"
-		| "bottom-center"
-	actionLabel?: string
-}
-
-export type GeneralToast = (
-	message: string,
-	options?: GeneralToastParams,
-	action?: () => void
-) => Promise<void>
-
-export interface IToast {
-	message: GeneralToast
-	info: GeneralToast
-	success: GeneralToast
-	warning: GeneralToast
-	error: GeneralToast
-}
-
-export interface IUiWorker {
-	render: (view: IComponent<ListSchema.List | FormSchema.Form | MarkdownSchema>) => Promise<void>
-	goBack: () => Promise<void>
-	showLoadingBar: (loading: boolean) => Promise<void>
-	setScrollLoading: (loading: boolean) => Promise<void>
-	setSearchTerm: (term: string) => Promise<void>
-	setSearchBarPlaceholder: (placeholder: string) => Promise<void>
-	setProgressBar: (progress: number | null) => Promise<void>
-}
-
-export interface IUiIframe {
-	// goHome: () => Promise<void>
-	goBack: () => Promise<void>
-	hideBackButton: () => Promise<void>
-	hideMoveButton: () => Promise<void>
-	hideRefreshButton: () => Promise<void>
-	/**
-	 * position can be "top-left" | "top-right" | "bottom-left" | "bottom-right" | CustomPosition
-	 * `CustomPosition` is an object with optional `top`, `right`, `bottom`, `left` properties
-	 * Each property is a number, with `rem` unit, and will be applied to css `top`, `right`, `bottom`, `left` properties
-	 * @param position "top-left" | "top-right" | "bottom-left" | "bottom-right" | CustomPosition
-	 * @example
-	 * ```ts
-	 * ui.showBackButton({ top: 2, left: 2 })
-	 * ui.showBackButton('top-right')
-	 * ```
-	 * @returns
-	 */
-	showBackButton: (position?: Position) => Promise<void>
-	/**
-	 * position can be "top-left" | "top-right" | "bottom-left" | "bottom-right" | CustomPosition
-	 * `CustomPosition` is an object with optional `top`, `right`, `bottom`, `left` properties
-	 * Each property is a number, with `rem` unit, and will be applied to css `top`, `right`, `bottom`, `left` properties
-	 * @param position "top-left" | "top-right" | "bottom-left" | "bottom-right" | CustomPosition
-	 * @example
-	 * ```ts
-	 * ui.showBackButton({ top: 2, left: 2 })
-	 * ui.showBackButton('top-right')
-	 * ```
-	 * @returns
-	 */
-	showMoveButton: (position?: Position) => Promise<void>
-	showRefreshButton: (position?: Position) => Promise<void>
-	getTheme: () => Promise<{
-		theme: ThemeColor
-		radius: Radius
-		lightMode: LightMode
-	}>
-	reloadPage: () => Promise<void>
-	startDragging: () => Promise<void>
-	toggleMaximize: () => Promise<void>
-	internalToggleMaximize: () => Promise<void>
-	setTransparentWindowBackground: (transparent: boolean) => Promise<void>
-	registerDragRegion: () => Promise<void>
-}
-
-export interface IDb {
-	add: typeof JarvisExtDB.prototype.add
-	delete: typeof JarvisExtDB.prototype.delete
-	search: typeof JarvisExtDB.prototype.search
-	retrieveAll: typeof JarvisExtDB.prototype.retrieveAll
-	retrieveAllByType: typeof JarvisExtDB.prototype.retrieveAllByType
-	deleteAll: typeof JarvisExtDB.prototype.deleteAll
-	update: typeof JarvisExtDB.prototype.update
-}
-
-export interface IKV {
-	get: typeof KV.prototype.get
-	set: typeof KV.prototype.set
-	exists: typeof KV.prototype.exists
-	delete: typeof KV.prototype.delete
-}
-
-export interface IFs {
-	readDir: typeof readDir
-	readFile: typeof readFile
-	readTextFile: typeof readTextFile
-	stat: typeof stat
-	lstat: typeof lstat
-	exists: typeof exists
-	mkdir: typeof mkdir
-	create: typeof create
-	copyFile: typeof copyFile
-	remove: typeof remove
-	rename: typeof rename
-	truncate: typeof truncate
-	writeFile: typeof writeFile
-	writeTextFile: typeof writeTextFile
-	fileSearch: typeof fileSearch
-}
-
-export interface IOpen {
-	url: (url: string) => Promise<void>
-	file: (path: string) => Promise<void>
-	folder: (path: string) => Promise<void>
-}
-
-/* -------------------------------------------------------------------------- */
-/*                                  Event API                                 */
-/* -------------------------------------------------------------------------- */
-export type DragDropPayload = {
-	paths: string[]
-	position: { x: number; y: number }
-}
-export type DragEnterPayload = DragDropPayload
-export type DragOverPayload = {
-	position: { x: number; y: number }
-}
-
-export interface IEvent {
-	/**
-	 * Get files dropped on the window
-	 */
-	onDragDrop: (callback: (payload: DragDropPayload) => void) => void
-	/**
-	 * Listen to drag enter event, when mouse drag enters the window
-	 */
-	onDragEnter: (callback: (payload: DragEnterPayload) => void) => void
-	/**
-	 * Listen to drag leave event, when mouse drag leaves the window
-	 */
-	onDragLeave: (callback: () => void) => void
-	/**
-	 * Get the position of the dragged item
-	 */
-	onDragOver: (callback: (payload: DragOverPayload) => void) => void
-	/**
-	 * Listen to window blur (defocus) event
-	 */
-	onWindowBlur: (callback: () => void) => void
-	/**
-	 * Listen to window close request event
-	 */
-	onWindowCloseRequested: (callback: () => void) => void
-	/**
-	 * Listen to window on focus event
-	 */
-	onWindowFocus: (callback: () => void) => void
-}
-
-/**
- * https://docs.deno.com/runtime/fundamentals/security/
- */
-export interface DenoRunConfig {
-	allowNet?: string[]
-	allowAllNet?: boolean
-	allowRead?: string[]
-	allowAllRead?: boolean
-	allowWrite?: string[]
-	allowAllWrite?: boolean
-	allowRun?: string[]
-	allowAllRun?: boolean
-	allowEnv?: string[]
-	allowAllEnv?: boolean
-	allowFfi?: string[]
-	allowAllFfi?: boolean
-	allowSys?: DenoSysOptions[]
-	allowAllSys?: boolean
-	denyNet?: string[]
-	denyAllNet?: boolean
-	denyRead?: string[]
-	denyAllRead?: boolean
-	denyWrite?: string[]
-	denyAllWrite?: boolean
-	denyRun?: string[]
-	denyAllRun?: boolean
-	denyEnv?: string[]
-	denyAllEnv?: boolean
-	denyFfi?: string[]
-	denyAllFfi?: boolean
-	denySys?: DenoSysOptions[]
-	denyAllSys?: boolean
-}
-
-export interface IApp {
-	language: () => Promise<"en" | "zh">
-}
-
-export const MacSecurityOptions = v.union([
-	v.literal("ScreenCapture"),
-	v.literal("Camera"),
-	v.literal("Microphone"),
-	v.literal("Accessibility"),
-	v.literal("AllFiles")
-])
-export type MacSecurityOptions = v.InferOutput<typeof MacSecurityOptions>
-
-export interface ISecurity {
-	mac: {
-		revealSecurityPane: (privacyOption?: MacSecurityOptions) => Promise<void>
-		resetPermission: (privacyOption: MacSecurityOptions) => Promise<void>
-		verifyFingerprint: () => Promise<boolean>
-		requestScreenCapturePermission: () => Promise<boolean>
-		checkScreenCapturePermission: () => Promise<boolean>
-	}
-}

packages/api/src/ui/iframe/index.ts

@@ -20,10 +20,6 @@ import {
 	// constructPathAPI,
 	constructUpdownloadAPI
 } from "tauri-api-adapter/client"
-import { constructEventAPI } from "../api/event"
-import { constructIframeUiAPI } from "../api/iframe-ui"
-import { constructPathAPI } from "../api/path"
-import { constructShellAPI } from "../api/shell"
 import type {
 	IApp,
 	IDb,
@@ -36,13 +32,17 @@ import type {
 	IToast,
 	IUiIframe,
 	IUtils
-} from "../client"
-import type { IShellServer } from "../server/server-types"
+} from "../../api/client"
+import { constructEventAPI } from "../../api/event"
+import { constructIframeUiAPI } from "../../api/iframe-ui"
+import { constructPathAPI } from "../../api/path"
+import type { IShellServer } from "../../api/server-types"
+import { constructShellAPI } from "../../api/shell"
 
-export { type IUiIframe } from "../client"
+export { type IUiIframe } from "../../api/client"
 // export { expose, wrap } from "@huakunshen/comlink"
 // export { type IDbServer } from "../server/db"
-export { type IUiIframeServer2, type IUiIframeServer1 } from "../server/server-types"
+export { type IUiIframeServer2, type IUiIframeServer1 } from "../../api/server-types"
 
 /**
  * For the APIs annotated with "inherit from tauri-api-adapter", they inherit the client API completely from tauri-api-adapter
@@ -98,4 +98,4 @@ export const {
 	open,
 	app
 } = api
-export { Child, RPCChannel, Command, DenoCommand } from "../api/shell"
+export { Child, RPCChannel, Command, DenoCommand } from "../../api/shell"

packages/api/src/ui/index.ts

@@ -16,9 +16,9 @@
 // 	updownload,
 // 	fetch
 // } from "tauri-api-adapter"
-export { constructJarvisServerAPIWithPermissions } from "./server"
+export { constructJarvisServerAPIWithPermissions } from "../api/server"
 // export { type IUiWorkerServer, type IUiIframeServer } from "./server/ui"
-export * from "./client" // all client types
+export * from "../api/client" // all client types
 // export { expose, wrap } from "@huakunshen/comlink"
 // export { getWorkerApiClient, exposeApiToWorker, exposeApiToWindow } from "tauri-api-adapter"
 
@@ -38,15 +38,6 @@ export type {
 	IUpdownload,
 	IFetch
 } from "tauri-api-adapter"
-export type {
-	ISystem,
-	IToast,
-	IUiWorker,
-	IUiIframe,
-	IDb,
-	IKV,
-	IFs,
-	IOpen,
-	IEvent
-} from "../ui/client"
-export type { IShell } from "./api/shell"
+export type { ISystem, IToast, IUiIframe, IDb, IKV, IFs, IOpen, IEvent } from "../api/client"
+export type { IUiWorker } from "./worker"
+export type { IShell } from "../api/shell"

packages/api/src/ui/server/__tests__/fs.test.ts

@@ -1,9 +0,0 @@
-import { describe, expect, test } from "bun:test"
-import { minimatch } from "minimatch"
-import { translateScopeToPath } from "../../../utils/path"
-
-test("minimatch", () => {
-	// console.log(minimatch("/desktop/newbi/bar.foo", "/desktop/**/*.foo"))
-	// console.log("$DESKTOP/newbi/bar.foo".split("/"))
-	// find the first slash of "$DESKTOP/newbi/bar.foo"
-})

packages/api/src/ui/server/__tests__/shell.test.ts

@@ -1,36 +0,0 @@
-import { mockIPC } from "@tauri-apps/api/mocks"
-import { describe, expect, test } from "bun:test"
-import { translateDenoCommand } from "../deno"
-
-// can't run this because it relies on Tauri API, I can't run it without Tauri app env, may need to mock the API
-// test("translateDenoCommand", async () => {
-// 	// mockIPC((cmd, args) => {
-// 	// 	// simulated rust command called "add" that just adds two numbers
-// 	// 	console.log("cmd and args", cmd, args);
-
-// 	// 	// if (cmd === "add") {
-// 	// 	// 	return (args.a as number) + (args.b as number)
-// 	// 	// }
-// 	// })
-// 	const cmdOptions = await translateDenoCommand(
-// 		"$EXTENSION/src/test.ts",
-// 		{
-// 			allowAllEnv: false,
-// 			allowEnv: ["PATH"],
-// 			allowAllNet: true,
-// 			allowNet: [],
-// 			denyAllRead: true
-// 		},
-// 		[],
-// 		"/extensions/ext"
-// 	)
-
-// 	expect(cmdOptions.args).toEqual([
-// 		"run",
-// 		"--allow-env=PATH",
-// 		"--allow-net",
-// 		"--deny-read",
-// 		"/extensions/ext/src/test.ts"
-// 	])
-// 	console.log(cmdOptions)
-// })

packages/api/src/ui/server/db.ts

@@ -1,19 +0,0 @@
-/**
- * The server-side API for the database will not be implemented in this file/package
- * It will be constructed with JarvisExtDB in the main thread and exposed to the extension
- * We don't know extension ID here, so we can't construct the API here
- */
-import type { JarvisExtDB } from "../../commands"
-import type { IDb, IFs, ISystem, IToast, IUiIframe, IUiWorker } from "../client"
-
-// export function constructJarvisExtDBToServerDbAPI(db: JarvisExtDB): IDb {
-// 	return {
-// 		add: (data) => db.add(data),
-// 		delete: (dataId) => db.delete(dataId),
-// 		search: (searchParams) => db.search(searchParams),
-// 		retrieveAll: (options) => db.retrieveAll(options),
-// 		retrieveAllByType: (dataType) => db.retrieveAllByType(dataType),
-// 		deleteAll: () => db.deleteAll(),
-// 		update: (data) => db.update(data)
-// 	}
-// }

packages/api/src/ui/worker/index.ts

@@ -25,10 +25,6 @@ import {
 	// constructShellAPI,
 	constructUpdownloadAPI
 } from "tauri-api-adapter/client"
-import { constructEventAPI } from "../api/event"
-import { constructPathAPI } from "../api/path"
-import { constructShellAPI } from "../api/shell"
-import { constructToastAPI } from "../api/toast"
 import type {
 	IApp,
 	IDb,
@@ -40,12 +36,27 @@ import type {
 	ISecurity,
 	ISystem,
 	IToast,
-	IUiWorker,
 	IUtils
-} from "../client"
-import type { IShellServer } from "../server/server-types"
+} from "../../api/client"
+import { constructEventAPI } from "../../api/event"
+import { constructPathAPI } from "../../api/path"
+import type { IShellServer } from "../../api/server-types"
+import { constructShellAPI } from "../../api/shell"
+import { constructToastAPI } from "../../api/toast"
+import type { FormSchema, ListSchema, MarkdownSchema } from "../../models"
+import type { IComponent } from "./components"
 import type { WorkerExtension } from "./ext"
 
+export interface IUiWorker {
+	render: (view: IComponent<ListSchema.List | FormSchema.Form | MarkdownSchema>) => Promise<void>
+	goBack: () => Promise<void>
+	showLoadingBar: (loading: boolean) => Promise<void>
+	setScrollLoading: (loading: boolean) => Promise<void>
+	setSearchTerm: (term: string) => Promise<void>
+	setSearchBarPlaceholder: (placeholder: string) => Promise<void>
+	setProgressBar: (progress: number | null) => Promise<void>
+}
+
 // export { expose, wrap } from "@huakunshen/comlink"
 export { WorkerExtension } from "./ext"
 /**
@@ -77,7 +88,9 @@ type API = {
 	app: IApp
 }
 
-// const _api = wrap(globalThis as Endpoint) as unknown as API
+/* -------------------------------------------------------------------------- */
+/*                                   Expose                                   */
+/* -------------------------------------------------------------------------- */
 const io = new WorkerChildIO()
 const rpc = new RPCChannel<{}, API, DestroyableIoInterface>(io, {})
 export const api = rpc.getAPI()
@@ -110,7 +123,7 @@ export const {
 	security,
 	workerUi: ui
 } = api
-export { Child, RPCChannel, Command, DenoCommand } from "../api/shell"
+export { Child, RPCChannel, Command, DenoCommand } from "../../api/shell"
 /* -------------------------------------------------------------------------- */
 /*                             UI Component Schema                            */
 /* -------------------------------------------------------------------------- */
@@ -125,14 +138,3 @@ export { Icon } from "./components/icon"
 export { IconEnum, IconType, IconNode } from "../../models/icon"
 export * as schema from "./schema"
 export { NodeName, NodeNameEnum, FormNodeName, FormNodeNameEnum } from "../../models/constants"
-
-/* -------------------------------------------------------------------------- */
-/*                                   Expose                                   */
-/* -------------------------------------------------------------------------- */
-// export function expose(api: WorkerExtension) {
-// 	const io = new WorkerChildIO()
-// 	const rpc = new RPCChannel(io, {
-// 		expose: api
-// 	})
-// 	return rpc.getAPI()
-// }

packages/api/src/version.ts

@@ -21,7 +21,7 @@ export const breakingChangesVersionCheckpoints = [
 const checkpointVersions = breakingChangesVersionCheckpoints.map((c) => c.version)
 const sortedCheckpointVersions = sort(checkpointVersions)
 
-export const version = "0.0.46"
+export const version = "0.0.47"
 
 export function isVersionBetween(v: string, start: string, end: string) {
 	const vCleaned = clean(v)

packages/extensions/demo-worker-template-ext/build.ts

@@ -7,7 +7,7 @@ async function build() {
 	try {
 		// await $`bun build --minify --target=browser --outdir=./dist ./src/index.ts`
 		const output = await Bun.build({
-			entrypoints: ["./src/index.ts"],
+			entrypoints: ["./src/index.ts", "./src/headless.ts"],
 			outdir: "./dist",
 			minify: true,
 			target: "browser"

packages/extensions/demo-worker-template-ext/package.json

@@ -80,6 +80,17 @@
 				"main": "dist/index.js",
 				"cmds": []
 			}
+		],
+		"headlessCmds": [
+			{
+				"name": "Demo Headless Command",
+				"main": "dist/headless.js",
+				"cmds": [],
+				"icon": {
+					"type": "iconify",
+					"value": "mdi:head-remove-outline"
+				}
+			}
 		]
 	},
 	"scripts": {

packages/extensions/demo-worker-template-ext/src/headless.ts

@@ -0,0 +1,10 @@
+import { expose, HeadlessWorkerExtension, toast } from "@kksh/api/headless"
+
+class DemoHeadlessExt extends HeadlessWorkerExtension {
+	load(): Promise<void> {
+		console.log("Demo Headless Extension Loaded")
+		toast.info("Demo Headless Extension Loaded")
+		return Promise.resolve()
+	}
+}
+expose(new DemoHeadlessExt())

packages/tauri-plugins/jarvis/permissions/autogenerated/reference.md

@@ -1,4 +1,3 @@
-
 ## Permission Table
 
 <table>
@@ -7,7 +6,6 @@
 <th>Description</th>
 </tr>
 
-
 <tr>
 <td>
 

packages/ui/src/components/main/ExtCmdsGroup.svelte

@@ -1,7 +1,13 @@
 <!-- This file renders a group of extension commands -->
 <!-- Input props to this component is an array of ExtPackageJsonExtra[] -->
 <script lang="ts">
-	import { CmdTypeEnum, CustomUiCmd, ExtPackageJsonExtra, TemplateUiCmd } from "@kksh/api/models"
+	import {
+		CmdTypeEnum,
+		CustomUiCmd,
+		ExtPackageJsonExtra,
+		HeadlessCmd,
+		TemplateUiCmd
+	} from "@kksh/api/models"
 	import { Badge, Command } from "@kksh/svelte5"
 	import { IconMultiplexer } from "@kksh/ui"
 	import { DraggableCommandGroup } from "../custom"
@@ -22,7 +28,7 @@
 	} = $props()
 </script>
 
-{#snippet cmd(ext: ExtPackageJsonExtra, cmd: CustomUiCmd | TemplateUiCmd)}
+{#snippet cmd(ext: ExtPackageJsonExtra, cmd: CustomUiCmd | TemplateUiCmd | HeadlessCmd)}
 	<Command.Item
 		class="flex justify-between"
 		onSelect={() => {
@@ -50,10 +56,13 @@
 {/snippet}
 
 {#snippet ext(ext: ExtPackageJsonExtra)}
-	{#each ext.kunkun.customUiCmds as _cmd}
+	{#each ext.kunkun.customUiCmds ?? [] as _cmd}
 		{@render cmd(ext, _cmd)}
 	{/each}
-	{#each ext.kunkun.templateUiCmds as _cmd}
+	{#each ext.kunkun.templateUiCmds ?? [] as _cmd}
+		{@render cmd(ext, _cmd)}
+	{/each}
+	{#each ext.kunkun.headlessCmds ?? [] as _cmd}
 		{@render cmd(ext, _cmd)}
 	{/each}
 {/snippet}

pnpm-lock.yaml

@@ -12267,7 +12267,7 @@ snapshots:
 
   '@kwsites/file-exists@1.1.1':
     dependencies:
-      debug: 4.3.7
+      debug: 4.4.0(supports-color@9.4.0)
     transitivePeerDependencies:
       - supports-color
 
@@ -18518,7 +18518,7 @@ snapshots:
 
   koa-send@5.0.1:
     dependencies:
-      debug: 4.3.7
+      debug: 4.4.0(supports-color@9.4.0)
       http-errors: 1.8.1
       resolve-path: 1.4.0
     transitivePeerDependencies:

turbo.json

@@ -7,6 +7,9 @@
 			"inputs": ["$TURBO_DEFAULT$", ".env*"],
 			"outputs": [".next/**", "!.next/cache/**", "dist/**", "build/**"]
 		},
+		"check-types": {
+			"dependsOn": ["^check-types"]
+		},
 		"lint": {
 			"dependsOn": ["^lint"]
 		},