patrick/pr-tracker
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

fix: actually resave status on update

Browse source
This commit is contained in:
Patrick 2024-07-19 23:08:20 +02:00
parent ccd7e952cc
commit f9ff53fb14
Signed by: patrick
GPG key ID: 451F95EFB8BECD0F
1 changed files with 3 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
src/main.rs
View file

@ -11,7 +11,6 @@ mod tree;
use std::collections::HashSet; use std::collections::HashSet;
use std::fs::{remove_dir_all, remove_file, File}; use std::fs::{remove_dir_all, remove_file, File};
use std::io::BufReader;
use std::path::PathBuf; use std::path::PathBuf;
use std::{ffi::OsString, fs::read_dir}; use std::{ffi::OsString, fs::read_dir};
@ -195,9 +194,8 @@ async fn update_subscribers<S>(_request: Request<S>) -> http_types::Result<Respo
.to_owned(); .to_owned();
if file_path.is_file() && re_mail.is_match(&file_name) { if file_path.is_file() && re_mail.is_match(&file_name) {
println!("{} has received notifications for:", file_name); println!("{} has received notifications for:", file_name);
let file = File::open(file_path)?; let str = std::fs::read(file_path.clone())?;
let reader = BufReader::new(file); let val: HashSet<String> = serde_json::from_slice(&str)?;
let val: HashSet<String> = serde_json::from_reader(reader)?;
println!("{:#?}", val); println!("{:#?}", val);
let to_do = &current - &val; let to_do = &current - &val;
println!("They will be notified for: {:#?}", to_do); println!("They will be notified for: {:#?}", to_do);
@ -209,6 +207,7 @@ async fn update_subscribers<S>(_request: Request<S>) -> http_types::Result<Respo
page.pr_title.as_ref().unwrap(), page.pr_title.as_ref().unwrap(),
!remaining, !remaining,
)?; )?;
std::fs::write(file_path, json!(current).to_string())?;
} }
} }
} }