Skip to content

desktop/src-tauri/crates/core/tests/storage_jobs.rs

Comment 1, line 1

desktop/src-tauri/crates/core/tests/storage_jobs.rs:1

//! Storage/job tests: ingest_runs states, attribution exclusions, data revisions,

Comment 2, line 2

desktop/src-tauri/crates/core/tests/storage_jobs.rs:2

//! i64/JavaScript integer limits, seconds/milliseconds mistakes, nulls, quotas and aliases.

Comment 3, line 42

desktop/src-tauri/crates/core/tests/storage_jobs.rs:42

// Start a job; overlapping triggers for the same source merge into that running job.

Comment 4, line 57

desktop/src-tauri/crates/core/tests/storage_jobs.rs:57

// Commit batch statistics and job progress in one transaction.

Comment 5, line 76

desktop/src-tauri/crates/core/tests/storage_jobs.rs:76

// A finished job cannot be finished again.

Comment 6, line 99

desktop/src-tauri/crates/core/tests/storage_jobs.rs:99

// finish rejects running, which is not a terminal status.

Comment 7, line 110

desktop/src-tauri/crates/core/tests/storage_jobs.rs:110

// Leave a running job to simulate process exit.

Comment 8, line 113

desktop/src-tauri/crates/core/tests/storage_jobs.rs:113

// Reopening storage recovers running as interrupted.

Comment 9, line 120

desktop/src-tauri/crates/core/tests/storage_jobs.rs:120

// Completed jobs remain unchanged.

Comment 10, line 157

desktop/src-tauri/crates/core/tests/storage_jobs.rs:157

// The query returns the same data revision as the committed values.

Comment 11, line 181

desktop/src-tauri/crates/core/tests/storage_jobs.rs:181

// Exclude events whose ownership is unverified from totals.

Comment 12, line 185

desktop/src-tauri/crates/core/tests/storage_jobs.rs:185

// List exclusions by reason.

Comment 13, line 203

desktop/src-tauri/crates/core/tests/storage_jobs.rs:203

// 2^53+1 exceeds the JavaScript safe-integer limit and must round-trip exactly.

Comment 14, line 220

desktop/src-tauri/crates/core/tests/storage_jobs.rs:220

// Accept the MAX_TOKEN_VALUE boundary.

Comment 15, line 231

desktop/src-tauri/crates/core/tests/storage_jobs.rs:231

// Summing two MAX records exceeds i64: return an error and roll back without wrapping.

Comment 16, line 244

desktop/src-tauri/crates/core/tests/storage_jobs.rs:244

// Rollback leaves neither m1 nor m2 stored.

Comment 17, line 259

desktop/src-tauri/crates/core/tests/storage_jobs.rs:259

// Unix seconds near 2023-11-14 misread as milliseconds predate 2000; reject and diagnose.

Comment 18, line 286

desktop/src-tauri/crates/core/tests/storage_jobs.rs:286

// Every token field is unknown.

Comment 19, line 304

desktop/src-tauri/crates/core/tests/storage_jobs.rs:304

// quality_bucket=unknown counts calls without unknown-field denominators.

Comment 20, line 336

desktop/src-tauri/crates/core/tests/storage_jobs.rs:336

// Quotas do not contribute to token statistics.

Comment 21, line 394

desktop/src-tauri/crates/core/tests/storage_jobs.rs:394

/// quality_json persists reported/derived/estimated/unknown quality for every field.

Comment 22, line 414

desktop/src-tauri/crates/core/tests/storage_jobs.rs:414

// Estimated fields belong to the estimated quality partition, separate from reported fields.

Comment 23, line 426

desktop/src-tauri/crates/core/tests/storage_jobs.rs:426

/// Cache reads greater than total input retain their values with diagnostics; never hide them with max(0,...).

Comment 24, line 457

desktop/src-tauri/crates/core/tests/storage_jobs.rs:457

/// Default TokenUsage/TokenQuality values remain unknown through metrics helpers.

Comment 25, line 470

desktop/src-tauri/crates/core/tests/storage_jobs.rs:470

/// Store global/per-source schedules, timezones, next times and desired/applied state.

Comment 26, line 471

desktop/src-tauri/crates/core/tests/storage_jobs.rs:471

/// This M1 test checks table/storage behavior; M6 timer and concurrency checks are separate.

Comment 27, line 518

desktop/src-tauri/crates/core/tests/storage_jobs.rs:518

/// Store an import identity and update planned to committed; rolled_back is a separate status, and M2 tests import idempotency.