6008856021

Committed 29 Aug 2023 06:44AM UTC coverage: 76.756% (-1.0%) from 77.736%

Build # 6008856021

Build Type

push

github

Committed by

web-flow

Commit Message

chore: Remove unused generic type parameter in `dozer-core` (#1929)

Run Details

330 of 330 new or added lines in 38 files covered. (100.0%)

48977 of 63809 relevant lines covered (76.76%)

48470.73 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

21.18

/dozer-core/src/tests/processors.rs

use std::collections::HashMap;

use dozer_types::{errors::internal::BoxedError, types::Schema};

use crate::{
    node::{OutputPortDef, OutputPortType, PortHandle, Processor, ProcessorFactory},
    processor_record::ProcessorRecordStore,
    DEFAULT_PORT_HANDLE,
};

#[derive(Debug)]
pub struct ConnectivityTestProcessorFactory;

impl ProcessorFactory for ConnectivityTestProcessorFactory {
    fn type_name(&self) -> String {
        "ConnectivityTest".to_owned()
    }
    fn get_input_ports(&self) -> Vec<PortHandle> {
        vec![DEFAULT_PORT_HANDLE]
    }

    fn get_output_ports(&self) -> Vec<OutputPortDef> {
        vec![OutputPortDef::new(
            DEFAULT_PORT_HANDLE,
            OutputPortType::Stateless,
        )]
    }

    fn get_output_schema(
        &self,
        _output_port: &PortHandle,
        _input_schemas: &HashMap<PortHandle, Schema>,
    ) -> Result<Schema, BoxedError> {
        unimplemented!(
            "This struct is for connectivity test, only input and output ports are defined"
        )
    }

    fn build(
        &self,
        _input_schemas: HashMap<PortHandle, Schema>,
        _output_schemas: HashMap<PortHandle, Schema>,
        _record_store: &ProcessorRecordStore,
    ) -> Result<Box<dyn Processor>, BoxedError> {
        unimplemented!(
            "This struct is for connectivity test, only input and output ports are defined"
        )
    }

    fn id(&self) -> String {
        "ConnectivityTest".to_owned()
    }
}

#[derive(Debug)]
pub struct NoInputPortProcessorFactory;

impl ProcessorFactory for NoInputPortProcessorFactory {
    fn get_input_ports(&self) -> Vec<PortHandle> {
        vec![]
    }

    fn get_output_ports(&self) -> Vec<OutputPortDef> {
        vec![OutputPortDef::new(
            DEFAULT_PORT_HANDLE,
            OutputPortType::Stateless,
        )]
    }

    fn get_output_schema(
        &self,
        _output_port: &PortHandle,
        _input_schemas: &HashMap<PortHandle, Schema>,
    ) -> Result<Schema, BoxedError> {
        unimplemented!(
            "This struct is for connectivity test, only input and output ports are defined"
        )
    }

    fn build(
        &self,
        _input_schemas: HashMap<PortHandle, Schema>,
        _output_schemas: HashMap<PortHandle, Schema>,
        _record_store: &ProcessorRecordStore,
    ) -> Result<Box<dyn Processor>, BoxedError> {
        unimplemented!(
            "This struct is for connectivity test, only input and output ports are defined"
        )
    }

    fn type_name(&self) -> String {
        "NoInput".to_owned()
    }

    fn id(&self) -> String {
        "NoInput".to_owned()
    }
}

1	use std::collections::HashMap;
2
3	use dozer_types::{errors::internal::BoxedError, types::Schema};
4
5	use crate::{
6	node::{OutputPortDef, OutputPortType, PortHandle, Processor, ProcessorFactory},
7	processor_record::ProcessorRecordStore,
8	DEFAULT_PORT_HANDLE,
9	};
10
11	#[derive(Debug)]	×
12	pub struct ConnectivityTestProcessorFactory;
13		×
14	impl ProcessorFactory for ConnectivityTestProcessorFactory {
15	fn type_name(&self) -> String {	×
16	"ConnectivityTest".to_owned()	×
17	}	×
18	fn get_input_ports(&self) -> Vec<PortHandle> {	7✔
19	vec![DEFAULT_PORT_HANDLE]	7✔
20	}	7✔
21		×
22	fn get_output_ports(&self) -> Vec<OutputPortDef> {	3✔
23	vec![OutputPortDef::new(	3✔
24	DEFAULT_PORT_HANDLE,	3✔
25	OutputPortType::Stateless,	3✔
26	)]	3✔
27	}	3✔
28		×
29	fn get_output_schema(	×
30	&self,	×
31	_output_port: &PortHandle,	×
32	_input_schemas: &HashMap<PortHandle, Schema>,	×
33	) -> Result<Schema, BoxedError> {	×
34	unimplemented!(	×
35	"This struct is for connectivity test, only input and output ports are defined"	×
36	)	×
37	}	×
38		×
39	fn build(	×
40	&self,	×
41	_input_schemas: HashMap<PortHandle, Schema>,	×
42	_output_schemas: HashMap<PortHandle, Schema>,	×
43	_record_store: &ProcessorRecordStore,	×
44	) -> Result<Box<dyn Processor>, BoxedError> {	×
45	unimplemented!(	×
46	"This struct is for connectivity test, only input and output ports are defined"	×
47	)	×
48	}	×
49		×
50	fn id(&self) -> String {	×
51	"ConnectivityTest".to_owned()	×
52	}	×
53	}	×
54		×
55	#[derive(Debug)]	×
56	pub struct NoInputPortProcessorFactory;
57		×
58	impl ProcessorFactory for NoInputPortProcessorFactory {
59	fn get_input_ports(&self) -> Vec<PortHandle> {	1✔
60	vec![]	1✔
61	}	1✔
62		×
63	fn get_output_ports(&self) -> Vec<OutputPortDef> {	1✔
64	vec![OutputPortDef::new(	1✔
65	DEFAULT_PORT_HANDLE,	1✔
66	OutputPortType::Stateless,	1✔
67	)]	1✔
68	}	1✔
69		×
70	fn get_output_schema(	×
71	&self,	×
72	_output_port: &PortHandle,	×
73	_input_schemas: &HashMap<PortHandle, Schema>,	×
74	) -> Result<Schema, BoxedError> {	×
75	unimplemented!(	×
76	"This struct is for connectivity test, only input and output ports are defined"	×
77	)	×
78	}	×
79		×
80	fn build(	×
81	&self,	×
82	_input_schemas: HashMap<PortHandle, Schema>,	×
83	_output_schemas: HashMap<PortHandle, Schema>,	×
84	_record_store: &ProcessorRecordStore,	×
85	) -> Result<Box<dyn Processor>, BoxedError> {	×
86	unimplemented!(	×
87	"This struct is for connectivity test, only input and output ports are defined"	×
88	)	×
89	}	×
90		×
91	fn type_name(&self) -> String {	×
92	"NoInput".to_owned()	×
93	}	×
94		×
95	fn id(&self) -> String {	×
96	"NoInput".to_owned()	×
97	}	×
98	}	×

getdozer / dozer / 6008856021

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous