Method fetch_activity

backend/src/redis/mod.rs:235–262

(&self, repo_id: RepoId, first: usize)

impl git::activity::ActivityForPrefix for Arc<Redis> {
    fn fetch_activity(&self, repo_id: RepoId, first: usize) -> Result<Vec<git::activity::Change>> {
        let key = Key(format!("activity:{repo_id}"));
        log::info!("fetching activity for prefix {:?} from Redis", key);
        let mut con = self.connection()?;

        let iter: redis_rs::Iter<redis_rs::Value> = redis_rs::cmd("zrevrange")
            .arg(&key)
            .arg(0)
            .arg(first)
            .clone()
            .iter(&mut con)?;

        let mut changes = vec![];
        for value in iter {
            match value {
                redis_rs::Value::Data(data) => match serde_yaml::from_slice(&data) {
                    Ok(change) => changes.push(change),
                    Err(err) => log::error!("problem fetching change from redis: {}", err),
                },
                redis_rs::Value::Nil => {}
                other => {
                    log::error!("unexpected Redis value: {:?}", other);
                }
            }
        }

        Ok(changes)
    }
}