Method check_new_logs

ct_monitor/src/main.rs:339–368

(&mut self)

    }

    async fn check_new_logs(&mut self) -> Result<()> {
        let logs = self.get_logs(10000).await?;
        debug!("got {} logs", logs.len());
        let mut found_last_checked = false;

        for log in logs.iter() {
            let log_id = log.id;

            if let Some(last_checked) = self.last_checked {
                if log_id == last_checked {
                    found_last_checked = true;
                    break;
                }
            }
            debug!("🔍 checking log id={}", log_id);
            self.check_one_log(log).await?;
        }

        if !found_last_checked && self.last_checked.is_some() {
            bail!("last checked log not found, something went wrong");
        }

        if !logs.is_empty() {
            let last_log = &logs[0];
            debug!("last checked: {}", last_log.id);
            self.last_checked = Some(last_log.id);
        }

        Ok(())
    }

    async fn run(&mut self) {
        info!("monitoring {}...", self.base_domain);