Struct Store 

pub struct Store { /* private fields */ }

SQLite-based store for Aranet sensor data.

Implementations

impl Store

pub fn open<P: AsRef<Path>>(path: P) -> Result<Self>

Open or create a database at the given path.

pub fn open_default() -> Result<Self>

Open the default database location.

pub fn open_in_memory() -> Result<Self>

Open an in-memory database (for testing).

pub fn upsert_device( &self, device_id: &str, name: Option<&str>, ) -> Result<StoredDevice>

Get or create a device entry.

pub fn update_device_metadata( &self, device_id: &str, name: Option<&str>, device_type: Option<DeviceType>, ) -> Result<()>

Update device metadata (name and type).

This is a simpler version of update_device_info for when you only have basic device information (e.g., from BLE advertisement or connection).

pub fn update_device_info( &self, device_id: &str, info: &DeviceInfo, ) -> Result<()>

Update device info from DeviceInfo.

pub fn get_device(&self, device_id: &str) -> Result<Option<StoredDevice>>

Get a device by ID.

pub fn list_devices(&self) -> Result<Vec<StoredDevice>>

List all devices.

impl Store

pub fn insert_reading( &self, device_id: &str, reading: &CurrentReading, ) -> Result<i64>

Insert a current reading.

pub fn query_readings(&self, query: &ReadingQuery) -> Result<Vec<StoredReading>>

Query readings with filters.

pub fn get_latest_reading( &self, device_id: &str, ) -> Result<Option<StoredReading>>

Get the latest reading for a device.

pub fn count_readings(&self, device_id: Option<&str>) -> Result<u64>

Count readings for a device.

impl Store

pub fn insert_history( &self, device_id: &str, records: &[HistoryRecord], ) -> Result<usize>

Insert history records (with deduplication).

pub fn query_history( &self, query: &HistoryQuery, ) -> Result<Vec<StoredHistoryRecord>>

Query history records with filters.

pub fn count_history(&self, device_id: Option<&str>) -> Result<u64>

Count history records for a device.

impl Store

pub fn get_sync_state(&self, device_id: &str) -> Result<Option<SyncState>>

Get sync state for a device.

pub fn update_sync_state( &self, device_id: &str, last_index: u16, total_readings: u16, ) -> Result<()>

Update sync state after a successful sync.

pub fn calculate_sync_start( &self, device_id: &str, current_total: u16, ) -> Result<u16>

Calculate the start index for incremental sync.

Returns the index to start downloading from (1-based). If the device has new readings since last sync, returns the next index. If this is the first sync, returns 1 to download all.

impl Store

pub fn history_stats(&self, query: &HistoryQuery) -> Result<HistoryStats>

Get aggregate statistics for history records.

pub fn export_history_csv(&self, query: &HistoryQuery) -> Result<String>

Export history records to CSV format.

pub fn export_history_json(&self, query: &HistoryQuery) -> Result<String>

Export history records to JSON format.

pub fn import_history_csv(&self, csv_data: &str) -> Result<ImportResult>

Import history records from CSV format.

Expected CSV format:

timestamp,device_id,co2,temperature,pressure,humidity,radon
2024-01-15T10:30:00Z,Aranet4 17C3C,800,22.5,1013.25,45,

Returns the number of records imported (deduplicated by device_id + timestamp).

pub fn import_history_json(&self, json_data: &str) -> Result<ImportResult>

Import history records from JSON format.

Expected JSON format: an array of StoredHistoryRecord objects.

Returns the number of records imported (deduplicated by device_id + timestamp).