Snippets orphan removal

dao/src/main/resources/db/migration/V98__orphanRemovalForFindings.sql

@@ -0,0 +1,40 @@
+/*
+ * Copyright (C) 2025 The ORT Server Authors (See <https://github.com/eclipse-apoapsis/ort-server/blob/main/NOTICE>)
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ * SPDX-License-Identifier: Apache-2.0
+ * License-Filename: LICENSE
+ */
+
+-- This migration script adds cascade deletions on  scan_results table and it's children tables.
+
+ALTER TABLE snippet_findings
+    DROP CONSTRAINT snippet_findings_scan_summary_id_fkey,
+  ADD CONSTRAINT snippet_findings_scan_summary_id_fkey
+    FOREIGN KEY (scan_summary_id) REFERENCES scan_summaries (id) ON DELETE CASCADE;
+
+ALTER TABLE snippet_findings_snippets
+    DROP CONSTRAINT snippet_findings_snippets_snippet_finding_id_fkey,
+  ADD CONSTRAINT snippet_findings_snippets_snippet_finding_id_fkey
+    FOREIGN KEY (snippet_finding_id) REFERENCES snippet_findings (id) ON DELETE CASCADE;
+
+ALTER TABLE license_findings
+    DROP CONSTRAINT license_findings_scan_summary_id_fkey,
+  ADD CONSTRAINT license_findings_scan_summary_id_fkey
+    FOREIGN KEY (scan_summary_id) REFERENCES scan_summaries (id) ON DELETE CASCADE;
+
+ALTER TABLE copyright_findings
+    DROP CONSTRAINT copyright_findings_scan_summary_id_fkey,
+  ADD CONSTRAINT copyright_findings_scan_summary_id_fkey
+    FOREIGN KEY (scan_summary_id) REFERENCES scan_summaries (id) ON DELETE CASCADE;

services/hierarchy/src/main/kotlin/OrphanRemovalService.kt

@@ -38,11 +38,15 @@ import org.eclipse.apoapsis.ortserver.dao.repositories.repositoryconfiguration.P
 import org.eclipse.apoapsis.ortserver.dao.repositories.repositoryconfiguration.PackageCurationDataTable
 import org.eclipse.apoapsis.ortserver.dao.repositories.repositoryconfiguration.PackageCurationsTable
 import org.eclipse.apoapsis.ortserver.dao.repositories.repositoryconfiguration.PackageLicenseChoicesTable
+import org.eclipse.apoapsis.ortserver.dao.repositories.scannerrun.ScannerRunsScanResultsTable
 import org.eclipse.apoapsis.ortserver.dao.repositories.scannerrun.ScannerRunsScannersTable
 import org.eclipse.apoapsis.ortserver.dao.tables.NestedProvenanceSubRepositoriesTable
 import org.eclipse.apoapsis.ortserver.dao.tables.NestedProvenancesTable
 import org.eclipse.apoapsis.ortserver.dao.tables.NestedRepositoriesTable
 import org.eclipse.apoapsis.ortserver.dao.tables.PackageProvenancesTable
+import org.eclipse.apoapsis.ortserver.dao.tables.ScanResultsTable
+import org.eclipse.apoapsis.ortserver.dao.tables.ScanSummariesTable
+import org.eclipse.apoapsis.ortserver.dao.tables.SnippetFindingsSnippetsTable
 import org.eclipse.apoapsis.ortserver.dao.tables.SnippetsTable
 import org.eclipse.apoapsis.ortserver.dao.tables.shared.DeclaredLicensesTable
 import org.eclipse.apoapsis.ortserver.dao.tables.shared.IdentifiersIssuesTable
@@ -63,6 +67,7 @@ import org.slf4j.LoggerFactory
 /**
  * Maintenance service to remove orphaned entities.
  */
+@Suppress("TooManyFunctions")
 class OrphanRemovalService(
     private val db: Database
 ) {
@@ -82,6 +87,9 @@ class OrphanRemovalService(
         logger.info("Deleted {} records from {}", deleteOrphanedIdentifiers(), IdentifiersTable.tableName)
         logger.info("Deleted {} records from {}", deleteOrphanedVcsInfo(), VcsInfoTable.tableName)
         logger.info("Deleted {} records from {}", deleteOrphanedRemoteArtifacts(), RemoteArtifactsTable.tableName)
+        logger.info("Deleted {} records from {}", deleteOrphanedScanResults(), ScanResultsTable.tableName)
+        logger.info("Deleted {} records from {}", deleteOrphanedScanSummaries(), ScanSummariesTable.tableName)
+        logger.info("Deleted {} records from {}", deleteOrphanedSnippets(), SnippetsTable.tableName)
 
         logger.info("Deleting orphaned children of ORT runs finished.")
     }
@@ -302,4 +310,33 @@ class OrphanRemovalService(
                     )
             }
         }
+
+    private suspend fun deleteOrphanedScanResults() =
+        db.dbQuery {
+            ScanResultsTable.deleteWhere {
+                id notInSubQuery (
+                    ScannerRunsScanResultsTable.select(ScannerRunsScanResultsTable.scanResultId)
+                    )
+            }
+        }
+
+    private suspend fun deleteOrphanedScanSummaries() =
+        db.dbQuery {
+            ScanSummariesTable.deleteWhere {
+                id notInSubQuery (
+                    ScanResultsTable.select(ScanResultsTable.scanSummaryId)
+                    )
+            }
+        }
+
+    private suspend fun deleteOrphanedSnippets() =
+        db.dbQuery {
+            SnippetsTable.deleteWhere {
+                id notInSubQuery (
+                    SnippetFindingsSnippetsTable
+                        .select(SnippetFindingsSnippetsTable.snippetId.alias("id"))
+                        .where(SnippetFindingsSnippetsTable.snippetId.isNotNull())
+                    )
+            }
+        }
 }