#399

backend/app/services/post_import_runner.rb

@@ -18,6 +18,7 @@ class PostImportRunner
   private
 
   def run_row row
+    validate_row_structure!(row)
     attributes = row.fetch('attributes', { }).to_h.transform_keys { _1.to_s.underscore }
     raise ArgumentError, '取込項目が不正です．' unless (attributes.keys - ATTRIBUTE_KEYS).empty?
     raise ArgumentError, '取込項目が大きすぎます．' if attributes.values.any? { _1.to_s.bytesize > PostImportSourceParser::MAX_CELL_BYTES }
@@ -57,4 +58,16 @@ class PostImportRunner
     raise ArgumentError if sources.values.any? { _1.bytesize > PostImportSourceParser::MAX_CELL_BYTES }
     raise ArgumentError if sources.values.sum(&:bytesize) > PostImportSourceParser::MAX_CELL_BYTES
   end
+
+  def validate_row_structure! row
+    provenance = row['provenance']
+    raise ArgumentError unless provenance.is_a?(Hash)
+    allowed = ATTRIBUTE_KEYS + ['url']
+    raise ArgumentError unless (provenance.keys - allowed).empty?
+    raise ArgumentError unless provenance.values.all? { _1.in?(['automatic', 'mapped', 'fixed', 'manual']) }
+    metadata_url = row['metadata_url']
+    raise ArgumentError unless metadata_url.nil? || metadata_url.is_a?(String)
+    raise ArgumentError if metadata_url.to_s.bytesize > PostImportSourceParser::MAX_CELL_BYTES
+    raise ArgumentError if row.to_json.bytesize > PostImportSourceParser::MAX_BYTES
+  end
 end