63 行
2.3 KiB
Ruby
63 行
2.3 KiB
Ruby
class PostImportRunner
|
|
def initialize actor:, rows:
|
|
@actor = actor
|
|
@rows = rows
|
|
end
|
|
|
|
def run
|
|
normalised_rows = PostImportRowNormaliser.normalise!(@rows)
|
|
|
|
results = normalised_rows.map { |row| run_row(row) }
|
|
{
|
|
created: results.count { _1[:status] == 'created' },
|
|
skipped: results.count { _1[:status] == 'skipped' },
|
|
failed: results.count { _1[:status] == 'failed' },
|
|
rows: results,
|
|
}
|
|
end
|
|
|
|
private
|
|
|
|
def run_row row
|
|
attributes = row.fetch('attributes', { }).transform_keys { _1.to_s.underscore }
|
|
preview = PostImportPreviewer.new.preview_rows(
|
|
rows: [{
|
|
source_row: row['source_row'],
|
|
url: row['url'],
|
|
attributes:,
|
|
provenance: row['provenance'],
|
|
tag_sources: row['tag_sources'],
|
|
}],
|
|
fetch_metadata: false).first
|
|
if Array(preview.dig(:field_warnings, 'url')).include?(PostImportPreviewer::EXISTING_SKIP_WARNING)
|
|
return row.slice('source_row').merge(status: 'skipped')
|
|
end
|
|
|
|
if preview[:validation_errors].present?
|
|
return {
|
|
source_row: row['source_row'],
|
|
status: 'failed',
|
|
errors: preview[:validation_errors],
|
|
}
|
|
end
|
|
|
|
attributes['tags'] = preview[:attributes]['tags']
|
|
attributes['url'] = row['url']
|
|
post = PostCreator.new(actor: @actor, attributes:).create!
|
|
{ source_row: row['source_row'], status: 'created', post: PostRepr.base(post) }
|
|
rescue ActiveRecord::RecordInvalid => e
|
|
{ source_row: row['source_row'], status: 'failed', errors: e.record.errors.to_hash }
|
|
rescue Tag::NicoTagNormalisationError
|
|
{ source_row: row['source_row'], status: 'failed', errors: { tags: ['ニコニコ・タグは直接指定できません．'] } }
|
|
rescue Tag::DeprecatedTagNormalisationError
|
|
{ source_row: row['source_row'], status: 'failed', errors: { tags: ['廃止済みタグは付与できません．'] } }
|
|
rescue ArgumentError, PostCreator::VideoMsParseError
|
|
{ source_row: row['source_row'], status: 'failed', errors: { base: ['入力値が不正です．'] } }
|
|
rescue StandardError => e
|
|
Rails.logger.error(
|
|
"post_import_runner_failure #{ { error: e.class.name, message: e.message }.to_json }",
|
|
)
|
|
{ source_row: row['source_row'], status: 'failed', errors: { base: ['登録中にエラーが発生しました．'] } }
|
|
end
|
|
end
|