actually add feeds
This commit is contained in:
parent
e73c695acd
commit
7edbd92780
1 changed files with 12 additions and 4 deletions
|
|
@ -161,17 +161,25 @@ async fn remove_feed(db: &SqlitePool, user: u32, feed: &str) -> Result<(), Strin
|
|||
|
||||
async fn add_feed(db: &SqlitePool, user: u32, feed: &str) -> Result<(), String> {
|
||||
add_user(db, user).await?;
|
||||
if sqlx::query!(
|
||||
sqlx::query!(
|
||||
"update feeds set active = true where url = ? and added_by = ?",
|
||||
feed,
|
||||
user
|
||||
)
|
||||
.execute(db)
|
||||
.await
|
||||
.is_err()
|
||||
.map_err(|e| format!("Got error adding feed: {e}"))?;
|
||||
|
||||
if sqlx::query!(
|
||||
"select * from feeds where added_by = ? and url = ? and active = true",
|
||||
user,
|
||||
feed
|
||||
)
|
||||
.fetch_optional(db)
|
||||
.await
|
||||
.map_err(|e| format!("{e}"))?
|
||||
.is_some()
|
||||
{
|
||||
tracing::debug!("{feed} is new, adding new row");
|
||||
} else {
|
||||
return Ok(());
|
||||
}
|
||||
|
||||
|
|
|
|||
Loading…
Reference in a new issue