mirror of
https://github.com/memohai/Memoh.git
synced 2026-04-25 07:00:48 +09:00
晨苒
627b673a5c
* refactor: restructure memory into multi-provider adapters, remove manifest.json dependency - Rename internal/memory/provider to internal/memory/adapters with per-provider subdirectories (builtin, mem0, openviking) - Replace manifest.json-based delete/update with scan-based index from daily files - Add mem0 and openviking provider adapters with HTTP client, chat hooks, MCP tools, and CRUD - Wire provider lifecycle into registry (auto-instantiate on create, evict on update/delete) - Split docker-compose into base stack + optional overlays (qdrant, browser, mem0, openviking) - Update admin UI to support dynamic provider config schema rendering * chore(lint): fix all golangci-lint issues for clean CI * refactor(docker): replace compose overlay files with profiles * feat(memory): add built-in memory multi modes * fix(ci): golangci lint * feat(memory): edit built-in memory sparse design
94 lines
2.1 KiB
Go
94 lines
2.1 KiB
Go
package adapters
|
|
|
|
import (
|
|
"fmt"
|
|
"strings"
|
|
)
|
|
|
|
// TruncateSnippet truncates a string to n runes, appending "..." if truncated.
|
|
func TruncateSnippet(s string, n int) string {
|
|
trimmed := strings.TrimSpace(s)
|
|
runes := []rune(trimmed)
|
|
if len(runes) <= n {
|
|
return trimmed
|
|
}
|
|
return strings.TrimSpace(string(runes[:n])) + "..."
|
|
}
|
|
|
|
// DeduplicateItems removes duplicate MemoryItems by ID.
|
|
func DeduplicateItems(items []MemoryItem) []MemoryItem {
|
|
if len(items) == 0 {
|
|
return items
|
|
}
|
|
seen := make(map[string]struct{}, len(items))
|
|
result := make([]MemoryItem, 0, len(items))
|
|
for _, item := range items {
|
|
id := strings.TrimSpace(item.ID)
|
|
if id == "" {
|
|
id = strings.TrimSpace(item.Memory)
|
|
}
|
|
if id == "" {
|
|
continue
|
|
}
|
|
if _, ok := seen[id]; ok {
|
|
continue
|
|
}
|
|
seen[id] = struct{}{}
|
|
result = append(result, item)
|
|
}
|
|
return result
|
|
}
|
|
|
|
// StringFromConfig extracts a trimmed string value from a config map.
|
|
func StringFromConfig(config map[string]any, key string) string {
|
|
if config == nil {
|
|
return ""
|
|
}
|
|
v, ok := config[key]
|
|
if !ok {
|
|
return ""
|
|
}
|
|
s, ok := v.(string)
|
|
if !ok {
|
|
return ""
|
|
}
|
|
return strings.TrimSpace(s)
|
|
}
|
|
|
|
func MergeMetadata(base map[string]any, extra map[string]any) map[string]any {
|
|
if len(base) == 0 && len(extra) == 0 {
|
|
return nil
|
|
}
|
|
out := make(map[string]any, len(base)+len(extra))
|
|
for k, v := range base {
|
|
out[k] = v
|
|
}
|
|
for k, v := range extra {
|
|
out[k] = v
|
|
}
|
|
return out
|
|
}
|
|
|
|
func BuildProfileMetadata(userID, channelIdentityID, displayName string) map[string]any {
|
|
userID = strings.TrimSpace(userID)
|
|
channelIdentityID = strings.TrimSpace(channelIdentityID)
|
|
displayName = strings.TrimSpace(displayName)
|
|
if userID == "" && channelIdentityID == "" && displayName == "" {
|
|
return nil
|
|
}
|
|
out := map[string]any{}
|
|
if userID != "" {
|
|
out["profile_user_id"] = userID
|
|
out["profile_ref"] = fmt.Sprintf("user:%s", userID)
|
|
} else if channelIdentityID != "" {
|
|
out["profile_ref"] = fmt.Sprintf("channel_identity:%s", channelIdentityID)
|
|
}
|
|
if channelIdentityID != "" {
|
|
out["profile_channel_identity_id"] = channelIdentityID
|
|
}
|
|
if displayName != "" {
|
|
out["profile_display_name"] = displayName
|
|
}
|
|
return out
|
|
}
|