Something went wrong. Try again.
Bluesky -> traQ
Something went wrong. Try again.
665 B · 26 lines
Rust
at main
123456789101112131415161718192021222324252627use crate::database::DbPool;use crate::model::jetstream::JETSTREAM_CURSOR_KEY;
pub async fn get_jetstream_cursor(pool: &DbPool) -> anyhow::Result<Option<i64>> { let row = sqlx::query_scalar!( "SELECT value FROM system_states WHERE `key` = ?", JETSTREAM_CURSOR_KEY ) .fetch_optional(pool) .await?;
Ok(row)}
pub async fn save_jetstream_cursor(pool: &DbPool, cursor: i64) -> anyhow::Result<()> { sqlx::query!( "INSERT INTO system_states (`key`, value) VALUES (?, ?) ON DUPLICATE KEY UPDATE value = ?", JETSTREAM_CURSOR_KEY, cursor, cursor ) .execute(pool) .await?;
Ok(())}