Assistants API Function Calling in node.js

import OpenAI from "openai";
import yahooFinance from 'yahoo-finance2';

const openai = new OpenAI();

async function getStockPrice(symbol) {
try {
const quote = await yahooFinance.quote(symbol);
return {
symbol: symbol,
price: quote.regularMarketPrice,
currency: quote.currency
};
} catch (error) {
console.error(Error fetching stock price for ${symbol}: ${error});
throw error;
}
}

const tools = [
{
"type": "function",
"function": {
"name": "getStockPrice",
"description": "Get the current stock price of a company using its stock symbol",
"parameters": {
"type": "object",
"properties": {
"symbol": {
"type": "string",
"description": "Stock symbol (e.g., 'AAPL' for Apple)"
}
},
"required": ["symbol"]
}
}
}
];

// Step 1: Define your assistant
const assistant = await openai.beta.assistants.create({
name: "Data Analyst",
instructions:
"You are a Data Analyst",
tools: tools,
model: "gpt-4-1106-preview",
});

// Step 2: Creating a thread and sending a message
const thread = await openai.beta.threads.create();

// Step 3: Create a message
const message = await openai.beta.threads.messages.create(thread.id, {
role: "user",
content: "What is the stock price of Apple?",
});

// Step 4: Create a run with custom instructions
const run = await openai.beta.threads.runs.create(thread.id, {
assistant_id: assistant.id,
instructions: "Please address the user as Mervin Praison.",

});

console.log(run)

// Function to check run status and print messages
const checkStatusAndPrintMessages = async (threadId, runId) => {
let runStatus = await openai.beta.threads.runs.retrieve(threadId, runId);
console.log(runStatus)

if(runStatus.status === "completed"){
let messages = await openai.beta.threads.messages.list(threadId);
messages.data.forEach((msg) => {
const role = msg.role;
const content = msg.content[0].text.value;
console.log(
${role.charAt(0).toUpperCase() + role.slice(1)}: ${content}
);
});
console.log("Run is completed.");
clearInterval(intervalId);
} else if (runStatus.status === 'requires_action') {
console.log("Requires action");

    const requiredActions = runStatus.required_action.submit_tool_outputs.tool_calls;
    console.log(requiredActions);

    let toolsOutput = [];

    for (const action of requiredActions) {
        const funcName = action.function.name;
        const functionArguments = JSON.parse(action.function.arguments);

        if (funcName === "getStockPrice") {
            const output = await getStockPrice(functionArguments.symbol);
            toolsOutput.push({
                tool_call_id: action.id,
                output: JSON.stringify(output)  
            });
        } else {
            console.log("Function not found");
        }
    }

    // Submit the tool outputs to Assistant API
    await openai.beta.threads.runs.submitToolOutputs(
        thread.id,
        run.id,
        { tool_outputs: toolsOutput }
    );
} 
else {
    console.log("Run is not completed yet.");
}  

};

const intervalId = setInterval(() => {
checkStatusAndPrintMessages(thread.id, run.id)
}, 10000);