Astro endpoint working locally but not when running through wrangler

import type { APIContext } from 'astro';
import OpenAI from 'openai';

const openai = new OpenAI({
  apiKey: import.meta.env.OPENAI_API_KEY,
});

const ASSISTANT_ID = import.meta.env.ASSISTANT_ID;

async function createAndRunThread(message: string) {
  const thread = await openai.beta.threads.create({
      messages: [{ role: 'user', content: message }],
  });

  const run = await openai.beta.threads.runs.createAndPoll(thread.id, {
      assistant_id: ASSISTANT_ID,
  });

  if (run.status === 'completed') {
      const messages = await openai.beta.threads.messages.list(thread.id);
      const assistantMessage = messages.getPaginatedItems().find(msg => msg.role === 'assistant');
      
      // Extract text content and clean up citations
      let content = assistantMessage?.content[0]?.type === 'text' 
          ? assistantMessage.content[0].text.value 
          : '';
          
      // Remove citations using regex
      content = content.replace(/【[^】]*】/g, '');

      return {
          content
      };
  }

  throw new Error(`Run failed with status: ${run.status}`);
}

export async function GET({ url }: APIContext) {
  try {
      const message = url.searchParams.get('message');
      if (!message) {
          throw new Error('Message is required');
      }

      const thread = await createAndRunThread(message);
      return new Response(JSON.stringify(thread), {
          status: 200,
          headers: { 'Content-Type': 'application/json' },
      });
    } catch (error: unknown) {
      const errorMessage = error instanceof Error ? error.message : 'An unknown error occurred';
      return new Response(JSON.stringify({ error: errorMessage }), {
          status: 500,
          headers: { 'Content-Type': 'application/json' },
      });
  }
}

import type { APIContext } from 'astro';
import OpenAI from 'openai';

const openai = new OpenAI({
  apiKey: import.meta.env.OPENAI_API_KEY,
});

const ASSISTANT_ID = import.meta.env.ASSISTANT_ID;

async function createAndRunThread(message: string) {
  const thread = await openai.beta.threads.create({
      messages: [{ role: 'user', content: message }],
  });

  const run = await openai.beta.threads.runs.createAndPoll(thread.id, {
      assistant_id: ASSISTANT_ID,
  });

  if (run.status === 'completed') {
      const messages = await openai.beta.threads.messages.list(thread.id);
      const assistantMessage = messages.getPaginatedItems().find(msg => msg.role === 'assistant');
      
      // Extract text content and clean up citations
      let content = assistantMessage?.content[0]?.type === 'text' 
          ? assistantMessage.content[0].text.value 
          : '';
          
      // Remove citations using regex
      content = content.replace(/【[^】]*】/g, '');

      return {
          content
      };
  }

  throw new Error(`Run failed with status: ${run.status}`);
}

export async function GET({ url }: APIContext) {
  try {
      const message = url.searchParams.get('message');
      if (!message) {
          throw new Error('Message is required');
      }

      const thread = await createAndRunThread(message);
      return new Response(JSON.stringify(thread), {
          status: 200,
          headers: { 'Content-Type': 'application/json' },
      });
    } catch (error: unknown) {
      const errorMessage = error instanceof Error ? error.message : 'An unknown error occurred';
      return new Response(JSON.stringify({ error: errorMessage }), {
          status: 500,
          headers: { 'Content-Type': 'application/json' },
      });
  }
}