Mirror-bot/nitter-status
1
0 Fork 0
mirror of https://github.com/4cuck/nitter-status.git synced 2026-10-26 00:52:25 +00:00
Code Issues Projects Releases Activity

cleanup errors of removed hosts

Browse Source
This commit is contained in:
4cuck committed 2024-06-09 16:33:03 +02:00
1 parent 43df834685
commit e2cd80e934
1 file changed
+27 -16
Download Patch File Download Diff File Expand all files Collapse all files
scanner/src/cleanup.rs
+27 -16
View File
@@ -36,22 +36,33 @@ impl Scanner {
// I wish this was easier without row ids or giant SQL queries
let hosts = host::Entity::find().all(&self.inner.db).await?;
for host in hosts {
let res = check_errors::Entity::delete_many()
.filter(check_errors::Column::Host.eq(host.id))
.filter(
check_errors::Column::Time.not_in_subquery(
Query::select()
.column(check_errors::Column::Time)
.from(check_errors::Entity)
.and_where(check_errors::Column::Host.eq(host.id))
.order_by(check_errors::Column::Time, Order::Desc)
.limit(self.inner.config.error_retention_per_host as _)
.to_owned(),
),
)
.exec(&self.inner.db)
.await?;
tracing::debug!(host = host.id, deleted_errors = res.rows_affected);
let res = if host.enabled {
check_errors::Entity::delete_many()
.filter(check_errors::Column::Host.eq(host.id))
.filter(
check_errors::Column::Time.not_in_subquery(
Query::select()
.column(check_errors::Column::Time)
.from(check_errors::Entity)
.and_where(check_errors::Column::Host.eq(host.id))
.order_by(check_errors::Column::Time, Order::Desc)
.limit(self.inner.config.error_retention_per_host as _)
.to_owned(),
),
)
.exec(&self.inner.db)
.await?
} else {
check_errors::Entity::delete_many()
.filter(check_errors::Column::Host.eq(host.id))
.exec(&self.inner.db)
.await?
};
tracing::debug!(
host = host.id,
host.enabled,
deleted_errors = res.rows_affected
);
}
Ok(())