goclaw/internal/tools/message.go

package tools

import (
	"context"
	"encoding/json"
	"fmt"
	"log/slog"
	"os"
	"path/filepath"
	"regexp"
	"strconv"
	"strings"

	"github.com/google/uuid"

	"github.com/nextlevelbuilder/goclaw/internal/bus"
	"github.com/nextlevelbuilder/goclaw/internal/store"
)

// embeddedMediaPattern matches "MEDIA:" followed by a non-whitespace path.
// Duplicated from agent.mediaPathPattern to avoid tools→agent import cycle.
var embeddedMediaPattern = regexp.MustCompile(`MEDIA:\S+`)

// MessageTool allows the agent to proactively send messages to channels.
type MessageTool struct {
	workspace      string
	restrict       bool
	sender         ChannelSender
	editor         ChannelEditor
	topicResolver  TopicResolver
	topicPoster    TopicPoster
	reactionSetter ReactionSetter
	msgBus         *bus.MessageBus
	tenantChecker  ChannelTenantChecker
}

func NewMessageTool(workspace string, restrict bool) *MessageTool {
	return &MessageTool{workspace: workspace, restrict: restrict}
}

func (t *MessageTool) SetChannelSender(s ChannelSender)               { t.sender = s }
func (t *MessageTool) SetChannelEditor(e ChannelEditor)               { t.editor = e }
func (t *MessageTool) SetTopicResolver(r TopicResolver)               { t.topicResolver = r }
func (t *MessageTool) SetTopicPoster(p TopicPoster)                   { t.topicPoster = p }
func (t *MessageTool) SetReactionSetter(r ReactionSetter)             { t.reactionSetter = r }
func (t *MessageTool) SetMessageBus(b *bus.MessageBus)                { t.msgBus = b }
func (t *MessageTool) SetChannelTenantChecker(c ChannelTenantChecker) { t.tenantChecker = c }

func (t *MessageTool) Name() string { return "message" }
func (t *MessageTool) Description() string {
	return "Send a message to a channel (Telegram, Discord, Slack, Zalo, Feishu/Lark, WhatsApp, etc.). In a DM/group, omit `target` to reply to the current chat — DO NOT set a different target unless the user explicitly asked you to forward (then set `forward=true` + `forward_reason` quoting the request). In cron/heartbeat/subagent/team contexts, set `target` per job spec."
}

func (t *MessageTool) Parameters() map[string]any {
	return map[string]any{
		"type": "object",
		"properties": map[string]any{
			"action": map[string]any{
				"type":        "string",
				"description": "Action: 'send' a new message, 'edit' an existing one (change its text in place), or 'react' (set an emoji reaction on an existing message — e.g. mark your own status post as done). To edit, the user usually replies to the target message — use its id from reply_to_message_id in your context.",
				"enum":        []string{"send", "edit", "react"},
			},
			"message_id": map[string]any{
				"type":        "integer",
				"description": "For action='edit' or 'react': the id of the target message. For 'react' this is usually your OWN earlier post (the message_id returned when you sent it). For 'edit' take it from reply_to_message_id when the user replied to the message they want edited.",
			},
			"emoji": map[string]any{
				"type":        "string",
				"description": "For action='react': the reaction emoji to set on message_id. Telegram allows only a fixed set (e.g. 👍 👎 🔥 🎉 💯 🤝) — ✅ and ❌ are NOT valid reactions. Use 👍 for done/paid.",
			},
			"topic": map[string]any{
				"type":        "string",
				"description": "For action='send' in a forum group: the name of the target topic to post into (e.g. 'Announcements'). Posts into that topic of the CURRENT group and returns the sent message_id in the result — remember it if you may need to edit that post later. Omit to reply in the current topic/chat.",
			},
			"channel": map[string]any{
				"type":        "string",
				"description": "Channel name (default: current channel from context)",
			},
			"target": map[string]any{
				"type":        "string",
				"description": "Chat ID to send to (default: current chat from context). Must be a real chat/group ID, NOT a display name — passing a human-readable name here will fail (or silently go nowhere). If you only know a group by its display name, resolve the real ID first (e.g. zalo_list_groups on Zalo) instead of guessing.",
			},
			"message": map[string]any{
				"type":        "string",
				"description": "Message content to send. To send a file as attachment, use the prefix MEDIA: followed by the file path, e.g. 'MEDIA:docs/report.pdf' or 'MEDIA:/tmp/image.png'. The file will be uploaded as a document/photo/audio depending on its type.",
			},
			"forward": map[string]any{
				"type":        "boolean",
				"description": "Set true ONLY when the user explicitly asked to forward to a different chat than the current one. Required when target ≠ current chat in DM/group sessions.",
			},
			"forward_reason": map[string]any{
				"type":        "string",
				"description": "Quote the user's literal request when forward=true (e.g. 'gửi báo cáo này sang group dev'). Required when forward=true.",
			},
		},
		"required": []string{"action", "message"},
	}
}

