synd-persistence 0.4.0

Persistence adapters for syndicationd
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46

use synd_feed::types::Text;

use crate::sqlite::feed_registry::test_support::*;

#[tokio::test]
async fn subscription_catchup_reads_complete_entries_from_current_membership() -> anyhow::Result<()>
{
    let db = migrated_db().await?;
    let subscription = subscription("timeline-catchup");
    let first = record_fetched_crawl(
        &db,
        &subscription.feed_url,
        rss_body_with_entry("timeline feed", "old entry", "entry-1"),
        0,
    )
    .await?;
    project_feed(&db, first).await?;
    let second = record_fetched_crawl(
        &db,
        &subscription.feed_url,
        rss_body_with_entry("timeline feed", "current entry", "entry-2"),
        1,
    )
    .await?;
    project_feed(&db, second).await?;
    store_subscription_in_db(&db, subscription.clone()).await?;

    let recorded = project_timeline(
        &db,
        TimelineProjInput::FeedSubscribed(feed_subscribed_event(&subscription)),
    )
    .await?;

    assert_eq!(recorded.types(), &[TimelineChangedEvent::TYPE]);
    let page = list_timeline_entries(&db, subscription.subscriber_id).await?;
    assert_eq!(page.nodes.len(), 1);
    assert_eq!(
        page.nodes[0].entry.title().map(Text::content),
        Some("current entry")
    );
    assert_eq!(
        page.nodes[0].feed_meta.feed.title().map(Text::content),
        Some("timeline feed")
    );
    Ok(())
}