+3
-5
src/actor_store/db/migrations.rs
+3
-5
src/actor_store/db/migrations.rs
···
23
23
24
24
/// Run all migrations
25
25
pub(crate) async fn migrate_to_latest(&self) -> Result<()> {
26
-
// In a production system, we'd track which migrations have been run
26
+
// We could track which migrations have been run
27
27
// For simplicity, we just run them all for now
28
28
for migration in &self.migrations {
29
29
migration(&self.db)?;
···
42
42
/// Initial migration to create tables
43
43
fn init_migration(db: &ActorDb) -> Result<()> {
44
44
tokio::task::block_in_place(|| {
45
-
tokio::runtime::Handle::current().block_on(async {
46
-
// Use the create_tables function that's now defined in the db module
47
-
crate::actor_store::db::create_tables(&db.db).await
48
-
})
45
+
tokio::runtime::Handle::current()
46
+
.block_on(async { crate::actor_store::db::create_tables(&db.db).await })
49
47
})
50
48
}
+2
-2
src/actor_store/mod.rs
+2
-2
src/actor_store/mod.rs
···
18
18
/// Configuration for the repo.
19
19
pub(crate) config: RepoConfig,
20
20
/// Background task queue (we'll need to implement this later).
21
-
pub(crate) background_queue: Arc<()>, // Placeholder until we implement a proper queue
21
+
pub(crate) background_queue: Arc<()>, // TODO: Placeholder until we implement a proper queue
22
22
}
23
23
24
24
/// The location of an actor's data.
···
227
227
Ok(())
228
228
}
229
229
230
-
// To be implemented: destroy, reserve_keypair, etc.
230
+
// TODO: To be implemented: destroy, reserve_keypair, etc.
231
231
}
232
232
233
233
// Helper function for SHA-256 hashing