func (t *MessageTool) Execute(ctx context.Context, args map[string]any) *Result {
	action := argString(args, "action")
	if action == "edit" {
		return t.executeEdit(ctx, args)
	}
	if action == "react" {
		return t.executeReact(ctx, args)
	}
	if action != "send" {
		return ErrorResult(fmt.Sprintf("unsupported action: %s (only 'send', 'edit' and 'react' are supported)", action))
	}

	// Posting into a named forum topic of the current group.
	if topic := argString(args, "topic"); topic != "" {
		return t.executeTopicSend(ctx, args, topic)
	}

	message := argString(args, "message")
	if message == "" {
		return ErrorResult("message is required")
	}
	if IsDelegationArtifactRun(ctx) && strings.Contains(message, "MEDIA:") {
		return ErrorResult("delegation files are published only after the delegated run completes")
	}

	channel := argString(args, "channel")
	if channel == "" {
		channel = ToolChannelFromCtx(ctx)
	}
	if channel == "" {
		return ErrorResult("channel is required (no current channel in context)")
	}

	target := argString(args, "target")
	if target == "" {
		target = ToolChatIDFromCtx(ctx)
	}
	if target == "" {
		return ErrorResult("target chat ID is required (no current chat in context)")
	}

	// Self-send guard: prevent agent from sending to its own chat via message tool.
	// Text self-sends are always blocked (response goes through normal outbound).
	// MEDIA self-sends are allowed ONLY when the file was NOT already queued for
	// automatic delivery. This prevents both duplicate delivery and runaway retry
	// loops while preserving explicit delivery of files that are not auto-queued.
	ctxChannel := ToolChannelFromCtx(ctx)
	ctxChatID := ToolChatIDFromCtx(ctx)
	isSelfSend := ctxChannel != "" && ctxChatID != "" && channel == ctxChannel && target == ctxChatID
	if isSelfSend {
		isMediaSend := embeddedMediaPattern.MatchString(message)
		if !isMediaSend {
			return ErrorResult("You are already responding to this chat. Your response text will be delivered automatically. Do not use the message tool to send text to your own chat — just include the content in your response text. To deliver files, use write_file with deliver=true instead.")
		}
		// MEDIA self-send: block if any referenced file is already queued for
		// delivery. Sending a mixed set would still duplicate the queued files;
		// the model can retry with only the undelivered references.
		if dm := DeliveredMediaFromCtx(ctx); dm != nil {
			mediaRefs := embeddedMediaPattern.FindAllString(message, -1)
			hasDelivered := false
			for _, raw := range mediaRefs {
				if filePath, ok := t.resolveMediaPath(ctx, raw); ok {
					if dm.IsDelivered(filePath) {
						hasDelivered = true
						break
					}
				}
			}
			if hasDelivered {
				return ErrorResult("One or more files are already queued for automatic delivery. Do not send them again with message(MEDIA:path). Retry with only files that are not queued for automatic delivery.")
			}
		}
	}

	// Tenant isolation: validate channel belongs to current tenant.
	if err := t.validateChannelTenant(ctx, channel, target); err != nil {
		return err
	}

	// Cross-target guard: in DM/group/default sessions, prevent the agent from
	// sending to a chat other than the one bound to its context. FREE session
	// kinds (cron/heartbeat/subagent/team) compose targets per job spec and
	// bypass this guard. Opt-in forwarding requires forward=true +
	// non-empty forward_reason; notice is posted back to the origin chat and
	// an slog audit line is emitted.
	sessionKey := ToolSessionKeyFromCtx(ctx)
	var forwardReason string // non-empty ⇒ guard allowed a cross-target forward; post notice on success
	if MessageTargetEnforced(sessionKey) {
		crossTarget := channel != ctxChannel || target != ctxChatID
		if crossTarget && (ctxChannel != "" || ctxChatID != "") {
			forward, _ := args["forward"].(bool)
			reason := strings.TrimSpace(argString(args, "forward_reason"))
			if !forward || reason == "" {
				return ErrorResult(fmt.Sprintf(
					"Cross-target send blocked. You are bound to %s/%s but tried to send to %s/%s. "+
						"If the user explicitly asked you to forward, retry with forward=true AND forward_reason=\"<quote user's literal request>\".",
					ctxChannel, ctxChatID, channel, target))
			}
			slog.Warn("message.cross_target_forward",
				"session", sessionKey,
				"from_channel", ctxChannel, "from", ctxChatID,
				"to_channel", channel, "to", target,
				"reason", reason)
			forwardReason = reason
		}
	}
	// noticeOnSuccess posts the cross-target breadcrumb back to origin iff the
	// forward succeeded (res.IsError == false). Guarantees we never announce
	// a fake delivery when the downstream sender/bus publish fails.
	noticeOnSuccess := func(res *Result) *Result {
		if forwardReason != "" && res != nil && !res.IsError {
			t.postCrossTargetNotice(ctx, target, forwardReason)
		}
		return res
	}

	// Handle MEDIA: prefix — send file as attachment instead of text.
	if filePath, ok := t.resolveMediaPath(ctx, message); ok {
		return noticeOnSuccess(t.sendMedia(ctx, channel, target, filePath))
	}

	// Extract embedded MEDIA: paths from multi-line messages.
	// LLMs may include MEDIA: in conversational text rather than as a standalone prefix.
	message, embeddedMedia := t.extractEmbeddedMedia(ctx, message)

	// If we found embedded media and bus is available, prefer bus path (supports media attachments).
	if len(embeddedMedia) > 0 && t.msgBus != nil {
		outMsg := bus.OutboundMessage{
			Channel:  channel,
			ChatID:   target,
			Content:  message,
			Media:    embeddedMedia,
			Metadata: t.buildOutboundMetadata(ctx, target, forwardReason),
		}
		t.msgBus.PublishOutbound(outMsg)
		// Mark each embedded media path as delivered.
		if dm := DeliveredMediaFromCtx(ctx); dm != nil {
			for _, att := range embeddedMedia {
				dm.Mark(att.URL)
			}
		}
		return noticeOnSuccess(SilentResult(fmt.Sprintf(`{"status":"sent","channel":"%s","target":"%s"}`, channel, target)))
	}

	// Prefer direct channel sender for immediate delivery.
	// For group chats, fall through to message bus which supports metadata.
	if t.sender != nil && !isGroupContext(ctx) {
		if err := t.sender(ctx, channel, target, message); err != nil {
			return ErrorResult(fmt.Sprintf("failed to send message: %v", err))
		}
		return noticeOnSuccess(SilentResult(fmt.Sprintf(`{"status":"sent","channel":"%s","target":"%s"}`, channel, target)))
	}

	// Publish via message bus outbound queue.
	// Group messages include metadata so channel implementations (e.g. Zalo)
	// can distinguish group sends from DMs.
	if t.msgBus != nil {
		outMsg := bus.OutboundMessage{
			Channel:  channel,
			ChatID:   target,
			Content:  message,
			Metadata: t.buildOutboundMetadata(ctx, target, forwardReason),
		}
		t.msgBus.PublishOutbound(outMsg)
		return noticeOnSuccess(SilentResult(fmt.Sprintf(`{"status":"sent","channel":"%s","target":"%s"}`, channel, target)))
	}

	// Last resort: direct sender without group metadata.
	if t.sender != nil {
		if err := t.sender(ctx, channel, target, message); err != nil {
			return ErrorResult(fmt.Sprintf("failed to send message: %v", err))
		}
		return noticeOnSuccess(SilentResult(fmt.Sprintf(`{"status":"sent","channel":"%s","target":"%s"}`, channel, target)))
	}

	return ErrorResult("no channel sender or message bus available")
}

