Overview
| Comment: | fix wrong comment |
|---|---|
| Downloads: | Tarball | ZIP archive | SQL archive |
| Timelines: | family | ancestors | descendants | both | trunk |
| Files: | files | file ages | folders |
| SHA3-256: |
8f4dcf5e9d2476313c3602a66578c8be |
| User & Date: | arcade on 2026-01-09 09:59:31.937 |
| Other Links: | manifest | tags |
Context
|
2026-01-09
| ||
| 10:00 | move some Telegram code to separate module check-in: 9c4f09193a user: arcade tags: trunk | |
| 09:59 | fix wrong comment check-in: 8f4dcf5e9d user: arcade tags: trunk | |
| 09:58 | update workflow (minimize, fix a little) check-in: 3b65f27fe6 user: arcade tags: trunk | |
Changes
Modified src/sql.rs
from [ccfc867118]
to [179421fbd4].
| ︙ | ︙ | |||
155 156 157 158 159 160 161 |
let row = sqlx::query("select exists(select true from rsstg_post where url = $1 and source_id = $2) as exists;")
.bind(post_url)
.bind(id.into())
.fetch_one(&mut *self.0).await.stack()?;
if let Some(exists) = row.try_get("exists").stack()? {
Ok(exists)
} else {
| | | 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 |
let row = sqlx::query("select exists(select true from rsstg_post where url = $1 and source_id = $2) as exists;")
.bind(post_url)
.bind(id.into())
.fetch_one(&mut *self.0).await.stack()?;
if let Some(exists) = row.try_get("exists").stack()? {
Ok(exists)
} else {
bail!("Database error: can't check whether post exists.");
}
}
/// Get all pending events for (now + 1 minute)
pub async fn get_queue (&mut self) -> Result<Vec<Queue>> {
let block: Vec<Queue> = sqlx::query_as("select source_id, next_fetch, owner, last_scrape from rsstg_order natural left join rsstg_source where next_fetch < now() + interval '1 minute';")
.fetch_all(&mut *self.0).await.stack()?;
|
| ︙ | ︙ |