relay-knowledge 1.1.6

Graph-database-based knowledge graph project.
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

use rusqlite::{Connection, params};

use crate::storage::StorageError;

pub(super) fn mark_checkpoint_state(
    connection: &mut Connection,
    source_scope: &str,
    state: &str,
) -> Result<(), StorageError> {
    connection.execute(
        "
        UPDATE code_repository_index_checkpoints
        SET state = ?2, updated_at_ms = ?3
        WHERE source_scope = ?1
        ",
        params![source_scope, state, now_millis()],
    )?;

    Ok(())
}

fn now_millis() -> u64 {
    std::time::SystemTime::now()
        .duration_since(std::time::UNIX_EPOCH)
        .unwrap_or_default()
        .as_millis() as u64
}