package discord

import (
	"context"
	"encoding/json"
	"fmt"
	"io"
	"net/http"
	"net/http/httptest"
	"reflect"
	"strings"
	"sync"
	"sync/atomic"
	"testing"

	"github.com/bwmarrin/discordgo"
	"github.com/chenhg5/cc-connect/core"
)

// ── Thread tests (upstream) ──────────────────────────────────

type fakeThreadOps struct {
	resolveChannel        func(channelID string) (*discordgo.Channel, error)
	startThread           func(channelID, messageID, name string, archiveDuration int) (*discordgo.Channel, error)
	startStandaloneThread func(channelID, name string, typ discordgo.ChannelType, archiveDuration int) (*discordgo.Channel, error)
	joinThread            func(threadID string) error
}

func newTestDiscordSession(t *testing.T, server *httptest.Server) *discordgo.Session {
	t.Helper()

	oldEndpointDiscord := discordgo.EndpointDiscord
	oldEndpointAPI := discordgo.EndpointAPI
	oldEndpointChannels := discordgo.EndpointChannels
	oldEndpointWebhooks := discordgo.EndpointWebhooks
	discordgo.EndpointDiscord = server.URL + "/"
	discordgo.EndpointAPI = discordgo.EndpointDiscord + "api/v" + discordgo.APIVersion + "/"
	discordgo.EndpointChannels = discordgo.EndpointAPI + "channels/"
	discordgo.EndpointWebhooks = discordgo.EndpointAPI + "webhooks/"
	t.Cleanup(func() {
		discordgo.EndpointDiscord = oldEndpointDiscord
		discordgo.EndpointAPI = oldEndpointAPI
		discordgo.EndpointChannels = oldEndpointChannels
		discordgo.EndpointWebhooks = oldEndpointWebhooks
	})

	s, err := discordgo.New("Bot test-token")
	if err != nil {
		t.Fatalf("discordgo.New() error = %v", err)
	}
	s.Client = server.Client()
	return s
}

func (f fakeThreadOps) ResolveChannel(channelID string) (*discordgo.Channel, error) {
	if f.resolveChannel == nil {
		return nil, nil
	}
	return f.resolveChannel(channelID)
}

func (f fakeThreadOps) StartThread(channelID, messageID, name string, archiveDuration int) (*discordgo.Channel, error) {
	if f.startThread == nil {
		return nil, nil
	}
	return f.startThread(channelID, messageID, name, archiveDuration)
}

func (f fakeThreadOps) StartStandaloneThread(channelID, name string, typ discordgo.ChannelType, archiveDuration int) (*discordgo.Channel, error) {
	if f.startStandaloneThread == nil {
		return nil, nil
	}
	return f.startStandaloneThread(channelID, name, typ, archiveDuration)
}

func (f fakeThreadOps) JoinThread(threadID string) error {
	if f.joinThread == nil {
		return nil
	}
	return f.joinThread(threadID)
}

func TestResolveThreadReplyContext_UsesExistingThreadChannel(t *testing.T) {
	ops := fakeThreadOps{
		resolveChannel: func(channelID string) (*discordgo.Channel, error) {
			return &discordgo.Channel{ID: channelID, Type: discordgo.ChannelTypeGuildPublicThread}, nil
		},
	}

	joinedThread := ""
	ops.joinThread = func(threadID string) error {
		joinedThread = threadID
		return nil
	}

	// Override resolveChannel to return a thread with a populated ParentID,
	// so the helper can surface the parent channel for workspace binding.
	ops.resolveChannel = func(channelID string) (*discordgo.Channel, error) {
		return &discordgo.Channel{
			ID:       channelID,
			Type:     discordgo.ChannelTypeGuildPublicThread,
			ParentID: "channel-parent",
		}, nil
	}

	msg := &discordgo.MessageCreate{
		Message: &discordgo.Message{
			ID:        "m1",
			ChannelID: "thread-1",
			GuildID:   "guild-1",
			Author:    &discordgo.User{ID: "u1", Username: "jun"},
		},
	}

	sessionKey, rc, parentChannelID, err := resolveThreadReplyContext(msg, "bot-1", ops)
	if err != nil {
		t.Fatalf("resolveThreadReplyContext() error = %v", err)
	}
	if sessionKey != "discord:thread-1" {
		t.Fatalf("sessionKey = %q, want discord:thread-1", sessionKey)
	}
	if rc.channelID != "thread-1" || rc.threadID != "thread-1" {
		t.Fatalf("replyContext = %#v, want thread channel routing", rc)
	}
	if parentChannelID != "channel-parent" {
		t.Fatalf("parentChannelID = %q, want channel-parent", parentChannelID)
	}
	if joinedThread != "thread-1" {
		t.Fatalf("joinedThread = %q, want thread-1", joinedThread)
	}
}

func TestResolveThreadReplyContext_FallsBackToMessageChannelWhenParentMissing(t *testing.T) {
	// Defensive path: if discordgo (or a future API change) ever leaves
	// ParentID empty on a thread channel, the helper must still return
	// *some* parent channel ID — best fallback is the thread ID itself,
	// matching m.ChannelID. Auto-bind will then key off the thread name,
	// which is no worse than the pre-fix behavior.
	ops := fakeThreadOps{
		resolveChannel: func(channelID string) (*discordgo.Channel, error) {
			return &discordgo.Channel{ID: channelID, Type: discordgo.ChannelTypeGuildPublicThread}, nil
		},
		joinThread: func(string) error { return nil },
	}
	msg := &discordgo.MessageCreate{
		Message: &discordgo.Message{
			ID:        "m1",
			ChannelID: "thread-orphan",
			GuildID:   "guild-1",
			Author:    &discordgo.User{ID: "u1"},
		},
	}
	_, _, parentChannelID, err := resolveThreadReplyContext(msg, "bot-1", ops)
	if err != nil {
		t.Fatalf("resolveThreadReplyContext() error = %v", err)
	}
	if parentChannelID != "thread-orphan" {
		t.Fatalf("parentChannelID = %q, want thread-orphan (fallback)", parentChannelID)
	}
}

func TestResolveThreadReplyContext_CreatesThreadForGuildMessage(t *testing.T) {
	ops := fakeThreadOps{
		resolveChannel: func(channelID string) (*discordgo.Channel, error) {
			return &discordgo.Channel{ID: channelID, Type: discordgo.ChannelTypeGuildText}, nil
		},
	}

	var (
		startChannelID string
		startMessageID string
		startName      string
		joinedThread   string
	)
	ops.startThread = func(channelID, messageID, name string, archiveDuration int) (*discordgo.Channel, error) {
		startChannelID = channelID
		startMessageID = messageID
		startName = name
		if archiveDuration != 1440 {
			t.Fatalf("archiveDuration = %d, want 1440", archiveDuration)
		}
		return &discordgo.Channel{ID: "thread-99", Type: discordgo.ChannelTypeGuildPublicThread}, nil
	}
	ops.joinThread = func(threadID string) error {
		joinedThread = threadID
		return nil
	}

	msg := &discordgo.MessageCreate{
		Message: &discordgo.Message{
			ID:        "msg-42",
			ChannelID: "channel-1",
			GuildID:   "guild-1",
			Content:   "<@bot-1> investigate build failure",
			Author:    &discordgo.User{ID: "u1", Username: "jun"},
		},
	}

	sessionKey, rc, parentChannelID, err := resolveThreadReplyContext(msg, "bot-1", ops)
	if err != nil {
		t.Fatalf("resolveThreadReplyContext() error = %v", err)
	}
	if sessionKey != "discord:thread-99" {
		t.Fatalf("sessionKey = %q, want discord:thread-99", sessionKey)
	}
	if rc.channelID != "thread-99" || rc.threadID != "thread-99" {
		t.Fatalf("replyContext = %#v, want thread channel routing", rc)
	}
	if parentChannelID != "channel-1" {
		t.Fatalf("parentChannelID = %q, want channel-1", parentChannelID)
	}
	if startChannelID != "channel-1" || startMessageID != "msg-42" {
		t.Fatalf("thread start args = (%q, %q), want (channel-1, msg-42)", startChannelID, startMessageID)
	}
	if startName != "investigate build failure" {
		t.Fatalf("thread name = %q, want sanitized content", startName)
	}
	if joinedThread != "thread-99" {
		t.Fatalf("joinedThread = %q, want thread-99", joinedThread)
	}
}

