miden-node-ntx-builder 0.14.0-alpha.1

Miden node's network transaction builder component
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

//! Chain state queries and models.

use diesel::prelude::*;
use miden_node_db::DatabaseError;
use miden_protocol::block::{BlockHeader, BlockNumber};

use crate::db::models::conv as conversions;
use crate::db::schema;

// MODELS
// ================================================================================================

#[derive(Debug, Clone, Insertable)]
#[diesel(table_name = schema::chain_state)]
#[diesel(check_for_backend(diesel::sqlite::Sqlite))]
pub struct ChainStateInsert {
    /// Singleton row ID. Always `0` to satisfy the `CHECK (id = 0)` constraint.
    pub id: i32,
    pub block_num: i64,
    pub block_header: Vec<u8>,
}

// QUERIES
// ================================================================================================

/// Inserts or replaces the singleton chain state row.
///
/// # Raw SQL
///
/// ```sql
/// INSERT OR REPLACE INTO chain_state (id, block_num, block_header)
/// VALUES (0, ?1, ?2)
/// ```
pub fn upsert_chain_state(
    conn: &mut SqliteConnection,
    block_num: BlockNumber,
    block_header: &BlockHeader,
) -> Result<(), DatabaseError> {
    let row = ChainStateInsert {
        id: 0,
        block_num: conversions::block_num_to_i64(block_num),
        block_header: conversions::block_header_to_bytes(block_header),
    };
    diesel::replace_into(schema::chain_state::table).values(&row).execute(conn)?;
    Ok(())
}