Added Scheduler and Job support

Author: JulianFun123

pom.xml

@@ -31,6 +31,11 @@
             <artifactId>Templating-Engine</artifactId>
             <version>1.0-SNAPSHOT</version>
         </dependency>
+        <dependency>
+            <groupId>org.javawebstack</groupId>
+            <artifactId>Scheduler</artifactId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
         <dependency>
             <groupId>org.apache.commons</groupId>
             <artifactId>commons-email</artifactId>

src/main/java/org/javawebstack/framework/WebApplication.java

@@ -27,6 +27,17 @@
 import org.javawebstack.orm.wrapper.MySQL;
 import org.javawebstack.orm.wrapper.SQL;
 import org.javawebstack.orm.wrapper.SQLite;
+import org.javawebstack.scheduler.job.JobQueue;
+import org.javawebstack.scheduler.job.JobWorker;
+import org.javawebstack.scheduler.job.local.LocalJobQueue;
+import org.javawebstack.scheduler.job.redis.RedisJobQueue;
+import org.javawebstack.scheduler.job.sql.SQLJobQueue;
+import org.javawebstack.scheduler.scheduler.Schedule;
+import org.javawebstack.scheduler.scheduler.Scheduler;
+import org.javawebstack.scheduler.scheduler.local.LocalSchedule;
+import org.javawebstack.scheduler.scheduler.redis.RedisSchedule;
+import org.javawebstack.scheduler.scheduler.sql.SQLSchedule;
+import redis.clients.jedis.Jedis;
 
 import java.io.IOException;
 import java.util.*;
@@ -46,6 +57,8 @@ public abstract class WebApplication {
     private final CommandSystem commandSystem = new CommandSystem();
     private final Map<String, Seeder> seeders = new HashMap<>();
     private final I18N translation = new I18N();
+    private JobQueue jobQueue;
+    private Schedule schedule;
 
     public WebApplication() {
         injector = new SimpleInjector();
@@ -96,6 +109,26 @@ public WebApplication() {
         setupInjection(injector);
         modules.forEach(m -> m.setupInjection(this, injector));
 
+        switch (config.get("schedule.driver")) {
+            case "DATABASE":
+                jobQueue = new SQLJobQueue(sql, config.get("schedule.jobs.name", "default"));
+                schedule = new SQLSchedule(sql, config.get("schedule.jobs.name", "default"));
+                break;
+            case "REDIS":
+                jobQueue = new RedisJobQueue(new Jedis(config.get("redis.host", "localhost"), config.getInt("redis.port", 6379)), config.get("schedule.jobs.name", "default"));
+                schedule = new RedisSchedule(new Jedis(config.get("redis.host", "localhost"), config.getInt("redis.port", 6379)), config.get("schedule.jobs.name", "default"));
+                break;
+            case "LOCAL":
+            default:
+                jobQueue = new LocalJobQueue();
+                schedule = new LocalSchedule();
+                break;
+        }
+
+
+        injector.setInstance(JobQueue.class, jobQueue);
+        injector.setInstance(Schedule.class, schedule);
+
         server = new HTTPServer()
                 .port(config.getInt("http.server.port", 80));
         injector.setInstance(HTTPServer.class, server);

src/main/java/org/javawebstack/framework/command/schedule/WorkCommand.java

@@ -0,0 +1,49 @@
+package org.javawebstack.framework.command.schedule;
+
+import org.javawebstack.command.Command;
+import org.javawebstack.command.CommandResult;
+import org.javawebstack.command.CommandSystem;
+import org.javawebstack.framework.WebApplication;
+import org.javawebstack.injector.Inject;
+import org.javawebstack.scheduler.Worker;
+import org.javawebstack.scheduler.job.JobQueue;
+import org.javawebstack.scheduler.job.JobWorker;
+import org.javawebstack.scheduler.scheduler.Schedule;
+import org.javawebstack.scheduler.scheduler.Scheduler;
+
+import java.util.List;
+import java.util.Map;
+import java.util.Timer;
+import java.util.TimerTask;
+
+public class WorkCommand implements Command {
+    @Inject
+    private WebApplication webApplication;
+
+    @Inject
+    private JobQueue jobQueue;
+
+    @Inject
+    private Schedule schedule;
+
+    public CommandResult execute(CommandSystem commandSystem, List<String> list, Map<String, List<String>> map) {
+
+        Worker worker = new Worker();
+        worker.addWork(new JobWorker(jobQueue), new Scheduler(schedule, jobQueue));
+
+        int delay = 6000;
+
+        if (list.size() > 0) {
+            delay = Integer.parseInt(list.get(0));
+        }
+
+        Timer timer = new Timer();
+        timer.schedule(new TimerTask() {
+            public void run() {
+                worker.run();
+            }
+        }, delay, delay);
+
+        return null;
+    }
+}