github-api.js

const { Octokit } = require('@octokit/rest');

/**
 * GitHub API wrapper with comprehensive logging
 * All GitHub API interactions are centralized here
 */

// Logging helpers
function logApiCall(method, endpoint, params = {}) {
  const timestamp = new Date().toISOString();
  console.log(`[${timestamp}] GitHub API Call: ${method} ${endpoint}`, 
    Object.keys(params).length > 0 ? params : '');
}

function logApiResponse(method, endpoint, status, dataPreview) {
  const timestamp = new Date().toISOString();
  const preview = Array.isArray(dataPreview) 
    ? `Array(${dataPreview.length})` 
    : typeof dataPreview === 'object' 
      ? `Object{${Object.keys(dataPreview).slice(0, 3).join(', ')}...}` 
      : dataPreview;
  console.log(`[${timestamp}] GitHub API Response: ${method} ${endpoint} - Status: ${status}`, preview);
}

function logApiError(method, endpoint, error) {
  const timestamp = new Date().toISOString();
  console.error(`[${timestamp}] GitHub API Error: ${method} ${endpoint} - Status: ${error.status || 'N/A'} - ${error.message}`);
}

/**
 * Get authenticated user information
 */
async function getUserInfo(accessToken) {
  const octokit = new Octokit({ auth: accessToken });
  
  try {
    logApiCall('GET', '/user');
    const { data, status } = await octokit.rest.users.getAuthenticated();
    logApiResponse('GET', '/user', status, data);
    return data;
  } catch (error) {
    logApiError('GET', '/user', error);
    throw error;
  }
}

/**
 * List all repositories for authenticated user with pagination
 * Filters to only include repositories where user has admin access
 */
async function listRepositories(accessToken) {
  const octokit = new Octokit({ auth: accessToken });
  const allRepos = [];
  
  try {
    logApiCall('GET', '/user/repos', { per_page: 100, sort: 'updated', affiliation: 'owner,collaborator' });
    
    for await (const response of octokit.paginate.iterator(
      octokit.rest.repos.listForAuthenticatedUser,
      {
        per_page: 100,
        sort: 'updated',
        direction: 'desc',
        affiliation: 'owner,collaborator'
      }
    )) {
      logApiResponse('GET', '/user/repos', response.status, response.data);
      // Filter to only repos where user has admin permission
      const adminRepos = response.data.filter(repo => repo.permissions?.admin === true);
      allRepos.push(...adminRepos);
    }
    
    console.log(`[${new Date().toISOString()}] Total repositories with admin access: ${allRepos.length}`);
    return allRepos;
  } catch (error) {
    logApiError('GET', '/user/repos', error);
    throw error;
  }
}

/**
 * Archive a repository
 */
async function archiveRepository(accessToken, owner, repo) {
  const octokit = new Octokit({ auth: accessToken });
  
  try {
    logApiCall('PATCH', `/repos/${owner}/${repo}`, { archived: true });
    const { data, status } = await octokit.rest.repos.update({
      owner,
      repo,
      archived: true
    });
    logApiResponse('PATCH', `/repos/${owner}/${repo}`, status, data);
    return data;
  } catch (error) {
    logApiError('PATCH', `/repos/${owner}/${repo}`, error);
    throw error;
  }
}

/**
 * Delete a repository
 */
async function deleteRepository(accessToken, owner, repo) {
  const octokit = new Octokit({ auth: accessToken });
  
  try {
    logApiCall('DELETE', `/repos/${owner}/${repo}`);
    const { status } = await octokit.rest.repos.delete({
      owner,
      repo
    });
    logApiResponse('DELETE', `/repos/${owner}/${repo}`, status, 'Repository deleted');
    return { success: true };
  } catch (error) {
    logApiError('DELETE', `/repos/${owner}/${repo}`, error);
    throw error;
  }
}

module.exports = {
  getUserInfo,
  listRepositories,
  archiveRepository,
  deleteRepository
};