ErrorNoInternet/ErrorNoWatcher
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat(matrix): make sync_timeout configurable

Browse Source
This commit is contained in:
Ryan 2025-04-03 20:30:27 -04:00
parent cc03ba6e72
commit 94d1727d87
Signed by: ErrorNoInternet
GPG Key ID: 2486BFB7B1E6A4A3
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/matrix/mod.rs
View File

@ -57,10 +57,11 @@ async fn persist_sync_token(
} }
pub async fn login(state: &State, options: &Table, globals: &Table, name: String) -> Result<()> { pub async fn login(state: &State, options: &Table, globals: &Table, name: String) -> Result<()> {
let (homeserver_url, username, password) = ( let (homeserver_url, username, password, sync_timeout) = (
options.get::<String>("homeserver_url")?, options.get::<String>("homeserver_url")?,
options.get::<String>("username")?, options.get::<String>("username")?,
&options.get::<String>("password")?, &options.get::<String>("password")?,
options.get::<u64>("sync_timeout"),
); );
let root_dir = dirs::data_dir() let root_dir = dirs::data_dir()
.context("no data directory")? .context("no data directory")?
@ -78,8 +79,12 @@ pub async fn login(state: &State, options: &Table, globals: &Table, name: String
} }
let client = builder.build().await?; let client = builder.build().await?;
let mut sync_settings = SyncSettings::new();
if let Ok(seconds) = sync_timeout {
sync_settings = sync_settings.timeout(Duration::from_secs(seconds));
}
let mut new_session; let mut new_session;
let mut sync_settings = SyncSettings::new().timeout(Duration::from_secs(60));
let session_file = root_dir.join("session.json"); let session_file = root_dir.join("session.json");
if let Some(session) = fs::read_to_string(&session_file) if let Some(session) = fs::read_to_string(&session_file)
.await .await