func TestSessionKeyForChannel_UsesThreadKeyWhenChannelIsThread(t *testing.T) {
	ops := fakeThreadOps{
		resolveChannel: func(channelID string) (*discordgo.Channel, error) {
			return &discordgo.Channel{ID: channelID, Type: discordgo.ChannelTypeGuildPrivateThread}, nil
		},
	}

	if got := resolveSessionKeyForChannel("thread-7", "user-1", false, true, ops); got != "discord:thread-7" {
		t.Fatalf("resolveSessionKeyForChannel() = %q, want discord:thread-7", got)
	}
}

func TestResolveParentChannelID(t *testing.T) {
	cases := []struct {
		name      string
		channelID string
		channel   *discordgo.Channel
		resolve   func(string) (*discordgo.Channel, error)
		want      string
	}{
		{
			name:      "thread-with-parent",
			channelID: "thread-1",
			channel:   &discordgo.Channel{ID: "thread-1", Type: discordgo.ChannelTypeGuildPublicThread, ParentID: "channel-parent"},
			want:      "channel-parent",
		},
		{
			name:      "regular-channel-passes-through",
			channelID: "channel-1",
			channel:   &discordgo.Channel{ID: "channel-1", Type: discordgo.ChannelTypeGuildText},
			want:      "channel-1",
		},
		{
			name:      "thread-without-parent-falls-back",
			channelID: "thread-orphan",
			channel:   &discordgo.Channel{ID: "thread-orphan", Type: discordgo.ChannelTypeGuildPublicThread},
			want:      "thread-orphan",
		},
		{
			name:      "resolve-error-falls-back",
			channelID: "channel-x",
			resolve:   func(string) (*discordgo.Channel, error) { return nil, fmt.Errorf("not found") },
			want:      "channel-x",
		},
	}
	for _, tc := range cases {
		t.Run(tc.name, func(t *testing.T) {
			ops := fakeThreadOps{}
			if tc.resolve != nil {
				ops.resolveChannel = tc.resolve
			} else {
				ch := tc.channel
				ops.resolveChannel = func(string) (*discordgo.Channel, error) { return ch, nil }
			}
			if got := resolveParentChannelID(tc.channelID, ops); got != tc.want {
				t.Errorf("resolveParentChannelID(%q) = %q, want %q", tc.channelID, got, tc.want)
			}
		})
	}
}

func TestReconstructReplyCtx_ThreadSessionKey(t *testing.T) {
	p := &Platform{}

	rctx, err := p.ReconstructReplyCtx("discord:thread-7")
	if err != nil {
		t.Fatalf("ReconstructReplyCtx() error = %v", err)
	}
	rc := rctx.(replyContext)
	if rc.channelID != "thread-7" || rc.threadID != "thread-7" {
		t.Fatalf("replyContext = %#v, want thread reply context", rc)
	}
}

func TestResolveCronReplyTarget_CreatesStandaloneThread(t *testing.T) {
	ops := fakeThreadOps{
		resolveChannel: func(channelID string) (*discordgo.Channel, error) {
			return &discordgo.Channel{ID: channelID, Type: discordgo.ChannelTypeGuildText}, nil
		},
	}

	var (
		startChannelID string
		startName      string
		startType      discordgo.ChannelType
		joinedThread   string
	)
	ops.startStandaloneThread = func(channelID, name string, typ discordgo.ChannelType, archiveDuration int) (*discordgo.Channel, error) {
		startChannelID = channelID
		startName = name
		startType = typ
		if archiveDuration != 1440 {
			t.Fatalf("archiveDuration = %d, want 1440", archiveDuration)
		}
		return &discordgo.Channel{ID: "thread-fresh", Type: discordgo.ChannelTypeGuildPublicThread}, nil
	}
	ops.joinThread = func(threadID string) error {
		joinedThread = threadID
		return nil
	}

	sessionKey, rc, err := resolveCronReplyTarget("discord:channel-1:user-1", "Daily sync", ops)
	if err != nil {
		t.Fatalf("resolveCronReplyTarget() error = %v", err)
	}
	if sessionKey != "discord:thread-fresh" {
		t.Fatalf("sessionKey = %q, want discord:thread-fresh", sessionKey)
	}
	if rc.channelID != "thread-fresh" || rc.threadID != "thread-fresh" {
		t.Fatalf("replyContext = %#v, want fresh thread routing", rc)
	}
	if startChannelID != "channel-1" {
		t.Fatalf("startChannelID = %q, want channel-1", startChannelID)
	}
	if startName != "Daily sync" {
		t.Fatalf("thread name = %q, want Daily sync", startName)
	}
	if startType != discordgo.ChannelTypeGuildPublicThread {
		t.Fatalf("thread type = %v, want public thread", startType)
	}
	if joinedThread != "thread-fresh" {
		t.Fatalf("joinedThread = %q, want thread-fresh", joinedThread)
	}
}

func TestResolveCronReplyTarget_ReusesExistingThreadKey(t *testing.T) {
	ops := fakeThreadOps{
		resolveChannel: func(channelID string) (*discordgo.Channel, error) {
			switch channelID {
			case "thread-1":
				return &discordgo.Channel{ID: "thread-1", Type: discordgo.ChannelTypeGuildPublicThread, ParentID: "channel-1"}, nil
			case "channel-1":
				return &discordgo.Channel{ID: "channel-1", Type: discordgo.ChannelTypeGuildText}, nil
			default:
				t.Fatalf("unexpected channel lookup %q", channelID)
				return nil, nil
			}
		},
	}

	startChannelID := ""
	ops.startStandaloneThread = func(channelID, name string, typ discordgo.ChannelType, archiveDuration int) (*discordgo.Channel, error) {
		startChannelID = channelID
		return &discordgo.Channel{ID: "thread-fresh-2", Type: discordgo.ChannelTypeGuildPublicThread}, nil
	}

	sessionKey, rc, err := resolveCronReplyTarget("discord:thread-1", "cron", ops)
	if err != nil {
		t.Fatalf("resolveCronReplyTarget() error = %v", err)
	}
	if sessionKey != "discord:thread-fresh-2" {
		t.Fatalf("sessionKey = %q, want discord:thread-fresh-2", sessionKey)
	}
	if rc.threadID != "thread-fresh-2" {
		t.Fatalf("replyContext = %#v, want thread-fresh-2", rc)
	}
	if startChannelID != "channel-1" {
		t.Fatalf("startChannelID = %q, want channel-1", startChannelID)
	}
}

