Merge pull request #84 from chaotic-cx/feat/global-rebuild

feat(backend): add being able to specify global bump triggers

backend/src/config/repo-manager.config.ts

@@ -1,10 +1,10 @@
 import { registerAs } from "@nestjs/config";
 
 export default registerAs("repoMan", () => ({
-    alwaysRebuild: process.env.REPOMANAGER_ALWAYS_REBUILD ?? "{}",
     gitAuthor: process.env.GIT_AUTHOR ?? "Chaotic Temeraire",
     gitEmail: process.env.GIT_EMAIL ?? "[email protected]",
     gitUsername: process.env.GIT_USERNAME ?? "git",
     gitlabToken: process.env.CAUR_GITLAB_TOKEN,
+    globalTriggers: process.env.REPOMANAGER_ALWAYS_REBUILD ?? "[]",
     schedulerInterval: process.env.REPOMANAGER_SCHEDULE ?? "0 * * * *",
 }));

backend/src/interfaces/repo-manager.ts

@@ -1,4 +1,5 @@
 import { Package } from "../builder/builder.entity";
+import { ArchlinuxPackage } from "../repo-manager/repo-manager.entity";
 
 export interface Repo {
     name: string;
@@ -47,18 +48,24 @@ export interface RepoSettings {
     gitEmail: string;
     gitUsername: string;
     gitlabToken: string;
-    alwaysRebuild: { [key: string]: string };
-}
-
-export interface PkgnameVersion {
-    pkgname: string;
-    archVersion: string;
+    globalTriggers: string[];
 }
 
 export interface RepoUpdateRunParams {
-    archPkg: ParsedPackage;
+    archPkg: ArchlinuxPackage;
     configs: CiConfigs;
     pkg: Package;
 }
 
 export type CiConfigs = { [key: string]: string };
+
+export interface BumpResult {
+    bumped: Map<string, string>;
+    repo: string;
+}
+
+export interface PackageConfig {
+    configs: CiConfigs;
+    pkgInDb: Package;
+    rebuildTriggers: string[];
+}

backend/src/repo-manager/repo-manager.controller.ts

@@ -15,4 +15,9 @@ export class RepoManagerController {
     updateChaoticVersions(): void {
         void this.repoManager.updateChaoticVersions();
     }
+
+    @Get("rebuild")
+    checkGlobalRebuildTriggers(): void {
+        void this.repoManager.checkGlobalRebuildTriggers();
+    }
 }

backend/src/repo-manager/repo-manager.entity.ts

@@ -39,6 +39,7 @@ export class RepoManagerSettings {
 }
 
 const packageMutex = new Mutex();
+const settingsMutex = new Mutex();
 
 /**
  * Check if a package exists in the database, if not create a new entry
@@ -74,3 +75,34 @@ export async function archPkgExists(
         }
     });
 }
+
+/**
+ * Check if a setting exists in the database, if not create a new entry
+ * @param key The key to check
+ * @param connection The repository connection
+ */
+export function repoSettingsExists(
+    key: string,
+    connection: Repository<RepoManagerSettings>,
+): Promise<RepoManagerSettings> {
+    return settingsMutex.runExclusive(async () => {
+        try {
+            const settings: RepoManagerSettings[] = await connection.find({ where: { key } });
+            let settingExists: Partial<RepoManagerSettings> = settings.find((oneSetting) => {
+                return oneSetting.key === key;
+            });
+
+            if (settingExists === undefined) {
+                Logger.log(`Setting ${key} not found in database, creating new entry`, "RepoManagerEntity");
+                settingExists = await connection.save({
+                    key,
+                    value: "",
+                });
+            }
+
+            return settingExists as RepoManagerSettings;
+        } catch (err: unknown) {
+            Logger.error(err, "RepoManagerEntity");
+        }
+    });
+}