rework loop to pass rubocop

lib/avalon/batch/manifest.rb

@@ -12,164 +12,38 @@
 #   specific language governing permissions and limitations under the License.
 # ---  END LICENSE_HEADER BLOCK  ---
 
-require 'roo'
-
-module Avalon
-  module Batch
-    class Manifest
-      include Enumerable
-      extend Forwardable
-
-      EXTENSIONS = ['csv','xls','xlsx','ods']
-      FILE_FIELDS = [:file,:label,:offset,:skip_transcoding,:absolute_location,:date_digitized]
-      SKIP_FIELDS = [:collection]
-
-      def_delegators :@entries, :each
-      attr_reader :spreadsheet, :file, :name, :email, :entries, :package
-
-      class << self
-        def locate(root)
-          possibles = Dir[File.join(root, "**/*.{#{EXTENSIONS.join(',')}}")]
-          possibles.reject do |file|
-            File.basename(file) =~ /^~\$/ or self.error?(file) or self.processing?(file) or self.processed?(file)
-          end
-        end
-
-        def error?(file)
-          if File.file?("#{file}.error")
-            if File.mtime(file) > File.mtime("#{file}.error")
-              File.unlink("#{file}.error")
-              return false
-            else
-              return true
-            end
-          end
-          return false
-        end
-
-        def processing?(file)
-          File.file?("#{file}.processing")
-        end
-
-        def processed?(file)
-          File.file?("#{file}.processed")
-        end
-      end
-
-      def initialize(file, package)
-        @file = file
-        @package = package
-        load!
-      end
-
-      def load!
-        @entries = []
-        begin
-          @spreadsheet = Roo::Spreadsheet.open(file)
-          @name = @spreadsheet.row(@spreadsheet.first_row)[0]
-          @email = @spreadsheet.row(@spreadsheet.first_row)[1]
-
-          header_row = @spreadsheet.row(@spreadsheet.first_row + 1)
-
-          @field_names = header_row.collect { |field|
-            field.to_s.downcase.gsub(/\s/,'_').strip.to_sym
-          }
-          create_entries!
-        rescue Exception => err
-          error! "Invalid manifest file: #{err.message}"
-        end
-      end
-
-      def start!
-        File.open("#{@file}.processing",'w') { |f| f.puts Time.now.xmlschema }
-      end
-
-      def error! msg=nil
-        File.open("#{@file}.error",'a') do |f|
-          if msg.nil?
-            entries.each do |entry|
-              if entry.errors.count > 0
-                f.puts "Row #{entry.row}:"
-                entry.errors.messages.each { |k,m| f.puts %{  #{m.join("\n  ")}} }
-              end
-            end
-          else
-            f.puts msg
-          end
-        end
-        rollback! if processing?
-      end
-
-      def rollback!
-        File.unlink("#{@file}.processing")
-      end
-
-      def commit!
-        File.open("#{@file}.processed",'w') { |f| f.puts Time.now.xmlschema }
-        rollback! if processing?
-      end
-
-      def error?
-        result = self.class.error?(@file)
-        load! unless result
-        result
-      end
-
-      def processing?
-        self.class.processing?(@file)
-      end
-
-      def processed?
-        self.class.processed?(@file)
-      end
-
-      def errors
-        @errors ||= []
-      end
-
-      private
-      def true?(value)
-        not (value.to_s =~ /^(y(es)?|t(rue)?)$/i).nil?
-      end
-
-      def create_entries!
-        f = @spreadsheet.first_row + 2
-        l = @spreadsheet.last_row
-        f.upto(l) do |index|
-          opts = {
-            :publish => false,
-            :hidden  => false
-          }
-
-          values = @spreadsheet.row(index).collect do |val|
-            (val.is_a?(Float) and (val == val.to_i)) ? val.to_i.to_s : val.to_s
-          end
-          content=[]
-
-          fields = Hash.new { |h,k| h[k] = [] }
-          @field_names.each_with_index do |f,i|
-            unless f.blank? || SKIP_FIELDS.include?(f) || values[i].blank?
-              if FILE_FIELDS.include?(f)
-                content << {} if f == :file
-                content.last[f] = f == :skip_transcoding ? true?(values[i]) : values[i]
-              else
-                fields[f] << values[i]
-              end
-            end
-          end
-
-          opts.keys.each { |opt|
-            val = Array(fields.delete(opt)).first.to_s
-            if opts[opt].is_a?(TrueClass) or opts[opt].is_a?(FalseClass)
-              opts[opt] = true?(val)
-            else
-              opts[opt] = val
-            end
-          }
-          entries << Entry.new(fields.select { |f| !FILE_FIELDS.include?(f) }, content, opts, index, self)
-        end
-      end
-
-    end
-  end
+class IngestBatchMailer < ActionMailer::Base
+ layout 'mailer'
+
+ def status_email(ingest_batch_id)
+   @ingest_batch = IngestBatch.find(ingest_batch_id)
+   @media_objects = @ingest_batch.media_objects
+   @email = @ingest_batch.email || Avalon::Configuration.lookup('email.notification')
+   mail(
+     to: @email,
+     from: Avalon::Configuration.lookup('email.notification'),
+     subject: "Batch ingest status for: #{@ingest_batch.name}"
+   )
+ end
+
+ def batch_ingest_validation_error(package, base_errors)
+   @package = package
+   @base_errors = base_errors
+   email = package.manifest.email || Avalon::Configuration.lookup('email.notification')
+   mail(
+     to: email,
+     from: Avalon::Configuration.lookup('email.notification'),
+     subject: "Failed batch ingest processing errors for: #{package.manifest.name}"
+   )
+ end
+
+ def batch_ingest_validation_success(package)
+   @package = package
+   email = package.manifest.email || Avalon::Configuration.lookup('email.notification')
+   mail(
+     to: email,
+     from: Avalon::Configuration.lookup('email.notification'),
+     subject: "Successfully processed batch ingest: #{package.manifest.name}"
+   )
+ end
 end