Skip to content

Commit

Permalink
squash! processor: add another condition to waitForRepoMigration
Browse files Browse the repository at this point in the history
  • Loading branch information
AbdulrhmnGhanem committed Sep 28, 2022
1 parent af9177b commit ce2589f
Showing 1 changed file with 12 additions and 8 deletions.
20 changes: 12 additions & 8 deletions processor/src/watcher.ts
Original file line number Diff line number Diff line change
Expand Up @@ -35,19 +35,12 @@ export function watch(repoDir, { giteaDB }: WatchOptions) {
let originalUrl = ''

if (giteaDB != null) {
const giteaRepo = await giteaDB.getRepoInfo(ownerName, repoName)
let giteaRepo = await giteaDB.getRepoInfo(ownerName, repoName)
if (giteaRepo == null) {
log.error(`${ownerName}/${repoName} is not in giteaDB`)
dirWatchers[gitDir].queuing = false
return
}
defaultBranch = giteaRepo.default_branch
originalUrl = giteaRepo.original_url
repoDescription = giteaRepo.description
giteaId = giteaRepo.id
// use case-correct names from the DB
ownerName = giteaRepo.owner_name
repoName = giteaRepo.name

if (giteaRepo.is_empty) {
await giteaDB.waitForNonEmpty(giteaId)
Expand All @@ -56,6 +49,17 @@ export function watch(repoDir, { giteaDB }: WatchOptions) {
if (giteaRepo.is_mirror) {
await giteaDB.waitForRepoMigration(giteaId)
}
// Get the repo info again after the migration is done.
// Some fields, (e.g., default_branch) only gets populated after migration.
giteaRepo = await giteaDB.getRepoInfo(ownerName, repoName)

defaultBranch = giteaRepo.default_branch
originalUrl = giteaRepo.original_url
repoDescription = giteaRepo.description
giteaId = giteaRepo.id
// use case-correct names from the DB
ownerName = giteaRepo.owner_name
repoName = giteaRepo.name
}

await addProjectToQueues({
Expand Down

0 comments on commit ce2589f

Please sign in to comment.