eql_core 0.1.12

use crate::common::{query_result::LogQueryRes, types::LogField};
use std::error::Error;
use alloy::{
    providers::{Provider, RootProvider}, rpc::types::Filter, transports::http::{Client, Http}
};
use serde::{Deserialize, Serialize};

#[derive(Debug, Serialize, Deserialize, thiserror::Error)]
pub enum LogResolverErrors {
    #[error("Query returned no results within the given filters")]
    NoLogsFound,
}

pub async fn resolve_log_query(
    filter: Filter, 
    fields: Vec<LogField>,
    provider: &RootProvider<Http<Client>>,
) -> Result<Vec<LogQueryRes>, Box<dyn Error>> {
    let logs = provider.get_logs(&filter).await?;
    if logs.is_empty() {
        return Err(Box::new(LogResolverErrors::NoLogsFound))
    }

    let results: Vec<LogQueryRes> = logs.into_iter().map(|log| {
        let mut result = LogQueryRes::default();

        for field in &fields {
            match field {
                LogField::Address => result.address = Some(log.inner.address),
                LogField::Topic0 => result.topic0 = log.topic0().copied(),
                LogField::Topic1 => result.topic1 = log.inner.data.topics().get(1).copied(),
                LogField::Topic2 => result.topic2 = log.inner.data.topics().get(2).copied(),
                LogField::Topic3 => result.topic3 = log.inner.data.topics().get(3).copied(),
                LogField::Data => result.data = Some(log.data().data.clone()),
                LogField::BlockHash => result.block_hash = log.block_hash,
                LogField::BlockNumber => result.block_number = log.block_number,
                LogField::BlockTimestamp => result.block_timestamp = log.block_timestamp,
                LogField::TransactionHash => result.transaction_hash = log.transaction_hash,
                LogField::TransactionIndex => result.transaction_index = log.transaction_index,
                LogField::LogIndex => result.log_index = log.log_index,
                LogField::Removed => result.removed = Some(log.removed),
            }
        }

        result
    }).collect();

    Ok(results)
}