public Optional<StreamDestinationFilterRuleDTO> findByIdForStream(String streamId, String id) {
        collection.find(and(eq(FIELD_STREAM_ID, streamId), idEq(id)));
        return utils.getById(id);
    }
@Test
    @MongoDBFixtures("StreamDestinationFilterServiceTest-2024-07-01-1.json")
    void findByIdForStream() {
        assertThat(service.findByIdForStream("foo", "54e3deadbeefdeadbeef0000")).get().satisfies(dto -> {
            assertThat(dto.title()).isEqualTo("Test Filter 1");
            assertThat(dto.streamId()).isEqualTo("54e3deadbeefdeadbeef1000");
            assertThat(dto.destinationType()).isEqualTo("indexer");
            assertThat(dto.status()).isEqualTo(StreamDestinationFilterRuleDTO.Status.ENABLED);
            assertThat(dto.rule()).satisfies(rule -> {
                assertThat(rule.operator()).isEqualTo(RuleBuilderStep.Operator.OR);
                assertThat(rule.conditions()).hasSize(2);
                assertThat(rule.actions()).isNull();
            });
        });
    }