fetch-utils.ts

import axios from "axios";

// Fetch data with rate limit handling
export const fetchWithRateLimit = async (
  url: string,
  headers: { Authorization: string; Accept: string },
  params?: any
): Promise<any> => {
  try {
    const response = await axios.get(url, { headers, params });
    return response.data;
  } catch (error: any) {
    // Handle rate limit errors
    if (
      error.response?.status === 403 &&
      error.response.headers["x-ratelimit-remaining"] === "0"
    ) {
      const resetTime = parseInt(
        error.response.headers["x-ratelimit-reset"],
        10
      );
      const sleepTime =
        Math.max(0, resetTime - Math.floor(Date.now() / 1000)) + 1;
      console.log(`Rate limit exceeded. Sleeping for ${sleepTime} seconds...`);
      await new Promise((resolve) => setTimeout(resolve, sleepTime * 1000));
      return fetchWithRateLimit(url, headers, params);
    }

    // Add retries for server errors (5xx)
    if (error.response?.status >= 500 && error.response?.status < 600) {
      const retryDelay = 5000; // 5 seconds
      console.log(`Server error ${error.response.status}, retrying in ${retryDelay/1000} seconds...`);
      await new Promise((resolve) => setTimeout(resolve, retryDelay));
      return fetchWithRateLimit(url, headers, params);
    }

    // Log other API errors with minimal details
    console.error(`GitHub API request failed for ${url}: ${error.message}`);
    throw error;
  }
};

// Unified function to fetch reactions for a comment
export const fetchCommentReactions = async (
  owner: string,
  repo: string,
  comment: any,
  headers: { Authorization: string; Accept: string }
): Promise<any[]> => {
  try {
    // Review comments have a path property or are explicitly marked as review type
    const isReviewComment = !!comment.path || (typeof comment === 'object' && comment.type === 'review');
    const commentId = typeof comment === 'object' ? comment.id : comment;
    const url = isReviewComment
      ? `https://api.github.com/repos/${owner}/${repo}/pulls/comments/${commentId}/reactions`
      : `https://api.github.com/repos/${owner}/${repo}/issues/comments/${commentId}/reactions`;
    
    return await fetchWithRateLimit(url, headers);
  } catch (error: any) {
    // If it's a 404, the comment was likely deleted
    if (error.response?.status === 404) {
      console.log(
        `Comment ${typeof comment === 'object' ? comment.id : comment} was deleted or is no longer accessible`
      );
      return [];
    }

    // For other errors, log more details
    console.error(
      `Error fetching reactions for comment ${typeof comment === 'object' ? comment.id : comment}:`,
      error.message
    );
    return [];
  }
};