feat: implement interactive task editor and MCP server integration

Author: programmersd21

.goreleaser.yaml

@@ -79,24 +79,35 @@ release:
   draft: false
   prerelease: auto
 
-homebrew_casks:
+brews:
   - name: kairo
 
     ids:
       - kairo
 
-    binaries:
-      - kairo
-
     repository:
       owner: programmersd21
-      name: kairo_tap
+      name: homebrew-kairo
+      branch: main
       token: "{{ .Env.TAP_GITHUB_TOKEN }}"
 
-    directory: Casks
-
-    commit_msg_template: "Brew cask update for {{ .ProjectName }} {{ .Tag }}"
+    directory: Formula
 
     homepage: "https://github.com/programmersd21/kairo"
     description: "Minimal, powerful task management"
+    license: "MIT"
+
+    commit_author:
+      name: goreleaserbot
+      email: bot@goreleaser.com
+
+    commit_msg_template: "brew: update {{ .ProjectName }} to {{ .Tag }}"
+
+    install: |
+      bin.install "kairo"
+
+    test: |
+      system "#{bin}/kairo", "--version"
+
+    skip_upload: auto
 

CHANGELOG.md

@@ -9,6 +9,12 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ### Added
 
+* **Markdown Preview Panel**: The task editor now features a side-by-side markdown preview panel (toggled with `ctrl+p` or automatically on wide screens) for real-time visualization of task descriptions.
+* **Plugin Notification API**: Connected the Lua `kairo.notify` function to the TUI status bar, allowing plugins to provide visual feedback directly to the user.
+* **Fixed Plugin Notifications**: Resolved an issue where plugin notifications were not appearing in the status bar due to missing async message handling.
+* **MCP Server Port Control**: Added support for running the built-in MCP server in SSE/HTTP mode on a specific port (`kairo mcp <port>`).
+* **MCP Configuration**: Added `mcp_port` setting to `config.toml` and `KAIRO_MCP_PORT` environment variable support for flexible port overrides and auto-start configuration.
+* **REAL MCP Server Enhancements**: Transformed the built-in MCP server into a professional-grade implementation with support for Resources (`tasks://all`), Prompts (`manage_tasks`), and expanded Tools (including `kairo_get_task` and `kairo_list_tags`).
 * **AI Total App Control**: Updated the AI Assistant's system prompt and tool definitions to enable seamless control over UI themes and Lua plugins.
 * **Help Menu Clarity**: Added dedicated keybinding information for the Import/Export menu to the global help screen.
 

README.md

@@ -22,7 +22,7 @@ Pick your platform:
 ### 🍺 macOS (Homebrew)
 
 ```bash
-brew tap programmersd21/kairo_tap && brew install --cask kairo
+brew install programmersd21/kairo/kairo
 ```
 
 ### 🐧 Linux / macOS (curl)
@@ -96,7 +96,10 @@ Kairo is the missing middle:
 
 * Lua plugin system (event hooks: task_create, task_update, app_start, etc.)
 * Headless CLI API for automation
-* MCP server exposing full task schema to AI agents
+* **Professional MCP Server**: Full Model Context Protocol implementation
+    * **Tools**: CRUD operations, tag listing, and theme management
+    * **Resources**: Direct access to JSON task data (`tasks://all`)
+    * **Prompts**: Pre-configured AI workflows (`manage_tasks`)
 * Custom themes via Lua or config
 
 ### 🤖 AI (optional)
@@ -109,6 +112,7 @@ Kairo is the missing middle:
 ### 🎨 Terminal UI
 
 * Bento-style layout with Lip Gloss styling
+* **Markdown Preview**: Side-by-side real-time rendering in the task editor (`ctrl+p`)
 * 32 built-in themes (dark/light/hybrid)
 * Live theme switching (`t`)
 * Full-viewport rendering (no terminal bleed-through)
@@ -140,7 +144,8 @@ kairo api list --tag work
 kairo api update --id <id> --status done
 kairo export --format markdown
 kairo sync
