cameleer/cameleer-saas
2
0
Fork 0
Code Issues 22 Pull Requests Actions Packages Projects Releases Wiki Activity

refactor: move PG cleanup to TenantDatabaseService, keep only ClickHouse

Browse Source 
TenantDataCleanupService now handles only ClickHouse GDPR erasure;
the dropPostgresSchema private method is removed and the public method
renamed cleanupClickHouse(). VendorTenantService updated accordingly
with the TODO comment removed.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
This commit is contained in:
hsiegeln
2026-04-15 00:17:00 +02:00
parent c1458e4995
commit d7eb700860
2 changed files with 9 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
src/main/java/net/siegeln/cameleer/saas/provisioning/TenantDataCleanupService.java
View File

@@ -12,8 +12,8 @@ import java.util.ArrayList;
import java.util.List;
/**
* Cleans up tenant data from the server PostgreSQL and ClickHouse databases
* when a tenant is deleted (GDPR data erasure).
* Deletes tenant data from ClickHouse tables when a tenant is deleted
* (GDPR data erasure). PostgreSQL cleanup is handled by TenantDatabaseService.
*/
@Service
public class TenantDataCleanupService {
@@ -26,33 +26,14 @@ public class TenantDataCleanupService {
this.props = props;
}
public void cleanup(String slug) {
dropPostgresSchema(slug);
/**
* Deletes tenant data from ClickHouse tables (GDPR data erasure).
* PostgreSQL cleanup is handled by TenantDatabaseService.
*/
public void cleanupClickHouse(String slug) {
deleteClickHouseData(slug);
}
private void dropPostgresSchema(String slug) {
String url = props.datasourceUrl();
if (url == null || url.isBlank()) {
log.warn("No server datasource URL configured — skipping PostgreSQL schema cleanup");
return;
}
String schema = "tenant_" + slug;
if (!schema.matches("^[a-z0-9_-]+$")) {
log.error("Refusing to drop schema with unexpected characters: {}", schema);
return;
}
try (Connection conn = DriverManager.getConnection(url, props.datasourceUsername(), props.datasourcePassword());
Statement stmt = conn.createStatement()) {
stmt.execute("DROP SCHEMA IF EXISTS \"" + schema + "\" CASCADE");
log.info("Dropped PostgreSQL schema: {}", schema);
} catch (Exception e) {
log.warn("Failed to drop PostgreSQL schema '{}': {}", schema, e.getMessage());
}
}
private void deleteClickHouseData(String slug) {
String url = props.clickhouseUrl();
if (url == null || url.isBlank()) {

5
src/main/java/net/siegeln/cameleer/saas/vendor/VendorTenantService.java vendored
View File

@@ -336,9 +336,8 @@ public class VendorTenantService {
log.warn("Failed to drop tenant database for {}: {}", tenant.getSlug(), e.getMessage());
}
// Erase tenant data from server databases (GDPR)
// TODO: split into cleanupClickHouse() in next task
dataCleanupService.cleanup(tenant.getSlug());
// Erase tenant data from ClickHouse (GDPR)
dataCleanupService.cleanupClickHouse(tenant.getSlug());
// Soft-delete
tenant.setStatus(TenantStatus.DELETED);