OpenSource/teloxide
OpenSource/teloxide
1
0
Fork 0
mirror of https://github.com/teloxide/teloxide.git synced 2024-12-22 14:35:36 +01:00
Code Issues Projects Releases Packages Wiki Activity

Apply review suggestions

Browse source
This commit is contained in:
Hirrolot 2024-07-21 08:08:36 +05:00
parent 4d7adcd709
commit 71448b7a0c
No known key found for this signature in database
GPG key ID: F0C33B48BD883C81
2 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
CHANGELOG.md
View file

@ -46,7 +46,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
- `filter_web_app_data` - `filter_web_app_data`
- Implement `PostgresStorage`, a persistent dialogue storage based on [PostgreSQL](https://www.postgresql.org/)([PR 996](https://github.com/teloxide/teloxide/pull/996)). - Implement `PostgresStorage`, a persistent dialogue storage based on [PostgreSQL](https://www.postgresql.org/)([PR 996](https://github.com/teloxide/teloxide/pull/996)).
- Implement `GetChatId` for `teloxide_core::types::{Chat, ChatJoinRequest, ChatMemberUpdated}`. - Implement `GetChatId` for `teloxide_core::types::{Chat, ChatJoinRequest, ChatMemberUpdated}`.
- Use [deadpool-redis](https://crates.io/crates/deadpool-redis) for Redis connection pooling. - Use [deadpool-redis](https://crates.io/crates/deadpool-redis) for Redis connection pooling ([PR 1081](https://github.com/teloxide/teloxide/pull/1081)).
### Fixed ### Fixed

4
crates/teloxide/src/dispatching/dialogue/storage/redis_storage.rs
View file

@ -65,12 +65,12 @@ where
ChatId(chat_id): ChatId, ChatId(chat_id): ChatId,
) -> BoxFuture<'static, Result<(), Self::Error>> { ) -> BoxFuture<'static, Result<(), Self::Error>> {
Box::pin(async move { Box::pin(async move {
let mut pool = self.pool.get().await?; let mut conn = self.pool.get().await?;
let deleted_rows_count = redis::pipe() let deleted_rows_count = redis::pipe()
.atomic() .atomic()
.del(chat_id) .del(chat_id)
.query_async::<_, redis::Value>(&mut pool) .query_async::<_, redis::Value>(&mut conn)
.await?; .await?;
if let redis::Value::Bulk(values) = deleted_rows_count { if let redis::Value::Bulk(values) = deleted_rows_count {