diff options
| author | Emmanuel Vasilakis <mrzammler@mm.st> | 2021-11-17 09:19:05 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-11-17 09:19:05 +0200 |
| commit | 5471894ac2a4732748ca3133e4d0b3bf3b4fe50e (patch) | |
| tree | c12fde2e099bfe53fea6df758768d13532c4078f /database | |
| parent | ffd9aaaff5744c15f40f1b6fff086e00805673fe (diff) | |
Delete from aclk alerts table if ack'ed from cloud one day ago (#11779)
Diffstat (limited to 'database')
| -rw-r--r-- | database/sqlite/sqlite_aclk.c | 5 | ||||
| -rw-r--r-- | database/sqlite/sqlite_aclk.h | 1 |
2 files changed, 6 insertions, 0 deletions
diff --git a/database/sqlite/sqlite_aclk.c b/database/sqlite/sqlite_aclk.c index 1f1b0b3191..3d9c26d5ff 100644 --- a/database/sqlite/sqlite_aclk.c +++ b/database/sqlite/sqlite_aclk.c @@ -623,6 +623,11 @@ void sql_maint_aclk_sync_database(struct aclk_database_worker_config *wc, struct "(SELECT unique_id FROM aclk_chart_%s) AND unique_id NOT IN (SELECT unique_id FROM aclk_chart_latest_%s);", wc->uuid_str, wc->uuid_str, wc->uuid_str); db_execute(buffer_tostring(sql)); + buffer_flush(sql); + + buffer_sprintf(sql,"DELETE FROM aclk_alert_%s WHERE date_submitted IS NOT NULL AND " + "date_cloud_ack < strftime('%%s','now','-%d seconds');", wc->uuid_str, ACLK_DELETE_ACK_ALERTS_INTERNAL); + db_execute(buffer_tostring(sql)); buffer_free(sql); return; diff --git a/database/sqlite/sqlite_aclk.h b/database/sqlite/sqlite_aclk.h index 9424a00b7c..9bf6482a83 100644 --- a/database/sqlite/sqlite_aclk.h +++ b/database/sqlite/sqlite_aclk.h @@ -20,6 +20,7 @@ #define ACLK_DATABASE_CLEANUP_INTERVAL (3600) #define ACLK_DATABASE_ROTATION_INTERVAL (3600) #define ACLK_DELETE_ACK_INTERNAL (600) +#define ACLK_DELETE_ACK_ALERTS_INTERNAL (86400) #define ACLK_SYNC_QUERY_SIZE 512 struct aclk_completion { |