lib/daemonic.rb in daemonic-0.0.2 vs lib/daemonic.rb in daemonic-0.1.0

@@ -1,17 +1,49 @@
+require "thread"
+require "optparse"
+require "logger"
+require "fileutils"
+require "timeout"
+
 require "daemonic/version"
-require "daemonic/master"
-require "daemonic/pool"
-require "daemonic/configuration"
+require "daemonic/daemon"
 require "daemonic/cli"
+require "daemonic/producer"
+require "daemonic/pool"
 
+Thread.abort_on_exception = true
+
 module Daemonic
 
-  def self.start(options)
-    config = Configuration.new(options, Dir.pwd)
-    config.reload
-    Process.daemon if config.daemonize?
-    Master.new(config).start
+  def self.run(worker, default_options = {})
+    command, options = CLI.new(ARGV, default_options).run
+    case command
+    when :start   then start(worker, options)
+    when :stop    then stop(options)
+    when :status  then status(options)
+    when :restart then restart(worker, options)
+    end
   end
 
+  def self.start(worker, options)
+    daemon = Daemon.new(options)
+    daemon.start do
+      Producer.new(worker, options).run
+    end
+  end
+
+  def self.stop(options)
+    Daemon.new(options).stop
+  end
+
+  def self.status(options)
+    Daemon.new(options).status
+  end
+
+  def self.restart(worker, options)
+    daemon = Daemon.new(options.merge(daemonize: true))
+    daemon.restart do
+      Producer.new(worker, options).run
+    end
+  end
 
 end