diff --git a/dev_requirements.txt b/dev_requirements.txt new file mode 100644 index 0000000..cffeec6 --- /dev/null +++ b/dev_requirements.txt @@ -0,0 +1,2 @@ +pytest +pytest-cov \ No newline at end of file diff --git a/src/blockperf/app.py b/src/blockperf/app.py index 169e86f..6594bff 100644 --- a/src/blockperf/app.py +++ b/src/blockperf/app.py @@ -335,7 +335,9 @@ def logevents_logfile(self): new_lines = fp.readlines() # Create logevents from lines logevents = map( - lambda line: LogEvent.from_logline(line, self.start_time), + lambda line: LogEvent.from_logline( + line, self.app_config.masked_addresses, self.start_time + ), new_lines, ) # Filter out None's diff --git a/src/blockperf/config.py b/src/blockperf/config.py index 950a7c3..079c7dd 100644 --- a/src/blockperf/config.py +++ b/src/blockperf/config.py @@ -275,24 +275,6 @@ def node_service_unit(self) -> str: def max_concurrent_blocks(self) -> int: return int(self.active_slot_coef) * 3600 - @property - def sample_logdir() -> Union[Path, None]: - _sample_logdir := os.getenv("BLOCKPERF_SAMPLE_LOGDIR", self.config_parser.get( - "DEFAULT", - "sample_logdir", - fallback=None, - )) - - if not _sample_logdir: - return None - - _sample_logdir_path = Path(_sample_logdir) - if not _sample_logdir_path.exists(): - return None - - return _sample_logdir_path - - @property def masked_addresses(self) -> list: _masked_addresses = os.getenv("BLOCKPERF_MASKED_ADDRESSES", None)