How to fire Rules in Drools when having a function(monitor) that contains an infinite loop?

Question

I have a function(MonitorLog) that contains an infinite loop; it's necessary because I want to monitor a file and do an action when there is a modification. However, then part in Drools doesn't want to start("WS is updated" don't appear). Some help please ?

package smartWssec ;
dialect "mvel"
rule "SmartWssec"
when
$log :PolicyUpdateWssec(flag == true ,changelog == true)
then
$log.UpdateXml("D:\Mod\policy.xml")// consequence
System.out.println("Ws-Policy Updated")
end

//////////////////////////////////////////////////////

package smartWssec;


import java.io.IOException;

import org.kie.api.KieServices;
import org.kie.api.runtime.KieContainer;
import org.kie.api.runtime.KieSession;



    public class MainPolicyUpdateWssec {


    public static void main(String[] args) throws IOException, InterruptedException {
                //create a Session 
    KieServices ks = KieServices.Factory.get();
    KieContainer kContainer = ks.getKieClasspathContainer();
    KieSession kSession =     kContainer.newKieSession("ksession-rules");
            try {

                //create fact
                PolicyUpdateWssec LogModSecurity = new PolicyUpdateWssec();
                LogModSecurity.MonitorLog("D:\Mod");
                LogModSecurity.ReadLog("D:\Mod\Modsecurity.txt");
                //insert fact and fire Rules
                kSession.insert(LogModSecurity);
                kSession.fireAllRules();

            }
            finally {
            kSession.dispose();
            }
            }

/////////////////////////////////////////////////////////////////////////////

 public  class PolicyUpdateWssec {
private boolean flag;
private boolean changelog;



public boolean getchangelog(){
    return changelog;
}
public void setChangelog(boolean changelog){
    this.changelog=changelog;
}

public boolean getflag(){
    return flag;
    }

public void setflag(boolean flag){
    this.flag=flag;
}


public void Update(String filename){

    try (PrintStream ps = new PrintStream("D:\Mod\Wspolicyupdate.txt");
            Stream stream = Files.lines(Paths.get(filename))) {
            stream.map(line -> line.replaceAll("","













wls:SecurityHeader(wsu:Timestamp)













wsp:Body()







")).forEach(ps::println);
            System.out.println("Ws-Policy updated");
        } catch (IOException e) {
            e.printStackTrace();
        }}

 public void ReadLog(String filename) throws IOException{

String line =null;
boolean flag=false;

 // FileReader reads text files in the default encoding

 FileReader fileReader = new FileReader(filename);

 // Always wrap FileReader in BufferedReader

 BufferedReader bufferedReader = new BufferedReader(fileReader);

  while((line = bufferedReader.readLine()) != null) {


    flag=line.matches("(.*)sql_injection_attacks(.*)");
    if(flag==true) setflag(flag);

    }

   // Always close files
   bufferedReader.close();         
}

public void MonitorLog(String path) throws InterruptedException{

boolean changelog=false;

    try {
        WatchService watcher = FileSystems.getDefault().newWatchService();
        Path dir = Paths.get(path);
        dir.register(watcher, ENTRY_CREATE, ENTRY_DELETE, ENTRY_MODIFY);

        System.out.println("Watch Service registered for : " + dir.getFileName());

             WatchKey key = watcher.poll(10, TimeUnit.SECONDS);

            try {

            // wait for a key to be available

                key = watcher.take();
            } catch (InterruptedException ex) {
                return;
            }

            for (WatchEvent event : key.pollEvents()) {
                // get event type
                WatchEvent.Kind kind = event.kind();

                // get file name
                @SuppressWarnings("unchecked")
                WatchEvent ev = (WatchEvent) event;
                Path fileName = ev.context();

                System.out.println(kind.name() + ": " + fileName);

                if (kind == ENTRY_MODIFY ) {
                    changelog=true;
                    setChangelog(changelog);
                    System.out.println("WS-Policy is being Updated .......");


                }

            }



        watcher.close();            
    }
    catch (IOException ex) {
        System.err.println(ex);
    }


    } 




public void UpdateXml(String filename) {

ArrayList lines = new ArrayList();
String line = null;

File f1=null;
FileReader fr=null;

BufferedReader br=null;
FileWriter fw=null;
BufferedWriter out=null;
try {
    f1 = new File(filename);
    fr = new FileReader(f1);
    br = new BufferedReader(fr);
    while ((line = br.readLine()) != null) {
        if (line.contains(""))
        line = line.replace("", "













wls:SecurityHeader(wsu:Timestamp)













wsp:Body()







");
        lines.add(line);
    }

    fw = new FileWriter(f1);
    out = new BufferedWriter(fw);
    for (String s : lines)
    out.write(s);
    out.flush();

} catch (Exception ex) {
    ex.printStackTrace();
} finally {
    try{
    fr.close();
    br.close();
    out.close();
    }catch(IOException ioe)

    {
        ioe.printStackTrace();
    }

}
}}

How to fire Rules in Drools when having a function(monitor) that contains an infinite loop?

Answers (1)

Related Questions