Read environment at initialisation

This allows us to expose the environment attribute from the engine
object and utilise it to build exported startup files.

lib/foreman/engine.rb

@@ -11,6 +11,8 @@ class Foreman::Engine
 
   attr_reader :procfile
   attr_reader :directory
+  attr_reader :environment
+  attr_reader :options
 
   extend Term::ANSIColor
 
@@ -20,6 +22,7 @@ class Foreman::Engine
     @procfile  = read_procfile(procfile)
     @directory = File.expand_path(File.dirname(procfile))
     @options = options
+    @environment = read_environment(options[:env])
   end
 
   def processes
@@ -52,12 +55,10 @@ class Foreman::Engine
   end
 
   def start
-    environment = read_environment(@options[:env])
-
     proctitle "ruby: foreman master"
 
     processes_in_order.each do |name, process|
-      fork process, @options, environment
+      fork process
     end
 
     trap("TERM") { puts "SIGTERM received"; terminate_gracefully }
@@ -67,9 +68,8 @@ class Foreman::Engine
   end
 
   def execute(name)
-    environment = read_environment(@options[:env])
 
-    fork processes[name], @options, environment
+    fork processes[name]
 
     trap("TERM") { puts "SIGTERM received"; terminate_gracefully }
     trap("INT")  { puts "SIGINT received";  terminate_gracefully }
@@ -85,16 +85,16 @@ class Foreman::Engine
 
 private ######################################################################
 
-  def fork(process, options={}, environment={})
+  def fork(process)
     concurrency = Foreman::Utils.parse_concurrency(@options[:concurrency])
 
     1.upto(concurrency[process.name]) do |num|
-      fork_individual(process, num, port_for(process, num, @options[:port]), environment)
+      fork_individual(process, num, port_for(process, num, @options[:port]))
     end
   end
 
-  def fork_individual(process, num, port, environment)
+  def fork_individual(process, num, port)
-    environment.each { |k,v| ENV[k] = v }
+    @environment.each { |k,v| ENV[k] = v }
 
     ENV["PORT"] = port.to_s
     ENV["PS"]   = "#{process.name}.#{num}"

spec/foreman/engine_spec.rb

@@ -37,8 +37,8 @@ describe "Foreman::Engine" do
   describe "start" do
     it "forks the processes" do
       write_procfile
-      mock(subject).fork(subject.processes["alpha"], {}, {})
+      mock(subject).fork(subject.processes["alpha"])
-      mock(subject).fork(subject.processes["bravo"], {}, {})
+      mock(subject).fork(subject.processes["bravo"])
       mock(subject).watch_for_termination
       subject.start
     end
@@ -46,9 +46,9 @@ describe "Foreman::Engine" do
     it "handles concurrency" do
       write_procfile
       engine = Foreman::Engine.new("Procfile",:concurrency => "alpha=2")
-      mock(engine).fork_individual(engine.processes["alpha"], 1, 5000, {})
+      mock(engine).fork_individual(engine.processes["alpha"], 1, 5000)
-      mock(engine).fork_individual(engine.processes["alpha"], 2, 5001, {})
+      mock(engine).fork_individual(engine.processes["alpha"], 2, 5001)
-      mock(engine).fork_individual(engine.processes["bravo"], 1, 5100, {})
+      mock(engine).fork_individual(engine.processes["bravo"], 1, 5100)
       mock(engine).watch_for_termination
       engine.start
     end
@@ -57,7 +57,7 @@ describe "Foreman::Engine" do
   describe "execute" do
     it "runs the processes" do
       write_procfile
-      mock(subject).fork(subject.processes["alpha"], {}, {})
+      mock(subject).fork(subject.processes["alpha"])
       mock(subject).watch_for_termination
       subject.execute("alpha")
     end
@@ -81,9 +81,6 @@ describe "Foreman::Engine" do
     it "should fail if specified and doesnt exist" do
       mock.instance_of(Foreman::Engine).error("No such file: /tmp/env")
       engine = Foreman::Engine.new("Procfile", :env => "/tmp/env")
-      stub(engine).info
-      mock(engine).watch_for_termination
-      engine.execute("alpha")
     end
 
     it "should read .env if none specified" do
@@ -91,7 +88,7 @@ describe "Foreman::Engine" do
       engine = Foreman::Engine.new("Procfile")
       stub(engine).info
       mock(engine).watch_for_termination
-      mock(engine).fork_individual(anything, anything, anything, { "FOO" => "qoo" })
+      mock(engine).fork_individual(anything, anything, anything)
       engine.execute("bravo")
     end
   end