diff --git a/cmd/picoclaw/cmd_gateway.go b/cmd/picoclaw/cmd_gateway.go
index 539d0d579..f943b35ef 100644
--- a/cmd/picoclaw/cmd_gateway.go
+++ b/cmd/picoclaw/cmd_gateway.go
@@ -221,7 +221,8 @@ func gatewayCmd() {
 
 		if webAppURL != "" {
 			provider := &agentLoopDataProvider{loop: agentLoop}
-			handler := miniapp.NewHandler(provider, cfg.Channels.Telegram.Token)
+			sender := &telegramCommandSender{bus: msgBus}
+			handler := miniapp.NewHandler(provider, sender, cfg.Channels.Telegram.Token)
 			handler.RegisterRoutes(healthServer.Mux())
 			fmt.Printf("✓ Mini App registered at %s\n", webAppURL)
 		}
@@ -331,3 +332,20 @@ func (p *agentLoopDataProvider) GetPlanInfo() miniapp.PlanInfo {
 func (p *agentLoopDataProvider) GetSessionStats() *stats.Stats {
 	return p.loop.GetSessionStats()
 }
+
+// telegramCommandSender injects Mini App commands into the message bus.
+type telegramCommandSender struct {
+	bus *bus.MessageBus
+}
+
+func (s *telegramCommandSender) SendCommand(senderID, chatID, command string) {
+	s.bus.PublishInbound(bus.InboundMessage{
+		Channel:  "telegram",
+		SenderID: senderID,
+		ChatID:   chatID,
+		Content:  command,
+		Metadata: map[string]string{
+			"source": "webapp",
+		},
+	})
+}
diff --git a/pkg/miniapp/miniapp.go b/pkg/miniapp/miniapp.go
index f074e0d69..924a5750d 100644
--- a/pkg/miniapp/miniapp.go
+++ b/pkg/miniapp/miniapp.go
@@ -7,6 +7,7 @@ import (
 	"encoding/hex"
 	"encoding/json"
 	"fmt"
+	"io"
 	"net/http"
 	"net/url"
 	"sort"
@@ -50,16 +51,23 @@ type DataProvider interface {
 	GetSessionStats() *stats.Stats
 }
 
+// CommandSender injects a command into the message bus on behalf of a user.
+type CommandSender interface {
+	SendCommand(senderID, chatID, command string)
+}
+
 // Handler serves the Mini App HTML and API endpoints.
 type Handler struct {
 	provider DataProvider
+	sender   CommandSender
 	botToken string
 }
 
 // NewHandler creates a new Mini App handler.
-func NewHandler(provider DataProvider, botToken string) *Handler {
+func NewHandler(provider DataProvider, sender CommandSender, botToken string) *Handler {
 	return &Handler{
 		provider: provider,
+		sender:   sender,
 		botToken: botToken,
 	}
 }
@@ -70,6 +78,7 @@ func (h *Handler) RegisterRoutes(mux *http.ServeMux) {
 	mux.HandleFunc("/miniapp/api/skills", h.requireAuth(h.apiSkills))
 	mux.HandleFunc("/miniapp/api/plan", h.requireAuth(h.apiPlan))
 	mux.HandleFunc("/miniapp/api/session", h.requireAuth(h.apiSession))
+	mux.HandleFunc("/miniapp/api/command", h.requireAuth(h.apiCommand))
 }
 
 func (h *Handler) serveIndex(w http.ResponseWriter, r *http.Request) {
@@ -116,6 +125,65 @@ func (h *Handler) apiSession(w http.ResponseWriter, r *http.Request) {
 	writeJSON(w, s)
 }
 
+func (h *Handler) apiCommand(w http.ResponseWriter, r *http.Request) {
+	if r.Method != http.MethodPost {
+		http.Error(w, `{"error":"method not allowed"}`, http.StatusMethodNotAllowed)
+		return
+	}
+
+	body, err := io.ReadAll(io.LimitReader(r.Body, 4096))
+	if err != nil {
+		http.Error(w, `{"error":"bad request"}`, http.StatusBadRequest)
+		return
+	}
+
+	var req struct {
+		Command string `json:"command"`
+	}
+	if err := json.Unmarshal(body, &req); err != nil || req.Command == "" {
+		http.Error(w, `{"error":"missing command"}`, http.StatusBadRequest)
+		return
+	}
+
+	if !strings.HasPrefix(req.Command, "/") {
+		http.Error(w, `{"error":"command must start with /"}`, http.StatusBadRequest)
+		return
+	}
+
+	// Extract user ID from initData to identify the sender
+	initData := r.URL.Query().Get("initData")
+	userID, chatID := extractUserFromInitData(initData)
+	if userID == "" {
+		http.Error(w, `{"error":"cannot identify user"}`, http.StatusBadRequest)
+		return
+	}
+
+	h.sender.SendCommand(userID, chatID, req.Command)
+	writeJSON(w, map[string]string{"status": "ok"})
+}
+
+// extractUserFromInitData parses user.id from the initData query string.
+// initData contains a "user" param with JSON like {"id":123456,...}.
+func extractUserFromInitData(initData string) (userID, chatID string) {
+	values, err := url.ParseQuery(initData)
+	if err != nil {
+		return "", ""
+	}
+	userJSON := values.Get("user")
+	if userJSON == "" {
+		return "", ""
+	}
+	var user struct {
+		ID int64 `json:"id"`
+	}
+	if err := json.Unmarshal([]byte(userJSON), &user); err != nil || user.ID == 0 {
+		return "", ""
+	}
+	id := fmt.Sprintf("%d", user.ID)
+	// For Mini App commands, chatID = userID (private chat)
+	return id, id
+}
+
 func writeJSON(w http.ResponseWriter, v any) {
 	w.Header().Set("Content-Type", "application/json")
 	json.NewEncoder(w).Encode(v)
diff --git a/pkg/miniapp/static/index.html b/pkg/miniapp/static/index.html
index bb255eabb..425e53bbf 100644
--- a/pkg/miniapp/static/index.html
+++ b/pkg/miniapp/static/index.html
@@ -338,7 +338,6 @@
     <div class="cmd-chips">
       <button class="cmd-chip" data-cmd="/session">/session</button>
       <button class="cmd-chip" data-cmd="/skills">/skills</button>
-      <button class="cmd-chip" data-cmd="/todo">/todo</button>
       <button class="cmd-chip" data-cmd="/plan status">/plan status</button>
     </div>
   </div>
@@ -389,13 +388,19 @@ document.querySelectorAll('.cmd-chip').forEach(chip => {
   });
 });
 
-function sendCommand(cmd) {
+async function sendCommand(cmd) {
   if (!cmd.startsWith('/')) return;
   try {
-    tg.sendData(cmd);
+    const sep = '/miniapp/api/command'.includes('?') ? '&' : '?';
+    const res = await fetch(API_BASE + '/miniapp/api/command' + sep + 'initData=' + encodeURIComponent(initData), {
+      method: 'POST',
+      headers: { 'Content-Type': 'application/json' },
+      body: JSON.stringify({ command: cmd }),
+    });
+    if (!res.ok) throw new Error('API error: ' + res.status);
+    tg.showAlert('Sent: ' + cmd);
   } catch (e) {
-    console.log('sendData:', cmd);
-    tg.showAlert('Command sent: ' + cmd);
+    tg.showAlert('Failed to send command');
   }
 }