lib/rspeed/observer.rb in rspeed-0.5.1 vs lib/rspeed/observer.rb in rspeed-0.5.2

@@ -7,37 +7,38 @@
     def after(example)
       file_path   = example.metadata[:file_path]
       line_number = example.metadata[:line_number]
       spent_time  = example.clock.now - example.metadata[:start_at]
 
-      File.open(RSpeed::Variable::CSV, 'a') do |file|
-        file.write("#{spent_time},#{file_path}:#{line_number}\n")
-      end
+      json = { file: "#{file_path}:#{line_number}", time: spent_time }.to_json
+
+      RSpeed::Redis.client.lpush(RSpeed::Variable.profile, json)
     end
 
     def after_suite(splitter = ::RSpeed::Splitter.new)
       RSpeed::Redis.set(RSpeed::Variable.pipe_name, true)
 
-      splitter.append if splitter.append?
-
       return unless RSpeed::Redis.specs_finished?
 
       splitter.rename
 
       RSpeed::Redis.clean
+
+      RSpeed::Logger.log('RSpeed finished.')
     end
 
     def before(example)
       example.update_inherited_metadata(start_at: example.clock.now)
     end
 
     def before_suite
-      truncate_csv_file
-
-      RSpeed::Redis.destroy(RSpeed::Variable.tmp) unless RSpeed::Redis.specs_initiated?
+      clean_profile
     end
 
-    def truncate_csv_file
-      File.open(RSpeed::Variable::CSV, 'w') { |file| file.truncate(0) }
+    def clean_profile
+      RSpeed::Logger.log('[RSpeed::Observer#clean_profile] Cleanning current flag and profile.')
+
+      RSpeed::Redis.destroy(RSpeed::Variable.pipe_name)
+      RSpeed::Redis.destroy(RSpeed::Variable.profile)
     end
   end
 end