Fix DM threading behavior - no threads in direct messages

Corrected the bot behavior for better UX:
- DMs: Respond directly in conversation without creating threads
- Channels: Continue to respond only to @mentions in threads
- Added GetChannelHistory method to fetch DM conversation history
- Updated examples to clearly show channel vs DM behavior

This provides the most natural experience:
- Clean channels with threaded discussions
- Natural flowing conversations in DMs

🤖 Generated with [opencode](https://opencode.ai)

Co-Authored-By: opencode <noreply@opencode.ai>

Author: ezynda3

cookbook/slack-bot/README.md

@@ -13,7 +13,7 @@ A sophisticated Slack bot built with Flyt workflow framework that integrates Ope
 - **Conversation Memory**: Maintains context across messages with thread history
 - **Smart Threading**: 
   - In channels: Only responds to @mentions and always replies in threads
-  - In DMs: Maintains conversation flow naturally
+  - In DMs: Responds directly in conversation (no threading)
 - **Context Awareness**: Includes thread/DM history in LLM context for better responses
 
 ## Architecture
@@ -191,28 +191,37 @@ The bot will connect to Slack and start listening for messages.
 
 ### Example Interactions
 
-**Calculator:**
+**In a Channel (must @mention):**
 ```
-User: Can you calculate 25 * 4 + sqrt(16)?
-Bot: I'll help you calculate that expression.
+User: Can you calculate 25 * 4?
+Bot: [No response - not mentioned]
+
+User: @Bot Can you calculate 25 * 4 + sqrt(16)?
+Bot: [In thread] I'll help you calculate that expression.
      Result: 104
+
+User: [In same thread] Now divide by 2
+Bot: [In thread] Dividing 104 by 2 gives us 52.
 ```
 
-**Chuck Norris Facts:**
+**In Direct Message:**
 ```
 User: Tell me a Chuck Norris fact about programming
 Bot: Here's a Chuck Norris fact for you:
      Chuck Norris doesn't use web standards. The web conforms to Chuck Norris.
+
+User: Give me another one
+Bot: [Knows context] Here's another Chuck Norris fact:
+     Chuck Norris can unit test an entire application with a single assert.
 ```
 
-**Combined:**
+**Combined Tools in DM:**
 ```
-User: What's 2^10 and also give me a Chuck Norris fact
-Bot: I'll calculate 2^10 and get you a Chuck Norris fact.
-     
-     The calculation 2^10 equals 1024.
-     
-     And here's your Chuck Norris fact:
+User: What's 2^10?
+Bot: The calculation 2^10 equals 1024.
+
+User: Cool! Now give me a Chuck Norris fact
+Bot: Here's your Chuck Norris fact:
      Chuck Norris can divide by zero.
 ```
 
@@ -229,7 +238,7 @@ Bot: I'll calculate 2^10 and get you a Chuck Norris fact.
 7. GPT-4.1 formulates a final response using the tool results
 8. The response is sent back:
    - In channels: Always as a thread reply
-   - In DMs: In the conversation flow
+   - In DMs: Directly in the conversation (no threads)
 9. Conversation history is maintained per thread for context continuity
 
 ### Available Tools

cookbook/slack-bot/main.go

@@ -11,6 +11,7 @@ import (
 
 	"github.com/joho/godotenv"
 	"github.com/mark3labs/flyt"
+	"github.com/slack-go/slack"
 	"github.com/slack-go/slack/slackevents"
 	"github.com/slack-go/slack/socketmode"
 )
@@ -161,16 +162,10 @@ func (b *SlackBot) handleMessage(ctx context.Context, event *slackevents.Message
 
 	log.Printf("DM from %s: %s", event.User, event.Text)
 
-	// For DMs, use the message timestamp as thread (maintains conversation flow)
-	threadTS := event.ThreadTimeStamp
-	if threadTS == "" {
-		threadTS = event.TimeStamp
-	}
-
-	// Process message through Flyt workflow
-	b.processWithFlyt(ctx, event.Text, event.Channel, threadTS, event.User)
+	// For DMs, don't use threads - respond directly in the conversation
+	// Pass empty string for threadTS to indicate no threading
+	b.processWithFlyt(ctx, event.Text, event.Channel, "", event.User)
 }
-
 func (b *SlackBot) handleMention(ctx context.Context, event *slackevents.AppMentionEvent) {
 	log.Printf("Mention from %s in channel %s: %s", event.User, event.Channel, event.Text)
 
@@ -247,29 +242,38 @@ func (b *SlackBot) processWithFlyt(ctx context.Context, message, channel, thread
 
 func (b *SlackBot) fetchConversationHistory(channel, threadTS string) []map[string]string {
 	var history []map[string]string
+	var messages []slack.Message
+	var err error
 
 	if threadTS != "" {
-		// Fetch thread messages
-		messages, err := b.slack.GetThreadMessages(channel, threadTS)
+		// For threads in channels, fetch thread messages
+		messages, err = b.slack.GetThreadMessages(channel, threadTS)
 		if err != nil {
 			log.Printf("Failed to fetch thread history: %v", err)
 			return history
 		}
+	} else if b.isDirectMessage(channel) {
+		// For DMs, fetch recent channel history
+		messages, err = b.slack.GetChannelHistory(channel, 20)
+		if err != nil {
+			log.Printf("Failed to fetch DM history: %v", err)
+			return history
+		}
+	}
 
-		// Convert to simplified format, excluding bot's own messages
-		botID := b.slack.GetBotUserID()
-		for _, msg := range messages {
-			// Skip bot's own messages and empty messages
-			if msg.User == botID || msg.BotID != "" || msg.Text == "" {
-				continue
-			}
-
-			history = append(history, map[string]string{
-				"user":      msg.User,
-				"text":      msg.Text,
-				"timestamp": msg.Timestamp,
-			})
+	// Convert to simplified format, excluding bot's own messages
+	botID := b.slack.GetBotUserID()
+	for _, msg := range messages {
+		// Skip bot's own messages and empty messages
+		if msg.User == botID || msg.BotID != "" || msg.Text == "" {
+			continue
 		}
+
+		history = append(history, map[string]string{
+			"user":      msg.User,
+			"text":      msg.Text,
+			"timestamp": msg.Timestamp,
+		})
 	}
 
 	// Limit history to last 10 messages for context
@@ -279,6 +283,7 @@ func (b *SlackBot) fetchConversationHistory(channel, threadTS string) []map[stri
 
 	return history
 }
+
 func (b *SlackBot) createWorkflow(llmService *LLMService) *flyt.Flow {
 	// Create nodes with injected dependencies
 	parseNode := &ParseMessageNode{

cookbook/slack-bot/slack.go

@@ -188,6 +188,21 @@ func (s *SlackService) GetThreadMessages(channel, threadTS string) ([]slack.Mess
 	return messages, nil
 }
 
+// GetChannelHistory retrieves recent messages from a channel or DM
+func (s *SlackService) GetChannelHistory(channel string, limit int) ([]slack.Message, error) {
+	params := &slack.GetConversationHistoryParameters{
+		ChannelID: channel,
+		Limit:     limit,
+	}
+
+	resp, err := s.client.GetConversationHistory(params)
+	if err != nil {
+		return nil, fmt.Errorf("failed to get channel history: %w", err)
+	}
+
+	return resp.Messages, nil
+}
+
 // EnrichMessageContext adds user and channel information to the message context
 func (s *SlackService) EnrichMessageContext(userID, channelID string) map[string]string {
 	context := make(map[string]string)