plugin_manager.rb

class SiriProxy::PluginManager
	attr_accessor :plugins

	def initialize()
	  load_plugins()	
	
		@blockNextObjectsFromServer = 0
		@blockNextObjectsFromClient = 0
		@blockRestOfSessionFromServer = false
	end

  def load_plugins()
    @plugins = []
    if APP_CONFIG.plugins
      APP_CONFIG.plugins.each do |pluginConfig|
          if pluginConfig.is_a? String
            className = pluginConfig
            requireName = "siriproxy-#{className.downcase}"
          else
            className = pluginConfig['name']
            requireName = pluginConfig['require'] || "siriproxy-#{className.downcase}"
          end
          require requireName 
          plugin = SiriProxy::Plugin.const_get(className).new(pluginConfig)
          plugin.plugin_manager = self
          @plugins << plugin
      end
    end
		puts "Plugins laoded: #{@plugins}"
  end
	
	def object_from_guzzoni(object, connection) 
		if(@blockRestOfSessionFromServer)
			if(connection.last_ref_id == object["refId"])
				puts "[Info - Dropping Object from Guzzoni] #{object["class"]}"
				return nil
			else
				@blockRestOfSessionFromServer = false
			end
		end
		
		if(@blockNextObjectsFromServer > 0)
			puts "[Info - Dropping Object from Guzzoni] #{object["class"]}"
			@blockNextObjectsFromServer -= 1
			return nil
		end
		
		plugins.each { |plugin|
			object = plugin.object_from_guzzoni(object, connection)
		}
		
		object
	end
	
	def object_from_client(object, connection)
		if(@blockNextObjectsFromClient > 0)
			puts "[Info - Dropping Object from iPhone] #{object["class"]}"
			@blockNextObjectsFromClient -= 1
			return nil
		end
		
		##Often this indicates a bug in OUR code. So let's not send it to Apple. :-)
		if(object["class"] == "CommandIgnored")
			pp object
			return nil
		end
		
		plugins.each { |plugin|
			object = plugin.object_from_client(object, connection)
		}

		# This is used for commands from phone that should not be sent back to Apple, 
		# and will be interpreted by plugins directly
		if(object && object["properties"] && object['properties']['proxyOnly'])
			puts "[Info - Not forwarding Object from iPhone because proxyOnly flag was set] #{object["class"]}"
			return nil
		end
		
		object
	end
	
	def unknown_command(object, connection, command)
		puts "[UnknownCommand] #{command}"

		plugins.each { |plugin|
			object = plugin.unknown_command(object, connection, command)
		}

		object
	end
	
	def speech_recognized(object, connection, phrase)
		puts "[Recognized Speech] #{phrase}"
		
		plugins.each { |plugin|
			object = plugin.speech_recognized(object, connection, phrase)
		}
		
		object
	end
	
	
	def block_next_objects_from_server(count=1)
		@blockNextObjectsFromServer += count		
	end
	
	def block_next_objects_from_client(count=1)
		@blockNextObjectsFromClient += count		
	end
	
	#Blocks everything from server until a new refId is seen
	def block_rest_of_session_from_server
		@blockRestOfSessionFromServer = true
	end
end