enigmatick 0.4.1

Enigmatick is a social media platform that integrates with servers that implement the ActivityPub protocol (e.g., Mastodon)
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
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91

use crate::db::runner::DbRunner;
// Ensure this is imported if SYSTEM_USER is used for downloads
use crate::models::cache::{
    create_cache_item, get_cache_item_by_url, CacheItem, Cacheable, NewCacheItem,
};
use anyhow::{anyhow, Result}; // Ensure anyhow is imported

pub async fn cache_content<C: DbRunner>(
    conn: &C,
    cacheable: Result<Cacheable>,
) -> Result<CacheItem> {
    // Convert Cacheable to NewCacheItem. Propagate errors from try_from/from.
    let new_cache_item_to_process = match cacheable? {
        Cacheable::Document(document) => {
            NewCacheItem::try_from(document).map_err(anyhow::Error::msg)
        }
        Cacheable::Image(image) => Ok(NewCacheItem::from(image)),
    }?;

    let item_url = new_cache_item_to_process.url.clone();

    // 1. Attempt to get it first. This handles race conditions or if it was cached by another process.
    if let Ok(existing_item) = get_cache_item_by_url(conn, item_url.clone()).await {
        log::debug!("Item found in cache (runner::cache::cache_content): {item_url}");
        return Ok(existing_item);
    }

    // 2. If not cached, download it.
    //    The download method in models/cache.rs uses guaranteed_actor, which might fetch SYSTEM_USER.
    //    Passing None for profile to download() will make it use SYSTEM_USER.
    log::debug!("Item not in cache, attempting download: {item_url}");
    let downloaded_item_meta = new_cache_item_to_process.download(conn, None).await?; // Pass conn, profile is None

    // 3. Create the item in the database.
    //    create_cache_item uses ON CONFLICT DO NOTHING.
    //    The result of create_cache_item (Result<CacheItem>) is not strictly needed here
    //    because we will re-fetch.
    let _ = create_cache_item(conn, downloaded_item_meta.clone()).await;

    // 4. Re-fetch the item to ensure we get the definitive version from the DB.
    //    This covers cases where it was just inserted or inserted by a racing process.
    get_cache_item_by_url(conn, item_url.clone())
        .await
        .map_err(|_| {
            anyhow!(format!(
            "Failed to retrieve cache item from DB after download and create attempt for URL: {}",
            item_url
        ))
        })
}

// pub async fn cache_content(conn: &Db, cacheable: Result<Cacheable>) -> Result<CacheItem> {
//     // Convert Cacheable to NewCacheItem. Propagate errors from try_from/from.
//     let new_cache_item_to_process = match cacheable? {
//         Cacheable::Document(document) => {
//             NewCacheItem::try_from(document).map_err(anyhow::Error::msg)
//         }
//         Cacheable::Image(image) => Ok(NewCacheItem::from(image)),
//     }?;

//     let item_url = new_cache_item_to_process.url.clone();

//     // 1. Attempt to get it first. This handles race conditions or if it was cached by another process.
//     if let Some(existing_item) = get_cache_item_by_url(Some(conn), item_url.clone()).await {
//         log::debug!("Item found in cache (runner::cache::cache_content): {item_url}");
//         return Ok(existing_item);
//     }

//     // 2. If not cached, download it.
//     //    The download method in models/cache.rs uses guaranteed_actor, which might fetch SYSTEM_USER.
//     //    Passing None for profile to download() will make it use SYSTEM_USER.
//     log::debug!("Item not in cache, attempting download: {item_url}");
//     let downloaded_item_meta = new_cache_item_to_process.download(conn, None).await?; // Pass conn, profile is None

//     // 3. Create the item in the database.
//     //    create_cache_item uses ON CONFLICT DO NOTHING.
//     //    The result of create_cache_item (Option<CacheItem>) is not strictly needed here
//     //    because we will re-fetch.
//     create_cache_item(Some(conn), downloaded_item_meta.clone()).await;

//     // 4. Re-fetch the item to ensure we get the definitive version from the DB.
//     //    This covers cases where it was just inserted or inserted by a racing process.
//     get_cache_item_by_url(Some(conn), item_url.clone())
//         .await
//         .ok_or_else(|| {
//             anyhow!(
//                 "Failed to retrieve cache item from DB after download and create attempt for URL: {}",
//                 item_url
//             )
//         })
// }