// buildOutboundMetadata merges group-context routing metadata with
// forward-origin tracking. The bus consumer (dispatchOutbound) runs async
// with no path back to this call, so when forwardReason is non-empty we
// stash the origin channel/chat here — that's the only way a downstream
// delivery failure can be reported back to the chat that requested the
// forward instead of vanishing silently.
func (t *MessageTool) buildOutboundMetadata(ctx context.Context, target, forwardReason string) map[string]string {
	var meta map[string]string
	if isGroupContext(ctx) {
		meta = map[string]string{"group_id": target}
	}
	if forwardReason == "" {
		return meta
	}
	origCh := ToolChannelFromCtx(ctx)
	origChat := ToolChatIDFromCtx(ctx)
	if origCh == "" || origChat == "" {
		return meta
	}
	if meta == nil {
		meta = make(map[string]string, 2)
	}
	meta[bus.MetaForwardOriginChannel] = origCh
	meta[bus.MetaForwardOriginChatID] = origChat
	return meta
}

// executeTopicSend posts a message into a named forum topic of the current group.
// The topic is always in the current chat, so channel/chat come from context
// (reliable) — this also sidesteps the self-send guard, since a topic post is a
// deliberate cross-topic delivery, not a reply loop.
func (t *MessageTool) executeTopicSend(ctx context.Context, args map[string]any, topicName string) *Result {
	message := argString(args, "message")
	if message == "" {
		return ErrorResult("message is required")
	}
	channel := ToolChannelFromCtx(ctx)
	if channel == "" {
		channel = argString(args, "channel")
	}
	target := ToolChatIDFromCtx(ctx)
	if target == "" {
		target = argString(args, "target")
	}
	if channel == "" || target == "" {
		return ErrorResult("posting to a topic needs the current channel/chat context")
	}
	if t.topicResolver == nil {
		return ErrorResult("topic posting is not supported in this context")
	}
	threadID, ok := t.topicResolver(ctx, channel, target, topicName)
	if !ok {
		return ErrorResult(fmt.Sprintf("topic %q not found in this group — I only know topics created while I'm in the group. Ask an admin to (re)create it, or tell me the topic differently.", topicName))
	}
	if err := t.validateChannelTenant(ctx, channel, target); err != nil {
		return err
	}

	// Preferred path: post synchronously and return the sent message_id so the
	// agent can remember it and later edit that exact post (no duplicates).
	if t.topicPoster != nil {
		threadNum, _ := strconv.Atoi(threadID)
		msgID, err := t.topicPoster(ctx, channel, target, threadNum, message)
		if err != nil {
			return ErrorResult(fmt.Sprintf("failed to post to topic %q: %v", topicName, err))
		}
		return SilentResult(fmt.Sprintf(`{"status":"sent","channel":"%s","target":"%s","topic":"%s","thread_id":%d,"message_id":%d}`, channel, target, topicName, threadNum, msgID))
	}

	// Fallback: async via the bus (no message_id available).
	if t.msgBus == nil {
		return ErrorResult("topic posting requires the message bus")
	}
	t.msgBus.PublishOutbound(bus.OutboundMessage{
		Channel: channel,
		ChatID:  target,
		Content: message,
		Metadata: map[string]string{
			"group_id":          target,
			"message_thread_id": threadID,
		},
	})
	return SilentResult(fmt.Sprintf(`{"status":"sent","channel":"%s","target":"%s","topic":"%s","thread_id":"%s"}`, channel, target, topicName, threadID))
}

