Skip to content

Commit fadf11a

Browse files
committed
fix
1 parent 4b85a4d commit fadf11a

File tree

2 files changed

+6
-6
lines changed

2 files changed

+6
-6
lines changed

faster_web3/_utils/events.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@
99
from typing import (
1010
TYPE_CHECKING,
1111
Any,
12+
Callable,
1213
Collection,
1314
Dict,
1415
Final,
@@ -337,7 +338,7 @@ def __init__(
337338
self,
338339
event_abi: ABIEvent,
339340
abi_codec: ABICodec,
340-
formatter: Optional[EventData] = None,
341+
formatter: Optional[Callable[[LogReceipt], LogReceipt]] = None,
341342
) -> None:
342343
self.event_abi: Final = event_abi
343344
self.abi_codec: Final = abi_codec
@@ -408,7 +409,7 @@ def data_args(self) -> Tuple[Any, ...]:
408409
return tuple(filter(is_not_indexed, self.ordered_args))
409410

410411
@property
411-
def topics(self) -> List[HexStr]:
412+
def topics(self) -> Tuple[HexStr, ...]:
412413
arg_topics = tuple(arg.match_values for arg in self.indexed_args)
413414
return normalize_topic_list(cons(to_hex(self.event_topic), arg_topics))
414415

faster_web3/_utils/filters.py

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -238,7 +238,7 @@ class LogFilter(Filter):
238238
data_filter_set = None
239239
data_filter_set_regex = None
240240
data_filter_set_function = None
241-
log_entry_formatter = None
241+
log_entry_formatter: Optional[Callable[[LogReceipt], LogReceipt]] = None
242242
filter_params: Optional[FilterParams] = None
243243
builder: Optional[EventFilterBuilder] = None
244244

@@ -252,9 +252,8 @@ def __init__(self, *args: Any, **kwargs: Any) -> None:
252252
super().__init__(*args, **kwargs)
253253

254254
def format_entry(self, entry: LogReceipt) -> LogReceipt:
255-
if self.log_entry_formatter:
256-
return self.log_entry_formatter(entry)
257-
return entry
255+
formatter = self.log_entry_formatter
256+
return formatter(entry) if formatter else entry
258257

259258
def set_data_filters(
260259
self, data_filter_set: Collection[Tuple[TypeStr, Any]]

0 commit comments

Comments
 (0)