Assert timeseries row count equals `expected`.
(
core: &mut CoreLoop,
tx: &mut Producer<BridgeRequest>,
rx: &mut Consumer<BridgeResponse>,
collection: &str,
expected: usize,
)
| 371 | |
| 372 | /// Assert timeseries row count equals `expected`. |
| 373 | pub fn assert_ts_count( |
| 374 | core: &mut CoreLoop, |
| 375 | tx: &mut Producer<BridgeRequest>, |
| 376 | rx: &mut Consumer<BridgeResponse>, |
| 377 | collection: &str, |
| 378 | expected: usize, |
| 379 | ) { |
| 380 | let r = send_raw(core, tx, rx, timeseries_scan(collection)); |
| 381 | assert_eq!(r.status, Status::Ok); |
| 382 | let json = payload_json(&r.payload); |
| 383 | let val: serde_json::Value = |
| 384 | serde_json::from_str(&json).unwrap_or(serde_json::Value::Array(vec![])); |
| 385 | let arr = val.as_array().map(|v| v.len()).unwrap_or(0); |
| 386 | assert_eq!( |
| 387 | arr, expected, |
| 388 | "timeseries {collection} row count: expected {expected}, got {arr}; json={json}" |
| 389 | ); |
| 390 | } |