()
| 120 | /// Verify that a non-User source is skipped even when the cache has mode Writes. |
| 121 | #[test] |
| 122 | fn skips_trigger_source() { |
| 123 | let cache = AuditDmlCache::new(); |
| 124 | let coll_db = CollectionToDatabase::new(); |
| 125 | let db_id = DatabaseId::new(42); |
| 126 | coll_db.insert(TenantId::new(1), Arc::from("orders"), db_id); |
| 127 | cache.set(db_id, AuditDmlMode::Writes); |
| 128 | |
| 129 | // We can't easily spin up a full SharedState in a unit test, so we |
| 130 | // test the routing logic directly by inspecting the guard clauses. |
| 131 | let event = minimal_event(EventSource::Trigger, WriteOp::Insert); |
| 132 | match event.source { |
| 133 | EventSource::User => panic!("should not be User"), |
| 134 | EventSource::Trigger |
| 135 | | EventSource::RaftFollower |
| 136 | | EventSource::CrdtSync |
| 137 | | EventSource::Deferred => {} |
| 138 | } |
| 139 | } |
| 140 | |
| 141 | /// Verify that a Heartbeat op is skipped. |
| 142 | #[test] |
nothing calls this directly
no test coverage detected