Fix some mypy specific type issues

3 files changed, 22 insertions, 15 deletions

diff --git a/slack/commands.py b/slack/commands.py
index b4bb1b5..c60b420 100644
--- a/slack/commands.py
+++ b/slack/commands.py
@@ -53,8 +53,13 @@ class Command:
 
 def weechat_command(
     completion: str = "", min_args: int = 0, slack_buffer_required: bool = False
-):
-    def decorator(f: Callable[[str, List[str], Dict[str, Optional[str]]], None]):
+) -> Callable[
+    [Callable[[str, List[str], Dict[str, Optional[str]]], None]],
+    Callable[[str, str], None],
+]:
+    def decorator(
+        f: Callable[[str, List[str], Dict[str, Optional[str]]], None]
+    ) -> Callable[[str, str], None]:
         cmd = removeprefix(f.__name__, "command_").replace("_", " ")
         top_level = " " not in cmd
 
@@ -367,7 +372,7 @@ async def complete_user_next(
     complete_input(conversation, query)
 
 
-def complete_previous(conversation: SlackConversation, query: str):
+def complete_previous(conversation: SlackConversation, query: str) -> int:
     if conversation.completion_context == "ACTIVE_COMPLETION":
         conversation.completion_index -= 1
         if conversation.completion_index < 0:
diff --git a/slack/http.py b/slack/http.py
index 9347842..73a3303 100644
--- a/slack/http.py
+++ b/slack/http.py
@@ -3,7 +3,7 @@ from __future__ import annotations
 import os
 import resource
 from io import StringIO
-from typing import Dict
+from typing import Dict, Tuple
 
 import weechat
 
@@ -19,7 +19,9 @@ def available_file_descriptors():
     return max_file_descriptors - num_current_file_descriptors
 
 
-async def hook_process_hashtable(command: str, options: Dict[str, str], timeout: int):
+async def hook_process_hashtable(
+    command: str, options: Dict[str, str], timeout: int
+) -> Tuple[str, int, str, str]:
     future = FutureProcess()
     log(
         LogLevel.DEBUG,
diff --git a/slack/slack_api.py b/slack/slack_api.py
index fd75277..1404e81 100644
--- a/slack/slack_api.py
+++ b/slack/slack_api.py
@@ -91,7 +91,7 @@ class SlackApi:
 
     async def fetch_conversations_history(self, conversation: SlackConversation):
         method = "conversations.history"
-        params = {"channel": conversation.id}
+        params: Params = {"channel": conversation.id}
         response: SlackConversationsHistoryResponse = await self._fetch(method, params)
         if response["ok"] is False:
             raise SlackApiError(self.workspace, method, response, params)
@@ -99,7 +99,7 @@ class SlackApi:
 
     async def fetch_conversations_info(self, conversation_id: str):
         method = "conversations.info"
-        params = {"channel": conversation_id}
+        params: Params = {"channel": conversation_id}
         response: SlackConversationsInfoResponse = await self._fetch(method, params)
         if response["ok"] is False:
             raise SlackApiError(self.workspace, method, response, params)
@@ -112,7 +112,7 @@ class SlackApi:
         pages: int = -1,
     ):
         method = "conversations.members"
-        params = {"channel": conversation.id, "limit": limit}
+        params: Params = {"channel": conversation.id, "limit": limit}
         response: SlackConversationsMembersResponse = await self._fetch_list(
             method, "members", params, pages
         )
@@ -128,7 +128,7 @@ class SlackApi:
         pages: int = -1,
     ):
         method = "users.conversations"
-        params = {
+        params: Params = {
             "types": types,
             "exclude_archived": exclude_archived,
             "limit": limit,
@@ -145,7 +145,7 @@ class SlackApi:
 
     async def fetch_user_info(self, user_id: str):
         method = "users.info"
-        params = {"user": user_id}
+        params: Params = {"user": user_id}
         response: SlackUserInfoResponse = await self._fetch(method, params)
         if response["ok"] is False:
             raise SlackApiError(self.workspace, method, response, params)
@@ -153,7 +153,7 @@ class SlackApi:
 
     async def fetch_users_info(self, user_ids: Iterable[str]):
         method = "users.info"
-        params = {"users": ",".join(user_ids)}
+        params: Params = {"users": ",".join(user_ids)}
         response: SlackUsersInfoResponse = await self._fetch(method, params)
         if response["ok"] is False:
             raise SlackApiError(self.workspace, method, response, params)
@@ -161,7 +161,7 @@ class SlackApi:
 
     async def fetch_bot_info(self, bot_id: str):
         method = "bots.info"
-        params = {"bot": bot_id}
+        params: Params = {"bot": bot_id}
         response: SlackBotInfoResponse = await self._fetch(method, params)
         if response["ok"] is False:
             raise SlackApiError(self.workspace, method, response, params)
@@ -169,7 +169,7 @@ class SlackApi:
 
     async def fetch_bots_info(self, bot_ids: Iterable[str]):
         method = "bots.info"
-        params = {"bots": ",".join(bot_ids)}
+        params: Params = {"bots": ",".join(bot_ids)}
         response: SlackBotsInfoResponse = await self._fetch(method, params)
         if response["ok"] is False:
             raise SlackApiError(self.workspace, method, response, params)
@@ -184,7 +184,7 @@ class SlackApi:
 
     async def fetch_usergroups_info(self, usergroup_ids: Sequence[str]):
         method = "usergroups/info"
-        params = {"ids": usergroup_ids}
+        params: EdgeParams = {"ids": usergroup_ids}
         response: SlackEdgeUsergroupsInfoResponse = await self._fetch_edgeapi(
             method, params
         )
@@ -194,7 +194,7 @@ class SlackApi:
 
     async def fetch_users_search(self, query: str):
         method = "users/search"
-        params = {
+        params: EdgeParams = {
             "include_profile_only_users": True,
             "query": query,
             "count": 25,