Update remote executor example to reflect the executor changes

.gitignore

@@ -6,3 +6,4 @@ Gemfile.lock
 .bundle
 .idea
 .ruby-version
+examples/remote_executor_db.sqlite

examples/example_helper.rb

@@ -10,9 +10,9 @@ def world
 
     def create_world
       config = Dynflow::Config.new
-      yield config if block_given?
       config.persistence_adapter = persistence_adapter
       config.logger_adapter      = logger_adapter
+      yield config if block_given?
       Dynflow::World.new(config)
     end
 

examples/remote_executor.rb

@@ -20,36 +20,44 @@ class RemoteExecutorExample
   class << self
 
     def run_server
-      world               = ExampleHelper.create_world(persistence_adapter: persistence_adapter)
-      listener            = Dynflow::Listeners::Socket.new world, socket
-
-      Thread.new { Dynflow::Daemon.new(listener, world).run }
-      ExampleHelper.run_web_console(world)
-    ensure
-      File.delete(db_path)
+      world               = ExampleHelper.create_world do |config|
+        config.persistence_adapter = persistence_adapter
+        config.connector           = connector
+      end
+      begin
+        ExampleHelper.run_web_console(world)
+      rescue Errno::EADDRINUSE
+        STDIN.gets
+      end
     end
 
-    def run_client
-      executor = ->(world) { Dynflow::Executors::RemoteViaSocket.new(world, socket) }
-      world    = ExampleHelper.create_world(persistence_adapter: persistence_adapter,
-                                            executor:            executor)
-
-      loop do
-        world.trigger(SampleAction).finished.wait
-        sleep 0.5
-      end
+    def db_path
+      File.expand_path("../remote_executor_db.sqlite", __FILE__)
     end
 
-    def socket
-      File.join(Dir.tmpdir, 'dynflow_socket')
+    def persistence_conn_string
+      ENV['DB_CONN_STRING'] || "sqlite://#{db_path}"
     end
 
     def persistence_adapter
-      Dynflow::PersistenceAdapters::Sequel.new "sqlite://#{db_path}"
+      Dynflow::PersistenceAdapters::Sequel.new persistence_conn_string
     end
 
-    def db_path
-      File.expand_path("../remote_executor_db.sqlite", __FILE__)
+    def connector
+      Proc.new { |world| Dynflow::Connectors::Database.new(world) }
+    end
+
+    def run_client
+      world    = ExampleHelper.create_world do |config|
+        config.persistence_adapter = persistence_adapter
+        config.executor            = false
+        config.connector           = connector
+      end
+
+      loop do
+        world.trigger(SampleAction).finished.wait
+        sleep 0.5
+      end
     end
 
   end