store: Asyncify rollup::Rollup::last_rollup

Author: lutter

store/postgres/src/deployment_store.rs

@@ -958,7 +958,7 @@ impl DeploymentStore {
 
         let mut conn = self.get_conn()?;
         let layout = store.layout(&mut conn, site.cheap_clone()).await?;
-        layout.last_rollup(&mut conn)
+        layout.last_rollup(&mut conn).await
     }
 
     pub(crate) async fn get_proof_of_indexing(

store/postgres/src/relational.rs

@@ -1124,11 +1124,11 @@ impl Layout {
     /// for all aggregations, meaning that if some aggregations do not have
     /// an entry with the maximum timestamp that there was just no data for
     /// that interval, but we did try to aggregate at that time.
-    pub(crate) fn last_rollup(
+    pub(crate) async fn last_rollup(
         &self,
         conn: &mut PgConnection,
     ) -> Result<Option<BlockTime>, StoreError> {
-        Rollup::last_rollup(&self.rollups, conn)
+        Rollup::last_rollup(&self.rollups, conn).await
     }
 
     /// Construct `Rolllup` for each of the aggregation mappings

store/postgres/src/relational/rollup.rs

@@ -283,7 +283,7 @@ impl Rollup {
         query.execute(conn)
     }
 
-    pub(crate) fn last_rollup(
+    pub(crate) async fn last_rollup(
         rollups: &[Rollup],
         conn: &mut PgConnection,
     ) -> Result<Option<BlockTime>, StoreError> {