feat: remove unused dependencies, add event for received searches

src/aioslsk/events.py

@@ -200,6 +200,14 @@ class SearchResultEvent(Event):
  result: SearchResult
 
 
+@dataclass(frozen=True)
+class SearchRequestReceivedEvent(Event):
+ """Emitted when a search request by another user has been received"""
+ username: str
+ query: str
+ result_count: int
+
+
 @dataclass(frozen=True)
 class SimilarUsersEvent(Event):
  users: List[User]

src/aioslsk/search/manager.py

@@ -17,24 +17,16 @@
  InternalEventBus,
  ConnectionStateChangedEvent,
  MessageReceivedEvent,
- UserDirectoryEvent,
  UserInfoEvent,
- UserSharesReplyEvent,
+ SearchRequestReceivedEvent,
  SearchResultEvent,
 )
 from ..protocol.messages import (
  ChatRoomSearch,
  DistributedSearchRequest,
  DistributedServerSearchRequest,
  FileSearch,
- MessageDataclass,
- PeerDirectoryContentsRequest,
- PeerDirectoryContentsReply,
  PeerSearchReply,
- PeerSharesRequest,
- PeerSharesReply,
- PeerUserInfoReply,
- PeerUserInfoRequest,
  ServerSearchRequest,
  UserSearch,
  WishlistInterval,
@@ -145,11 +137,19 @@ async def _query_shares_and_reply(self, ticket: int, username: str, query: str):
  """
  visible, locked = self._shares_manager.query(query, username=username)
 
+ result_count = len(visible) + len(locked)
  self.received_searches.append(
  ReceivedSearch(
  username=username,
  query=query,
- matched_files=len(visible) + len(locked)
+ result_count=result_count
+ )
+ )
+ await self._event_bus.emit(
+ SearchRequestReceivedEvent(
+ username=username,
+ query=query,
+ result_count=result_count
  )
  )
 

src/aioslsk/search/model.py

@@ -16,10 +16,12 @@ class SearchType(Enum):
 
 @dataclass
 class ReceivedSearch:
- """Used for keeping track of searches received from the distributed parent"""
+ """Used for keeping track of searches received from the distributed parent
+ or server
+ """
  username: str
  query: str
- matched_files: int
+ result_count: int
 
 
 @dataclass