pub mod models;
pub mod rule;
pub mod rule_view;
pub mod task;
use crate::{
core::config::Config,
service::report::{rule::RuleService, rule_view::RuleViewService, task::TaskService},
};
pub struct ReportService {
pub rule: RuleService,
pub rule_view: RuleViewService,
pub task: TaskService,
}
impl ReportService {
pub fn new(config: Config) -> Self {
Self {
rule: RuleService::new(config.clone()),
rule_view: RuleViewService::new(config.clone()),
task: TaskService::new(config),
}
}
pub fn new_from_shared(shared: std::sync::Arc<Config>) -> Self {
Self {
rule: RuleService::new(shared.as_ref().clone()),
rule_view: RuleViewService::new(shared.as_ref().clone()),
task: TaskService::new(shared.as_ref().clone()),
}
}
}
#[cfg(test)]
mod tests {
use super::*;
use std::time::Duration;
#[test]
fn test_report_service_creation() {
let config = Config::default();
let service = ReportService::new(config.clone());
assert_eq!(service.rule.config.app_id, config.app_id);
assert_eq!(service.rule.config.app_secret, config.app_secret);
assert_eq!(service.rule_view.config.app_id, config.app_id);
assert_eq!(service.task.config.app_id, config.app_id);
}
#[test]
fn test_report_service_with_custom_config() {
let config = Config::builder()
.app_id("report_test_app")
.app_secret("report_test_secret")
.req_timeout(Duration::from_secs(170))
.build();
let service = ReportService::new(config.clone());
assert_eq!(service.rule.config.app_id, "report_test_app");
assert_eq!(service.rule.config.app_secret, "report_test_secret");
assert_eq!(
service.rule.config.req_timeout,
Some(Duration::from_secs(170))
);
assert_eq!(service.rule_view.config.app_id, "report_test_app");
assert_eq!(
service.task.config.req_timeout,
Some(Duration::from_secs(170))
);
}
#[test]
fn test_report_service_config_independence() {
let config1 = Config::builder().app_id("report_app_1").build();
let config2 = Config::builder().app_id("report_app_2").build();
let service1 = ReportService::new(config1);
let service2 = ReportService::new(config2);
assert_eq!(service1.rule.config.app_id, "report_app_1");
assert_eq!(service2.rule.config.app_id, "report_app_2");
assert_ne!(service1.rule.config.app_id, service2.rule.config.app_id);
assert_ne!(
service1.rule_view.config.app_id,
service2.task.config.app_id
);
}
#[test]
fn test_report_service_sub_services_accessible() {
let config = Config::default();
let service = ReportService::new(config.clone());
assert_eq!(service.rule.config.app_id, config.app_id);
assert_eq!(service.rule_view.config.app_id, config.app_id);
assert_eq!(service.task.config.app_id, config.app_id);
}
#[test]
fn test_report_service_config_cloning() {
let config = Config::builder()
.app_id("clone_test_app")
.app_secret("clone_test_secret")
.build();
let service = ReportService::new(config.clone());
assert_eq!(service.rule.config.app_id, "clone_test_app");
assert_eq!(service.rule.config.app_secret, "clone_test_secret");
assert_eq!(service.rule_view.config.app_secret, "clone_test_secret");
assert_eq!(service.task.config.app_id, "clone_test_app");
}
#[test]
fn test_report_service_timeout_propagation() {
let config = Config::builder()
.req_timeout(Duration::from_secs(190))
.build();
let service = ReportService::new(config);
assert_eq!(
service.rule.config.req_timeout,
Some(Duration::from_secs(190))
);
assert_eq!(
service.rule_view.config.req_timeout,
Some(Duration::from_secs(190))
);
assert_eq!(
service.task.config.req_timeout,
Some(Duration::from_secs(190))
);
}
#[test]
fn test_report_service_multiple_instances() {
let config = Config::default();
let service1 = ReportService::new(config.clone());
let service2 = ReportService::new(config.clone());
assert_eq!(service1.rule.config.app_id, service2.rule.config.app_id);
assert_eq!(
service1.rule.config.app_secret,
service2.rule.config.app_secret
);
assert_eq!(
service1.rule_view.config.app_id,
service2.rule_view.config.app_id
);
assert_eq!(
service1.task.config.app_secret,
service2.task.config.app_secret
);
}
#[test]
fn test_report_service_config_consistency() {
let config = Config::builder()
.app_id("consistency_test")
.app_secret("consistency_secret")
.req_timeout(Duration::from_secs(140))
.build();
let service = ReportService::new(config);
assert_eq!(service.rule.config.app_id, "consistency_test");
assert_eq!(service.rule.config.app_secret, "consistency_secret");
assert_eq!(
service.rule.config.req_timeout,
Some(Duration::from_secs(140))
);
assert_eq!(service.rule_view.config.app_id, "consistency_test");
assert_eq!(service.task.config.app_secret, "consistency_secret");
}
}