const { App } = require('@microsoft/teams.apps');
const { ChatPrompt } = require('@microsoft/teams.ai');
const { OpenAIChatModel } = require('@microsoft/teams.openai');
const { MessageActivity, TokenCredentials } = require('@microsoft/teams.api');
const path = require("path");
const config = require("../config");
const { ManagedIdentityCredential } = require('@azure/identity');
const fs = require("fs-extra");
const functionHandlers = require("./handlers");

// Load function definitions from JSON file
const loadFunctionDefinitions = () => {
  const functionsPath = path.join(__dirname, 'functions.json');
  return JSON.parse(fs.readFileSync(functionsPath, 'utf8'));
};

// Function to read AI instructions from file
const getAIInstructions = () => {
  const instructionsPath = path.join(__dirname, 'instructions.txt');
  return fs.readFileSync(instructionsPath, 'utf8');
};

const createTokenFactory = () => {
  return async (scope, tenantId) => {
    const managedIdentityCredential = new ManagedIdentityCredential({
        clientId: process.env.CLIENT_ID
      });
    const scopes = Array.isArray(scope) ? scope : [scope];
    const tokenResponse = await managedIdentityCredential.getToken(scopes, {
      tenantId: tenantId
    });
   
    return tokenResponse.token;
  };
};

// Configure authentication using TokenCredentials
const tokenCredentials = {
  clientId: process.env.CLIENT_ID || '',
  token: createTokenFactory()
};

const credentialOptions = config.MicrosoftAppType === "UserAssignedMsi" ? { ...tokenCredentials } : undefined;

// Create the main App instance
const app = new App({...credentialOptions});

const instructions = getAIInstructions();
const functionDefs = loadFunctionDefinitions();

app.on('message', async ({ send, activity }) => {
  await send({ type: 'typing' });

  try {
    const conversationPrompt = new ChatPrompt(
      {
        instructions: instructions,
        {{#useOpenAI}}
        model: new OpenAIChatModel({
          model:  "gpt-3.5-turbo",
          apiKey: config.openAIKey
        })
        {{/useOpenAI}}
        {{#useAzureOpenAI}}
        model: new OpenAIChatModel({
          model: config.azureOpenAIDeployment,
          apiKey: config.azureOpenAIKey,
          endpoint: config.azureOpenAIEndpoint,
          apiVersion: "2024-10-21"
        })
        {{/useAzureOpenAI}}
      }
    )
    // Replace with function definition code


    // Send message to AI
    const response = await conversationPrompt.send(activity.text);

    const responseActivity = new MessageActivity(response.content).addAiGenerated().addFeedback();
    await send(responseActivity);
  } catch (error) {
    console.error('Error processing message:', error);
    await send('Sorry, I encountered an error processing your request.');
  }
});

app.on("conversationUpdate", async ({ send, activity }) => {
  const welcomeText = "How can I help you today?";
  if (activity.membersAdded && activity.membersAdded.length > 0) {
    for (const member of activity.membersAdded) {
      if (member.id !== activity.recipient?.id) {
        await send(welcomeText);
      }
    }
  }
})

app.on('message.submit.feedback', async ({ activity }) => {
  //add custom feedback process logic here
  console.log("Your feedback is " + JSON.stringify(activity.value));
})

module.exports = app;