mirror of
https://github.com/memohai/Memoh.git
synced 2026-04-25 07:00:48 +09:00
BBQ
bc374fe8cd
* refactor(attachment): multimodal attachment refactor with snapshot schema and storage layer - Add snapshot schema migration (0008) and update init/versions/snapshots - Add internal/attachment and internal/channel normalize for unified attachment handling - Move containerfs provider from internal/media to internal/storage - Update agent types, channel adapters (Telegram/Feishu), inbound and handlers - Add containerd snapshot lineage and local_channel tests - Regenerate sqlc, swagger and SDK * refactor(media): content-addressed asset system with unified naming - Replace asset_id foreign key with content_hash as sole identifier for bot_history_message_assets (pure soft-link model) - Remove mime, size_bytes, storage_key from DB; derive at read time via media.Resolve from actual storage - Merge migrations 0008/0009 into single 0008; keep 0001 as canonical schema - Add Docker initdb script for deterministic migration execution order - Fix cross-channel real-time image display (Telegram → WebUI SSE) - Fix message disappearing on refresh (null assets fallback) - Fix file icon instead of image preview (mime derivation from storage) - Unify AssetID → ContentHash naming across Go, Agent, and Frontend - Change storage key prefix from 4-char to 2-char for directory sharding - Add server-entrypoint.sh for Docker deployment migration handling * refactor(infra): embedded migrations, Docker simplification, and config consolidation - Embed SQL migrations into Go binary, removing shell-based migration scripts - Consolidate config files into conf/ directory (app.example.toml, app.docker.toml, app.dev.toml) - Simplify Docker setup: remove initdb.d scripts, streamline nginx config and entrypoint - Remove legacy CLI, feishu-echo commands, and obsolete incremental migration files - Update install script and docs to require sudo for one-click install - Add mise tasks for dev environment orchestration * chore: recover migrations --------- Co-authored-by: Acbox <acbox0328@gmail.com>
67 lines
2.0 KiB
Go
67 lines
2.0 KiB
Go
package channel
|
|
|
|
import (
|
|
"path/filepath"
|
|
"strings"
|
|
|
|
"github.com/memohai/memoh/internal/attachment"
|
|
)
|
|
|
|
// InferAttachmentType infers a canonical attachment type from type/mime/name.
|
|
func InferAttachmentType(currentType AttachmentType, mime, name string) AttachmentType {
|
|
switch strings.ToLower(strings.TrimSpace(string(currentType))) {
|
|
case string(AttachmentImage):
|
|
return AttachmentImage
|
|
case string(AttachmentGIF):
|
|
return AttachmentGIF
|
|
case string(AttachmentAudio):
|
|
return AttachmentAudio
|
|
case string(AttachmentVoice):
|
|
return AttachmentVoice
|
|
case string(AttachmentVideo):
|
|
return AttachmentVideo
|
|
case string(AttachmentFile):
|
|
// keep inferring below for better classification
|
|
default:
|
|
// unknown type: infer from mime/name
|
|
}
|
|
|
|
normalizedMime := attachment.NormalizeMime(mime)
|
|
switch {
|
|
case strings.HasPrefix(normalizedMime, "image/gif"):
|
|
return AttachmentGIF
|
|
case strings.HasPrefix(normalizedMime, "image/"):
|
|
return AttachmentImage
|
|
case strings.HasPrefix(normalizedMime, "audio/"):
|
|
return AttachmentAudio
|
|
case strings.HasPrefix(normalizedMime, "video/"):
|
|
return AttachmentVideo
|
|
}
|
|
|
|
ext := strings.ToLower(strings.TrimSpace(filepath.Ext(strings.TrimSpace(name))))
|
|
switch ext {
|
|
case ".gif":
|
|
return AttachmentGIF
|
|
case ".jpg", ".jpeg", ".png", ".webp", ".bmp", ".heic", ".heif":
|
|
return AttachmentImage
|
|
case ".mp3", ".wav", ".ogg", ".m4a", ".aac", ".flac":
|
|
return AttachmentAudio
|
|
case ".mp4", ".mov", ".mkv", ".webm":
|
|
return AttachmentVideo
|
|
default:
|
|
return AttachmentFile
|
|
}
|
|
}
|
|
|
|
// NormalizeInboundChannelAttachment normalizes a channel attachment at adapter boundary.
|
|
func NormalizeInboundChannelAttachment(att Attachment) Attachment {
|
|
att.Type = InferAttachmentType(att.Type, att.Mime, att.Name)
|
|
att.Mime = attachment.NormalizeMime(att.Mime)
|
|
att.URL = strings.TrimSpace(att.URL)
|
|
att.PlatformKey = strings.TrimSpace(att.PlatformKey)
|
|
att.SourcePlatform = strings.TrimSpace(att.SourcePlatform)
|
|
att.Name = strings.TrimSpace(att.Name)
|
|
att.Caption = strings.TrimSpace(att.Caption)
|
|
return att
|
|
}
|