func TestSendWithButtons_UsesFollowupComponents(t *testing.T) {
	requests := make([]string, 0, 2)
	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		requests = append(requests, r.URL.Path)
		var payload map[string]any
		if err := json.NewDecoder(r.Body).Decode(&payload); err != nil {
			t.Fatalf("decode request: %v", err)
		}
		switch {
		case strings.Contains(r.URL.Path, "/messages/@original"):
			if payload["content"] != "choose mode" {
				t.Fatalf("original content = %#v, want choose mode", payload["content"])
			}
		case strings.Contains(r.URL.Path, "/webhooks/app-1/token-1"):
			if payload["content"] != "choose mode" {
				t.Fatalf("followup content = %#v, want choose mode", payload["content"])
			}
			components, ok := payload["components"].([]any)
			if !ok || len(components) != 1 {
				t.Fatalf("components = %#v, want one row", payload["components"])
			}
			row := components[0].(map[string]any)
			rowComponents := row["components"].([]any)
			if rowComponents[0].(map[string]any)["custom_id"] != "cmd:/mode default" {
				t.Fatalf("button0 = %#v, want cmd:/mode default", rowComponents[0])
			}
			if rowComponents[1].(map[string]any)["custom_id"] != "cmd:/mode yolo" {
				t.Fatalf("button1 = %#v, want cmd:/mode yolo", rowComponents[1])
			}
		}
		w.Header().Set("Content-Type", "application/json")
		_, _ = fmt.Fprint(w, `{"id":"msg-1","channel_id":"ch-1"}`)
	}))
	defer server.Close()

	oldEndpointDiscord := discordgo.EndpointDiscord
	oldEndpointAPI := discordgo.EndpointAPI
	oldEndpointChannels := discordgo.EndpointChannels
	oldEndpointWebhooks := discordgo.EndpointWebhooks
	discordgo.EndpointDiscord = server.URL + "/"
	discordgo.EndpointAPI = discordgo.EndpointDiscord + "api/v" + discordgo.APIVersion + "/"
	discordgo.EndpointChannels = discordgo.EndpointAPI + "channels/"
	discordgo.EndpointWebhooks = discordgo.EndpointAPI + "webhooks/"
	defer func() {
		discordgo.EndpointDiscord = oldEndpointDiscord
		discordgo.EndpointAPI = oldEndpointAPI
		discordgo.EndpointChannels = oldEndpointChannels
		discordgo.EndpointWebhooks = oldEndpointWebhooks
	}()

	s, err := discordgo.New("Bot test-token")
	if err != nil {
		t.Fatalf("discordgo.New() error = %v", err)
	}
	s.Client = server.Client()

	p := &Platform{session: s}
	rc := &interactionReplyCtx{interaction: &discordgo.Interaction{AppID: "app-1", Token: "token-1"}}
	err = p.SendWithButtons(context.Background(), rc, "choose mode", [][]core.ButtonOption{{
		{Text: "Default", Data: "cmd:/mode default"},
		{Text: "YOLO", Data: "cmd:/mode yolo"},
	}})
	if err != nil {
		t.Fatalf("SendWithButtons() error = %v", err)
	}
	if len(requests) != 2 {
		t.Fatalf("requests = %v, want 2", requests)
	}
}

func TestSendWithButtons_PreservesMultipleRows(t *testing.T) {
	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		var payload map[string]any
		if err := json.NewDecoder(r.Body).Decode(&payload); err != nil {
			t.Fatalf("decode request: %v", err)
		}
		if strings.Contains(r.URL.Path, "/messages/@original") {
			w.Header().Set("Content-Type", "application/json")
			_, _ = fmt.Fprint(w, `{"id":"msg-1","channel_id":"ch-1"}`)
			return
		}
		components, ok := payload["components"].([]any)
		if !ok || len(components) != 2 {
			t.Fatalf("components = %#v, want two rows", payload["components"])
		}
		first := components[0].(map[string]any)["components"].([]any)
		second := components[1].(map[string]any)["components"].([]any)
		if first[0].(map[string]any)["custom_id"] != "cmd:/reasoning 1" || first[1].(map[string]any)["custom_id"] != "cmd:/reasoning 2" {
			t.Fatalf("first row = %#v, want cmd:/reasoning 1 and 2", first)
		}
		if second[0].(map[string]any)["custom_id"] != "cmd:/reasoning 3" {
			t.Fatalf("second row = %#v, want cmd:/reasoning 3", second)
		}
		w.Header().Set("Content-Type", "application/json")
		_, _ = fmt.Fprint(w, `{"id":"msg-2","channel_id":"ch-1"}`)
	}))
	defer server.Close()

	oldEndpointDiscord := discordgo.EndpointDiscord
	oldEndpointAPI := discordgo.EndpointAPI
	oldEndpointChannels := discordgo.EndpointChannels
	oldEndpointWebhooks := discordgo.EndpointWebhooks
	discordgo.EndpointDiscord = server.URL + "/"
	discordgo.EndpointAPI = discordgo.EndpointDiscord + "api/v" + discordgo.APIVersion + "/"
	discordgo.EndpointChannels = discordgo.EndpointAPI + "channels/"
	discordgo.EndpointWebhooks = discordgo.EndpointAPI + "webhooks/"
	defer func() {
		discordgo.EndpointDiscord = oldEndpointDiscord
		discordgo.EndpointAPI = oldEndpointAPI
		discordgo.EndpointChannels = oldEndpointChannels
		discordgo.EndpointWebhooks = oldEndpointWebhooks
	}()

	s, err := discordgo.New("Bot test-token")
	if err != nil {
		t.Fatalf("discordgo.New() error = %v", err)
	}
	s.Client = server.Client()

	p := &Platform{session: s}
	rc := &interactionReplyCtx{interaction: &discordgo.Interaction{AppID: "app-1", Token: "token-1"}}
	err = p.SendWithButtons(context.Background(), rc, "choose reasoning", [][]core.ButtonOption{
		{{Text: "low", Data: "cmd:/reasoning 1"}, {Text: "medium", Data: "cmd:/reasoning 2"}},
		{{Text: "high", Data: "cmd:/reasoning 3"}},
	})
	if err != nil {
		t.Fatalf("SendWithButtons() error = %v", err)
	}
}

func TestSendFile_SendsChannelAttachment(t *testing.T) {
	var contentType string
	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		contentType = r.Header.Get("Content-Type")
		w.Header().Set("Content-Type", "application/json")
		_, _ = fmt.Fprint(w, `{"id":"msg-file","channel_id":"ch-1"}`)
	}))
	defer server.Close()

	oldEndpointDiscord := discordgo.EndpointDiscord
	oldEndpointAPI := discordgo.EndpointAPI
	oldEndpointChannels := discordgo.EndpointChannels
	discordgo.EndpointDiscord = server.URL + "/"
	discordgo.EndpointAPI = discordgo.EndpointDiscord + "api/v" + discordgo.APIVersion + "/"
	discordgo.EndpointChannels = discordgo.EndpointAPI + "channels/"
	defer func() {
		discordgo.EndpointDiscord = oldEndpointDiscord
		discordgo.EndpointAPI = oldEndpointAPI
		discordgo.EndpointChannels = oldEndpointChannels
	}()

	s, err := discordgo.New("Bot test-token")
	if err != nil {
		t.Fatalf("discordgo.New() error = %v", err)
	}
	s.Client = server.Client()

	p := &Platform{session: s}
	err = p.SendFile(context.Background(), replyContext{channelID: "ch-1"}, core.FileAttachment{
		FileName: "report.pdf",
		MimeType: "application/pdf",
		Data:     []byte("pdf-data"),
	})
	if err != nil {
		t.Fatalf("SendFile() error = %v", err)
	}
	if !strings.Contains(contentType, "multipart/form-data") {
		t.Fatalf("content type = %q, want multipart/form-data", contentType)
	}
}

