Merge pull request acidprime#2 from raphink/dev/pass_env

Allow to pass optional environment for each server name

Author: acidprime

lib/puppet/catalog-diff/compilecatalog.rb

@@ -34,7 +34,8 @@ def lookup_environment(node_name)
     end
 
     def compile_catalog(node_name,server)
-      environment = lookup_environment(node_name)
+      server,environment = server.split('/')
+      environment ||= lookup_environment(node_name)
       endpoint = "/#{environment}/catalog/#{node_name}"
       Puppet.debug("Connecting to server: #{server}")
       begin

lib/puppet/catalog-diff/searchfacts.rb

@@ -15,7 +15,7 @@ def find_nodes(options = {})
      if options[:use_puppetdb]
        active_nodes = find_nodes_puppetdb()
      else
-       active_nodes = find_nodes_rest(options[:old_server])
+       active_nodes = find_nodes_rest(options[:old_server].split('/')[0])
      end
      if active_nodes.empty?
        raise "No active nodes were returned from your fact search"

lib/puppet/face/catalog/diff.rb

@@ -119,8 +119,8 @@
 
       else
         # User passed use two hostnames
-        old_catalogs = Dir.mktmpdir("#{catalog1}-")
-        new_catalogs = Dir.mktmpdir("#{catalog2}-")
+        old_catalogs = Dir.mktmpdir("#{catalog1.gsub('/', '_')}-")
+        new_catalogs = Dir.mktmpdir("#{catalog2.gsub('/', '_')}-")
         pull_output = Puppet::Face[:catalog, '0.0.1'].pull(old_catalogs,new_catalogs,options[:fact_search],:old_server => catalog1,:new_server => catalog2,:changed_depth => options[:changed_depth], :threads => options[:threads])
         diff_output = Puppet::Face[:catalog, '0.0.1'].diff(old_catalogs,new_catalogs,options)
         nodes = diff_output