Skip to content

Commit

Permalink
remove unused code
Browse files Browse the repository at this point in the history
  • Loading branch information
djkhl committed Jun 5, 2024
1 parent 5a8a0be commit 2c142bd
Showing 1 changed file with 8 additions and 25 deletions.
33 changes: 8 additions & 25 deletions logprep/processor/field_manager/processor.py
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,6 @@

import itertools
from collections import namedtuple
from typing import Any, List, Tuple

from logprep.abc.processor import Processor
from logprep.processor.base.exceptions import FieldExistsWarning
Expand Down Expand Up @@ -167,11 +166,14 @@ def _write_to_single_target(self, args, extend_target_list, overwrite_target, ru
raise FieldExistsWarning(rule, event, [target_field])

def _overwrite_from_source_values(self, source_fields_values):
lists, not_lists = self._separate_lists_form_other_types(source_fields_values)
ordered_flattened_list = self._get_ordered_flatten_list(
source_fields_values, lists, not_lists
)
return ordered_flattened_list
duplicates = []
ordered_flatten_list = []
flat_source_fields = self._get_flatten_source_fields(source_fields_values)
for field_value in flat_source_fields:
if field_value not in duplicates:
duplicates.append(field_value)
ordered_flatten_list.append(field_value)
return ordered_flatten_list

def _handle_missing_fields(self, event, rule, source_fields, field_values):
if rule.ignore_missing_fields:
Expand All @@ -187,19 +189,6 @@ def _handle_missing_fields(self, event, rule, source_fields, field_values):
return True
return False

def _get_ordered_flatten_list(
self, source_fields_values, lists: List[List], not_lists: List[Any]
) -> List:
duplicates = []
ordered_flatten_list = []
flat_source_fields = self._get_flatten_source_fields(source_fields_values)
for field_value in flat_source_fields:
if field_value not in duplicates:
duplicates.append(field_value)
if field_value in list(itertools.chain(*lists, not_lists)):
ordered_flatten_list.append(field_value)
return ordered_flatten_list

@staticmethod
def _get_field_values(event, source):
return [get_dotted_field_value(event, source_field) for source_field in source]
Expand All @@ -209,12 +198,6 @@ def _get_missing_fields_error(self, source_fields, field_values):
error = BaseException(f"{self.name}: missing source_fields: {missing_fields}")
return error

@staticmethod
def _separate_lists_form_other_types(field_values: List[Any]) -> Tuple[List[List], List[Any]]:
field_values_lists = list(filter(lambda x: isinstance(x, list), field_values))
field_values_not_list = list(filter(lambda x: not isinstance(x, list), field_values))
return field_values_lists, field_values_not_list

@staticmethod
def _get_flatten_source_fields(source_fields_values):
flat_source_fields = []
Expand Down

0 comments on commit 2c142bd

Please sign in to comment.