utils.js

require('dotenv').config({ path: __dirname + '/.env' })
const { writeFile } = require('fs/promises')
const path = require('path')
const fetch = require('node-fetch')
const config = require('./config.json')
const git = require('simple-git')()

const GH_API_BASE = 'https://api.github.com'
const ghAuthHeaders = {
  Authorization: `token ${process.env.GH_TOKEN}`
}

function filterAndProcessRepos (repos) {
  return repos
    .filter(repo => !repo.fork)
    .map(({
      description,
      full_name: name,
      ssh_url: cloneUrl,
      hooks_url: hookUrl
    }) => ({ name, description, hookUrl, cloneUrl }))
}

function getPublicRepoParams () {
  const searchParams = new URLSearchParams()
  for (const [key, value] of Object.entries(config.githubRepoListParams)) {
    searchParams.set(key, value)
  }
  return searchParams
}

async function getPublicRepos () {
  const searchParams = getPublicRepoParams()
  const response = await fetch(`${GH_API_BASE}/user/repos?${searchParams}`, { headers: ghAuthHeaders })
  const json = await response.json()
  return filterAndProcessRepos(json)
}

async function createMetaList (repos) {
  console.log('[INFO]', 'Creating list of cloned directories')
  const list = JSON.stringify(repos.map(repo => repo.name))
  const filePath = path.join(config.repositoriesPath, 'repositories.json')
  await writeFile(filePath, list, 'utf-8')
  return repos
}

async function cloneToPath (repo, log = false) {
  if (log) console.log('[INFO] Cloning %s', repo.name)
  const remotePath = repo.cloneUrl
  const localPath = path.join(config.repositoriesPath, repo.name)
  await git.clone(remotePath, localPath)
  return localPath
}

async function updateDescription (localPath, repo, log = false) {
  if (log) console.log('[INFO] Adding description for %s', repo.name)
  const descriptionFilePath = path.join(localPath, '.git', 'description')
  await writeFile(descriptionFilePath, repo.description || '', 'utf-8')
}

async function createWebhook (repo, log = false) {
  if (log) console.log('[INFO] Creating webhook for %s', repo.name)
  const requestBody = {
    config: {
      url: config.webhookBase + '/push',
      content_type: 'json',
      secret: process.env.WEBHOOK_SECRET
    }
  }
  await fetch(repo.hookUrl, {
    method: 'POST',
    headers: {
      'Content-Type': 'application/json',
      ...ghAuthHeaders
    },
    body: JSON.stringify(requestBody)
  })
}

module.exports = {
  ghAuthHeaders,
  getPublicRepos,
  createMetaList,
  cloneToPath,
  updateDescription,
  createWebhook
}