(directory: &SqliteServerDirectory, now_unix_ms: i64)
| 188 | ]; |
| 189 | |
| 190 | pub async fn seed_dev_data(directory: &SqliteServerDirectory, now_unix_ms: i64) -> Result<usize> { |
| 191 | for (index, seed) in DEV_SERVER_SEEDS.iter().enumerate() { |
| 192 | let current_unix_ms = now_unix_ms + i64::try_from(index).unwrap_or(0); |
| 193 | let history = seed.history_samples(); |
| 194 | directory.clear_samples(seed.server_id).await?; |
| 195 | directory.clear_sessions(seed.server_id).await?; |
| 196 | for (sample_index, players) in history[..history.len() - 1].iter().enumerate() { |
| 197 | let trailing = i64::try_from(history.len() - sample_index - 1).unwrap_or(0); |
| 198 | directory |
| 199 | .insert_sample( |
| 200 | seed.server_id, |
| 201 | current_unix_ms - trailing * 30 * 60 * 1000, |
| 202 | *players, |
| 203 | ) |
| 204 | .await?; |
| 205 | } |
| 206 | for session in seed.recent_sessions(current_unix_ms) { |
| 207 | directory.insert_session(seed.server_id, &session).await?; |
| 208 | } |
| 209 | directory |
| 210 | .register(seed.to_request(), current_unix_ms) |
| 211 | .await?; |
| 212 | directory |
| 213 | .observe(seed.server_id, current_unix_ms, true) |
| 214 | .await?; |
| 215 | } |
| 216 | |
| 217 | Ok(DEV_SEED_SERVER_COUNT) |
| 218 | } |
| 219 | |
| 220 | pub async fn seed_dev_mods(store: &ModStore) -> Result<usize> { |
| 221 | let mut seeded = 0; |
no test coverage detected