Make forklift for rufus user table run once per minute

pom.xml

@@ -116,6 +116,16 @@
       <artifactId>hsqldb</artifactId>
       <version>2.4.0</version>
     </dependency>
+      <dependency>
+      <groupId>org.quartz-scheduler</groupId>
+      <artifactId>quartz</artifactId>
+      <version>2.2.1</version>
+  </dependency>
+  <dependency>
+      <groupId>org.quartz-scheduler</groupId>
+      <artifactId>quartz-jobs</artifactId>
+      <version>2.2.1</version>
+  </dependency> 
   </dependencies>
   <build>
     <plugins>

src/main/java/com/tanza/rufus/RufusApplication.java

@@ -9,6 +9,7 @@
 import com.tanza.rufus.feed.FeedParser;
 import com.tanza.rufus.feed.FeedProcessorImpl;
 import com.tanza.rufus.feed.FeedUtils;
+import com.tanza.rufus.jobs.UserForklift;
 import com.tanza.rufus.resources.ArticleResource;
 import com.tanza.rufus.resources.UserResource;
 
@@ -34,6 +35,14 @@
 import java.util.List;
 
 import org.skife.jdbi.v2.DBI;
+import org.quartz.JobDetail;
+import org.quartz.Scheduler;
+import org.quartz.SchedulerException;
+import org.quartz.SimpleTrigger;
+import org.quartz.impl.StdSchedulerFactory;
+import static org.quartz.JobBuilder.*;
+import static org.quartz.TriggerBuilder.*;
+import static org.quartz.SimpleScheduleBuilder.*;
 
 public class RufusApplication extends Application<RufusConfiguration> {
     private static final byte[] VERIFICATION_KEY = FeedUtils.getVerificationKey();
@@ -82,7 +91,6 @@ public void run(RufusConfiguration conf, Environment env) throws Exception {
         final DBIFactory factory = new DBIFactory();
         final DBI jdbi = factory.build(env, conf.getDataSourceFactory1(), DB_SOURCE);
         final DBI jdbi2 = factory.build(env, conf.getDataSourceFactory2(), DB_SOURCE2);
-        this.userForklift(jdbi, jdbi2);
 
         final UserDao userDao = jdbi.onDemand(UserDao.class);
         final ArticleDao articleDao = jdbi.onDemand(ArticleDao.class);
@@ -125,24 +133,34 @@ public void run(RufusConfiguration conf, Environment env) throws Exception {
                 .setAuthenticator(cachingJwtAuthenticator)
                 .buildAuthFilter()
         ));
+        this.runUserForklift(jdbi, jdbi2);
     }
 
-    public void userForklift(DBI h2jdbi, DBI hsqldbjdbi) throws Exception{
+    public void runUserForklift(DBI h2jdbi, DBI hsqldbjdbi) throws Exception {
+
+        try{
+    Scheduler sched = StdSchedulerFactory.getDefaultScheduler();
 
-        UserDao userDao = h2jdbi.open(UserDao.class);
-        List<User> usersOldDb = userDao.getAll();
-        userDao.close();
+    sched.start();
 
-        if (!usersOldDb.isEmpty()){
-        userDao = hsqldbjdbi.open(UserDao.class);
-        List<Long> usersNewDbIds = userDao.getAllIds();
-        for (User user : usersOldDb){
-            if(!usersNewDbIds.contains(user.getId()))
-            userDao.insertUser(user);
-        }
-        userDao.close();
-        }
+    JobDetail userForklift = newJob(UserForklift.class).withIdentity("userForklift", "group1").build();
+
+    SimpleTrigger userFTrigger = newTrigger().withIdentity("userFTrigger", "group1").startNow()
+        .withSchedule(simpleSchedule().withIntervalInSeconds(60).repeatForever()).build();
+
+
+    userForklift.getJobDataMap().put(UserForklift.H2DB, h2jdbi);
+    userForklift.getJobDataMap().put(UserForklift.HSQLDB, hsqldbjdbi);
+
+    sched.scheduleJob(userForklift, userFTrigger);
+    Thread.yield();
+
+
+        }catch (SchedulerException se) {
+              se.printStackTrace();
+          }
 
     }
 
+
 }

src/main/java/com/tanza/rufus/core/User.java

@@ -45,4 +45,11 @@ public String getPassword() {
     public void setPassword(String password) {
         this.password = password;
     }
+
+    @Override
+    public boolean equals(Object o){
+        User u = (User) o;
+        return ((this.id == u.getId()) && (this.email.equals(u.getEmail())) && (this.password.equals(u.getPassword())));
+    }
+
 }

src/main/java/com/tanza/rufus/jobs/UserForklift.java

@@ -0,0 +1,54 @@
+package com.tanza.rufus.jobs;
+
+import org.quartz.Scheduler;
+import org.quartz.SchedulerException;
+import org.quartz.impl.StdSchedulerFactory;
+import org.skife.jdbi.v2.DBI;
+
+import com.tanza.rufus.core.User;
+import com.tanza.rufus.db.UserDao;
+
+import static org.quartz.JobBuilder.*;
+import static org.quartz.TriggerBuilder.*;
+
+import java.util.List;
+
+import org.quartz.JobDataMap;
+import org.quartz.JobExecutionContext;
+import org.quartz.JobExecutionException;
+
+import static org.quartz.SimpleScheduleBuilder.*;
+
+
+public class UserForklift implements org.quartz.Job {
+
+	public static final String H2DB = "h2db";
+	public static final String HSQLDB = "hsqldb";
+
+      public UserForklift() {
+      }
+
+      public void execute(JobExecutionContext context) throws JobExecutionException {
+
+          System.out.println("User forklift started");
+    	JobDataMap data = context.getJobDetail().getJobDataMap();
+        DBI h2jdbi = (DBI) data.get(H2DB);
+        DBI hsqldbjdbi = (DBI) data.get(HSQLDB);
+
+        UserDao userDao = h2jdbi.open(UserDao.class);
+        List<User> usersOldDb = userDao.getAll();
+        userDao.close();
+
+        if (!usersOldDb.isEmpty()){
+        userDao = hsqldbjdbi.open(UserDao.class);
+        List<User> usersNewDb = userDao.getAll();
+        for (User user : usersOldDb){
+            if(!usersNewDb.contains(user))
+            userDao.insertUser(user);
+        }
+        userDao.close();
+        }
+
+      }
+  }
+