commit d6c4d11e50b169ebfbef3ece453d0ef060bbd4d7 from: Thomas Böhler date: Thu Oct 23 18:49:42 2025 UTC feat: send oldest feed items from db first Signed-off-by: Thomas Böhler commit - 274c1d64ae73752876251006a4fa590084696f22 commit + d6c4d11e50b169ebfbef3ece453d0ef060bbd4d7 blob - ccc87c84f9775c81c35e578488764b0200eb8df8 (mode 644) blob + /dev/null --- .sqlx/query-9955438bce6b0c7cd1c7896a6fdf0b7b58390a5d996ba7cef003bd4b3052353d.json +++ /dev/null @@ -1,50 +0,0 @@ -{ - "db_name": "SQLite", - "query": "select * from posts where sent != true order by pub_date desc", - "describe": { - "columns": [ - { - "name": "guid", - "ordinal": 0, - "type_info": "Text" - }, - { - "name": "title", - "ordinal": 1, - "type_info": "Text" - }, - { - "name": "url", - "ordinal": 2, - "type_info": "Text" - }, - { - "name": "pub_date", - "ordinal": 3, - "type_info": "Integer" - }, - { - "name": "content", - "ordinal": 4, - "type_info": "Text" - }, - { - "name": "sent", - "ordinal": 5, - "type_info": "Bool" - } - ], - "parameters": { - "Right": 0 - }, - "nullable": [ - false, - true, - true, - true, - true, - false - ] - }, - "hash": "9955438bce6b0c7cd1c7896a6fdf0b7b58390a5d996ba7cef003bd4b3052353d" -} blob - /dev/null blob + 8160a599955980db78f807d1cf163b7aaecbaba7 (mode 644) --- /dev/null +++ .sqlx/query-6fb84d0187549d351c79b0ae94985d4202a25b488f2c8f2f519a406d9f24fe48.json @@ -0,0 +1,50 @@ +{ + "db_name": "SQLite", + "query": "select * from posts where sent != true order by pub_date asc", + "describe": { + "columns": [ + { + "name": "guid", + "ordinal": 0, + "type_info": "Text" + }, + { + "name": "title", + "ordinal": 1, + "type_info": "Text" + }, + { + "name": "url", + "ordinal": 2, + "type_info": "Text" + }, + { + "name": "pub_date", + "ordinal": 3, + "type_info": "Integer" + }, + { + "name": "content", + "ordinal": 4, + "type_info": "Text" + }, + { + "name": "sent", + "ordinal": 5, + "type_info": "Bool" + } + ], + "parameters": { + "Right": 0 + }, + "nullable": [ + false, + true, + true, + true, + true, + false + ] + }, + "hash": "6fb84d0187549d351c79b0ae94985d4202a25b488f2c8f2f519a406d9f24fe48" +} blob - 765296b9ac837c9a6a30c9549aa257a7587bff5e blob + bc3f4b2eb0e538c542fe3def6424db0d062b8d12 --- src/main.rs +++ src/main.rs @@ -105,7 +105,7 @@ async fn accumulator( // time the same entry also gets fetched (from the url) and sent. let unsent_posts = sqlx::query_as!( models::Post, - "select * from posts where sent != true order by pub_date desc" + "select * from posts where sent != true order by pub_date asc" ) .fetch_all(&mut *conn) .await