func TestSendFile_UsesInteractionEndpoints(t *testing.T) {
	requests := make([]string, 0, 2)
	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		requests = append(requests, r.URL.Path)
		w.Header().Set("Content-Type", "application/json")
		_, _ = fmt.Fprint(w, `{"id":"msg-file","channel_id":"ch-1"}`)
	}))
	defer server.Close()

	oldEndpointDiscord := discordgo.EndpointDiscord
	oldEndpointAPI := discordgo.EndpointAPI
	oldEndpointChannels := discordgo.EndpointChannels
	oldEndpointWebhooks := discordgo.EndpointWebhooks
	discordgo.EndpointDiscord = server.URL + "/"
	discordgo.EndpointAPI = discordgo.EndpointDiscord + "api/v" + discordgo.APIVersion + "/"
	discordgo.EndpointChannels = discordgo.EndpointAPI + "channels/"
	discordgo.EndpointWebhooks = discordgo.EndpointAPI + "webhooks/"
	defer func() {
		discordgo.EndpointDiscord = oldEndpointDiscord
		discordgo.EndpointAPI = oldEndpointAPI
		discordgo.EndpointChannels = oldEndpointChannels
		discordgo.EndpointWebhooks = oldEndpointWebhooks
	}()

	s, err := discordgo.New("Bot test-token")
	if err != nil {
		t.Fatalf("discordgo.New() error = %v", err)
	}
	s.Client = server.Client()

	p := &Platform{session: s}
	rc := &interactionReplyCtx{interaction: &discordgo.Interaction{AppID: "app-1", Token: "token-1"}}
	err = p.SendFile(context.Background(), rc, core.FileAttachment{
		FileName: "report.pdf",
		MimeType: "application/pdf",
		Data:     []byte("pdf-data"),
	})
	if err != nil {
		t.Fatalf("SendFile() error = %v", err)
	}
	if len(requests) != 1 || !strings.Contains(requests[0], "/messages/@original") {
		t.Fatalf("requests = %v, want one original interaction edit", requests)
	}
}

func TestNew_ProgressStyleSupportsCompactAndCard(t *testing.T) {
	tests := []struct {
		style       string
		wantPayload bool
	}{
		{style: "compact", wantPayload: false},
		{style: "card", wantPayload: true},
	}

	for _, tt := range tests {
		t.Run(tt.style, func(t *testing.T) {
			pAny, err := New(map[string]any{
				"token":          "discord-token",
				"progress_style": tt.style,
			})
			if err != nil {
				t.Fatalf("New() error = %v", err)
			}

			sp, ok := pAny.(core.ProgressStyleProvider)
			if !ok {
				t.Fatalf("platform type %T does not implement ProgressStyleProvider", pAny)
			}
			if got := sp.ProgressStyle(); got != tt.style {
				t.Fatalf("ProgressStyle() = %q, want %q", got, tt.style)
			}

			payloadCap, ok := pAny.(core.ProgressCardPayloadSupport)
			if !ok {
				t.Fatalf("platform type %T does not implement ProgressCardPayloadSupport", pAny)
			}
			if got := payloadCap.SupportsProgressCardPayload(); got != tt.wantPayload {
				t.Fatalf("SupportsProgressCardPayload() = %v, want %v", got, tt.wantPayload)
			}
		})
	}
}

func TestNew_ProgressStyleRejectsInvalidValue(t *testing.T) {
	_, err := New(map[string]any{
		"token":          "discord-token",
		"progress_style": "invalid-style",
	})
	if err == nil {
		t.Fatal("expected error for invalid progress_style")
	}
	if !strings.Contains(err.Error(), "invalid progress_style") {
		t.Fatalf("error = %q, want invalid progress_style", err.Error())
	}
}

func TestNew_LegacyProgressStyleDoesNotEnableProgressInterfaces(t *testing.T) {
	pAny, err := New(map[string]any{
		"token": "discord-token",
	})
	if err != nil {
		t.Fatalf("New() error = %v", err)
	}
	if _, ok := pAny.(core.ProgressStyleProvider); ok {
		t.Fatalf("legacy discord platform should not implement ProgressStyleProvider, got %T", pAny)
	}
	if _, ok := pAny.(core.ProgressCardPayloadSupport); ok {
		t.Fatalf("legacy discord platform should not implement ProgressCardPayloadSupport, got %T", pAny)
	}
}

func TestDispatchMessage_UsesWrappedProgressPlatformForHandler(t *testing.T) {
	pAny, err := New(map[string]any{
		"token":          "discord-token",
		"progress_style": "card",
	})
	if err != nil {
		t.Fatalf("New() error = %v", err)
	}

	pp, ok := pAny.(*progressPlatform)
	if !ok {
		t.Fatalf("platform type = %T, want *progressPlatform", pAny)
	}

	var got core.Platform
	pp.Platform.handler = func(p core.Platform, msg *core.Message) {
		got = p
	}

	pp.Platform.dispatchMessage(&core.Message{SessionKey: "discord:ch-1"})

	if got == nil {
		t.Fatal("handler platform = nil, want wrapped platform")
	}
	if got != pp {
		t.Fatalf("handler platform = %T, want wrapped %T", got, pp)
	}
	sp, ok := got.(core.ProgressStyleProvider)
	if !ok {
		t.Fatalf("handler platform type %T does not implement ProgressStyleProvider", got)
	}
	if gotStyle := sp.ProgressStyle(); gotStyle != "card" {
		t.Fatalf("ProgressStyle() = %q, want card", gotStyle)
	}
}

func TestDispatchMessage_LegacyPlatformFallsBackToBasePlatform(t *testing.T) {
	pAny, err := New(map[string]any{
		"token": "discord-token",
	})
	if err != nil {
		t.Fatalf("New() error = %v", err)
	}

	p, ok := pAny.(*Platform)
	if !ok {
		t.Fatalf("platform type = %T, want *Platform", pAny)
	}

	var got core.Platform
	p.handler = func(platform core.Platform, msg *core.Message) {
		got = platform
	}

	p.dispatchMessage(&core.Message{SessionKey: "discord:ch-1"})

	if got != p {
		t.Fatalf("handler platform = %T, want base %T", got, p)
	}
	if _, ok := got.(core.ProgressStyleProvider); ok {
		t.Fatalf("legacy handler platform should not implement ProgressStyleProvider, got %T", got)
	}
}

func TestSendPreviewStart_ProgressPayloadUsesEmbed(t *testing.T) {
	var (
		requestPath string
		rawBody     string
		payload     map[string]any
	)
	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		requestPath = r.URL.Path
		body, err := io.ReadAll(r.Body)
		if err != nil {
			t.Fatalf("read request body: %v", err)
		}
		rawBody = string(body)
		if err := json.Unmarshal(body, &payload); err != nil {
			t.Fatalf("decode request: %v", err)
		}
		w.Header().Set("Content-Type", "application/json")
		_, _ = fmt.Fprint(w, `{"id":"msg-preview","channel_id":"ch-1"}`)
	}))
	defer server.Close()

	s := newTestDiscordSession(t, server)
	p := &Platform{session: s, progressStyle: "card"}

	progress := core.BuildProgressCardPayloadV2([]core.ProgressCardEntry{
		{Kind: core.ProgressEntryThinking, Text: "planning"},
		{Kind: core.ProgressEntryToolUse, Tool: "Bash", Text: "pwd"},
	}, false, "Codex", core.LangEnglish, core.ProgressCardStateRunning)
	if progress == "" {
		t.Fatal("BuildProgressCardPayloadV2() returned empty payload")
	}

	handleAny, err := p.SendPreviewStart(context.Background(), replyContext{channelID: "ch-1"}, progress)
	if err != nil {
		t.Fatalf("SendPreviewStart() error = %v", err)
	}
	handle, ok := handleAny.(*discordPreviewHandle)
	if !ok {
		t.Fatalf("preview handle type = %T, want *discordPreviewHandle", handleAny)
	}
	if handle.channelID != "ch-1" || handle.messageID != "msg-preview" {
		t.Fatalf("preview handle = %#v, want channel/message IDs", handle)
	}
	if requestPath != "/api/v"+discordgo.APIVersion+"/channels/ch-1/messages" {
		t.Fatalf("requestPath = %q, want channel message create path", requestPath)
	}
	if strings.Contains(rawBody, core.ProgressCardPayloadPrefix) {
		t.Fatalf("request body should not leak payload prefix, got %q", rawBody)
	}
	embeds, ok := payload["embeds"].([]any)
	if !ok || len(embeds) != 1 {
		t.Fatalf("embeds = %#v, want one embed", payload["embeds"])
	}
	embed, ok := embeds[0].(map[string]any)
	if !ok {
		t.Fatalf("embed = %#v, want object", embeds[0])
	}
	if embed["title"] != "Codex · Processing" {
		t.Fatalf("embed title = %#v, want Codex · Processing", embed["title"])
	}
	desc, _ := embed["description"].(string)
	if !strings.Contains(desc, "💭 planning") {
		t.Fatalf("embed description = %q, want thinking line", desc)
	}
	if !strings.Contains(desc, "🔧 Bash — pwd") {
		t.Fatalf("embed description = %q, want tool line", desc)
	}
	if _, exists := payload["content"]; exists {
		t.Fatalf("content = %#v, want omitted for embed preview send", payload["content"])
	}
}

