diff options
Diffstat (limited to 'src/main.rs')
| -rw-r--r-- | src/main.rs | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/src/main.rs b/src/main.rs index ab6ede7..ebe05a3 100644 --- a/src/main.rs +++ b/src/main.rs | |||
| @@ -132,6 +132,13 @@ async fn main() -> Result<()> { | |||
| 132 | // Get a reference to the rejected events index for shutdown persistence | 132 | // Get a reference to the rejected events index for shutdown persistence |
| 133 | let shutdown_rejected_index = sync_manager.rejected_events_index(); | 133 | let shutdown_rejected_index = sync_manager.rejected_events_index(); |
| 134 | 134 | ||
| 135 | // Wire repo_sync_index into write policy so user-submitted purgatory announcements | ||
| 136 | // get registered for state event sync immediately (Fix 3). | ||
| 137 | let repo_sync_index = sync_manager.repo_sync_index(); | ||
| 138 | relay_with_db | ||
| 139 | .write_policy | ||
| 140 | .set_repo_sync_index(repo_sync_index); | ||
| 141 | |||
| 135 | tokio::spawn(async move { | 142 | tokio::spawn(async move { |
| 136 | sync_manager.run().await; | 143 | sync_manager.run().await; |
| 137 | }); | 144 | }); |