vector-core 0.2.0

Core library for Vector — the single source of truth for all Vector clients, SDKs, and interfaces.
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
92

//! Profile database operations — read/write SlimProfile to SQLite.

use crate::profile::{SlimProfile, Status};

/// Load all profiles from the database.
pub fn get_all_profiles() -> Result<Vec<SlimProfile>, String> {
    let conn = super::get_db_connection_guard_static()?;

    let mut stmt = conn.prepare(
        "SELECT npub, name, display_name, nickname, lud06, lud16, banner, avatar, \
         about, website, nip05, status_content, status_url, bot, avatar_cached, \
         banner_cached, is_blocked FROM profiles"
    ).map_err(|e| format!("Failed to prepare statement: {}", e))?;

    let profiles = stmt.query_map([], |row| {
        Ok(SlimProfile {
            id: row.get(0)?,
            name: row.get(1)?,
            display_name: row.get(2)?,
            nickname: row.get(3)?,
            lud06: row.get(4)?,
            lud16: row.get(5)?,
            banner: row.get(6)?,
            avatar: row.get(7)?,
            about: row.get(8)?,
            website: row.get(9)?,
            nip05: row.get(10)?,
            status: Status {
                title: row.get(11)?,
                purpose: String::new(),
                url: row.get(12)?,
            },
            last_updated: 0,
            mine: false,
            bot: row.get::<_, i32>(13)? != 0,
            avatar_cached: {
                let p: String = row.get(14)?;
                if !p.is_empty() && !std::path::Path::new(&p).exists() { String::new() } else { p }
            },
            banner_cached: {
                let p: String = row.get(15)?;
                if !p.is_empty() && !std::path::Path::new(&p).exists() { String::new() } else { p }
            },
            is_blocked: row.get::<_, i32>(16).unwrap_or(0) != 0,
        })
    })
    .map_err(|e| format!("Failed to query profiles: {}", e))?
    .collect::<Result<Vec<_>, _>>()
    .map_err(|e| format!("Failed to collect profiles: {}", e))?;

    Ok(profiles)
}

/// Upsert a profile to the database (INSERT ... ON CONFLICT DO UPDATE).
pub fn set_profile(profile: &SlimProfile) -> Result<(), String> {
    let conn = super::get_write_connection_guard_static()?;

    conn.execute(
        "INSERT INTO profiles (npub, name, display_name, nickname, lud06, lud16, banner, avatar, \
         about, website, nip05, status_content, status_url, bot, avatar_cached, banner_cached, is_blocked) \
         VALUES (?1, ?2, ?3, ?4, ?5, ?6, ?7, ?8, ?9, ?10, ?11, ?12, ?13, ?14, ?15, ?16, ?17) \
         ON CONFLICT(npub) DO UPDATE SET \
            name = excluded.name, display_name = excluded.display_name, \
            nickname = excluded.nickname, lud06 = excluded.lud06, lud16 = excluded.lud16, \
            banner = excluded.banner, avatar = excluded.avatar, about = excluded.about, \
            website = excluded.website, nip05 = excluded.nip05, \
            status_content = excluded.status_content, status_url = excluded.status_url, \
            bot = excluded.bot, avatar_cached = excluded.avatar_cached, \
            banner_cached = excluded.banner_cached, is_blocked = excluded.is_blocked",
        rusqlite::params![
            profile.id,
            profile.name,
            profile.display_name,
            profile.nickname,
            profile.lud06,
            profile.lud16,
            profile.banner,
            profile.avatar,
            profile.about,
            profile.website,
            profile.nip05,
            profile.status.title,
            profile.status.url,
            profile.bot as i32,
            profile.avatar_cached,
            profile.banner_cached,
            profile.is_blocked as i32,
        ],
    ).map_err(|e| format!("Failed to insert profile: {}", e))?;

    Ok(())
}