func TestSendPreviewStart_CompactStyleUsesPlainText(t *testing.T) {
	var payload map[string]any
	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		if err := json.NewDecoder(r.Body).Decode(&payload); err != nil {
			t.Fatalf("decode request: %v", err)
		}
		w.Header().Set("Content-Type", "application/json")
		_, _ = fmt.Fprint(w, `{"id":"msg-preview","channel_id":"ch-1"}`)
	}))
	defer server.Close()

	pAny, err := New(map[string]any{
		"token":          "discord-token",
		"progress_style": "compact",
	})
	if err != nil {
		t.Fatalf("New() error = %v", err)
	}

	starter, ok := pAny.(core.PreviewStarter)
	if !ok {
		t.Fatalf("platform type %T does not implement PreviewStarter", pAny)
	}

	pp, ok := pAny.(*progressPlatform)
	if !ok {
		t.Fatalf("platform type = %T, want *progressPlatform", pAny)
	}
	pp.session = newTestDiscordSession(t, server)

	handleAny, err := starter.SendPreviewStart(context.Background(), replyContext{channelID: "ch-1"}, "compact preview")
	if err != nil {
		t.Fatalf("SendPreviewStart() error = %v", err)
	}
	if _, ok := handleAny.(*discordPreviewHandle); !ok {
		t.Fatalf("preview handle type = %T, want *discordPreviewHandle", handleAny)
	}
	if got, _ := payload["content"].(string); got != "compact preview" {
		t.Fatalf("content = %q, want compact preview", got)
	}
	if embeds, exists := payload["embeds"]; exists && embeds != nil {
		t.Fatalf("embeds = %#v, want omitted or null for compact text preview", embeds)
	}
}

func TestUpdateMessage_ProgressPayloadUsesEmbed(t *testing.T) {
	var (
		requestPath string
		payload     map[string]any
	)
	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		requestPath = r.URL.Path
		if err := json.NewDecoder(r.Body).Decode(&payload); err != nil {
			t.Fatalf("decode request: %v", err)
		}
		w.Header().Set("Content-Type", "application/json")
		_, _ = fmt.Fprint(w, `{"id":"msg-preview","channel_id":"ch-1"}`)
	}))
	defer server.Close()

	s := newTestDiscordSession(t, server)
	p := &Platform{session: s, progressStyle: "card"}

	exitCode := 0
	progress := core.BuildProgressCardPayloadV2([]core.ProgressCardEntry{
		{Kind: core.ProgressEntryToolResult, Tool: "Bash", Text: "hi", Status: "completed", ExitCode: &exitCode},
	}, false, "Codex", core.LangEnglish, core.ProgressCardStateCompleted)
	if progress == "" {
		t.Fatal("BuildProgressCardPayloadV2() returned empty payload")
	}

	err := p.UpdateMessage(context.Background(), &discordPreviewHandle{channelID: "ch-1", messageID: "msg-preview"}, progress)
	if err != nil {
		t.Fatalf("UpdateMessage() error = %v", err)
	}
	if requestPath != "/api/v"+discordgo.APIVersion+"/channels/ch-1/messages/msg-preview" {
		t.Fatalf("requestPath = %q, want channel message edit path", requestPath)
	}
	if got, _ := payload["content"].(string); got != "" {
		t.Fatalf("content = %q, want explicit empty string to clear text content", got)
	}
	embeds, ok := payload["embeds"].([]any)
	if !ok || len(embeds) != 1 {
		t.Fatalf("embeds = %#v, want one embed", payload["embeds"])
	}
	embed, ok := embeds[0].(map[string]any)
	if !ok {
		t.Fatalf("embed = %#v, want object", embeds[0])
	}
	if embed["title"] != "Codex · Completed" {
		t.Fatalf("embed title = %#v, want Codex · Completed", embed["title"])
	}
	desc, _ := embed["description"].(string)
	if !strings.Contains(desc, "🧾 Bash — completed · exit 0 · hi") {
		t.Fatalf("embed description = %q, want completed tool result", desc)
	}
	footer, ok := embed["footer"].(map[string]any)
	if !ok || footer["text"] == nil {
		t.Fatalf("footer = %#v, want footer text", embed["footer"])
	}
	if !strings.Contains(footer["text"].(string), "Full response is in the next message.") {
		t.Fatalf("footer text = %q, want completion note", footer["text"].(string))
	}
}

func TestBuildDiscordProgressEmbed_ShowsTruncatedNotice(t *testing.T) {
	payload := &core.ProgressCardPayload{
		Agent:     "Codex",
		Lang:      string(core.LangEnglish),
		State:     core.ProgressCardStateRunning,
		Truncated: true,
		Items: []core.ProgressCardEntry{
			{Kind: core.ProgressEntryThinking, Text: "reviewing repository state"},
		},
	}

	embed := buildDiscordProgressEmbed(payload)
	if embed == nil {
		t.Fatal("buildDiscordProgressEmbed() returned nil")
	}
	if !strings.Contains(embed.Description, "Showing latest updates only.") {
		t.Fatalf("embed description = %q, want truncated notice", embed.Description)
	}
	if !strings.Contains(embed.Description, "💭 reviewing repository state") {
		t.Fatalf("embed description = %q, want progress line", embed.Description)
	}
}

func TestUpdateMessage_PlainTextClearsEmbeds(t *testing.T) {
	var payload map[string]any
	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		if err := json.NewDecoder(r.Body).Decode(&payload); err != nil {
			t.Fatalf("decode request: %v", err)
		}
		w.Header().Set("Content-Type", "application/json")
		_, _ = fmt.Fprint(w, `{"id":"msg-preview","channel_id":"ch-1"}`)
	}))
	defer server.Close()

	s := newTestDiscordSession(t, server)
	p := &Platform{session: s}

	err := p.UpdateMessage(context.Background(), &discordPreviewHandle{channelID: "ch-1", messageID: "msg-preview"}, "plain preview")
	if err != nil {
		t.Fatalf("UpdateMessage() error = %v", err)
	}
	if got, _ := payload["content"].(string); got != "plain preview" {
		t.Fatalf("content = %q, want plain preview", got)
	}
	embeds, ok := payload["embeds"].([]any)
	if !ok {
		t.Fatalf("embeds = %#v, want explicit empty embeds array", payload["embeds"])
	}
	if len(embeds) != 0 {
		t.Fatalf("embeds = %#v, want empty embeds array", embeds)
	}
}

