Skip to content

Commit 792fc5a

Browse files
committed
db stuff again
1 parent 2a4caae commit 792fc5a

File tree

2 files changed

+4
-11
lines changed

2 files changed

+4
-11
lines changed

discord/client.py

Lines changed: 2 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -339,16 +339,8 @@ async def __aexit__(
339339
def _get_websocket(self, guild_id: Optional[int] = None, *, shard_id: Optional[int] = None) -> DiscordWebSocket:
340340
return self.ws
341341

342-
def _get_state(self, **options: Any) -> ConnectionState:
343-
state = ConnectionState(
344-
dispatch=self.dispatch,
345-
handlers=self._handlers,
346-
hooks=self._hooks,
347-
http=self.http,
348-
**options
349-
)
350-
state.database = getattr(self, "db", None)
351-
return state
342+
def _get_state(self, **options: Any) -> ConnectionState[DatabaseT, Self]:
343+
return ConnectionState(dispatch=self.dispatch, handlers=self._handlers, hooks=self._hooks, http=self.http, **options)
352344

353345
def _handle_ready(self) -> None:
354346
self._ready.set()

discord/state.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -184,6 +184,7 @@ def __init__(
184184
handlers: Dict[str, Callable[..., Any]],
185185
hooks: Dict[str, Callable[..., Coroutine[Any, Any, Any]]],
186186
http: HTTPClient,
187+
database: DatabaseT = None,
187188
**options: Any,
188189
) -> None:
189190
# Set later, after Client.login
@@ -200,7 +201,7 @@ def __init__(
200201
self._ready_task: Optional[asyncio.Task] = None
201202
self.application_id: Optional[int] = utils._get_as_snowflake(options, 'application_id')
202203
self.application_flags: ApplicationFlags = utils.MISSING
203-
self.database: DatabaseT = None
204+
self.database: DatabaseT = database
204205
self.heartbeat_timeout: float = options.get('heartbeat_timeout', 60.0)
205206
self.guild_ready_timeout: float = options.get('guild_ready_timeout', 2.0)
206207
if self.guild_ready_timeout < 0:

0 commit comments

Comments
 (0)