Mirrors/chatmail-core
1
0
Fork 0
mirror of https://github.com/chatmail/core.git synced 2026-04-17 21:46:35 +03:00
Code Issues Packages Projects Releases Wiki Activity

Use ephemeral::Timer in MsgId.ephemeral_timer() method

Browse Source
This commit is contained in:
Alexander Krotov
2020-06-29 22:49:53 +03:00
committed by link2xt
parent f931a905a7
commit 0c47489a3b
1 changed files with 5 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/ephemeral.rs
View File

@@ -211,10 +211,7 @@ impl ChatId {
impl MsgId { impl MsgId {
/// Returns ephemeral message timer value for the message. /// Returns ephemeral message timer value for the message.
pub(crate) async fn ephemeral_timer( pub(crate) async fn ephemeral_timer(self, context: &Context) -> crate::sql::Result<Timer> {
self,
context: &Context,
) -> crate::sql::Result<Option<i64>> {
let res = match context let res = match context
.sql .sql
.query_get_value_result( .query_get_value_result(
@@ -223,16 +220,16 @@ impl MsgId {
) )
.await? .await?
{ {
None | Some(0) => None, None | Some(0) => Timer::Disabled,
Some(timer) => Some(timer), Some(duration) => Timer::Enabled { duration },
}; };
Ok(res) Ok(res)
} }
/// Starts ephemeral message timer for the message if it is not started yet. /// Starts ephemeral message timer for the message if it is not started yet.
pub(crate) async fn start_ephemeral_timer(self, context: &Context) -> crate::sql::Result<()> { pub(crate) async fn start_ephemeral_timer(self, context: &Context) -> crate::sql::Result<()> {
if let Some(ephemeral_timer) = self.ephemeral_timer(context).await? { if let Timer::Enabled { duration } = self.ephemeral_timer(context).await? {
let ephemeral_timestamp = time() + ephemeral_timer; let ephemeral_timestamp = time() + i64::from(duration);
context context
.sql .sql