// executeEdit edits an existing message in a channel (e.g. flip a ❌ to a ✅ in a
// status post). The message_id is typically the id of the message the user
// replied to — surfaced to the agent as reply_to_message_id in context.
func (t *MessageTool) executeEdit(ctx context.Context, args map[string]any) *Result {
	if t.editor == nil {
		return ErrorResult("editing messages is not supported in this context")
	}
	messageID := argInt(args, "message_id")
	if messageID == 0 {
		return ErrorResult("message_id is required for edit (use the id of the message to change — usually the one the user replied to)")
	}
	message := argString(args, "message")
	if message == "" {
		return ErrorResult("message (the new full text) is required for edit")
	}

	// Edits target the message the user replied to in the CURRENT chat, so prefer
	// the context channel/chat (reliable) over LLM-supplied args — models often
	// pass the platform name ("telegram") instead of the channel instance, or a
	// null target. Fall back to args only when context is absent.
	channel := ToolChannelFromCtx(ctx)
	if channel == "" {
		channel = argString(args, "channel")
	}
	if channel == "" {
		return ErrorResult("channel is required (no current channel in context)")
	}
	target := ToolChatIDFromCtx(ctx)
	if target == "" {
		target = argString(args, "target")
	}
	if target == "" {
		return ErrorResult("target chat ID is required (no current chat in context)")
	}

	if err := t.validateChannelTenant(ctx, channel, target); err != nil {
		return err
	}
	if err := t.editor(ctx, channel, target, messageID, message); err != nil {
		return ErrorResult(fmt.Sprintf("failed to edit message: %v", err))
	}
	return SilentResult(fmt.Sprintf(`{"status":"edited","channel":"%s","target":"%s","message_id":%d}`, channel, target, messageID))
}

