refreshGithubRepoSettings.ts

/* eslint-disable no-continue */
import cronGenerator from 'cron-time-generator'

import { IS_DEV_ENV, timeout } from '@crowd/common'
import { getServiceChildLogger } from '@crowd/logging'

import SequelizeRepository from '../../database/repositories/sequelizeRepository'
import IntegrationService from '../../services/integrationService'
import { CrowdJob } from '../../types/jobTypes'

const log = getServiceChildLogger('refreshGithubRepoSettings')

const refreshForGitHub = async () => {
  log.info('Updating Github repo settings.')
  const dbOptions = await SequelizeRepository.getDefaultIRepositoryOptions()

  interface Integration {
    id: string
    tenantId: string
    integrationIdentifier: string
  }

  const githubIntegrations = await dbOptions.database.sequelize.query(
    `SELECT id, "tenantId", "integrationIdentifier" FROM integrations 
       WHERE platform = 'github' AND "deletedAt" IS NULL
       AND "createdAt" < NOW() - INTERVAL '1 minute' AND "integrationIdentifier" IS NOT NULL`,
  )

  for (const integration of githubIntegrations[0] as Integration[]) {
    log.info(`Updating repo settings for Github integration: ${integration.id}`)

    try {
      const options = await SequelizeRepository.getDefaultIRepositoryOptions()
      options.currentTenant = { id: integration.tenantId }

      const integrationService = new IntegrationService(options)
      // newly discovered repos will be mapped to default segment of the integration
      await integrationService.updateGithubIntegrationSettings(integration.integrationIdentifier)

      log.info(`Successfully updated repo settings for Github integration: ${integration.id}`)
    } catch (err) {
      log.error(
        `Error updating repo settings for Github integration ${integration.id}: ${err.message}`,
      )
    } finally {
      await timeout(1000)
    }
  }

  log.info('Finished updating Github repo settings.')
}

export const refreshGithubRepoSettings = async () => {
  log.info('Updating Github repo settings.')

  await refreshForGitHub()
}

const job: CrowdJob = {
  name: 'Refresh Github repo settings',
  // every day
  cronTime: IS_DEV_ENV ? cronGenerator.every(5).minutes() : cronGenerator.every(1).days(),
  onTrigger: async () => {
    await refreshGithubRepoSettings()
  },
}

export default job