func TestSendChannelReply_WithoutMessageIDFallsBackToChannelSend(t *testing.T) {
	var payload map[string]any
	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		if err := json.NewDecoder(r.Body).Decode(&payload); err != nil {
			t.Fatalf("decode request: %v", err)
		}
		w.Header().Set("Content-Type", "application/json")
		_, _ = fmt.Fprint(w, `{"id":"msg-reply","channel_id":"ch-1"}`)
	}))
	defer server.Close()

	oldEndpointDiscord := discordgo.EndpointDiscord
	oldEndpointAPI := discordgo.EndpointAPI
	oldEndpointChannels := discordgo.EndpointChannels
	discordgo.EndpointDiscord = server.URL + "/"
	discordgo.EndpointAPI = discordgo.EndpointDiscord + "api/v" + discordgo.APIVersion + "/"
	discordgo.EndpointChannels = discordgo.EndpointAPI + "channels/"
	defer func() {
		discordgo.EndpointDiscord = oldEndpointDiscord
		discordgo.EndpointAPI = oldEndpointAPI
		discordgo.EndpointChannels = oldEndpointChannels
	}()

	s, err := discordgo.New("Bot test-token")
	if err != nil {
		t.Fatalf("discordgo.New() error = %v", err)
	}
	s.Client = server.Client()

	p := &Platform{session: s}
	err = p.sendChannelReply(replyContext{channelID: "ch-1"}, "language set to English")
	if err != nil {
		t.Fatalf("sendChannelReply() error = %v", err)
	}
	if payload["content"] != "language set to English" {
		t.Fatalf("content = %#v, want language set to English", payload["content"])
	}
	if _, ok := payload["message_reference"]; ok {
		t.Fatalf("message_reference = %#v, want omitted when messageID is empty", payload["message_reference"])
	}
}

// ── Dedup tests ──────────────────────────────────────────────

// simulateHandlerCall mimics the dedup + dispatch logic in the MessageCreate
// handler registered by Platform.Start.  It returns true when the message
// was dispatched (not a duplicate).
func (p *Platform) simulateHandlerCall(msgID, userID, userName, channelID, content string) bool {
	// --- dedup (same logic as Start handler) ---
	if !rememberDedupID(&p.seenMsgs, msgID) {
		return false
	}

	msg := &core.Message{
		SessionKey: p.makeSessionKey(channelID, userID),
		Platform:   "discord",
		MessageID:  msgID,
		UserID:     userID,
		UserName:   userName,
		Content:    content,
	}
	p.handler(p, msg)
	return true
}

// simulateInteractionHandlerCall mimics the dedup + dispatch logic shared by
// slash commands and button interactions. It returns true when the interaction
// was dispatched (not a duplicate).
func (p *Platform) simulateInteractionHandlerCall(interactionID, userID, userName, channelID, content string) bool {
	if !rememberDedupID(&p.seenInteractions, interactionID) {
		return false
	}

	msg := &core.Message{
		SessionKey: p.makeSessionKey(channelID, userID),
		Platform:   "discord",
		MessageID:  interactionID,
		UserID:     userID,
		UserName:   userName,
		Content:    content,
	}
	p.handler(p, msg)
	return true
}

// newTestPlatform creates a Platform suitable for unit tests (no real Discord
// connection).  The provided handler records every dispatched message.
func newTestPlatform(handler core.MessageHandler) *Platform {
	return &Platform{
		token:     "test-token",
		allowFrom: "*",
		handler:   handler,
		botID:     "BOT_ID",
		readyCh:   make(chan struct{}),
	}
}

// TestDuplicateMessage_SameIDDeduped reproduces GitHub issue #122:
// Discord gateway delivers the same MessageCreate event twice within ~1 ms.
// The second delivery must be silently dropped.
func TestDuplicateMessage_SameIDDeduped(t *testing.T) {
	var calls int32
	p := newTestPlatform(func(_ core.Platform, _ *core.Message) {
		atomic.AddInt32(&calls, 1)
	})

	const msgID = "1482313396505411717"

	// First delivery — must be processed.
	if !p.simulateHandlerCall(msgID, "user1", "quabug", "ch1", "hello") {
		t.Fatal("first delivery was incorrectly treated as duplicate")
	}

	// Second delivery (same msg_id, ~1 ms later) — must be dropped.
	if p.simulateHandlerCall(msgID, "user1", "quabug", "ch1", "hello") {
		t.Fatal("second delivery was not caught as duplicate")
	}

	if n := atomic.LoadInt32(&calls); n != 1 {
		t.Fatalf("handler called %d times, want 1", n)
	}
}

// TestDuplicateMessage_DifferentIDsProcessed ensures distinct messages are
// not incorrectly suppressed by dedup.
func TestDuplicateMessage_DifferentIDsProcessed(t *testing.T) {
	var calls int32
	p := newTestPlatform(func(_ core.Platform, _ *core.Message) {
		atomic.AddInt32(&calls, 1)
	})

	if !p.simulateHandlerCall("msg-1", "user1", "quabug", "ch1", "first") {
		t.Fatal("msg-1 should be processed")
	}
	if !p.simulateHandlerCall("msg-2", "user1", "quabug", "ch1", "second") {
		t.Fatal("msg-2 should be processed")
	}
	if !p.simulateHandlerCall("msg-3", "user1", "quabug", "ch1", "third") {
		t.Fatal("msg-3 should be processed")
	}

	if n := atomic.LoadInt32(&calls); n != 3 {
		t.Fatalf("handler called %d times, want 3", n)
	}
}

// TestDuplicateMessage_ConcurrentRace fires N goroutines that all try to
// deliver the same message simultaneously — exactly one must win.
func TestDuplicateMessage_ConcurrentRace(t *testing.T) {
	var calls int32
	p := newTestPlatform(func(_ core.Platform, _ *core.Message) {
		atomic.AddInt32(&calls, 1)
	})

	const (
		msgID      = "race-msg-1"
		goroutines = 50
	)

	var wg sync.WaitGroup
	wg.Add(goroutines)
	start := make(chan struct{}) // barrier so all goroutines race together

	for i := 0; i < goroutines; i++ {
		go func() {
			defer wg.Done()
			<-start
			p.simulateHandlerCall(msgID, "user1", "quabug", "ch1", "race")
		}()
	}

	close(start) // release all goroutines at once
	wg.Wait()

	if n := atomic.LoadInt32(&calls); n != 1 {
		t.Fatalf("handler called %d times under race, want exactly 1", n)
	}
}

// TestDuplicateMessage_MultipleDuplicateBursts sends multiple distinct
// messages, each duplicated, and verifies that each unique message is
// processed exactly once.
func TestDuplicateMessage_MultipleDuplicateBursts(t *testing.T) {
	received := make(map[string]int)
	var mu sync.Mutex
	p := newTestPlatform(func(_ core.Platform, msg *core.Message) {
		mu.Lock()
		received[msg.MessageID]++
		mu.Unlock()
	})

	// Simulate 10 messages, each delivered twice (as observed in logs).
	for i := 0; i < 10; i++ {
		id := "burst-" + string(rune('A'+i))
		p.simulateHandlerCall(id, "user1", "quabug", "ch1", "msg")
		p.simulateHandlerCall(id, "user1", "quabug", "ch1", "msg") // duplicate
	}

	for id, count := range received {
		if count != 1 {
			t.Errorf("message %q processed %d times, want 1", id, count)
		}
	}
	if len(received) != 10 {
		t.Errorf("got %d unique messages, want 10", len(received))
	}
}