// executeReact sets an emoji reaction on an existing message (e.g. 👍 on the
// bot's own status post once it's fully paid). Targets message_id in the current
// channel/chat. Only platform-supported reaction emojis are allowed.
func (t *MessageTool) executeReact(ctx context.Context, args map[string]any) *Result {
	if t.reactionSetter == nil {
		return ErrorResult("reactions are not supported in this context")
	}
	messageID := argInt(args, "message_id")
	if messageID == 0 {
		return ErrorResult("message_id is required for react (the id of the message to react to — usually your own earlier post)")
	}
	emoji := argString(args, "emoji")
	if emoji == "" {
		return ErrorResult("emoji is required for react (e.g. 👍 — note ✅/❌ are not valid Telegram reactions)")
	}

	channel := ToolChannelFromCtx(ctx)
	if channel == "" {
		channel = argString(args, "channel")
	}
	if channel == "" {
		return ErrorResult("channel is required (no current channel in context)")
	}
	target := ToolChatIDFromCtx(ctx)
	if target == "" {
		target = argString(args, "target")
	}
	if target == "" {
		return ErrorResult("target chat ID is required (no current chat in context)")
	}

	if err := t.validateChannelTenant(ctx, channel, target); err != nil {
		return err
	}
	if err := t.reactionSetter(ctx, channel, target, messageID, emoji); err != nil {
		return ErrorResult(fmt.Sprintf("failed to set reaction: %v", err))
	}
	return SilentResult(fmt.Sprintf(`{"status":"reacted","channel":"%s","target":"%s","message_id":%d,"emoji":"%s"}`, channel, target, messageID, emoji))
}

