From 999b8353c65f11e90b2f450311c2ef4e9543be8d Mon Sep 17 00:00:00 2001 From: Mia Date: Sat, 1 Feb 2025 16:17:52 +0000 Subject: [PATCH] update_repo_state -> update_repo_version --- consumer/src/indexer/db.rs | 2 +- consumer/src/indexer/mod.rs | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/consumer/src/indexer/db.rs b/consumer/src/indexer/db.rs index 46179795..0b12ef5f 100644 --- a/consumer/src/indexer/db.rs +++ b/consumer/src/indexer/db.rs @@ -42,7 +42,7 @@ pub async fn account_sync_status( .optional() } -pub async fn update_repo_state( +pub async fn update_repo_version( conn: &mut AsyncPgConnection, repo: &str, rev: &str, diff --git a/consumer/src/indexer/mod.rs b/consumer/src/indexer/mod.rs index 8752e33b..b1c03214 100644 --- a/consumer/src/indexer/mod.rs +++ b/consumer/src/indexer/mod.rs @@ -109,7 +109,7 @@ async fn index_commit(conn: &mut AsyncPgConnection, commit: AtpCommitEvent) -> e // ensure new repo rev > current rev, but only when the repo is synced // (if repo is processing, they'll end up on the queue anyway) if is_active - && db::update_repo_state(t, &commit.repo, &commit.rev, commit.commit).await? == 0 + && db::update_repo_version(t, &commit.repo, &commit.rev, commit.commit).await? == 0 { tracing::warn!("Got a repo update older than the current rev. not processing ops."); return Ok(false); -- 2.51.2