@@ -3774,6 +3774,10 @@ pub async fn create_broadcast(context: &Context, chat_name: String) -> Result<Ch
3774
3774
create_broadcast_ex ( context, Sync , grpid, chat_name, secret) . await
3775
3775
}
3776
3776
3777
+ const SQL_INSERT_BROADCAST_SECRET : & str =
3778
+ "INSERT INTO broadcasts_shared_secrets (chat_id, secret) VALUES (?, ?)
3779
+ ON CONFLICT(chat_id) DO UPDATE SET secret=excluded.secret" ;
3780
+
3777
3781
pub ( crate ) async fn create_broadcast_ex (
3778
3782
context : & Context ,
3779
3783
sync : sync:: Sync ,
@@ -3809,12 +3813,7 @@ pub(crate) async fn create_broadcast_ex(
3809
3813
) ,
3810
3814
) ?;
3811
3815
let chat_id = t. last_insert_rowid ( ) ;
3812
- // TODO code duplication of `INSERT INTO broadcasts_shared_secrets`
3813
- t. execute (
3814
- "INSERT INTO broadcasts_shared_secrets (chat_id, secret) VALUES (?, ?)
3815
- ON CONFLICT(chat_id) DO UPDATE SET secret=excluded.chat_id" ,
3816
- ( chat_id, & secret) ,
3817
- ) ?;
3816
+ t. execute ( SQL_INSERT_BROADCAST_SECRET , ( chat_id, & secret) ) ?;
3818
3817
Ok ( t. last_insert_rowid ( ) . try_into ( ) ?)
3819
3818
} ;
3820
3819
context. sql . transaction ( trans_fn) . await ?
@@ -3855,14 +3854,9 @@ pub(crate) async fn save_broadcast_shared_secret(
3855
3854
secret : & str ,
3856
3855
) -> Result < ( ) > {
3857
3856
info ! ( context, "Saving broadcast secret for chat {chat_id}" ) ;
3858
- info ! ( context, "dbg the new secret for chat {chat_id} is {secret}" ) ;
3859
3857
context
3860
3858
. sql
3861
- . execute (
3862
- "INSERT INTO broadcasts_shared_secrets (chat_id, secret) VALUES (?, ?)
3863
- ON CONFLICT(chat_id) DO UPDATE SET secret=excluded.secret" ,
3864
- ( chat_id, secret) ,
3865
- )
3859
+ . execute ( SQL_INSERT_BROADCAST_SECRET , ( chat_id, secret) )
3866
3860
. await ?;
3867
3861
3868
3862
Ok ( ( ) )
0 commit comments