// TestDuplicateInteraction_SameIDDeduped verifies the shared interaction dedup
// path used by slash commands and button interactions.
func TestDuplicateInteraction_SameIDDeduped(t *testing.T) {
	var calls int32
	p := newTestPlatform(func(_ core.Platform, _ *core.Message) {
		atomic.AddInt32(&calls, 1)
	})

	const interactionID = "1499999999999999999"

	if !p.simulateInteractionHandlerCall(interactionID, "user1", "quabug", "ch1", "/config thinking_max_len 200") {
		t.Fatal("first interaction delivery was incorrectly treated as duplicate")
	}
	if p.simulateInteractionHandlerCall(interactionID, "user1", "quabug", "ch1", "/config thinking_max_len 200") {
		t.Fatal("second interaction delivery was not caught as duplicate")
	}

	if n := atomic.LoadInt32(&calls); n != 1 {
		t.Fatalf("handler called %d times, want 1", n)
	}
}

func TestDuplicateInteraction_ConcurrentRace(t *testing.T) {
	var calls int32
	p := newTestPlatform(func(_ core.Platform, _ *core.Message) {
		atomic.AddInt32(&calls, 1)
	})

	const (
		interactionID = "race-interaction-1"
		goroutines    = 50
	)

	var wg sync.WaitGroup
	wg.Add(goroutines)
	start := make(chan struct{})

	for i := 0; i < goroutines; i++ {
		go func() {
			defer wg.Done()
			<-start
			p.simulateInteractionHandlerCall(interactionID, "user1", "quabug", "ch1", "cmd:new")
		}()
	}

	close(start)
	wg.Wait()

	if n := atomic.LoadInt32(&calls); n != 1 {
		t.Fatalf("handler called %d times under race, want exactly 1", n)
	}
}

// ── @everyone mention tests ──────────────────────────────────

func TestIsDiscordBotMention_Everyone(t *testing.T) {
	tests := []struct {
		name                       string
		respondToAtEveryoneAndHere bool
		mentionEveryone            bool
		want                       bool
	}{
		{"enabled + @everyone", true, true, true},
		{"disabled + @everyone", false, true, false},
		{"enabled + no @everyone", true, false, false},
	}
	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			m := &discordgo.MessageCreate{
				Message: &discordgo.Message{
					MentionEveryone: tt.mentionEveryone,
					Content:         "hello",
					Author:          &discordgo.User{ID: "user1"},
				},
			}
			got := isDiscordBotMention(m, "bot1", "", tt.respondToAtEveryoneAndHere)
			if got != tt.want {
				t.Errorf("isDiscordBotMention(respondToAtEveryoneAndHere=%v, MentionEveryone=%v) = %v, want %v",
					tt.respondToAtEveryoneAndHere, tt.mentionEveryone, got, tt.want)
			}
		})
	}
}

// ── Mention tests ────────────────────────────────────────────

// TestStripDiscordMention verifies mention stripping helper.
func TestStripDiscordMention(t *testing.T) {
	tests := []struct {
		name    string
		content string
		botID   string
		want    string
	}{
		{"strips bot mention at start", "<@123456> hello", "123456", "hello"},
		{"strips bot mention with ! prefix", "<@!123456> hello", "123456", "hello"},
		{"strips bot mention in middle", "hey <@123456> do this", "123456", "hey  do this"},
		{"no mention", "hello world", "123456", "hello world"},
		{"only mention", "<@123456>", "123456", ""},
		{"different bot ID unchanged", "<@999999> hello", "123456", "<@999999> hello"},
	}

	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			got := stripDiscordMention(tt.content, tt.botID)
			if got != tt.want {
				t.Errorf("stripDiscordMention(%q, %q) = %q, want %q",
					tt.content, tt.botID, got, tt.want)
			}
		})
	}
}

func TestReplyContextForDeferredInteractionFallback(t *testing.T) {
	cid := "chan-1"
	tests := []struct {
		name string
		ch   *discordgo.Channel
		want replyContext
	}{
		{"nil channel", nil, replyContext{channelID: cid}},
		{"guild text", &discordgo.Channel{ID: cid, Type: discordgo.ChannelTypeGuildText}, replyContext{channelID: cid}},
		{"public thread", &discordgo.Channel{ID: cid, Type: discordgo.ChannelTypeGuildPublicThread}, replyContext{channelID: cid, threadID: cid}},
		{"private thread", &discordgo.Channel{ID: cid, Type: discordgo.ChannelTypeGuildPrivateThread}, replyContext{channelID: cid, threadID: cid}},
	}
	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			got := replyContextForDeferredInteractionFallback(tt.ch, cid)
			if !reflect.DeepEqual(got, tt.want) {
				t.Fatalf("got %+v want %+v", got, tt.want)
			}
		})
	}
}

func TestClassifyAttachments_RoutesPDFAndOtherFilesToFiles(t *testing.T) {
	payloads := map[string][]byte{
		"https://cdn.discord/pdf":   []byte("%PDF-1.4 pretend"),
		"https://cdn.discord/zip":   []byte("PK\x03\x04 pretend"),
		"https://cdn.discord/png":   []byte("\x89PNG pretend"),
		"https://cdn.discord/ogg":   []byte("OggS pretend"),
		"https://cdn.discord/blank": []byte("legacy image bytes"),
	}
	download := func(u string) ([]byte, error) {
		data, ok := payloads[u]
		if !ok {
			return nil, fmt.Errorf("unexpected url %s", u)
		}
		return data, nil
	}

	atts := []*discordgo.MessageAttachment{
		{URL: "https://cdn.discord/pdf", ContentType: "application/pdf", Filename: "report.pdf"},
		{URL: "https://cdn.discord/zip", ContentType: "application/zip", Filename: "bundle.zip"},
		{URL: "https://cdn.discord/png", ContentType: "image/png", Filename: "shot.png", Width: 1024, Height: 768},
		{URL: "https://cdn.discord/ogg", ContentType: "audio/ogg", Filename: "voice.ogg"},
		{URL: "https://cdn.discord/blank", ContentType: "", Filename: "legacy.jpg", Width: 640, Height: 480},
	}

	images, files, audio := classifyAttachments(atts, download)

	if len(images) != 2 {
		t.Fatalf("images = %d, want 2 (png + empty-ct fallback)", len(images))
	}
	if images[0].FileName != "shot.png" || images[0].MimeType != "image/png" {
		t.Fatalf("images[0] = %+v, want png attachment", images[0])
	}
	if images[1].FileName != "legacy.jpg" {
		t.Fatalf("images[1] = %+v, want legacy jpg via width/height fallback", images[1])
	}

	if len(files) != 2 {
		t.Fatalf("files = %d, want 2 (pdf + zip)", len(files))
	}
	gotNames := []string{files[0].FileName, files[1].FileName}
	if !reflect.DeepEqual(gotNames, []string{"report.pdf", "bundle.zip"}) {
		t.Fatalf("file names = %v, want [report.pdf bundle.zip]", gotNames)
	}
	if files[0].MimeType != "application/pdf" || string(files[0].Data) != "%PDF-1.4 pretend" {
		t.Fatalf("files[0] = %+v, want downloaded pdf bytes", files[0])
	}

	if audio == nil || audio.Format != "ogg" || string(audio.Data) != "OggS pretend" {
		t.Fatalf("audio = %+v, want ogg voice attachment", audio)
	}
}

func TestClassifyAttachments_SkipsFailedDownloadsButKeepsSiblings(t *testing.T) {
	download := func(u string) ([]byte, error) {
		if strings.HasSuffix(u, "broken") {
			return nil, fmt.Errorf("boom")
		}
		return []byte("ok"), nil
	}

	atts := []*discordgo.MessageAttachment{
		{URL: "https://cdn.discord/broken", ContentType: "application/pdf", Filename: "bad.pdf"},
		{URL: "https://cdn.discord/good", ContentType: "application/pdf", Filename: "good.pdf"},
	}

	_, files, _ := classifyAttachments(atts, download)
	if len(files) != 1 || files[0].FileName != "good.pdf" {
		t.Fatalf("files = %+v, want only good.pdf", files)
	}
}

