JoinTest.java

package org.drools.ansible.rulebook.integration.api;

import org.drools.base.util.index.ConstraintTypeOperator;
import org.drools.core.reteoo.Rete;
import org.drools.kiesession.rulebase.InternalKnowledgeBase;
import org.junit.Test;
import org.kie.api.runtime.rule.Match;

import java.util.List;

import static org.junit.Assert.assertEquals;

public class JoinTest {

    @Test
    public void testJoin() {
        String json =
                """
                {
                    "rules": [
                            {
                                "Rule": {
                                    "condition": {
                                        "AllCondition": [
                                            {
                                                "EqualsExpression": {
                                                    "lhs": {
                                                        "Event": "i"
                                                    },
                                                    "rhs": {
                                                        "Integer": "3"
                                                    }
                                                }
                                            },
                                            {
                                                "EqualsExpression": {
                                                    "lhs": {
                                                        "Event": "j"
                                                    },
                                                    "rhs": {
                                                        "Integer": "3"
                                                    }
                                                }
                                            }
                                        ]
                                    },
                                    "enabled": true,
                                    "name": "R1"
                                }
                            }
                        ]
                }
                """;

        RulesExecutor rulesExecutor = RulesExecutorFactory.createFromJson(json);

        List<Match> matchedRules = rulesExecutor.processEvents("{ \"i\": 3 }").join();
        assertEquals(0, matchedRules.size());

        matchedRules = rulesExecutor.processEvents("{ \"i\": 3 }").join();
        assertEquals(0, matchedRules.size());

        matchedRules = rulesExecutor.processEvents("{ \"j\": 3 }").join();
        assertEquals(2, matchedRules.size());
        assertEquals("R1", matchedRules.get(0).getRule().getName());
        assertEquals("R1", matchedRules.get(1).getRule().getName());

        rulesExecutor.dispose();
    }
}