Add ability to stream (and indent) command output

2 files changed, 43 insertions, 0 deletions

diff --git a/lib/chef/event_dispatch/base.rb b/lib/chef/event_dispatch/base.rb
index 82beefeec9..bfd4503097 100644
--- a/lib/chef/event_dispatch/base.rb
+++ b/lib/chef/event_dispatch/base.rb
@@ -277,6 +277,20 @@ class Chef
       def resource_updated(resource, action)
       end
 
+      # A stream has opened.
+      def stream_opened(stream, options = {})
+      end
+
+      # A stream has closed.
+      def stream_closed(stream, options = {})
+      end
+
+      # A chunk of data from a stream.  The stream is managed by "stream," which
+      # can be any tag whatsoever.  Data in different "streams" may not be placed
+      # on the same line or even sent to the same console.
+      def stream_output(stream, output, options = {})
+      end
+
       # Called before handlers run
       def handlers_start(handler_count)
       end
diff --git a/lib/chef/event_dispatch/events_output_stream.rb b/lib/chef/event_dispatch/events_output_stream.rb
new file mode 100644
index 0000000000..8de9b0fed1
--- /dev/null
+++ b/lib/chef/event_dispatch/events_output_stream.rb
@@ -0,0 +1,29 @@
+class Chef
+  module EventDispatch
+    class EventsOutputStream
+      # This is a fake stream that connects to events.
+      #
+      # == Arguments
+      # events: the EventDispatch object to send data to (run_context.events)
+      # options is a hash with these possible options:
+      # - name: a string that identifies the stream to the user. Preferably short.
+
+      def initialize(events, options = {})
+        @events = events
+        @options = options
+        events.stream_opened(self, options)
+      end
+
+      attr_reader :options
+      attr_reader :events
+
+      def print(str)
+        events.stream_output(self, str, options)
+      end
+
+      def close
+        events.stream_closed(self, options)
+      end
+    end
+  end
+end