// ── isGroupReplyAllGuild tests ────────────────────────────────

func TestIsGroupReplyAllGuild_EmptyListReturnsFalse(t *testing.T) {
	p := &Platform{}
	if p.isGroupReplyAllGuild("G123") {
		t.Fatal("empty groupReplyAllGuilds should return false")
	}
}

func TestIsGroupReplyAllGuild_WildcardMatchesAnyGuild(t *testing.T) {
	p := &Platform{groupReplyAllGuilds: []string{"*"}}
	if !p.isGroupReplyAllGuild("any-guild-id") {
		t.Fatal("wildcard '*' should match any guild ID")
	}
}

func TestIsGroupReplyAllGuild_SpecificGuildMatches(t *testing.T) {
	p := &Platform{groupReplyAllGuilds: []string{"G-A", "G-B"}}
	if !p.isGroupReplyAllGuild("G-A") {
		t.Fatal("G-A should match")
	}
	if !p.isGroupReplyAllGuild("G-B") {
		t.Fatal("G-B should match")
	}
}

func TestIsGroupReplyAllGuild_UnknownGuildReturnsFalse(t *testing.T) {
	p := &Platform{groupReplyAllGuilds: []string{"G-A", "G-B"}}
	if p.isGroupReplyAllGuild("G-OTHER") {
		t.Fatal("unlisted guild G-OTHER should not match")
	}
}

// ── applyReferencedMessage tests ─────────────────────────────

func TestApplyReferencedMessage_PrependsAuthorAndContent(t *testing.T) {
	ref := &discordgo.Message{
		Author:  &discordgo.User{Username: "alice"},
		Content: "hello world",
	}
	content, images := applyReferencedMessage(ref, "my reply", nil, nil)

	wantContent := "[replying to alice: hello world]\nmy reply"
	if content != wantContent {
		t.Fatalf("content = %q, want %q", content, wantContent)
	}
	if len(images) != 0 {
		t.Fatalf("images = %v, want empty", images)
	}
}

func TestApplyReferencedMessage_NoAuthorUsesEmptyString(t *testing.T) {
	ref := &discordgo.Message{Content: "anon msg"}
	content, _ := applyReferencedMessage(ref, "reply", nil, nil)

	if !strings.Contains(content, "[replying to : anon msg]") {
		t.Fatalf("content = %q, want empty author placeholder", content)
	}
}

func TestApplyReferencedMessage_DownloadsAndPrependsImages(t *testing.T) {
	imgData := []byte("fake-png")
	download := func(u string) ([]byte, error) {
		return imgData, nil
	}
	ref := &discordgo.Message{
		Author:  &discordgo.User{Username: "bob"},
		Content: "see this",
		Attachments: []*discordgo.MessageAttachment{
			{URL: "https://cdn/img.png", ContentType: "image/png", Filename: "img.png", Width: 100, Height: 100},
		},
	}
	existing := []core.ImageAttachment{{MimeType: "image/jpeg", Data: []byte("existing"), FileName: "old.jpg"}}

	_, images := applyReferencedMessage(ref, "reply", existing, download)

	if len(images) != 2 {
		t.Fatalf("images len = %d, want 2", len(images))
	}
	// Referenced image is prepended — it comes first.
	if images[0].FileName != "img.png" {
		t.Fatalf("images[0].FileName = %q, want img.png (referenced image should be prepended)", images[0].FileName)
	}
	if images[1].FileName != "old.jpg" {
		t.Fatalf("images[1].FileName = %q, want old.jpg", images[1].FileName)
	}
}

func TestApplyReferencedMessage_SkipsNonImageAttachments(t *testing.T) {
	ref := &discordgo.Message{
		Content: "has doc",
		Attachments: []*discordgo.MessageAttachment{
			// Width/Height == 0 means it's not an image — must be skipped.
			{URL: "https://cdn/doc.pdf", ContentType: "application/pdf", Filename: "doc.pdf"},
		},
	}
	download := func(u string) ([]byte, error) {
		t.Fatal("download should not be called for non-image attachments")
		return nil, nil
	}

	_, images := applyReferencedMessage(ref, "reply", nil, download)
	if len(images) != 0 {
		t.Fatalf("images = %v, want empty — PDF should not be forwarded as image", images)
	}
}

func TestApplyReferencedMessage_SkipsFailedImageDownloads(t *testing.T) {
	download := func(u string) ([]byte, error) {
		return nil, fmt.Errorf("network error")
	}
	ref := &discordgo.Message{
		Content: "broken image",
		Attachments: []*discordgo.MessageAttachment{
			{URL: "https://cdn/img.png", ContentType: "image/png", Filename: "img.png", Width: 100, Height: 100},
		},
	}

	_, images := applyReferencedMessage(ref, "reply", nil, download)
	if len(images) != 0 {
		t.Fatalf("images = %v, want empty — failed download should be skipped", images)
	}
}

// ── workspace-aware command routing (ChannelKey) test ─────────

// TestDispatchMessage_SetsChannelKeyForThreadIsolation verifies that when
// thread_isolation is enabled the dispatched message carries a ChannelKey equal
// to the parent channel ID so that multi-workspace binding resolution uses the
// parent channel rather than the ephemeral thread ID.
func TestDispatchMessage_SetsChannelKeyForThreadIsolation(t *testing.T) {
	parentChannelID := "parent-ch-999"
	threadID := "thread-999"

	var got *core.Message
	p := newTestPlatform(func(_ core.Platform, msg *core.Message) {
		got = msg
	})
	p.threadIsolation = true
	p.botID = "BOT_ID"

	ops := fakeThreadOps{
		resolveChannel: func(channelID string) (*discordgo.Channel, error) {
			// The message is in a guild text channel (not a thread), so we return
			// a non-thread type to trigger the "create thread" path.
			return &discordgo.Channel{ID: channelID, Type: discordgo.ChannelTypeGuildText}, nil
		},
		startThread: func(channelID, messageID, name string, archiveDuration int) (*discordgo.Channel, error) {
			return &discordgo.Channel{
				ID:       threadID,
				Type:     discordgo.ChannelTypeGuildPublicThread,
				ParentID: parentChannelID,
			}, nil
		},
		joinThread: func(threadID string) error { return nil },
	}

	m := &discordgo.MessageCreate{Message: &discordgo.Message{
		ID:        "msg-ws-key",
		ChannelID: parentChannelID,
		GuildID:   "G-ws",
		Content:   "hello",
		Author:    &discordgo.User{ID: "U1", Username: "user1"},
	}}

	threadSessionKey, rctx, _, err := resolveThreadReplyContext(m, "BOT_ID", ops)
	if err != nil {
		t.Fatalf("resolveThreadReplyContext error: %v", err)
	}

	msg := &core.Message{
		SessionKey: threadSessionKey,
		ChannelKey: parentChannelID,
		Platform:   "discord",
		ChannelID:  m.ChannelID,
		MessageID:  m.Message.ID,
		UserID:     m.Author.ID,
		Content:    m.Message.Content,
		ReplyCtx:   rctx,
	}
	p.dispatchMessage(msg)

	if got == nil {
		t.Fatal("message was not dispatched")
	}
	if got.ChannelKey != parentChannelID {
		t.Fatalf("ChannelKey = %q, want %q", got.ChannelKey, parentChannelID)
	}
	if got.SessionKey == got.ChannelKey {
		t.Fatal("SessionKey should differ from ChannelKey (thread ID vs parent channel)")
	}
}