// validateChannelTenant checks the target channel belongs to the current tenant.
// Returns an error Result if the send should be blocked, nil if allowed.
func (t *MessageTool) validateChannelTenant(ctx context.Context, channel, target string) *Result {
	if t.tenantChecker == nil {
		return nil
	}
	chTenant, chExists := t.tenantChecker(channel)
	if !chExists {
		return ErrorResult(fmt.Sprintf("channel %q not found", channel))
	}
	// Allow: legacy/config-based channels (zero tenant) or master tenant context (system ops).
	if chTenant == uuid.Nil {
		return nil
	}
	ctxTenant := store.TenantIDFromContext(ctx)
	if ctxTenant == uuid.Nil {
		return nil // master tenant / system context
	}
	if chTenant != ctxTenant {
		slog.Warn("security.cross_tenant_send_blocked",
			"channel", channel, "target", target,
			"ctx_tenant", ctxTenant, "ch_tenant", chTenant)
		return ErrorResult("channel not accessible from this tenant")
	}
	return nil
}

// sendMedia sends a file as a media attachment via the outbound message bus.
func (t *MessageTool) sendMedia(ctx context.Context, channel, target, filePath string) *Result {
	if err := ValidateRegularFileForRead(filePath); err != nil {
		return ErrorResult(fmt.Sprintf("media path is not a safe regular file: %v", err))
	}
	if t.msgBus == nil {
		return ErrorResult("media sending requires message bus")
	}

	// Build metadata for group routing (Zalo needs group_id to choose group API).
	var meta map[string]string
	if isGroupContext(ctx) {
		meta = map[string]string{"group_id": target}
	}

	t.msgBus.PublishOutbound(bus.OutboundMessage{
		Channel:  channel,
		ChatID:   target,
		Media:    []bus.MediaAttachment{{URL: filePath, ContentType: mimeFromPath(filePath)}},
		Metadata: meta,
	})
	// Mark delivered so subsequent send_file or message(MEDIA:) calls detect the duplicate.
	if dm := DeliveredMediaFromCtx(ctx); dm != nil {
		dm.Mark(filePath)
	}
	out, _ := json.Marshal(map[string]string{
		"status":  "sent",
		"channel": channel,
		"target":  target,
		"media":   filepath.Base(filePath),
	})
	return SilentResult(string(out))
}

// extractEmbeddedMedia scans a multi-line message for embedded MEDIA: path references.
// Returns cleaned text (MEDIA: lines removed) and resolved media attachments.
// Prevents raw MEDIA: paths from leaking to channels when LLMs embed them
// in conversational text instead of using a standalone MEDIA: prefix.
func (t *MessageTool) extractEmbeddedMedia(ctx context.Context, message string) (string, []bus.MediaAttachment) {
	if !strings.Contains(message, "MEDIA:") {
		return message, nil
	}

	lines := strings.Split(message, "\n")
	var cleaned []string
	var media []bus.MediaAttachment

	for _, line := range lines {
		trimmed := strings.TrimSpace(line)
		// Skip [[audio_as_voice]] tags (TTS voice messages).
		if strings.HasPrefix(trimmed, "[[audio_as_voice]]") {
			continue
		}
		// Find all MEDIA: tokens on this line.
		matches := embeddedMediaPattern.FindAllString(trimmed, -1)
		if len(matches) == 0 {
			cleaned = append(cleaned, line)
			continue
		}
		// Extract each MEDIA: path and resolve via security-checked path resolution.
		for _, raw := range matches {
			if resolved, ok := t.resolveMediaPath(ctx, raw); ok {
				if err := ValidateRegularFileForRead(resolved); err != nil {
					continue
				}
				media = append(media, bus.MediaAttachment{
					URL:         resolved,
					ContentType: mimeFromPath(resolved),
				})
			}
		}
		// Strip MEDIA: tokens from line, keep surrounding text.
		remainder := strings.TrimSpace(embeddedMediaPattern.ReplaceAllString(line, ""))
		if remainder != "" {
			cleaned = append(cleaned, remainder)
		}
	}

	return strings.TrimSpace(strings.Join(cleaned, "\n")), media
}

