mirror of
https://github.com/ruvnet/RuView
synced 2026-07-28 18:21:42 +00:00
rUv
535043731c
HAP accessory signing seed no longer reachable via derived Debug. /api/history/period and /api/logbook no longer break the default (unfiltered) call shape above 32 entities. fire_event's event_type validation relaxed to match real HA's contract. homecore-migrate gained a --force flag for re-running imports. Public v2051 release notes corrected. 110 tests across the 3 touched crates, 0 failed, clippy clean.
194 lines
6.5 KiB
Rust
194 lines
6.5 KiB
Rust
use axum::body::Body;
|
|
use axum::http::{Request, StatusCode};
|
|
use homecore::HomeCore;
|
|
use homecore_api::{router, LongLivedTokenStore, SharedState};
|
|
use http_body_util::BodyExt;
|
|
use tower::ServiceExt;
|
|
|
|
async fn app() -> (axum::Router, HomeCore) {
|
|
let homecore = HomeCore::new();
|
|
let tokens = LongLivedTokenStore::empty();
|
|
tokens.register("test-token").await;
|
|
let state = SharedState::with_tokens(homecore.clone(), "Test", "test", tokens);
|
|
(router(state), homecore)
|
|
}
|
|
|
|
fn post(uri: &str, body: &str) -> Request<Body> {
|
|
Request::builder()
|
|
.method("POST")
|
|
.uri(uri)
|
|
.header("authorization", "Bearer test-token")
|
|
.header("content-type", "application/json")
|
|
.body(Body::from(body.to_owned()))
|
|
.unwrap()
|
|
}
|
|
|
|
#[tokio::test]
|
|
async fn rest_event_is_delivered_to_domain_bus() {
|
|
let (app, homecore) = app().await;
|
|
let mut receiver = homecore.bus().subscribe_domain();
|
|
let response = app
|
|
.oneshot(post("/api/events/test_event", r#"{"answer":42}"#))
|
|
.await
|
|
.unwrap();
|
|
assert_eq!(response.status(), StatusCode::OK);
|
|
let event = receiver.recv().await.unwrap();
|
|
assert_eq!(event.event_type, "test_event");
|
|
assert_eq!(event.event_data["answer"], 42);
|
|
}
|
|
|
|
#[tokio::test]
|
|
async fn rest_template_uses_live_state_environment() {
|
|
let (app, _) = app().await;
|
|
let response = app
|
|
.oneshot(post("/api/template", r#"{"template":"{{ 6 * 7 }}"}"#))
|
|
.await
|
|
.unwrap();
|
|
assert_eq!(response.status(), StatusCode::OK);
|
|
let bytes = response.into_body().collect().await.unwrap().to_bytes();
|
|
assert_eq!(&bytes[..], b"42");
|
|
}
|
|
|
|
#[tokio::test]
|
|
async fn compatibility_matrix_is_authenticated() {
|
|
let (app, _) = app().await;
|
|
let response = app
|
|
.oneshot(
|
|
Request::builder()
|
|
.uri("/api/homecore/compatibility")
|
|
.body(Body::empty())
|
|
.unwrap(),
|
|
)
|
|
.await
|
|
.unwrap();
|
|
assert_eq!(response.status(), StatusCode::UNAUTHORIZED);
|
|
}
|
|
|
|
#[tokio::test]
|
|
async fn history_reads_real_recorder_rows() {
|
|
use homecore::{Context, EntityId};
|
|
use homecore_recorder::Recorder;
|
|
|
|
let homecore = HomeCore::new();
|
|
let recorder = Recorder::open("sqlite::memory:").await.unwrap();
|
|
let mut changes = homecore.states().subscribe();
|
|
homecore.states().set(
|
|
EntityId::parse("light.history_probe").unwrap(),
|
|
"on",
|
|
serde_json::json!({"brightness": 123}),
|
|
Context::new(),
|
|
);
|
|
let change = changes.recv().await.unwrap();
|
|
recorder.record_state(&change).await.unwrap();
|
|
|
|
let tokens = LongLivedTokenStore::empty();
|
|
tokens.register("test-token").await;
|
|
let state =
|
|
SharedState::with_tokens(homecore, "Test", "test", tokens).with_recorder(Some(recorder));
|
|
let response = router(state)
|
|
.oneshot(
|
|
Request::builder()
|
|
.uri("/api/history/period?filter_entity_id=light.history_probe")
|
|
.header("authorization", "Bearer test-token")
|
|
.body(Body::empty())
|
|
.unwrap(),
|
|
)
|
|
.await
|
|
.unwrap();
|
|
assert_eq!(response.status(), StatusCode::OK);
|
|
let bytes = response.into_body().collect().await.unwrap().to_bytes();
|
|
let body: serde_json::Value = serde_json::from_slice(&bytes).unwrap();
|
|
assert_eq!(body[0][0]["entity_id"], "light.history_probe");
|
|
assert_eq!(body[0][0]["state"], "on");
|
|
assert_eq!(body[0][0]["attributes"]["brightness"], 123);
|
|
}
|
|
|
|
/// The real HA frontend's history/logbook pages call these endpoints with NO
|
|
/// entity filter by design (meaning "all entities") — a real install
|
|
/// routinely has 50-500+ entities. The 32-entity cap must only reject an
|
|
/// explicit, unusually-large `filter_entity_id`/`entity` list, never the
|
|
/// default unfiltered "all entities" shape.
|
|
#[tokio::test]
|
|
async fn history_and_logbook_unfiltered_are_not_capped_by_entity_count() {
|
|
use homecore::{Context, EntityId};
|
|
use homecore_recorder::Recorder;
|
|
|
|
let homecore = HomeCore::new();
|
|
let recorder = Recorder::open("sqlite::memory:").await.unwrap();
|
|
for i in 0..40 {
|
|
homecore.states().set(
|
|
EntityId::parse(&format!("sensor.probe_{i}")).unwrap(),
|
|
"on",
|
|
serde_json::json!({}),
|
|
Context::new(),
|
|
);
|
|
}
|
|
assert_eq!(homecore.states().all().len(), 40, "sanity: more than MAX_HISTORY_ENTITIES");
|
|
|
|
let tokens = LongLivedTokenStore::empty();
|
|
tokens.register("test-token").await;
|
|
let state =
|
|
SharedState::with_tokens(homecore, "Test", "test", tokens).with_recorder(Some(recorder));
|
|
let app = router(state);
|
|
|
|
let history_response = app
|
|
.clone()
|
|
.oneshot(
|
|
Request::builder()
|
|
.uri("/api/history/period")
|
|
.header("authorization", "Bearer test-token")
|
|
.body(Body::empty())
|
|
.unwrap(),
|
|
)
|
|
.await
|
|
.unwrap();
|
|
assert_eq!(
|
|
history_response.status(),
|
|
StatusCode::OK,
|
|
"unfiltered history with >32 known entities must not be rejected"
|
|
);
|
|
|
|
let logbook_response = app
|
|
.oneshot(
|
|
Request::builder()
|
|
.uri("/api/logbook")
|
|
.header("authorization", "Bearer test-token")
|
|
.body(Body::empty())
|
|
.unwrap(),
|
|
)
|
|
.await
|
|
.unwrap();
|
|
assert_eq!(
|
|
logbook_response.status(),
|
|
StatusCode::OK,
|
|
"unfiltered logbook with >32 known entities must not be rejected"
|
|
);
|
|
}
|
|
|
|
/// An explicit, unusually-large `filter_entity_id` list is still rejected —
|
|
/// only the default "no filter" shape is exempt from the cap.
|
|
#[tokio::test]
|
|
async fn history_explicit_oversized_filter_is_still_rejected() {
|
|
use homecore_recorder::Recorder;
|
|
|
|
let homecore = HomeCore::new();
|
|
let recorder = Recorder::open("sqlite::memory:").await.unwrap();
|
|
let tokens = LongLivedTokenStore::empty();
|
|
tokens.register("test-token").await;
|
|
let state =
|
|
SharedState::with_tokens(homecore, "Test", "test", tokens).with_recorder(Some(recorder));
|
|
|
|
let filter: String = (0..40).map(|i| format!("sensor.probe_{i}")).collect::<Vec<_>>().join(",");
|
|
let response = router(state)
|
|
.oneshot(
|
|
Request::builder()
|
|
.uri(format!("/api/history/period?filter_entity_id={filter}"))
|
|
.header("authorization", "Bearer test-token")
|
|
.body(Body::empty())
|
|
.unwrap(),
|
|
)
|
|
.await
|
|
.unwrap();
|
|
assert_eq!(response.status(), StatusCode::BAD_REQUEST);
|
|
}
|