feat: add method upsertGithubRepository in GitHub provider

Author: UlisesGascon

src/providers/index.js

@@ -42,9 +42,21 @@ const fetchOrgReposListByLogin = async (login) => {
   return repoList
 }
 
+const fetchRepoByFullName = async (fullName) => {
+  debug(`Fetching repository (${fullName})...`)
+  ensureGithubToken()
+  const octokit = new Octokit({ auth: process.env.GITHUB_TOKEN })
+  const { data } = await octokit.request('GET /repos/{owner}/{repo}', {
+    owner: fullName.split('/')[0],
+    repo: fullName.split('/')[1]
+  })
+  return data
+}
+
 const github = {
   fetchOrgByLogin,
   fetchOrgReposListByLogin,
+  fetchRepoByFullName
 }
 
 module.exports = {

src/store/index.js

@@ -1,5 +1,16 @@
 const debug = require('debug')('store')
 
+const upsertGithubRepository = knex => async (repository, orgId) => {
+  debug(`Upserting repository (${repository.full_name})...`)
+
+  const existingRepository = await knex('github_repositories').where({ full_name: repository.full_name }).first()
+  if (existingRepository) {
+    return knex('github_repositories').where({ full_name: repository.full_name, github_organization_id: orgId }).update(repository).returning('*')
+  } else {
+    return knex('github_repositories').insert({ ...repository, github_organization_id: orgId }).returning('*')
+  }
+}
+
 const getAllGithubOrganizations = knex => async () => {
   debug('Getting all GitHub organizations...')
   return knex('github_organizations').select()
@@ -41,7 +52,8 @@ const initializeStore = (knex) => {
     addProject: addProject(knex),
     addGithubOrganization: addGithubOrganization(knex),
     getAllGithubOrganizations: getAllGithubOrganizations(knex),
-    updateGithubOrganization: updateGithubOrganization(knex)
+    updateGithubOrganization: updateGithubOrganization(knex),
+    upsertGithubRepository: upsertGithubRepository(knex)
   }
 }