adding assets setter and getter to BulkTask

app/models/bulk_task.rb

@@ -19,6 +19,16 @@ def self.refresh
     end
   end
 
+  def assets
+    return nil if asset_ids.nil?
+    @assets ||= self.asset_ids.map { |pid| ActiveFedora::Base.find(:pid => pid).first }   
+  end
+
+  def assets=(as)
+    @assets = assets
+    self.asset_ids = as.map { |a| a.pid }
+  end
+
   def status
     ActiveSupport::StringInquirer.new(attributes['status'])
   end
@@ -55,20 +65,21 @@ def enqueue
   def ingest
     raise 'Already ingested batch job.' if ingested?
     begin
-      assets = send("ingest_#{type}")
+      self.assets = send("ingest_#{type}")
     rescue OregonDigital::CsvBulkIngestible::CsvBatchError => e
       build_errors(e)
       raise e
     end
-    self.asset_ids = assets.map { |a| a.pid }
     clear_errors
     self.status = 'ingested'
     self.save
   end
 
   def delete_assets
     return status if asset_ids.nil?
-    self.asset_ids.map { |pid| ActiveFedora::Base.find(:pid => pid).first.delete }
+    self.assets.each do |asset|
+      asset.delete
+    end
     self.asset_ids = nil
     self.status = 'deleted'
     self.save
@@ -147,7 +158,7 @@ def build_errors(e)
     end
 
     def ingest_csv
-      assets = GenericAsset.ingest_from_csv(absolute_path)
+      GenericAsset.ingest_from_csv(absolute_path)
     end
 
     def ingest_bag

spec/models/bulk_task_spec.rb

@@ -21,6 +21,29 @@
       expect(subject).to be_new
     end
   end
+
+  describe 'assets' do
+    before do
+      subject.assets = assets
+    end
+
+    it 'has assets' do
+      expect(subject.assets).to eq assets
+    end
+
+    it 'has asset ids' do
+      expect(subject.asset_ids).to eq pids
+    end
+
+    context 'when resetting assets' do
+      before do
+        subject.assets = [GenericAsset.new, GenericAsset.new].map { |asset| asset.save; asset }
+      end
+      it 'overrides old assets' do
+        expect(subject.assets).to eq assets
+      end
+    end
+  end
 
   describe 'refresh' do
     before do