-kairo mcp
+kairo mcp        # stdio mode (local)
+kairo mcp 8080   # sse mode (remote)
 ```
 
 ---

VERSION.txt

@@ -1 +1 @@
-1.3.1
+1.3.2

cmd/kairo/main.go

@@ -5,6 +5,7 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
+	"net/http"
 	"os"
 	"os/signal"
 	"path/filepath"
@@ -143,7 +144,7 @@ func main() {
 			}
 			return
 		case "mcp":
-			if err := runMCP(ctx, svc); err != nil {
+			if err := runMCP(ctx, svc, os.Args[2:]); err != nil {
 				fmt.Fprintln(os.Stderr, "kairo mcp:", err)
 				os.Exit(2)
 			}
@@ -360,6 +361,7 @@ func runHelp(args []string) {
 		fmt.Println("  completion  Generate shell completion scripts")
 		fmt.Println("  export      Export tasks to JSON or Markdown")
 		fmt.Println("  import      Import tasks from JSON or Markdown")
+		fmt.Println("  mcp         Run the built-in MCP server")
 		fmt.Println("  sync        Sync tasks with Git repository")
 		fmt.Println("  update      Update Kairo to the latest version")
 		fmt.Println("  version     Show the current version")
@@ -394,12 +396,54 @@ func runHelp(args []string) {
 		fmt.Println("Sync tasks with Git repository.")
 		fmt.Println("\nUsage:")
 		fmt.Println("  kairo sync")
+	case "mcp":
+		fmt.Println("Run the built-in Model Context Protocol (MCP) server.")
+		fmt.Println("\nUsage:")
+		fmt.Println("  kairo mcp [port]")
+		fmt.Println("\nExample:")
+		fmt.Println("  kairo mcp        (Runs in Stdio mode for local AI agents)")
+		fmt.Println("  kairo mcp 8080   (Runs in SSE/HTTP mode on port 8080)")
+		fmt.Println("\nDescription:")
+		fmt.Println("  Exposes your Kairo tasks and tools to AI agents using the MCP standard.")
+		fmt.Println("  Stdio mode is used for local integration (e.g. Claude Desktop).")
+		fmt.Println("  SSE mode allows remote connections via HTTP.")
 	default:
 		fmt.Printf("Unknown help topic %q\n", args[0])
 	}
 }
-func runMCP(ctx context.Context, svc service.TaskService) error {
+func runMCP(ctx context.Context, svc service.TaskService, args []string) error {
 	s := mcp.NewServer(svc)
+
+	cfg, _ := config.Load()
+	port := os.Getenv("KAIRO_MCP_PORT")
+	if port == "" {
+		port = cfg.App.MCPPort
+	}
+	if len(args) > 0 {
+		port = args[0]
+	}
+
+	if port != "" {
+		addr := ":" + port
+		baseURL := "http://localhost" + addr
+		sseServer := mcpserver.NewSSEServer(s, mcpserver.WithBaseURL(baseURL))
+
+		handler := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+			w.Header().Set("Access-Control-Allow-Origin", "*")
+			w.Header().Set("Access-Control-Allow-Methods", "GET, POST, OPTIONS")
+			w.Header().Set("Access-Control-Allow-Headers", "Content-Type, Authorization")
+			if r.Method == "OPTIONS" {
+				w.WriteHeader(http.StatusOK)
+				return
+			}
+			sseServer.ServeHTTP(w, r)
+		})
+
+		fmt.Printf("Starting Kairo MCP SSE server on %s (CORS enabled)\n", addr)
+		fmt.Printf("SSE endpoint: %s/sse\n", baseURL)
+		return http.ListenAndServe(addr, handler)
+	}
+
 	server := mcpserver.NewStdioServer(s)
 	return server.Listen(ctx, os.Stdin, os.Stdout)
 }

internal/app/model.go

@@ -145,13 +145,15 @@ type Model struct {
 
 	statusText string
 	isErr      bool
+	statusID   int
 
 	updateAvailable *updateAvailableMsg
 
 	syncEngine *ksync.Engine
 
 	plugHost *plugins.Host
 	plugCh   chan struct{}
+	statusCh chan statusMsg
 	configCh chan config.Config
 
 	RainbowAnimationOffset int
@@ -283,9 +285,12 @@ func New(ctx context.Context, cfg config.Config, svc service.TaskService) (tea.M
 		if dir != "" {
 			_ = os.MkdirAll(dir, 0o755)
 			m.plugHost = plugins.New(svc, dir)
+			m.statusCh = make(chan statusMsg, 8)
 			m.plugHost.SetNotifyFunc(func(msg string, isErr bool) {
-				m.statusText = msg
-				m.isErr = isErr
+				select {
+				case m.statusCh <- statusMsg{Message: msg, IsErr: isErr}:
+				default:
+				}
 			})
 			_ = m.plugHost.LoadAll()
 
@@ -343,6 +348,9 @@ func (m *Model) Init() tea.Cmd {
 	if m.plugCh != nil {
 		cmds = append(cmds, m.listenPluginsCmd())
 	}
+	if m.statusCh != nil {
+		cmds = append(cmds, m.listenStatusCmd())
+	}
 	if m.configCh != nil {
 		cmds = append(cmds, m.listenConfigCmd())
 	}
@@ -395,6 +403,20 @@ func (m *Model) Update(msg tea.Msg) (tea.Model, tea.Cmd) {
 	case errMsg:
 		m.statusText = x.Err.Error()
 		m.isErr = true
+		m.statusID++
+		return m, m.clearStatusCmd(m.statusID)
+
+	case statusMsg:
+		m.statusText = x.Message
+		m.isErr = x.IsErr
+		m.statusID++
+		return m, tea.Batch(m.listenStatusCmd(), m.clearStatusCmd(m.statusID))
+
+	case clearStatusMsg:
+		if x.ID == m.statusID {
+			m.statusText = ""
+			m.isErr = false
+		}
 		return m, nil
 
 	case tasksLoadedMsg:
@@ -1377,7 +1399,11 @@ func (m *Model) startMCPCmd() tea.Cmd {
 			return nil
 		}
 		exe, _ := os.Executable()
-		cmd := exec.Command(exe, "mcp")
+		args := []string{"mcp"}
+		if m.cfg.App.MCPPort != "" {
+			args = append(args, m.cfg.App.MCPPort)
+		}
+		cmd := exec.Command(exe, args...)
 		if err := cmd.Start(); err != nil {
 			return mcpStatusMsg{Running: false}
 		}
@@ -2198,6 +2224,18 @@ func keymapMatch(b interface{ Keys() []string }, k tea.KeyMsg) bool {
 	}
 	return false
 }
+
+func (m *Model) listenStatusCmd() tea.Cmd {
+	return func() tea.Msg {
+		return <-m.statusCh
+	}
+}
+
+func (m *Model) clearStatusCmd(id int) tea.Cmd {
+	return tea.Tick(5*time.Second, func(t time.Time) tea.Msg {
+		return clearStatusMsg{ID: id}
+	})
+}
 func (m *Model) handleImportExportAction(action import_export_menu.Action, path string) tea.Cmd {
 	return func() tea.Msg {
 		taskAPI := api.New(m.svc)

internal/app/msg.go

@@ -8,6 +8,15 @@ type tasksLoadedMsg struct{ Tasks []core.Task }
 type tagsLoadedMsg struct{ Tags []string }
 type allTasksLoadedMsg struct{ Tasks []core.Task }
 
+type statusMsg struct {
+	Message string
+	IsErr   bool
+}
+
+type clearStatusMsg struct {
+	ID int
+}
+
 type taskCreatedMsg struct{ Task core.Task }
 type taskUpdatedMsg struct{ Task core.Task }
 type taskDeletedMsg struct{ ID string }

internal/config/config.go

@@ -29,6 +29,7 @@ type AppConfig struct {
 	GeminiAPIKey string `toml:"gemini_api_key"`
 	AIModel      string `toml:"ai_model"`
 	MCPEnabled   bool   `toml:"mcp_enabled"`
+	MCPPort      string `toml:"mcp_port"`
 }
 
 type StorageConfig struct {
@@ -93,11 +94,13 @@ type KeymapConfig struct {
 func Default() Config {
 	return Config{
 		App: AppConfig{
-			Theme:    "catppuccin",
-			VimMode:  false,
-			ShowHelp: true,
-			Rainbow:  false,
-			AIModel:  "gemini-3.1-flash-lite-preview",
+			Theme:      "catppuccin",
+			VimMode:    false,
+			ShowHelp:   true,
+			Rainbow:    false,
+			AIModel:    "gemini-3.1-flash-lite-preview",
+			MCPEnabled: false,
+			MCPPort:    "8080",
 		},
 		Theme: ThemeConfig{
 			Bg:      "", // Use theme default

internal/lua/engine.go

@@ -16,9 +16,10 @@ import (
 
 // Engine manages the Lua runtime and plugin execution
 type Engine struct {
-	service service.TaskService
-	hooks   *hooks.Manager
-	timeout time.Duration
+	service    service.TaskService
+	hooks      *hooks.Manager
+	notifyFunc func(string, bool)
+	timeout    time.Duration
 }
 
 // NewEngine creates a new Lua engine with the given service and hooks
@@ -30,6 +31,11 @@ func NewEngine(svc service.TaskService, hks *hooks.Manager) *Engine {
 	}
 }
 
+// SetNotifyFunc sets the notification callback for plugins
+func (e *Engine) SetNotifyFunc(f func(string, bool)) {
+	e.notifyFunc = f
+}
+
 // SetTimeout sets the execution timeout for plugin code
 func (e *Engine) SetTimeout(d time.Duration) {
 	e.timeout = d
@@ -55,7 +61,7 @@ func (e *Engine) SetupKairoAPI(L *lua.LState) {
 	L.SetField(kairo, "notify", L.NewFunction(e.luaNotify))
 
 	// Meta
-	L.SetField(kairo, "version", lua.LString("1.3.1"))
+	L.SetField(kairo, "version", lua.LString("1.3.2"))
 
 	// Set as global
 	L.SetGlobal("kairo", kairo)
@@ -308,18 +314,17 @@ func (e *Engine) luaOff(L *lua.LState) int {
 	return 0
 }
 
-// luaNotify sends a notification (stub for now)
-// In production, this would emit to the UI
+// luaNotify sends a notification
 func (e *Engine) luaNotify(L *lua.LState) int {
 	msg := L.CheckString(1)
 	isErr := false
 	if L.GetTop() > 1 {
 		isErr = lua.LVAsBool(L.Get(2))
 	}
 
-	// TODO: Emit notification to UI
-	_ = msg
-	_ = isErr
+	if e.notifyFunc != nil {
+		e.notifyFunc(msg, isErr)
+	}
 
 	return 0
 }