package handlers

import (
	"context"
	"fmt"

	"git.threesix.ai/jordan/sp4-v2-1770499323/pkg/logging"
	"git.threesix.ai/jordan/sp4-v2-1770499323/pkg/queue"
)

// ChatTaskHandler processes chat_task jobs from the queue.
type ChatTaskHandler struct {
	logger *logging.Logger
}

// NewChatTaskHandler creates a new ChatTaskHandler.
func NewChatTaskHandler(logger *logging.Logger) *ChatTaskHandler {
	return &ChatTaskHandler{
		logger: logger.WithComponent("chat_task"),
	}
}

// Handle processes a single chat_task job.
func (h *ChatTaskHandler) Handle(ctx context.Context, job *queue.Job) error {
	h.logger.Info("processing chat task",
		"job_id", job.ID,
		"payload", job.Payload,
	)

	action, _ := job.Payload["action"].(string)
	if action == "" {
		return fmt.Errorf("missing required payload field: action")
	}

	switch action {
	case "send_notification":
		return h.handleSendNotification(ctx, job)
	case "process_message":
		return h.handleProcessMessage(ctx, job)
	default:
		return fmt.Errorf("unknown chat task action: %s", action)
	}
}

func (h *ChatTaskHandler) handleSendNotification(ctx context.Context, job *queue.Job) error {
	userID, _ := job.Payload["user_id"].(string)
	message, _ := job.Payload["message"].(string)

	h.logger.Info("sending notification",
		"job_id", job.ID,
		"user_id", userID,
		"message", message,
	)

	// TODO: Implement actual notification delivery
	return nil
}

func (h *ChatTaskHandler) handleProcessMessage(ctx context.Context, job *queue.Job) error {
	channelID, _ := job.Payload["channel_id"].(string)
	content, _ := job.Payload["content"].(string)

	h.logger.Info("processing message",
		"job_id", job.ID,
		"channel_id", channelID,
		"content_length", len(content),
	)

	// TODO: Implement actual message processing
	return nil
}