api: add structured context for usage and session errors

apps/admin-api/src/app.rs

@@ -1695,6 +1695,36 @@ mod tests {
         );
     }
 
+    #[tokio::test(flavor = "multi_thread")]
+    #[serial]
+    async fn returns_structured_context_for_missing_stream_session() {
+        let registry = test_registry().await;
+        let storage_root = test_storage_root("missing_stream_session");
+        let base_url = spawn_admin_api(build_test_app(registry, storage_root)).await;
+        let client = authorized_client(&base_url).await;
+
+        let response = client
+            .get(format!("{base_url}/stream-sessions/sess_missing"))
+            .send()
+            .await
+            .unwrap();
+        let status = response.status();
+        let body = response.json::<Value>().await.unwrap();
+
+        assert_eq!(status, reqwest::StatusCode::NOT_FOUND);
+        assert_eq!(body["error"]["code"], "not_found");
+        assert_eq!(
+            body["error"]["message"],
+            "stream session sess_missing was not found"
+        );
+        assert_eq!(
+            body["error"]["context"],
+            json!({
+                "session_id": "sess_missing"
+            })
+        );
+    }
+
     #[tokio::test(flavor = "multi_thread")]
     #[serial]
     async fn uploads_wsdl_and_tests_soap_operation() {
@@ -1812,6 +1842,53 @@ mod tests {
         );
     }
 
+    #[tokio::test(flavor = "multi_thread")]
+    #[serial]
+    async fn returns_structured_context_for_missing_operation_usage() {
+        let registry = test_registry().await;
+        let storage_root = test_storage_root("missing_operation_usage");
+        let upstream_base_url = spawn_upstream_server().await;
+        let base_url = spawn_admin_api(build_test_app(registry, storage_root)).await;
+        let client = authorized_client(&base_url).await;
+
+        let created = client
+            .post(format!("{base_url}/operations"))
+            .json(&test_operation_payload(
+                &upstream_base_url,
+                "crm_missing_usage",
+            ))
+            .send()
+            .await
+            .unwrap()
+            .json::<Value>()
+            .await
+            .unwrap();
+        let operation_id = created["operation_id"].as_str().unwrap().to_owned();
+
+        let response = client
+            .get(format!(
+                "{base_url}/usage/operations/{operation_id}?period=7d"
+            ))
+            .send()
+            .await
+            .unwrap();
+        let status = response.status();
+        let body = response.json::<Value>().await.unwrap();
+
+        assert_eq!(status, reqwest::StatusCode::NOT_FOUND);
+        assert_eq!(body["error"]["code"], "not_found");
+        assert_eq!(
+            body["error"]["message"],
+            format!("usage for operation {operation_id} was not found")
+        );
+        assert_eq!(
+            body["error"]["context"],
+            json!({
+                "operation_id": operation_id
+            })
+        );
+    }
+
     #[tokio::test(flavor = "multi_thread")]
     #[serial]
     async fn manages_auth_profiles_and_yaml_upsert() {