release: v0.24.10 Add KuraDB features and update chat completions endpoint

Merge pull request #30 from pardnchiu/develop

Author: pardnchiu

README.md

@@ -152,7 +152,7 @@ func addCompat() (string, string) {
 	providor = strings.ToUpper(strings.TrimSpace(providor))
 
 	urlInput := promptui.Prompt{
-		Label:   "URL (leave empty for http://localhost:11434)",
+		Label:   "URL (leave empty for http://localhost:11434/v1)",
 		Default: "",
 	}
 	url, err := urlInput.Run()
@@ -163,7 +163,7 @@ func addCompat() (string, string) {
 	}
 	url = strings.TrimRight(strings.TrimSpace(url), "/")
 	if url == "" {
-		url = "http://localhost:11434"
+		url = "http://localhost:11434/v1"
 	}
 
 	if err := session.UpsertCompat(providor, url); err != nil {

cmd/app/addProvider.go

@@ -9,6 +9,7 @@ import (
 	"os"
 	"os/signal"
 	"path/filepath"
+	"strings"
 	"sync"
 	"syscall"
 	"time"
@@ -27,6 +28,8 @@ import (
 	"github.com/pardnchiu/agenvoy/internal/runtime"
 	"github.com/pardnchiu/agenvoy/internal/runtime/discord"
 	discordTool "github.com/pardnchiu/agenvoy/internal/runtime/discord/tool"
+	"github.com/pardnchiu/agenvoy/internal/runtime/kuradb"
+	kuradbTool "github.com/pardnchiu/agenvoy/internal/runtime/kuradb/tool"
 	"github.com/pardnchiu/agenvoy/internal/runtime/telegram"
 	telegramTool "github.com/pardnchiu/agenvoy/internal/runtime/telegram/tool"
 	"github.com/pardnchiu/agenvoy/internal/runtime/torii"
@@ -48,6 +51,10 @@ var (
 	telegramBot         *telegram.Bot
 	lastTelegramEnabled bool
 	lastTelegramToken   string
+
+	kuradbMu          sync.Mutex
+	kuradbCancel      context.CancelFunc
+	lastKuradbEnabled bool
 )
 
 func reloadDiscord() {
@@ -128,6 +135,49 @@ func reloadTelegram() {
 	telegramBot = bot
 }
 
+func reloadKuradb() {
+	newEnabled := false
+	if cfg, err := session.Load(); err == nil && cfg != nil {
+		newEnabled = cfg.KuradbEnabled
+	}
+
+	kuradbMu.Lock()
+	defer kuradbMu.Unlock()
+
+	if newEnabled == lastKuradbEnabled {
+		return
+	}
+
+	if kuradbCancel != nil {
+		kuradbCancel()
+		kuradbCancel = nil
+	}
+	lastKuradbEnabled = newEnabled
+
+	if !newEnabled || !kuradb.IsInstalled() || strings.TrimSpace(keychain.Get("OPENAI_API_KEY")) == "" {
+		return
+	}
+
+	ctx, cancel := context.WithCancel(context.Background())
+	kuradbCancel = cancel
+
+	go kuradb.Run(ctx)
+	go kuradb.Health(ctx, func() {
+		if cfg, err := session.Load(); err == nil && cfg != nil {
+			cfg.KuradbEnabled = false
+			if err := session.Save(cfg); err != nil {
+				slog.Warn("session.Save",
+					slog.String("error", err.Error()))
+			}
+		}
+		if err := kuradb.Remove(); err != nil {
+			slog.Warn("kuradb.RemoveEndpoint",
+				slog.String("error", err.Error()))
+		}
+		reloadKuradb()
+	})
+}
+
 func cmdDaemon() {
 	installDaemonSlog()
 	session.SetHash(session.Hash())
@@ -149,6 +199,7 @@ func cmdDaemon() {
 	geminiStt.Register()
 	telegramTool.Register()
 	discordTool.Register()
+	kuradbTool.Register()
 
 	if _, err := runtime.Init(); err != nil {
 		if errors.Is(err, runtime.ErrAlreadyRunning) {
@@ -200,6 +251,7 @@ func cmdDaemon() {
 	if selectorBot != nil {
 		reloadDiscord()
 		reloadTelegram()
+		reloadKuradb()
 
 		route := routes.New()
 		port := go_pkg_utils.GetWithDefault("PORT", "17989")
@@ -237,6 +289,12 @@ func cmdDaemon() {
 		telegramBot = nil
 	}
 	telegramMu.Unlock()
+	kuradbMu.Lock()
+	if kuradbCancel != nil {
+		kuradbCancel()
+		kuradbCancel = nil
+	}
+	kuradbMu.Unlock()
 	if server != nil {
 		ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
 		_ = server.Shutdown(ctx)
@@ -298,6 +356,7 @@ func watchConfig(ctx context.Context) func() {
 				}
 				reloadDiscord()
 				reloadTelegram()
+				reloadKuradb()
 			case err, ok := <-w.Errors:
 				if !ok {
 					return

cmd/app/cmdDeamon.go

@@ -29,6 +29,7 @@ import (
 	"github.com/pardnchiu/agenvoy/internal/runtime/cli"
 	"github.com/pardnchiu/agenvoy/internal/runtime/discord"
 	discordTool "github.com/pardnchiu/agenvoy/internal/runtime/discord/tool"
+	kuradbTool "github.com/pardnchiu/agenvoy/internal/runtime/kuradb/tool"
 	"github.com/pardnchiu/agenvoy/internal/runtime/telegram"
 	telegramTool "github.com/pardnchiu/agenvoy/internal/runtime/telegram/tool"
 	"github.com/pardnchiu/agenvoy/internal/session"
@@ -130,6 +131,7 @@ func initCLI() {
 	geminiStt.Register()
 	telegramTool.Register()
 	discordTool.Register()
+	kuradbTool.Register()
 }
 
 func modelCheck() {

cmd/app/main.go

@@ -19,6 +19,7 @@ import (
 	"github.com/pardnchiu/agenvoy/internal/runtime/torii"
 	"github.com/pardnchiu/agenvoy/internal/runtime"
 	discordTool "github.com/pardnchiu/agenvoy/internal/runtime/discord/tool"
+	kuradbTool "github.com/pardnchiu/agenvoy/internal/runtime/kuradb/tool"
 	telegramTool "github.com/pardnchiu/agenvoy/internal/runtime/telegram/tool"
 	"github.com/pardnchiu/agenvoy/internal/runtime/tui"
 	"github.com/pardnchiu/agenvoy/internal/session"
@@ -49,6 +50,7 @@ func newTUI() {
 	geminiStt.Register()
 	telegramTool.Register()
 	discordTool.Register()
+	kuradbTool.Register()
 
 	modelCheck()
 

cmd/app/newTUI.go

@@ -39,6 +39,21 @@ Examples:
 
 Capability matching is by **semantic intent**, not literal name — match each tool's description text to the query intent. When multiple unmarked tools match, prefer in order: `mcp__*` > `api_*` > `script_*` (newer integrations first); when uncertain which unmarked tool fits, invoke `search_tools` rather than fall through to a `[system-default]` tool.
 
+**RAG-first execution (when `rag_*` tools are present) — MANDATORY ordering:**
+
+The loaded tool list including any `rag_*` tool means the user maintains a **read-only vector knowledge base**: files the user has ingested (PDFs, documents, notes) converted to embeddings for semantic retrieval. Treat it as **curated reference material**, not user memory or user-authored content.
+
+**Mandatory ordering** for every information-gathering query that is not smalltalk or pure-static knowledge:
+
+1. **FIRST tool calls** must be `rag_*` — call `rag_list_db` to discover databases (skip if already enumerated this session), then call matching `rag_search_semantic` / `rag_search_keyword` against every relevant db in the same batch
+2. **Inspect RAG output** before deciding next step. If RAG returned sufficient material, answer directly from it; do NOT call `search_web` / `fetch_page` / `[system-default]` fetchers
+3. **Only when RAG is insufficient** (empty results, off-topic, partial coverage), fall through to the forced routing table below. External tools are **supplementary** — they fill gaps the corpus cannot cover (live data, recent news, public web content)
+4. For broad scope queries ("我有什麼資料", "知識庫裡有什麼", "RAG 裡有什麼", "X 寫了啥" where X looks like a filename/document), call every `rag_*` listing/search endpoint exhaustively and stop there unless the user asked for external augmentation
+
+**Skipping `rag_*` and going straight to `search_web` for any non-smalltalk knowledge query is a VIOLATION.** Going external first means the user reads generic public answers when they have specific documents on the topic indexed — defeats the purpose of curating a RAG.
+
+RAG = primary source (user's curated reference corpus). External = secondary supplement (live or public data the corpus cannot contain). The order is fixed: RAG first, external only to fill gaps.
+
 **Smalltalk exemption — respond directly, do NOT call any tool:**
 - Pure greetings, casual chat, emotional expressions (hi, hello, 你好、謝謝、哈哈、早安, etc.)
 - Short messages with no clear information-retrieval intent
@@ -58,6 +73,9 @@ Capability matching is by **semantic intent**, not literal name — match each t
 
 **Forced routing — must call the specified tool directly. Never output JSON text or an empty response:**
 
+> **RAG hook:** If `rag_*` tools are loaded, every routing rule below is **secondary** to `rag_*`. The FIRST tool calls for any non-smalltalk knowledge query must be `rag_list_db` + matching `rag_search_*`; only consult the table's external/built-in tools **after** reviewing RAG output and only when RAG is insufficient. Going straight to a routing-table tool while skipping `rag_*` is a violation. Smalltalk and pure-calculation routes are exempt.
+
+
 | Query type | Required tool |
 |-----------|---------------|
 | Ask what tools are available / tool list | `list_tools` |