// mimeFromPath returns a MIME type based on file extension.
// Duplicated from agent.mimeFromExt to avoid tools→agent import cycle.
func mimeFromPath(path string) string {
	switch strings.ToLower(filepath.Ext(path)) {
	case ".png":
		return "image/png"
	case ".jpg", ".jpeg":
		return "image/jpeg"
	case ".gif":
		return "image/gif"
	case ".webp":
		return "image/webp"
	case ".mp4":
		return "video/mp4"
	case ".ogg", ".opus":
		return "audio/ogg"
	case ".mp3":
		return "audio/mpeg"
	case ".wav":
		return "audio/wav"
	case ".pdf":
		return "application/pdf"
	case ".doc":
		return "application/msword"
	case ".docx":
		return "application/vnd.openxmlformats-officedocument.wordprocessingml.document"
	case ".xls":
		return "application/vnd.ms-excel"
	case ".xlsx":
		return "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet"
	default:
		return "application/octet-stream"
	}
}

// argString reads a tool argument as a non-empty string. LLM tool JSON often encodes
// numeric chat IDs as JSON numbers (float64); a plain .(string) type assert would
// ignore them and fall back to context — wrong for proactive sends to a group.
func argString(m map[string]any, key string) string {
	v, ok := m[key]
	if !ok || v == nil {
		return ""
	}
	switch s := v.(type) {
	case string:
		return strings.TrimSpace(s)
	case float64:
		if s != s { // NaN
			return ""
		}
		// Telegram chat IDs are integers; json.Unmarshal uses float64 for all numbers.
		if s == float64(int64(s)) {
			return strconv.FormatInt(int64(s), 10)
		}
		return strings.TrimSpace(fmt.Sprintf("%.0f", s))
	case int:
		return strconv.FormatInt(int64(s), 10)
	case int64:
		return strconv.FormatInt(s, 10)
	case json.Number:
		return strings.TrimSpace(string(s))
	default:
		return strings.TrimSpace(fmt.Sprint(s))
	}
}

// isGroupContext returns true if the current context indicates a group conversation.
func isGroupContext(ctx context.Context) bool {
	userID := store.UserIDFromContext(ctx)
	return ToolPeerKindFromCtx(ctx) == "group" ||
		strings.HasPrefix(userID, "group:") ||
		strings.HasPrefix(userID, "guild:")
}

// resolveMediaPath extracts and validates a file path from a "MEDIA:path" string.
// Uses the same workspace-aware path resolution as other filesystem tools.
// Multi-tenant isolation forces MEDIA: paths through restricted resolution.
// In practice MEDIA: paths may resolve to:
//   - files inside the agent workspace
//   - files inside an explicitly authorized team/collaboration read root
//
// Relative paths are resolved against the agent's workspace.
func (t *MessageTool) resolveMediaPath(ctx context.Context, s string) (string, bool) {
	s = strings.TrimSpace(s)
	if !strings.HasPrefix(s, "MEDIA:") {
		return "", false
	}
	raw := strings.TrimSpace(s[len("MEDIA:"):])
	if raw == "" || raw == "." {
		return "", false
	}

	workspace := ToolWorkspaceFromCtx(ctx)
	if workspace == "" {
		workspace = t.workspace
	}
	restrict := effectiveRestrict(ctx, t.restrict)

	// Use the read-only prefix set so orchestrators can publish media produced
	// by linked agents or team members without granting mutation access.
	resolved, err := resolvePathWithAllowed(raw, workspace, restrict, allowedWithTeamWorkspace(ctx, nil))
	if err != nil {
		return "", false
	}

	return resolved, true
}

// isInTempDir checks whether an absolute path is inside os.TempDir().
func isInTempDir(path string) bool {
	cleaned := filepath.Clean(path)
	if !filepath.IsAbs(cleaned) {
		return false
	}
	tmpDir := filepath.Clean(os.TempDir())
	return strings.HasPrefix(cleaned, tmpDir+string(filepath.Separator))
}