import { DEFAULT_SYSTEM_CONTENT, openai } from '../../ai/index.js';
import { feedbackBlock } from '../views/feedback_block.js';

const delay = (ms) => new Promise(resolve => setTimeout(resolve, ms));

/**
 * The `message` event is sent when the user direct messages the app in a DM or Assistant container.
 *
 * @param {Object} params
 * @param {import("@slack/web-api").WebClient} params.client - Slack web client.
 * @param {import("@slack/bolt").Context} params.context - Event context.
 * @param {import("@slack/logger").Logger} params.logger - Logger instance.
 * @param {import("@slack/types").MessageEvent} params.message - The incoming message.
 * @param {Function} params.getThreadContext - Function to get thread context.
 * @param {import("@slack/bolt").SayFn} params.say - Function to send messages.
 * @param {Function} params.setTitle - Function to set assistant thread title.
 * @param {Function} params.setStatus - Function to set assistant status.
 *
 * @see {@link https://docs.slack.dev/reference/events/message}
 */
export const message = async ({ client, context, logger, message, getThreadContext, say, setTitle, setStatus }) => {
  /**
   * Messages sent to the Assistant can have a specific message subtype.
   *
   * Here we check that the message has "text" and was sent to a thread to
   * skip unexpected message subtypes.
   *
   * @see {@link https://docs.slack.dev/reference/events/message#subtypes}
   */
  if (!('text' in message) || !('thread_ts' in message) || !message.text || !message.thread_ts) {
    return;
  }
  const { channel, thread_ts } = message;
  const { userId, teamId } = context;

  try {
    /**
     * Set the title of the Assistant thread to capture the initial topic/question
     * as a way to facilitate future reference by the user.
     *
     * @see {@link https://docs.slack.dev/reference/methods/assistant.threads.setTitle}
     */
    await setTitle(message.text);

    /**
     * Set the status of the Assistant to give the appearance of active processing.
     *
     * @see {@link https://docs.slack.dev/reference/methods/assistant.threads.setStatus}
     */
    await setStatus({
      status: 'thinking...',
      loading_messages: [
        'Teaching the hamsters to type faster…',
        'Untangling the internet cables…',
        'Consulting the office goldfish…',
        'Polishing up the response just for you…',
        'Convincing the AI to stop overthinking…',
      ],
    });

    const streamResponse = await client.chat.startStream({
      channel: channel,
      thread_ts: thread_ts,
      recipient_team_id: teamId,
      recipient_user_id: userId,
      chunks: [{
        type: 'markdown_text',
        text: '**Hello!** I am starting to process your request...\n\n',
      }, {
        type: 'task_update',
        id: '12',
        title: 'counting bytes...',
        status: 'in_progress',
      }],
    });

    await delay(4000);

    await client.chat.appendStream({
      channel: channel,
      ts: streamResponse.ts,
      // markdown_text: '',
      chunks: [{
        type: 'task_update',
        id: '12',
        title: 'adding numbers...',
        status: 'in_progress',
        details: 'sums have increased',
      }],
    });

    await delay(4000);

    await client.chat.stopStream({
      channel: channel,
      ts: streamResponse.ts,
      chunks: [{
        type: 'task_update',
        id: '12',
        title: 'solved equation!',
        status: 'complete',
        sources: [{
          type: 'url',
          url: 'https://oeis.org',
          text: 'The On-Line Encyclopedia of Integer Sequences (OEIS)',
        }],
      }, {
        type: 'markdown_text',
        text: 'that computes.',
      }],
    });
  } catch (e) {
    logger.error(e);

    // Send message to advise user and clear processing status if a failure occurs
    await say({ text: `Sorry, something went wrong! ${e}` });
  }
};