Handle renamed repositories

Author: codicocodes

src/lib/server/nvim-sync/config/syncRepoInfo.ts

@@ -1,4 +1,10 @@
 import { fetchGithubRepositoryByName, fetchReadme } from '$lib/server/github/api';
+
+export class RepoTransferredError extends Error {
+  constructor(public configId: number) {
+    super('Repo has been transferred to a different dotfyle user');
+  }
+}
 import type { GithubRepository, GithubTree } from '$lib/server/github/schema';
 import { prismaClient } from '$lib/server/prisma/client';
 import type { CreateNeovimConfigDTO } from '$lib/server/prisma/neovimconfigs/schema';
@@ -55,12 +61,50 @@ export async function syncReadme(token: string, config: NeovimConfig) {
 
 export async function syncExistingRepoInfo(token: string, config: NeovimConfig) {
   const repo = await fetchGithubRepositoryByName(token, config.owner, config.repo);
-  if (repo.name !== config.repo || repo.owner.login !== config.owner) {
-    console.log(
-      `[SYNC_CONFIGS] [WARNING] Redirected ${config.owner}/${config.repo} → ${repo.owner.login}/${repo.name}`
-    );
+  const ownerChanged = repo.owner.login !== config.owner;
+  const nameChanged = repo.name !== config.repo;
+  if (ownerChanged || nameChanged) {
+    if (ownerChanged) {
+      const newOwnerUser = await prismaClient.user.findUnique({
+        where: { username: repo.owner.login }
+      });
+      const isRename = !newOwnerUser || newOwnerUser.id === config.userId;
+      if (isRename) {
+        console.log(
+          `[SYNC_CONFIGS] [WARNING] Redirected ${config.owner}/${config.repo} -> ${repo.owner.login}/${repo.name}. Updating data.`
+        );
+        await prismaClient.user.update({
+          where: { id: config.userId },
+          data: {
+            username: repo.owner.login,
+            neovimConfigs: {
+              updateMany: {
+                where: { owner: config.owner },
+                data: { owner: repo.owner.login }
+              }
+            }
+          }
+        });
+      } else {
+        console.log(
+          `[SYNC_CONFIGS] [WARNING] ${config.owner}/${config.repo} owner changed to ${repo.owner.login} who is a different dotfyle user — skipping sync`
+        );
+        throw new RepoTransferredError(config.id);
+      }
+    }
+    if (nameChanged) {
+      await prismaClient.neovimConfig.update({
+        where: { id: config.id },
+        data: { repo: repo.name }
+      });
+    }
   }
-  const upsertDTO = upsertNeovimConfigDTOFactory(config.owner, config.root, config.initFile, repo);
+  const upsertDTO = upsertNeovimConfigDTOFactory(
+    repo.owner.login,
+    config.root,
+    config.initFile,
+    repo
+  );
   return upsertNeovimConfig(config.userId, upsertDTO);
 }
 

src/lib/trpc/procedures/syncExistingNeovimConfig.ts

@@ -4,7 +4,11 @@ import { t } from '../t';
 import { TRPCError } from '@trpc/server';
 import { getConfigBySlug } from '$lib/server/prisma/neovimconfigs/service';
 import { getGithubToken } from '$lib/server/prisma/users/service';
-import { syncExistingRepoInfo, syncReadme } from '$lib/server/nvim-sync/config/syncRepoInfo';
+import {
+  syncExistingRepoInfo,
+  syncReadme,
+  RepoTransferredError
+} from '$lib/server/nvim-sync/config/syncRepoInfo';
 import { getNeovimConfigSyncer } from '$lib/server/nvim-sync/config/NeovimConfigSyncer';
 import { hasBeenOneDay } from '$lib/utils';
 
@@ -20,7 +24,15 @@ export const syncExistingNeovimConfig = t.procedure
       throw new TRPCError({ code: 'FORBIDDEN' });
     }
     const token = await getGithubToken(user.id);
-    const config = await syncExistingRepoInfo(token, configBeforeSync);
+    const config = await syncExistingRepoInfo(token, configBeforeSync).catch((e) => {
+      if (e instanceof RepoTransferredError) {
+        throw new TRPCError({
+          code: 'CONFLICT',
+          message: 'Repo has been transferred to another user'
+        });
+      }
+      throw e;
+    });
     await syncReadme(token, config);
     const syncer = await getNeovimConfigSyncer(user, config);
     return await syncer.treeSync();

src/routes/api/sync/configs/+server.ts

@@ -4,6 +4,8 @@ import { syncExistingRepoInfo, syncReadme } from '$lib/server/nvim-sync/config/s
 import { getConfigsWithToken } from '$lib/server/prisma/neovimconfigs/service';
 import { getAllNeovimPluginNames } from '$lib/server/prisma/neovimplugins/service';
 import { deleteGithubToken } from '$lib/server/prisma/users/service';
+import { RepoTransferredError } from '$lib/server/nvim-sync/config/syncRepoInfo';
+import { prismaClient } from '$lib/server/prisma/client';
 import type { RequestHandler } from '@sveltejs/kit';
 
 const PAGE_SIZE = 50;
@@ -31,6 +33,13 @@ async function* getConfigSyncTasks() {
             await syncer.treeSync();
           })
         ]).catch(async (e: { status?: number; message?: string }) => {
+          if (e instanceof RepoTransferredError) {
+            await prismaClient.neovimConfig.update({
+              where: { id: e.configId },
+              data: { lastSyncedAt: new Date() }
+            });
+            return;
+          }
           if (e.status === 401) {
             await deleteGithubToken(config.userId);
             console.log(