#405

AGENTS.md

@@ -114,9 +114,6 @@ npm run preview
 - Ruby: `render` 系メソッド呼び出しでは、keyword 引数付きでも括弧を書かない。
 - Ruby: never put a line break immediately before `)`.
 - Ruby: do not use `%w` or `%i`.
-- Ruby: TypeScript / TSX の associative syntax に近い感覚で読むこと。
-  Hash の `}` は block の `}` ではない。call の `)` も function 定義の
-  parameter-list `)` ではない。delimiter の役割を見誤らないこと。
 - In Ruby, when an `if` condition is split across multiple lines and combines
   clauses with `&&` or `||`, wrap the whole condition in parentheses.
 - Ruby hashes are not blocks; keep `}` on the same line as the final pair.
@@ -130,152 +127,6 @@ npm run preview
 - Keep the first element on the same line as `[` by default.
 - If an array would exceed the line limit, break after `[` and indent
   elements by 4 spaces.
-
-### Ruby delimiter and wrapping rules
-
-- Ruby でも、closing delimiter は glyph ではなく syntax role で判定する。
-  `}` が block close なのか hash close なのか、`)` が method call なのか
-  grouping なのかを区別してから配置すること。
-- Ruby の multi-line method call では、receiver / method と opening `(` を
-  同じ行に保ち、closing `)` を単独行へ落とさない。
-- Ruby の multi-line hash literal / keyword-like argument hash では、opening
-  `{` を最初の pair と同じ行に置き、closing `}` を最後の pair と同じ行に
-  置く。Prettier 的な縦開き・縦閉じをしない。
-- Ruby の `if` / `unless` / `case` 条件で、複数行に分けるだけで安易に
-  `if ... end` へ展開しない。局所の既存コードが modifier 形式ならそれに
-  そろえる。
-- Ruby の guard 条件は、1 行で収まるなら modifier 形式を優先する。2 行以上に
-  なるなら通常の block 形式へ切り替へてよい。
-- Ruby の method chain や call argument を折り返す際、call-site の `)`
-  直前で行を空けたり、closing delimiter を block のやうに独立させない。
-
-Bad:
-
-```rb
-source =
-  if params[:format] == 'google_sheets'
-    PostImportGoogleSheetsFetcher.fetch!(params[:source],
-                                         rate_key: current_user.id)
-  else
-    params[:source]
-  end
-parsed = PostImportSourceParser.new(
-  source:,
-  format:,
-  has_header: params[:has_header],
-  json_path: params[:json_path],
-).parse
-```
-
-Good:
-
-```rb
-source =
-    if params[:format] == 'google_sheets'
-      PostImportGoogleSheetsFetcher.fetch!(params[:source],
-                                           rate_key: current_user.id)
-    else
-      params[:source]
-    end
-parsed = PostImportSourceParser.new(
-    source:,
-    format:,
-    has_header: params[:has_header],
-    json_path: params[:json_path]).parse
-```
-
-Bad:
-
-```rb
-result[field] = {
-  'kind' => kind,
-  'value' => value['value'].to_s,
-  'columns' => Array(columns).map { Integer(_1) },
-}
-```
-
-Good:
-
-```rb
-result[field] = {
-    'kind' => kind,
-    'value' => value['value'].to_s,
-    'columns' => Array(columns).map { Integer(_1) } }
-```
-
-Bad:
-
-```rb
-unless rows.all? { |row|
-         values = Array(row['values'])
-         values.length <= columns.length &&
-           values.all? { |value|
-             value.is_a?(String) &&
-               value.bytesize <= PostImportSourceParser::MAX_CELL_BYTES
-           }
-       }
-  raise ArgumentError, '解析結果のセルが不正です．'
-end
-```
-
-Good:
-
-```rb
-raise ArgumentError, '解析結果のセルが不正です．' unless rows.all? { |row|
-  values = Array(row['values'])
-  values.length <= columns.length && values.all? { |value|
-    value.is_a?(String) && value.bytesize <= PostImportSourceParser::MAX_CELL_BYTES
-  }
-}
-```
-
-Bad:
-
-```rb
-if row['url'].to_s.bytesize > PostImportSourceParser::MAX_CELL_BYTES
-  raise ArgumentError, 'URL が長すぎます．'
-end
-```
-
-Good:
-
-```rb
-raise ArgumentError, 'URL が長すぎます．' if row['url'].to_s.bytesize > PostImportSourceParser::MAX_CELL_BYTES
-```
-
-Bad:
-
-```rb
-parameters = row.is_a?(ActionController::Parameters) ? row :
-  ActionController::Parameters.new(row)
-```
-
-Good:
-
-```rb
-parameters =
-    row.is_a?(ActionController::Parameters) ? row : ActionController::Parameters.new(row)
-```
-
-Bad:
-
-```rb
-PostTagSection.create!(
-  post_id: post.id,
-  tag_id:,
-  begin_ms:,
-  end_ms:,
-)
-```
-
-Good:
-
-```rb
-PostTagSection.create!(post_id: post.id,
-                       tag_id:,
-                       begin_ms:,
-                       end_ms:)
-```
 - TypeScript and Python: use GNU-style spacing before parentheses where
   syntactically valid.
 - Never write Ruby, TypeScript, or TSX lines longer than 99 characters.

backend/app/controllers/post_imports_controller.rb

@@ -1,44 +0,0 @@
-class PostImportsController < ApplicationController
-  before_action :require_member!
-
-  def preview
-    rows = PostImportPreviewer.new.preview_rows(
-        rows: PostImportUrlListParser.parse(params[:source]))
-    render json: { rows: }
-  rescue ArgumentError => e
-    render_bad_request(e.message)
-  end
-
-  def validate
-    rows = normalised_import_rows(allow_warning_fields: true)
-    changed_row = Integer(params[:changed_row], exception: false)
-    result =
-        PostImportPreviewer.new.preview_rows(rows:,
-                                             fetch_metadata: changed_row,
-                                             metadata_cache: { })
-    render json: { rows: result }
-  rescue ArgumentError => e
-    render_bad_request(e.message)
-  end
-
-  def create
-    result = PostImportRunner.new(actor: current_user,
-                                  rows: normalised_import_rows).run
-    render json: result, status: result[:created].positive? ? :created : :ok
-  rescue ArgumentError => e
-    render_bad_request(e.message)
-  end
-
-  private
-
-  def require_member!
-    return head :unauthorized unless current_user
-    return if current_user.gte_member?
-
-    head :forbidden
-  end
-
-  def normalised_import_rows allow_warning_fields: false
-    PostImportRowNormaliser.normalise!(params[:rows], allow_warning_fields:)
-  end
-end

backend/app/controllers/posts_controller.rb

@@ -142,13 +142,37 @@ class PostsController < ApplicationController
     return head :unauthorized unless current_user
     return head :forbidden unless current_user.gte_member?
 
-    post = PostCreator.new(actor: current_user,
-                           attributes: { title: params[:title], url: params[:url],
-                                         thumbnail: params[:thumbnail], tags: params[:tags],
-                                         original_created_from: params[:original_created_from],
-                                         original_created_before: params[:original_created_before],
-                                         parent_post_ids: parse_parent_post_ids,
-                                         video_ms: params[:video_ms], duration: params[:duration] }).create!
+    # TODO: サイトに応じて thumbnail_base 設定
+    title = params[:title].presence
+    url = params[:url]
+    thumbnail = params[:thumbnail]
+    tag_names = params[:tags].to_s.split
+    original_created_from = params[:original_created_from]
+    original_created_before = params[:original_created_before]
+    parent_post_ids = parse_parent_post_ids
+    resized_thumbnail = thumbnail.present? ? Post.resized_thumbnail_attachment(thumbnail) : nil
+
+    post = Post.new(title:, url:, thumbnail_base: nil, uploaded_user: current_user,
+                    original_created_from:, original_created_before:)
+    post.thumbnail.attach(resized_thumbnail) if resized_thumbnail
+
+    ApplicationRecord.transaction do
+      post.save!
+
+      Tag.normalise_tags!(tag_names, deny_deprecated: true, with_sections: true) =>
+          { tags:, sections: }
+      TagVersioning.record_tag_snapshots!(tags, created_by_user: current_user)
+
+      tags = Tag.expand_parent_tags(tags).reject(&:deprecated?)
+      post.video_ms = normalise_video_ms(tags)
+      validate_video_sections!(post.video_ms, sections)
+      post.save!
+      sync_post_tags!(post, tags, sections)
+
+      sync_parent_posts!(post, parent_post_ids)
+
+      PostVersionRecorder.record!(post:, event_type: :create, created_by_user: current_user)
+    end
 
     post.reload
     render json: PostRepr.base(post), status: :created
@@ -158,7 +182,7 @@ class PostsController < ApplicationController
     render_unprocessable_entity '廃止済みタグは付与できません．', field: :tags
   rescue Tag::SectionLiteralParseError
     render_validation_error fields: { tags: ['タグ区間の記法が不正です．'] }
-  rescue PostCreator::VideoMsParseError
+  rescue VideoMsParseError
     render_validation_error fields: { video_ms: ['動画時間の記法が不正です．'] }
   rescue MiniMagick::Error
     render_validation_error fields: { thumbnail: ['サムネイル画像の変換に失敗しました．'] }

backend/app/models/post.rb

@@ -57,9 +57,9 @@ class Post < ApplicationRecord
 
   attribute :version_no, :integer, default: 1
 
-  before_validation :normalise_url, if: :will_save_change_to_url?
+  before_validation :normalise_url
 
-  validates :url, presence: true, uniqueness: true, length: { maximum: 768 }
+  validates :url, presence: true, uniqueness: true
   validates :video_ms, numericality: { only_integer: true, greater_than: 0 }, allow_nil: true
 
   validate :validate_original_created_range
@@ -173,14 +173,14 @@ class Post < ApplicationRecord
   def normalise_url
     return if url.blank?
 
-    self.url = PostUrlNormaliser.normalise(url) || url.strip
+    self.url = url.strip
 
     u = URI.parse(url)
     return unless u in URI::HTTP
 
     u.host = u.host.downcase if u.host
     u.path = u.path.sub(/\/\Z/, '') if u.path.present?
-    self.url = PostUrlSanitisationRule.sanitise(u.to_s)
+    self.url = u.to_s
   rescue URI::InvalidURIError
     ;
   end

backend/app/models/post_url_sanitisation_rule.rb

@@ -1,163 +0,0 @@
-class PostUrlSanitisationRule < ApplicationRecord
-  include Discard::Model
-
-  class InvalidUrlError < StandardError
-    attr_reader :invalid_rows
-
-    def initialize(invalid_rows)
-      @invalid_rows = invalid_rows
-      ids = invalid_rows.map { _1.fetch(:post_id) }.join(', ')
-      super("post URL sanitisation produced invalid URLs for posts #{ ids }")
-    end
-  end
-
-  class UrlConflictError < StandardError
-    attr_reader :conflicts
-
-    def initialize(conflicts)
-      @conflicts = conflicts
-      urls = conflicts.map { _1.fetch(:url) }.uniq.join(', ')
-      super("post URL sanitisation conflicts detected for #{ urls }")
-    end
-  end
-
-  self.primary_key = :priority
-
-  default_scope -> { kept }
-
-  validates :source_pattern, presence: true, uniqueness: true
-
-  validate :source_pattern_must_be_regexp
-
-  class << self
-    def sanitise(url) = sanitise_with_rules(url, rules)
-
-    def apply!
-      rewrites = nil
-
-      Post.transaction do
-        compiled_rules = rules
-
-        rewrites = Post.order(:id)
-                       .lock('FOR UPDATE')
-                       .pluck(:id, :url)
-                       .map do |post_id, original_url|
-          { post_id:,
-            original_url:,
-            sanitised_url: sanitise_with_rules(original_url, compiled_rules) }
-        end
-
-        invalid_rows = rewrites.filter { invalid_sanitised_url?(_1.fetch(:sanitised_url)) }
-                               .map { { post_id: _1.fetch(:post_id),
-                                        original_url: _1.fetch(:original_url),
-                                        sanitised_url: _1.fetch(:sanitised_url) } }
-        raise InvalidUrlError.new(invalid_rows) if invalid_rows.present?
-
-        conflicts = build_conflicts(rewrites)
-        raise UrlConflictError.new(conflicts) if conflicts.present?
-
-        changed = rewrites.filter { _1.fetch(:original_url) != _1.fetch(:sanitised_url) }
-        return if changed.empty?
-
-        token = SecureRandom.hex(6)
-
-        changed.each do |row|
-          Post.where(id: row.fetch(:post_id))
-              .update_all(url: temporary_url_for(row.fetch(:post_id), token))
-        end
-
-        changed.each do |row|
-          Post.where(id: row.fetch(:post_id))
-              .update_all(url: row.fetch(:sanitised_url))
-        end
-      end
-    rescue ActiveRecord::RecordNotUnique => error
-      conflicts = build_persisted_conflicts(rewrites)
-      raise error if conflicts.empty?
-
-      raise UrlConflictError.new(conflicts), cause: error
-    end
-
-    private
-
-    def rules = kept.order(:priority).map { |r| [Regexp.new(r.source_pattern), r.replacement] }
-
-    def sanitise_with_rules(url, compiled_rules)
-      compiled_rules.reduce(url.dup) do |value, (pattern, replacement)|
-        value.sub(pattern, replacement)
-      end
-    end
-
-    def temporary_url_for(post_id, token) =
-        "https://post-url-sanitising.invalid/#{ token }/#{ post_id }"
-
-    def invalid_sanitised_url?(url)
-      return true if url.blank?
-      return true if url.length > 768
-
-      parsed = URI.parse(url)
-      return true if !(parsed in URI::HTTP)
-      return true if parsed.host.blank?
-
-      false
-    rescue URI::InvalidURIError
-      true
-    end
-
-    def build_conflicts(rewrites)
-      rewrites
-          .group_by { _1.fetch(:sanitised_url).downcase }
-          .values
-          .filter { _1.size > 1 }
-          .flatten
-          .map { { url: _1.fetch(:sanitised_url),
-                   post_id: _1.fetch(:post_id),
-                   original_url: _1.fetch(:original_url) } }
-    end
-
-    def build_persisted_conflicts(rewrites)
-      return [] if rewrites.blank?
-
-      target_rows = rewrites.filter { _1.fetch(:original_url) != _1.fetch(:sanitised_url) }
-      target_keys = target_rows.map { _1.fetch(:sanitised_url).downcase }.uniq
-      return [] if target_keys.empty?
-
-      target_pairs = target_rows.to_h do |row|
-        [row.fetch(:post_id), row.fetch(:sanitised_url).downcase]
-      end
-
-      persisted_rows = Post.order(:id)
-                           .where('LOWER(url) IN (?)', target_keys)
-                           .pluck(:id, :url)
-                           .reject { |post_id, original_url| target_pairs[post_id] == original_url.downcase }
-                           .map { |post_id, original_url|
-        { url: original_url,
-          post_id:,
-          original_url:,
-          conflict_key: original_url.downcase }
-      }
-
-      target_conflicts = target_rows.map { { url: _1.fetch(:sanitised_url),
-                                             post_id: _1.fetch(:post_id),
-                                             original_url: _1.fetch(:original_url),
-                                             conflict_key: _1.fetch(:sanitised_url).downcase } }
-
-      (persisted_rows + target_conflicts)
-          .group_by { _1.fetch(:conflict_key) }
-          .values
-          .filter { _1.size > 1 }
-          .flatten
-          .map { _1.except(:conflict_key) }
-    end
-  end
-
-  private
-
-  def source_pattern_must_be_regexp
-    return if source_pattern.blank?
-
-    Regexp.new(source_pattern)
-  rescue RegexpError
-    errors.add :source_pattern, '変な正規表現だね〜（笑）'
-  end
-end

backend/app/services/post_creator.rb

@@ -1,118 +0,0 @@
-class PostCreator
-  class VideoMsParseError < ArgumentError; end
-
-  def initialize actor:, attributes:
-    @actor = actor
-    @attributes = attributes.symbolize_keys
-  end
-
-  def create!
-    post = Post.new(title: @attributes[:title].presence,
-                    url: @attributes[:url],
-                    thumbnail_base: @attributes[:thumbnail_base].presence,
-                    uploaded_user: @actor,
-                    original_created_from: @attributes[:original_created_from].presence,
-                    original_created_before: @attributes[:original_created_before].presence)
-    thumbnail = @attributes[:thumbnail]
-    post.thumbnail.attach(Post.resized_thumbnail_attachment(thumbnail)) if thumbnail.present?
-
-    ApplicationRecord.transaction do
-      post.save!
-      Tag.normalise_tags!(tag_names, deny_deprecated: true, with_sections: true) =>
-          { tags:, sections: }
-      TagVersioning.record_tag_snapshots!(tags, created_by_user: @actor)
-      tags = Tag.expand_parent_tags(tags).reject(&:deprecated?)
-      post.video_ms = normalise_video_ms(tags)
-      validate_video_sections!(post.video_ms, sections)
-      post.save!
-      sync_post_tags!(post, tags, sections)
-      sync_parent_posts!(post, parent_post_ids)
-      PostVersionRecorder.record!(post:, event_type: :create, created_by_user: @actor)
-    end
-    post
-  end
-
-  private
-
-  def tag_names = @attributes[:tags].to_s.split
-
-  def parent_post_ids
-    Array(@attributes[:parent_post_ids]).flat_map { _1.to_s.split }.map { |token|
-      id = Integer(token, exception: false)
-      raise ArgumentError, "親投稿 Id. が不正です: #{ token }" if id.nil? || id <= 0
-
-      id
-    }.uniq
-  end
-
-  def normalise_video_ms tags
-    return nil unless tags.any? { _1.id == Tag.video.id }
-
-    video_ms = @attributes[:video_ms]
-    if video_ms.present?
-      value = Integer(video_ms, exception: false)
-      raise VideoMsParseError unless value&.positive?
-
-      return value
-    end
-    duration = @attributes[:duration]
-    return nil if duration.blank?
-
-    return duration.to_i if duration.is_a?(Numeric) && duration.to_i.positive?
-
-    value = Tag.time_to_ms!(duration.to_s, tag_name: '動画時間')
-    raise VideoMsParseError unless value.positive?
-
-    value
-  rescue Tag::SectionLiteralParseError
-    raise VideoMsParseError
-  end
-
-  def validate_video_sections! video_ms, sections
-    return unless video_ms
-
-    sections.each_value do |ranges|
-      ranges.each do |begin_ms, end_ms|
-        next if begin_ms < video_ms && (!end_ms || end_ms <= video_ms)
-
-        post = Post.new
-        post.errors.add :video_ms, 'タグ区間が動画時間の範囲外です．'
-        raise ActiveRecord::RecordInvalid, post
-      end
-    end
-  end
-
-  def sync_post_tags! post, desired_tags, sections
-    desired_ids = desired_tags.map(&:id).to_set
-    current_ids = post.tags.pluck(:id).to_set
-    Tag.where(id: desired_ids - current_ids).find_each do |tag|
-      PostTag.create_or_find_by!(post:, tag:, created_user: @actor)
-    end
-    PostTagSection.where(post_id: post.id).destroy_all
-    sections.each do |tag_id, ranges|
-      ranges.each do |begin_ms, end_ms|
-        PostTagSection.create!(post_id: post.id,
-                               tag_id:,
-                               begin_ms:,
-                               end_ms:)
-      end
-    end
-    PostTag.where(post_id: post.id,
-                  tag_id: (current_ids - desired_ids).to_a).kept.find_each do |post_tag|
-      post_tag.discard_by!(@actor)
-    end
-  end
-
-  def sync_parent_posts! post, ids
-    if ids.include?(post.id)
-      post.errors.add :parent_post_ids, '自分自身を親投稿にはできません．'
-      raise ActiveRecord::RecordInvalid, post
-    end
-    missing = ids - Post.where(id: ids).pluck(:id)
-    if missing.present?
-      post.errors.add :parent_post_ids, "存在しない親投稿 Id. があります: #{ missing.join(' ') }"
-      raise ActiveRecord::RecordInvalid, post
-    end
-    ids.each { |parent_post_id| PostImplication.create_or_find_by!(post:, parent_post_id:) }
-  end
-end

backend/app/services/post_import_previewer.rb

@@ -1,265 +0,0 @@
-class PostImportPreviewer
-  FIELDS = [
-    'title',
-    'thumbnail_base',
-    'original_created_from',
-    'original_created_before',
-    'duration',
-    'tags',
-    'parent_post_ids',
-  ].freeze
-  FETCH_WARNING_FIELDS = ['url', 'title', 'thumbnail_base'].freeze
-  EXISTING_SKIP_WARNING = '既存投稿のためスキップします．'.freeze
-  TITLE_FETCH_WARNING = 'タイトルを取得できませんでした．'.freeze
-  THUMBNAIL_FETCH_WARNING = 'サムネールを取得できませんでした．'.freeze
-  METADATA_FETCH_WARNING = 'メタデータを取得できませんでした．'.freeze
-
-  def preview_rows rows:, fetch_metadata: true, metadata_cache: { }
-    urls = {}
-    rows.map { |row|
-      preview_row(row, urls:, fetch_metadata:, metadata_cache:)
-    }
-  end
-
-  def normalised_url value
-    PostUrlNormaliser.normalise(value)
-  end
-
-  private
-
-  def preview_row row, urls:, fetch_metadata:, metadata_cache:
-    row = row.symbolize_keys
-    attributes = initial_attributes(row)
-    provenance = initial_provenance(row)
-    tag_sources = initial_tag_sources(row, attributes, provenance)
-    field_warnings = initial_field_warnings(row)
-    base_warnings = initial_base_warnings(row)
-    url = row[:url].to_s.strip
-    provenance['url'] = 'manual'
-    normal_url = normalised_url(url)
-    url_for_metadata = normal_url || url
-    existing_post = normal_url.present? && Post.exists?(url: normal_url)
-
-    validation_errors = {}
-    validation_errors[:url] = ['URL が不正です．'] if normal_url.blank?
-    validation_errors[:url] = ['URL が重複しています．'] if normal_url.present? && urls.key?(normal_url)
-    urls[normal_url] = true if normal_url.present?
-
-    if row[:metadata_url].present? && row[:metadata_url] != url_for_metadata
-      clear_automatic_values!(attributes, provenance, tag_sources)
-      clear_fetch_warnings!(field_warnings)
-    end
-
-    if normal_url.present? && existing_post
-      add_field_warning!(field_warnings, 'url', EXISTING_SKIP_WARNING)
-      attributes['tags'] = merged_tags(tag_sources, provenance['tags'])
-      warnings_present = field_warnings.values.any?(&:present?) || base_warnings.present?
-      return {
-        source_row: row[:source_row],
-        url: normal_url,
-        attributes:,
-        provenance:,
-        tag_sources:,
-        metadata_url: url_for_metadata,
-        field_warnings:,
-        base_warnings:,
-        validation_errors:,
-        status: validation_errors.present? ? 'error' : (warnings_present ? 'warning' : 'ready'),
-      }
-    end
-
-    should_fetch = should_fetch_metadata?(fetch_metadata, row[:source_row].to_i)
-    if should_fetch
-      clear_fetch_warnings!(field_warnings)
-      metadata = metadata_for(url_for_metadata, metadata_cache)
-      apply_metadata!(attributes, provenance, tag_sources, metadata[:data])
-      apply_fetch_warnings!(field_warnings, metadata[:warnings])
-    end
-
-    attributes['url'] = url
-    validate_basic_data(attributes, validation_errors)
-    validate_preview_tags(merged_tags(tag_sources, provenance['tags']),
-                          validation_errors,
-                          field_warnings)
-    validate_parents(attributes['parent_post_ids'], validation_errors)
-    attributes.delete('url')
-    attributes['tags'] = merged_tags(tag_sources, provenance['tags'])
-
-    warnings_present = field_warnings.values.any?(&:present?) || base_warnings.present?
-    {
-      source_row: row[:source_row],
-      url: normal_url || url,
-      attributes:,
-      provenance:,
-      tag_sources:,
-      metadata_url: url_for_metadata,
-      field_warnings:,
-      base_warnings:,
-      validation_errors:,
-      status: validation_errors.present? ? 'error' : (warnings_present ? 'warning' : 'ready'),
-    }
-  end
-
-  def should_fetch_metadata? fetch_metadata, source_row
-    case fetch_metadata
-    when true then true
-    when Integer then fetch_metadata == source_row
-    when false, nil then false
-    else raise ArgumentError, 'メタデータ取得対象が不正です．'
-    end
-  end
-
-  def initial_attributes row
-    attributes = row[:attributes]&.stringify_keys || { }
-    FIELDS.to_h { |field| [field, attributes[field].to_s] }
-  end
-
-  def initial_provenance row
-    provenance = row[:provenance]&.stringify_keys || { }
-    FIELDS.to_h { |field| [field, provenance[field].presence || 'automatic'] }
-      .merge('url' => 'manual')
-  end
-
-  def initial_tag_sources row, attributes, provenance
-    sources = row[:tag_sources]&.stringify_keys || { 'automatic' => '', 'manual' => '' }
-    sources['automatic'] = sources['automatic'].to_s
-    sources['manual'] =
-      provenance['tags'] == 'manual' ? attributes['tags'].to_s : sources['manual'].to_s
-    sources
-  end
-
-  def initial_field_warnings row
-    (row[:field_warnings] || { }).stringify_keys.transform_values { |value| Array(value).map(&:to_s) }
-  end
-
-  def initial_base_warnings row
-    Array(row[:base_warnings]).map(&:to_s)
-  end
-
-  def clear_automatic_values! attributes, provenance, tag_sources
-    ['title', 'thumbnail_base', 'original_created_from',
-     'original_created_before', 'duration'].each do |field|
-      attributes[field] = '' if provenance[field] == 'automatic'
-    end
-    tag_sources['automatic'] = ''
-    attributes['tags'] = merged_tags(tag_sources, provenance['tags'])
-  end
-
-  def clear_fetch_warnings! field_warnings
-    FETCH_WARNING_FIELDS.each do |field|
-      field_warnings.delete(field)
-    end
-  end
-
-  def metadata_for url, cache
-    cache[url] ||= fetch_metadata(url)
-  end
-
-  def fetch_metadata url
-    return { data: { }, warnings: { 'url' => ['URL が空です．'] } } if url.blank?
-
-    data = PostMetadataFetcher.fetch(url).stringify_keys.compact
-    warnings = { }
-    add_field_warning!(warnings, 'title', TITLE_FETCH_WARNING) if data['title'].blank?
-    add_field_warning!(warnings, 'thumbnail_base', THUMBNAIL_FETCH_WARNING) if data['thumbnail_base'].blank?
-    { data:, warnings: }
-  rescue Preview::UrlSafety::UnsafeUrl,
-         Preview::HttpFetcher::FetchFailed,
-         Preview::HttpFetcher::ResponseTooLarge => e
-    Rails.logger.info(
-      "post_import_metadata_fetch_failure "\
-      "#{ { error: e.class.name, message: e.message }.to_json }",
-    )
-    { data: { }, warnings: { 'url' => [METADATA_FETCH_WARNING] } }
-  end
-
-  def apply_metadata! attributes, provenance, tag_sources, metadata
-    metadata.each do |field, value|
-      if field == 'tags'
-        next if provenance['tags'] == 'manual'
-
-        tag_sources['automatic'] = value.to_s
-        attributes['tags'] = merged_tags(tag_sources)
-        next
-      end
-      next unless provenance[field] == 'automatic'
-
-      attributes[field] = value
-      provenance[field] = 'automatic'
-    end
-  end
-
-  def apply_fetch_warnings! field_warnings, warnings
-    warnings.each do |field, values|
-      values.each do |value|
-        add_field_warning!(field_warnings, field, value)
-      end
-    end
-  end
-
-  def add_field_warning! field_warnings, field, message
-    field_warnings[field] ||= []
-    field_warnings[field] << message unless field_warnings[field].include?(message)
-  end
-
-  def merged_tags sources, origin = nil
-    return sources['manual'].to_s if origin == 'manual'
-
-    sources['automatic'].to_s
-  end
-
-  def validate_preview_tags raw, errors, field_warnings
-    names = raw.to_s.split
-    return if names.empty?
-    if names.any? { _1.downcase.start_with?('nico:') }
-      errors[:tags] = ['ニコニコ・タグは直接指定できません．']
-      return
-    end
-
-    parsed = names.map { |name| TagName.canonicalise(name.sub(/\[.*\]\z/, '')).first }
-    existing = Tag.joins(:tag_name).where(tag_names: { name: parsed }).includes(:tag_name).to_a
-    deprecated = existing.select(&:deprecated?).map(&:name)
-    errors[:tags] = ["廃止済みタグがあります: #{ deprecated.join(' ') }"] if deprecated.present?
-    known = existing.reject(&:deprecated?).map(&:name)
-    new_tags = parsed.uniq - known
-    if new_tags.present?
-      add_field_warning!(field_warnings, 'tags', "新規タグを作成します: #{ new_tags.join(' ') }")
-    end
-  rescue Tag::SectionLiteralParseError
-    errors[:tags] = ['タグ区間の記法が不正です．']
-  end
-
-  def validate_basic_data attributes, errors
-    post = Post.new(title: attributes['title'].presence,
-                    url: attributes['url'],
-                    thumbnail_base: attributes['thumbnail_base'].presence,
-                    original_created_from: attributes['original_created_from'].presence,
-                    original_created_before: attributes['original_created_before'].presence,
-                    video_ms: parse_duration(attributes['duration'], errors))
-    post.valid?
-    post.errors.each do |error|
-      next if error.attribute == :url && error.type == :taken
-
-      (errors[error.attribute] ||= []) << error.message
-    end
-  end
-
-  def parse_duration value, errors
-    return nil if value.blank?
-
-    value.is_a?(Numeric) ? value.to_i : Tag.time_to_ms!(value.to_s, tag_name: '動画時間')
-  rescue Tag::SectionLiteralParseError
-    errors[:video_ms] = ['動画時間の記法が不正です．']
-    nil
-  end
-
-  def validate_parents raw, errors
-    ids = raw.to_s.split.map { Integer(_1, exception: false) }
-    return if ids.compact.empty? && raw.to_s.blank?
-
-    errors[:parent_post_ids] = ['親投稿 Id. が不正です．'] and return if ids.any? { _1.nil? || _1 <= 0 }
-    if Post.where(id: ids).count != ids.uniq.length
-      errors[:parent_post_ids] = ['存在しない親投稿 Id. があります．']
-    end
-  end
-end

backend/app/services/post_import_row_normaliser.rb

@@ -1,172 +0,0 @@
-class PostImportRowNormaliser
-  ORIGINS = ['automatic', 'manual'].freeze
-  STRING_FIELDS = [
-    'title',
-    'thumbnail_base',
-    'original_created_from',
-    'original_created_before',
-    'tags',
-    'parent_post_ids',
-  ].freeze
-  FLEXIBLE_FIELDS = ['duration', 'video_ms'].freeze
-  ATTRIBUTE_FIELDS = (STRING_FIELDS + FLEXIBLE_FIELDS).freeze
-
-  def self.normalise! rows, allow_warning_fields: false
-    raise ArgumentError, '取込行の形式が不正です．' unless rows.is_a?(Array)
-    raise ArgumentError, '取込件数が多すぎます．' if rows.length > PostImportUrlListParser::MAX_ROWS
-
-    normalised_rows = rows.map { normalise_row!(_1, allow_warning_fields:) }
-    source_rows = normalised_rows.map { _1['source_row'] }
-    raise ArgumentError, '元行番号が重複しています．' if source_rows.uniq.length != source_rows.length
-    if normalised_rows.sum { row_bytesize(_1) } > PostImportUrlListParser::MAX_BYTES
-      raise ArgumentError, '取込データが大きすぎます．'
-    end
-
-    normalised_rows
-  end
-
-  def self.normalise_row! row, allow_warning_fields:
-    unless row.is_a?(Hash) || row.is_a?(ActionController::Parameters)
-      raise ArgumentError, '取込行の形式が不正です．'
-    end
-
-    parameters =
-        row.is_a?(ActionController::Parameters) ? row : ActionController::Parameters.new(row)
-    permitted = parameters.permit(*permitted_keys(allow_warning_fields))
-    normalised = permitted.to_h.deep_transform_keys { _1.to_s.underscore }
-
-    normalised['source_row'] = normalise_source_row!(normalised['source_row'])
-    normalise_url!(normalised['url'])
-    normalise_metadata_url!(normalised['metadata_url'])
-    normalise_attributes!(normalised.fetch('attributes', { }))
-    normalise_provenance!(normalised.fetch('provenance', { }))
-    normalise_tag_sources!(normalised['tag_sources'])
-    normalise_warning_values!(normalised, allow_warning_fields:)
-    if row_bytesize(normalised) > PostImportUrlListParser::MAX_BYTES
-      raise ArgumentError, '取込行が大きすぎます．'
-    end
-
-    normalised
-  end
-
-  def self.permitted_keys allow_warning_fields
-    keys = [
-      :source_row,
-      :sourceRow,
-      :url,
-      :metadata_url,
-      :metadataUrl,
-      { attributes: {} },
-      { provenance: {} },
-      { tag_sources: {} },
-      { tagSources: {} },
-    ]
-    return keys unless allow_warning_fields
-
-    keys + [
-      { field_warnings: {} },
-      { fieldWarnings: {} },
-      { base_warnings: [] },
-      { baseWarnings: [] },
-    ]
-  end
-  private_class_method :permitted_keys
-
-  def self.normalise_source_row! value
-    source_row = Integer(value, exception: false)
-    raise ArgumentError, '元行番号が不正です．' if source_row.nil? || source_row <= 0
-
-    source_row
-  end
-  private_class_method :normalise_source_row!
-
-  def self.normalise_url! value
-    raise ArgumentError, 'URL の形式が不正です．' unless value.is_a?(String)
-    raise ArgumentError, 'URL が長すぎます．' if value.bytesize > PostImportUrlListParser::MAX_URL_BYTES
-  end
-  private_class_method :normalise_url!
-
-  def self.normalise_metadata_url! value
-    raise ArgumentError, 'metadata_url の形式が不正です．' unless value.nil? || value.is_a?(String)
-    if value.to_s.bytesize > PostImportUrlListParser::MAX_URL_BYTES
-      raise ArgumentError, 'metadata_url が長すぎます．'
-    end
-  end
-  private_class_method :normalise_metadata_url!
-
-  def self.normalise_attributes! attributes
-    raise ArgumentError, 'attributes の形式が不正です．' unless attributes.is_a?(Hash)
-    raise ArgumentError, '取込項目が不正です．' unless (attributes.keys - ATTRIBUTE_FIELDS).empty?
-
-    attributes.each do |key, value|
-      case key
-      when *STRING_FIELDS
-        raise ArgumentError, '取込項目の型が不正です．' unless value.nil? || value.is_a?(String)
-      when *FLEXIBLE_FIELDS
-        unless value.nil? || value.is_a?(String) || value.is_a?(Numeric)
-          raise ArgumentError, '取込項目の型が不正です．'
-        end
-      end
-      if value.to_s.bytesize > PostImportUrlListParser::MAX_URL_BYTES
-        raise ArgumentError, '取込項目が大きすぎます．'
-      end
-    end
-  end
-  private_class_method :normalise_attributes!
-
-  def self.normalise_provenance! provenance
-    raise ArgumentError, 'provenance の形式が不正です．' unless provenance.is_a?(Hash)
-
-    allowed = ATTRIBUTE_FIELDS + ['url']
-    raise ArgumentError, '値の由来が不正です．' unless (provenance.keys - allowed).empty?
-    raise ArgumentError, '値の由来が不正です．' unless provenance.values.all? { ORIGINS.include?(_1) }
-  end
-  private_class_method :normalise_provenance!
-
-  def self.normalise_tag_sources! tag_sources
-    return if tag_sources.nil?
-
-    raise ArgumentError, 'タグ由来の形式が不正です．' unless tag_sources.is_a?(Hash)
-    raise ArgumentError, 'タグ由来の形式が不正です．' unless (tag_sources.keys - ORIGINS).empty?
-    raise ArgumentError, 'タグ由来の形式が不正です．' unless tag_sources.values.all? { _1.is_a?(String) }
-    if tag_sources.values.any? { _1.bytesize > PostImportUrlListParser::MAX_URL_BYTES }
-      raise ArgumentError, 'タグ由来が大きすぎます．'
-    end
-    if tag_sources.values.sum(&:bytesize) > PostImportUrlListParser::MAX_URL_BYTES
-      raise ArgumentError, 'タグ由来が大きすぎます．'
-    end
-  end
-  private_class_method :normalise_tag_sources!
-
-  def self.normalise_warning_values! normalised, allow_warning_fields:
-    return unless allow_warning_fields
-
-    field_warnings = normalised['field_warnings']
-    unless field_warnings.nil? || field_warnings.is_a?(Hash)
-      raise ArgumentError, '警告の形式が不正です．'
-    end
-    field_warnings&.each do |key, values|
-      raise ArgumentError, '警告の形式が不正です．' unless ATTRIBUTE_FIELDS.include?(key) || key == 'url'
-      unless values.is_a?(Array) && values.all? { _1.is_a?(String) }
-        raise ArgumentError, '警告の形式が不正です．'
-      end
-      if values.any? { _1.bytesize > PostImportUrlListParser::MAX_URL_BYTES }
-        raise ArgumentError, '警告が大きすぎます．'
-      end
-    end
-
-    base_warnings = normalised['base_warnings']
-    return if base_warnings.nil?
-
-    unless base_warnings.is_a?(Array) && base_warnings.all? { _1.is_a?(String) }
-      raise ArgumentError, '警告の形式が不正です．'
-    end
-    raise ArgumentError, '警告が大きすぎます．' if base_warnings.any? { _1.bytesize > PostImportUrlListParser::MAX_URL_BYTES }
-  end
-  private_class_method :normalise_warning_values!
-
-  def self.row_bytesize row
-    row.to_json.bytesize
-  end
-  private_class_method :row_bytesize
-end

backend/app/services/post_import_runner.rb

@@ -1,62 +0,0 @@
-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

backend/app/services/post_import_url_list_parser.rb

@@ -1,23 +0,0 @@
-class PostImportUrlListParser
-  MAX_ROWS = 100
-  MAX_BYTES = 1.megabyte
-  MAX_URL_BYTES = 20.kilobytes
-
-  def self.parse source
-    raw = source.to_s
-    raise ArgumentError, '入力が大きすぎます．' if raw.bytesize > MAX_BYTES
-
-    rows = raw.split(/\r\n|\n|\r/).each_with_index.filter_map { |line, index|
-      url = line.strip
-      next if url.blank?
-
-      raise ArgumentError, "#{ index + 1 } 行目: URL が長すぎます．" if url.bytesize > MAX_URL_BYTES
-
-      { source_row: index + 1, url: }
-    }
-    raise ArgumentError, 'URL を入力してください．' if rows.empty?
-    raise ArgumentError, "取込件数は #{ MAX_ROWS } 件までです．" if rows.length > MAX_ROWS
-
-    rows
-  end
-end

backend/app/services/post_metadata_fetcher.rb

@@ -1,60 +0,0 @@
-class PostMetadataFetcher
-  def self.fetch raw_url
-    uri, = Preview::UrlSafety.validate(raw_url)
-    response = Preview::HttpFetcher.fetch(
-      uri.to_s,
-      max_bytes: Preview::ThumbnailFetcher::HTML_MAX_BYTES,
-    )
-    metadata = Preview::HtmlMetadataExtractor.extract(response)
-    document = Nokogiri::HTML.parse(response.body)
-    content = lambda { |name|
-      document
-        .at_css("meta[property='#{ name }'], meta[name='#{ name }']")
-        &.[]('content')
-        &.strip
-        &.presence
-    }
-    duration = content.call('og:video:duration') || content.call('video:duration')
-    published = content.call('article:published_time') || content.call('date')
-    created_range = original_created_range(published)
-    platform_tags = platform_tags(uri)
-    { title: metadata[:title],
-      thumbnail_base: Preview::KnownSiteExtractor.thumbnail_url(uri) || metadata[:image_url],
-      original_created_from: created_range&.first&.iso8601,
-      original_created_before: created_range&.last&.iso8601,
-      duration: duration&.to_f&.then { _1.positive? ? (_1 * 1_000).round : nil },
-      tags: platform_tags.join(' ') }
-  end
-
-  def self.platform_tags uri
-    return ['動画', 'YouTube'] if Preview::KnownSiteExtractor.youtube_video_id(uri)
-    return ['動画', 'ニコニコ'] if Preview::KnownSiteExtractor.niconico_video_id(uri)
-
-    []
-  end
-
-  def self.original_created_range value
-    return nil if value.blank?
-
-    raw = value.to_s.strip
-    from = Time.zone.parse(raw)
-    zone = '(?:Z|[+-]\d{2}:?\d{2})?'
-    before =
-      case raw
-      when /\A\d{4}\z/ then from + 1.year
-      when /\A\d{4}-\d{2}\z/ then from + 1.month
-      when /\A\d{4}-\d{2}-\d{2}\z/ then from + 1.day
-      when /\A\d{4}-\d{2}-\d{2}T\d{2}#{ zone }\z/ then from + 1.hour
-      when /\A\d{4}-\d{2}-\d{2}T\d{2}:\d{2}#{ zone }\z/ then from + 1.minute
-      when /\A\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}#{ zone }\z/ then from + 1.second
-      when /\A\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}\.(\d+)#{ zone }\z/
-        from + (10**(-Regexp.last_match(1).length))
-      else
-        return nil
-      end
-    [from, before]
-  rescue ArgumentError, TypeError
-    nil
-  end
-  private_class_method :platform_tags, :original_created_range
-end

backend/app/services/post_url_normaliser.rb

@@ -1,13 +0,0 @@
-class PostUrlNormaliser
-  def self.normalise raw_url
-    value = raw_url.to_s.strip
-    uri = URI.parse(value)
-    return nil unless uri.is_a?(URI::HTTP) && uri.host.present?
-
-    uri.host = uri.host.downcase
-    uri.path = uri.path.sub(/\/\z/, '') if uri.path.present?
-    uri.to_s
-  rescue URI::InvalidURIError
-    nil
-  end
-end

backend/app/services/preview/http_fetcher.rb

@@ -12,12 +12,8 @@ module Preview
 
     Response = Data.define(:body, :content_type, :url)
 
-    def self.fetch(raw_url, max_bytes: DEFAULT_MAX_BYTES, redirects: MAX_REDIRECTS,
-                   allowed_hosts: nil)
+    def self.fetch(raw_url, max_bytes: DEFAULT_MAX_BYTES, redirects: MAX_REDIRECTS)
       uri, addresses = UrlSafety.validate(raw_url)
-      if allowed_hosts && !allowed_hosts.include?(uri.host.downcase)
-        raise FetchFailed, '許可されてゐない redirect 先です．'
-      end
       response = request(uri, addresses.first, max_bytes)
 
       if response.is_a?(Net::HTTPRedirection)
@@ -54,7 +50,7 @@ module Preview
               raise FetchFailed, 'redirect 先が不正です．'
             end
 
-        return fetch(redirect_url, max_bytes:, redirects: redirects - 1, allowed_hosts:)
+        return fetch(redirect_url, max_bytes:, redirects: redirects - 1)
       end
 
       unless response.is_a?(Net::HTTPSuccess)
@@ -71,10 +67,7 @@ module Preview
       log_failure(:timeout, url: uri&.to_s || raw_url, error: e.class.name, message: e.message)
       raise FetchTimeout, e.message
     rescue SocketError, SystemCallError, OpenSSL::SSL::SSLError, EOFError => e
-      log_failure(:network_error,
-                  url: uri&.to_s || raw_url,
-                  error: e.class.name,
-                  message: e.message)
+      log_failure(:network_error, url: uri&.to_s || raw_url, error: e.class.name, message: e.message)
       raise FetchFailed, e.message
     end
 

backend/app/services/preview/known_site_extractor.rb

@@ -4,15 +4,6 @@ module Preview
       youtube_thumbnail(uri)
     end
 
-    def self.youtube_video_id(uri)
-      case uri.host&.downcase
-      when 'youtu.be'
-        uri.path.split('/').reject(&:blank?).first
-      when 'www.youtube.com', 'youtube.com', 'm.youtube.com'
-        uri.path == '/watch' ? URI.decode_www_form(uri.query.to_s).to_h['v'] : nil
-      end&.then { _1 if _1.match?(/\A[A-Za-z0-9_-]{6,20}\z/) }
-    end
-
     def self.niconico_video_id(uri)
       case uri.host&.downcase
       when 'www.nicovideo.jp', 'nicovideo.jp'
@@ -23,8 +14,14 @@ module Preview
     end
 
     def self.youtube_thumbnail(uri)
-      id = youtube_video_id(uri)
-      return unless id
+      id =
+          case uri.host&.downcase
+          when 'youtu.be'
+            uri.path.split('/').reject(&:blank?).first
+          when 'www.youtube.com', 'youtube.com', 'm.youtube.com'
+            uri.path == '/watch' ? URI.decode_www_form(uri.query.to_s).to_h['v'] : nil
+          end
+      return unless id&.match?(/\A[A-Za-z0-9_-]{6,20}\z/)
 
       "https://i.ytimg.com/vi/#{ id }/hqdefault.jpg"
     end

backend/config/routes.rb

@@ -33,12 +33,6 @@ Rails.application.routes.draw do
     get :thumbnail
   end
 
-  scope 'posts/import', controller: :post_imports do
-    post :preview
-    post :validate
-    post '', action: :create
-  end
-
   resources :wiki_pages, path: 'wiki', only: [:index, :show, :create, :update] do
     collection do
       get :search

backend/db/migrate/20260713000000_create_post_url_sanitisation_rules.rb

@@ -1,61 +0,0 @@
-class CreatePostUrlSanitisationRules < ActiveRecord::Migration[8.0]
-  class PostUrlSanitisationRule < ActiveRecord::Base
-    self.table_name = 'post_url_sanitisation_rules'
-  end
-
-  def up
-    create_table :post_url_sanitisation_rules, id: :integer, primary_key: :priority do |t|
-      t.string :source_pattern, null: false
-      t.string :replacement, null: false
-      t.timestamps
-      t.datetime :discarded_at
-
-      t.index :source_pattern, unique: true
-      t.index :discarded_at
-    end
-
-    now = Time.current
-
-    PostUrlSanitisationRule.insert_all!([
-        { priority: 10,
-          source_pattern: '\Ahttps?://youtu\.be/([^/?#]+)(?:[?#].*)?\z',
-          replacement: 'https://www.youtube.com/watch?v=\1',
-          created_at: now,
-          updated_at: now },
-        { priority: 20,
-          source_pattern: '\Ahttps?://(?:www\.|m\.)?youtube\.com/live/([^/?#]+)(?:[?#].*)?\z',
-          replacement: 'https://www.youtube.com/watch?v=\1',
-          created_at: now,
-          updated_at: now },
-        { priority: 30,
-          source_pattern: '\Ahttps?://(?:www\.|m\.)?youtube\.com/shorts/([^/?#]+)(?:[?#].*)?\z',
-          replacement: 'https://www.youtube.com/watch?v=\1',
-          created_at: now,
-          updated_at: now },
-        { priority: 40,
-          source_pattern: '\Ahttps?://(?:www\.|m\.)?youtube\.com/embed/([^/?#]+)(?:[?#].*)?\z',
-          replacement: 'https://www.youtube.com/watch?v=\1',
-          created_at: now,
-          updated_at: now },
-        { priority: 50,
-          source_pattern:
-              '\Ahttps?://(?:www\.|m\.)?youtube\.com/watch\?(?:[^#&]+&)*v=([^&#]+)(?:[&#].*)?\z',
-          replacement: 'https://www.youtube.com/watch?v=\1',
-          created_at: now,
-          updated_at: now },
-        { priority: 60,
-          source_pattern: '\Ahttps?://nico\.ms/([^/?#]+)(?:[?#].*)?\z',
-          replacement: 'https://www.nicovideo.jp/watch/\1',
-          created_at: now,
-          updated_at: now },
-        { priority: 70,
-          source_pattern: '\Ahttps?://(?:www\.)?nicovideo\.jp/watch/([^?#/]+)(?:[?#].*)?\z',
-          replacement: 'https://www.nicovideo.jp/watch/\1',
-          created_at: now,
-          updated_at: now }])
-  end
-
-  def down
-    drop_table :post_url_sanitisation_rules
-  end
-end

backend/db/schema.rb

@@ -10,7 +10,7 @@
 #
 # It's strongly recommended that you check this file into your version control system.
 
-ActiveRecord::Schema[8.0].define(version: 2026_07_13_000000) do
+ActiveRecord::Schema[8.0].define(version: 2026_07_05_000000) do
   create_table "active_storage_attachments", charset: "utf8mb4", collation: "utf8mb4_0900_ai_ci", force: :cascade do |t|
     t.string "name", null: false
     t.string "record_type", null: false
@@ -331,16 +331,6 @@ ActiveRecord::Schema[8.0].define(version: 2026_07_13_000000) do
     t.index ["tag_id"], name: "index_post_tags_on_tag_id"
   end
 
-  create_table "post_url_sanitisation_rules", primary_key: "priority", id: :integer, charset: "utf8mb4", collation: "utf8mb4_0900_ai_ci", force: :cascade do |t|
-    t.string "source_pattern", null: false
-    t.string "replacement", null: false
-    t.datetime "created_at", null: false
-    t.datetime "updated_at", null: false
-    t.datetime "discarded_at"
-    t.index ["discarded_at"], name: "index_post_url_sanitisation_rules_on_discarded_at"
-    t.index ["source_pattern"], name: "index_post_url_sanitisation_rules_on_source_pattern", unique: true
-  end
-
   create_table "post_versions", charset: "utf8mb4", collation: "utf8mb4_0900_ai_ci", force: :cascade do |t|
     t.bigint "post_id", null: false
     t.integer "version_no", null: false

backend/db/seeds.rb

@@ -8,43 +8,6 @@
 #     MovieGenre.find_or_create_by!(name: genre_name)
 #   end
 
-post_url_sanitisation_rules = [
-  { priority: 10,
-    source_pattern: '\Ahttps?://youtu\.be/([^/?#]+)(?:[?#].*)?\z',
-    replacement: 'https://www.youtube.com/watch?v=\1' },
-  { priority: 20,
-    source_pattern: '\Ahttps?://(?:www\.|m\.)?youtube\.com/live/([^/?#]+)(?:[?#].*)?\z',
-    replacement: 'https://www.youtube.com/watch?v=\1' },
-  { priority: 30,
-    source_pattern: '\Ahttps?://(?:www\.|m\.)?youtube\.com/shorts/([^/?#]+)(?:[?#].*)?\z',
-    replacement: 'https://www.youtube.com/watch?v=\1' },
-  { priority: 40,
-    source_pattern: '\Ahttps?://(?:www\.|m\.)?youtube\.com/embed/([^/?#]+)(?:[?#].*)?\z',
-    replacement: 'https://www.youtube.com/watch?v=\1' },
-  { priority: 50,
-    source_pattern:
-        '\Ahttps?://(?:www\.|m\.)?youtube\.com/watch\?(?:[^#&]+&)*v=([^&#]+)(?:[&#].*)?\z',
-    replacement: 'https://www.youtube.com/watch?v=\1' },
-  { priority: 60,
-    source_pattern: '\Ahttps?://nico\.ms/([^/?#]+)(?:[?#].*)?\z',
-    replacement: 'https://www.nicovideo.jp/watch/\1' },
-  { priority: 70,
-    source_pattern: '\Ahttps?://(?:www\.)?nicovideo\.jp/watch/([^?#/]+)(?:[?#].*)?\z',
-    replacement: 'https://www.nicovideo.jp/watch/\1' }
-]
-
-post_url_sanitisation_rule_scope = PostUrlSanitisationRule.unscoped
-
-post_url_sanitisation_rules.each do |attributes|
-  priority = attributes.fetch(:priority)
-  source_pattern = attributes.fetch(:source_pattern)
-
-  next if post_url_sanitisation_rule_scope.exists?(priority:)
-  next if post_url_sanitisation_rule_scope.exists?(source_pattern:)
-
-  post_url_sanitisation_rule_scope.create!(attributes)
-end
-
 material_sync_source_uri = ENV['MATERIAL_SYNC_SOURCE_URI']
 material_sync_source_file_id = ENV['MATERIAL_SYNC_SOURCE_FILE_ID']
 

backend/spec/db/seeds_spec.rb

@@ -1,65 +0,0 @@
-require 'rails_helper'
-
-RSpec.describe 'database seeds' do
-  before do
-    PostUrlSanitisationRule.unscoped.delete_all
-  end
-
-  it 'registers the initial post URL sanitisation rules' do
-    load_seeds
-
-    urls = {
-      'https://youtu.be/abc123?si=share' => youtube_url('abc123'),
-      'https://www.youtube.com/live/abc123?t=10' => youtube_url('abc123'),
-      'https://youtube.com/shorts/abc123?feature=share' => youtube_url('abc123'),
-      'https://m.youtube.com/embed/abc123' => youtube_url('abc123'),
-      'https://youtube.com/watch?feature=share&v=abc123&t=10' => youtube_url('abc123'),
-      'https://nico.ms/sm123?from=share#fragment' => nico_url('sm123'),
-      'https://www.nicovideo.jp/watch/sm123?ref=share#fragment' => nico_url('sm123')
-    }
-
-    expect(PostUrlSanitisationRule.count).to eq(7)
-    urls.each do |url, canonical_url|
-      expect(PostUrlSanitisationRule.sanitise(url)).to eq(canonical_url)
-    end
-  end
-
-  it 'does not overwrite or restore an existing rule' do
-    rule = PostUrlSanitisationRule.create!(
-      priority: 10,
-      source_pattern: '\Ahttps://example\.com/custom\z',
-      replacement: 'https://example.com/replacement'
-    )
-    rule.discard!
-    original_attributes = rule.reload.attributes
-
-    2.times { load_seeds }
-
-    persisted_rule = PostUrlSanitisationRule.unscoped.find(10)
-    expect(persisted_rule.attributes).to eq(original_attributes)
-    expect(PostUrlSanitisationRule.unscoped.count).to eq(7)
-  end
-
-  it 'does not duplicate a rule moved to another priority' do
-    source_pattern = '\Ahttps?://youtu\.be/([^/?#]+)(?:[?#].*)?\z'
-    PostUrlSanitisationRule.create!(
-      priority: 80,
-      source_pattern:,
-      replacement: 'https://example.com/custom/\1'
-    )
-
-    load_seeds
-
-    rules = PostUrlSanitisationRule.unscoped
-    expect(rules.where(source_pattern:).count).to eq(1)
-    expect(rules.find(80).replacement).to eq('https://example.com/custom/\1')
-  end
-
-  def load_seeds
-    load Rails.root.join('db/seeds.rb')
-  end
-
-  def youtube_url(video_id) = "https://www.youtube.com/watch?v=#{ video_id }"
-
-  def nico_url(video_id) = "https://www.nicovideo.jp/watch/#{ video_id }"
-end

backend/spec/models/post_spec.rb

@@ -1,68 +0,0 @@
-require 'rails_helper'
-
-RSpec.describe Post, type: :model do
-  before do
-    PostUrlSanitisationRule.unscoped.delete_all
-  end
-
-  describe 'URL normalisation' do
-    it 'normalises the HTTP URL before applying sanitisation rules' do
-      PostUrlSanitisationRule.create!(
-        priority: 10,
-        source_pattern: '\\Ahttps://example\\.com/videos/([^/]+)\\z',
-        replacement: 'https://example.com/watch/\\1'
-      )
-
-      post = described_class.create!(
-        title: 'normalised URL',
-        url: '  https://EXAMPLE.com/videos/123/  '
-      )
-
-      expect(post.url).to eq('https://example.com/watch/123')
-    end
-
-    it 'does not normalise an unchanged URL when another attribute changes' do
-      post = create(:post)
-      post.update_column(:url, 'https://EXAMPLE.com/unchanged/')
-
-      post.update!(title: 'updated title')
-
-      expect(post.reload.url).to eq('https://EXAMPLE.com/unchanged/')
-    end
-
-    it 'validates the sanitised URL length' do
-      path = 'a' * 375
-
-      PostUrlSanitisationRule.create!(
-        priority: 10,
-        source_pattern: '\\Ahttps://example\\.com/(a+)\\z',
-        replacement: 'https://example.com/\\1\\1'
-      )
-
-      post = described_class.new(
-        title: 'long URL',
-        url: "https://example.com/#{ path }"
-      )
-
-      expect(post).to be_invalid
-      expect(post.errors.details.fetch(:url)).to include(
-        error: :too_long,
-        count: 768
-      )
-    end
-
-    it 'validates uniqueness after sanitisation' do
-      PostUrlSanitisationRule.create!(
-        priority: 10,
-        source_pattern: '\\Ahttps://example\\.com/alias\\z',
-        replacement: 'https://example.com/canonical'
-      )
-      create(:post, url: 'https://example.com/canonical')
-
-      post = described_class.new(title: 'duplicate URL', url: 'https://example.com/alias')
-
-      expect(post).to be_invalid
-      expect(post.errors.details.fetch(:url)).to include(error: :taken, value: post.url)
-    end
-  end
-end

backend/spec/models/post_url_sanitisation_rule_spec.rb

@@ -1,265 +0,0 @@
-require 'rails_helper'
-
-RSpec.describe PostUrlSanitisationRule, type: :model do
-  before do
-    described_class.unscoped.delete_all
-  end
-
-  describe 'validations' do
-    it 'requires a source pattern' do
-      rule = described_class.new(priority: 10, source_pattern: nil, replacement: '')
-
-      expect(rule).to be_invalid
-      expect(rule.errors.details.fetch(:source_pattern)).to eq([{ error: :blank }])
-    end
-
-    it 'requires a unique source pattern' do
-      described_class.create!(priority: 10, source_pattern: 'source', replacement: 'first')
-      rule = described_class.new(
-        priority: 20,
-        source_pattern: 'source',
-        replacement: 'second'
-      )
-
-      expect(rule).to be_invalid
-      expect(rule.errors.details.fetch(:source_pattern)).to include(
-        error: :taken,
-        value: 'source'
-      )
-    end
-
-    it 'rejects an invalid regexp' do
-      rule = described_class.new(priority: 10, source_pattern: '[', replacement: '')
-
-      expect(rule).to be_invalid
-      expect(rule.errors[:source_pattern]).to include('変な正規表現だね〜（笑）')
-    end
-  end
-
-  describe '.sanitise' do
-    it 'applies each active rule once in priority order' do
-      described_class.create!(priority: 30, source_pattern: 'c', replacement: 'd')
-      described_class.create!(priority: 10, source_pattern: 'a', replacement: 'aa')
-      described_class.create!(priority: 20, source_pattern: 'aa', replacement: 'c')
-      discarded = described_class.create!(
-        priority: 5,
-        source_pattern: '.',
-        replacement: 'discarded'
-      )
-      discarded.discard!
-
-      expect(described_class.sanitise('a')).to eq('d')
-    end
-
-    it 'canonicalises the initial YouTube and Nico URL forms' do
-      create_initial_rules
-
-      urls = {
-        'https://youtu.be/abc123?si=share' => youtube_url('abc123'),
-        'https://www.youtube.com/live/abc123?t=10' => youtube_url('abc123'),
-        'https://youtube.com/shorts/abc123?feature=share' => youtube_url('abc123'),
-        'https://m.youtube.com/embed/abc123' => youtube_url('abc123'),
-        'https://youtube.com/watch?feature=share&v=abc123&t=10' => youtube_url('abc123'),
-        'https://nico.ms/sm123?from=share#fragment' => nico_url('sm123'),
-        'https://www.nicovideo.jp/watch/sm123?ref=share#fragment' => nico_url('sm123')
-      }
-
-      urls.each do |url, canonical_url|
-        expect(described_class.sanitise(url)).to eq(canonical_url)
-      end
-    end
-  end
-
-  describe '.apply!' do
-    it 'locks posts in ID order and updates through temporary URLs' do
-      first = create(:post, url: 'https://example.com/source/1')
-      second = create(:post, url: 'https://example.com/source/2')
-      create_source_rule
-      sql = capture_sql { described_class.apply! }
-
-      lock_sql = sql.find { _1.match?(/SELECT .*posts.*FOR UPDATE/i) }
-      expect(lock_sql).to match(/ORDER BY .*posts.*id.* ASC/i)
-      expect(sql.grep(/post-url-sanitising\.invalid/).size).to eq(2)
-      expect(first.reload.url).to eq('https://example.com/canonical/1')
-      expect(second.reload.url).to eq('https://example.com/canonical/2')
-    end
-
-    it 'loads and compiles rules only once' do
-      create(:post, url: 'https://example.com/source/1')
-      create(:post, url: 'https://example.com/source/2')
-      create_source_rule
-
-      expect(described_class).to receive(:rules).once.and_call_original
-
-      described_class.apply!
-    end
-
-    it 'does not change post versions, version_no, or updated_at' do
-      post = create(:post, url: 'https://example.com/source/1')
-      post.update_columns(version_no: 7, updated_at: 1.day.ago)
-      original_updated_at = post.reload.updated_at
-      create_source_rule
-
-      expect { described_class.apply! }.not_to change(PostVersion, :count)
-
-      post.reload
-      expect(post.url).to eq('https://example.com/canonical/1')
-      expect(post.version_no).to eq(7)
-      expect(post.updated_at).to eq(original_updated_at)
-    end
-
-    invalid_urls = {
-      'a blank URL' => '',
-      'an unparseable URL' => 'https://[',
-      'a non-HTTP URL' => 'ftp://example.com/file',
-      'an HTTP URL without a host' => 'https:/path'
-    }
-
-    invalid_urls.each do |description, sanitised_url|
-      it "rolls back every update when sanitisation produces #{ description }" do
-        valid_post = create(:post, url: 'https://example.com/source/1')
-        invalid_post = create(:post, url: 'https://example.com/invalid')
-        create_source_rule
-        described_class.create!(
-          priority: 20,
-          source_pattern: '\\Ahttps://example\\.com/invalid\\z',
-          replacement: sanitised_url
-        )
-
-        expect { described_class.apply! }
-            .to raise_error(described_class::InvalidUrlError) { |error|
-          expect(error.invalid_rows).to eq([
-            { post_id: invalid_post.id,
-              original_url: 'https://example.com/invalid',
-              sanitised_url: }
-          ])
-        }
-        expect(valid_post.reload.url).to eq('https://example.com/source/1')
-        expect(invalid_post.reload.url).to eq('https://example.com/invalid')
-      end
-    end
-
-    it 'rolls back every update when sanitisation produces a URL longer than 768 characters' do
-      path = 'a' * 375
-      original_url = "https://example.com/#{ path }"
-      sanitised_url = "https://example.com/#{ path }#{ path }"
-      valid_post = create(:post, url: 'https://example.com/source/1')
-      invalid_post = create(:post, url: original_url)
-      create_source_rule
-      described_class.create!(
-        priority: 20,
-        source_pattern: '\\Ahttps://example\\.com/(a+)\\z',
-        replacement: 'https://example.com/\\1\\1'
-      )
-
-      expect { described_class.apply! }
-          .to raise_error(described_class::InvalidUrlError) { |error|
-        expect(error.invalid_rows).to eq([
-          { post_id: invalid_post.id,
-            original_url:,
-            sanitised_url: }
-        ])
-      }
-      expect(valid_post.reload.url).to eq('https://example.com/source/1')
-      expect(invalid_post.reload.url).to eq(original_url)
-    end
-
-    it 'rejects sanitised URL collisions case-insensitively without changing posts' do
-      source = create(:post, url: 'https://example.com/source/Foo')
-      canonical = create(:post, url: 'https://example.com/canonical/foo')
-      create_source_rule
-
-      expect { described_class.apply! }
-          .to raise_error(described_class::UrlConflictError) { |error|
-        expect(error.conflicts).to contain_exactly(
-          { url: 'https://example.com/canonical/Foo',
-            post_id: source.id,
-            original_url: 'https://example.com/source/Foo' },
-          { url: 'https://example.com/canonical/foo',
-            post_id: canonical.id,
-            original_url: 'https://example.com/canonical/foo' }
-        )
-      }
-      expect(source.reload.url).to eq('https://example.com/source/Foo')
-      expect(canonical.reload.url).to eq('https://example.com/canonical/foo')
-      expect(Post.count).to eq(2)
-    end
-
-    it 'converts a persisted URL constraint race into UrlConflictError' do
-      post = create(:post, url: 'https://example.com/source/1')
-      create_source_rule
-      conflict = { url: 'https://example.com/canonical/1',
-                   post_id: post.id,
-                   original_url: post.url }
-      database_error = ActiveRecord::RecordNotUnique.new('duplicate URL')
-      allow_any_instance_of(ActiveRecord::Relation)
-          .to receive(:update_all).and_raise(database_error)
-      allow(described_class).to receive(:build_persisted_conflicts).and_return([conflict])
-
-      expect { described_class.apply! }
-          .to raise_error(described_class::UrlConflictError) { |error|
-        expect(error.conflicts).to eq([conflict])
-        expect(error.cause).to equal(database_error)
-      }
-      expect(post.reload.url).to eq('https://example.com/source/1')
-    end
-
-    it 're-raises an unidentified RecordNotUnique error' do
-      post = create(:post, url: 'https://example.com/source/1')
-      create_source_rule
-      database_error = ActiveRecord::RecordNotUnique.new('another unique constraint')
-      allow_any_instance_of(ActiveRecord::Relation)
-          .to receive(:update_all).and_raise(database_error)
-      allow(described_class).to receive(:build_persisted_conflicts).and_return([])
-
-      expect { described_class.apply! }.to raise_error(database_error)
-      expect(post.reload.url).to eq('https://example.com/source/1')
-    end
-  end
-
-  def capture_sql
-    statements = []
-    subscriber = lambda do |_name, _start, _finish, _id, payload|
-      binds = payload.fetch(:binds, []).map { _1.value_for_database.to_s }
-      statements << ([payload.fetch(:sql)] + binds).join(' ')
-    end
-    ActiveSupport::Notifications.subscribed(subscriber, 'sql.active_record') { yield }
-    statements
-  end
-
-  def create_source_rule
-    described_class.create!(
-      priority: 10,
-      source_pattern: '\\Ahttps://example\\.com/source/(.+)\\z',
-      replacement: 'https://example.com/canonical/\\1'
-    )
-  end
-
-  def create_initial_rules
-    rules = [
-      ['\\Ahttps?://youtu\\.be/([^/?#]+)(?:[?#].*)?\\z', youtube_url('\\1')],
-      ['\\Ahttps?://(?:www\\.|m\\.)?youtube\\.com/live/([^/?#]+)(?:[?#].*)?\\z',
-       youtube_url('\\1')],
-      ['\\Ahttps?://(?:www\\.|m\\.)?youtube\\.com/shorts/([^/?#]+)(?:[?#].*)?\\z',
-       youtube_url('\\1')],
-      ['\\Ahttps?://(?:www\\.|m\\.)?youtube\\.com/embed/([^/?#]+)(?:[?#].*)?\\z',
-       youtube_url('\\1')],
-      ['\\Ahttps?://(?:www\\.|m\\.)?youtube\\.com/watch\\?(?:[^#&]+&)*' \
-       'v=([^&#]+)(?:[&#].*)?\\z', youtube_url('\\1')],
-      ['\\Ahttps?://nico\\.ms/([^/?#]+)(?:[?#].*)?\\z', nico_url('\\1')],
-      ['\\Ahttps?://(?:www\\.)?nicovideo\\.jp/watch/([^?#/]+)(?:[?#].*)?\\z',
-       nico_url('\\1')]
-    ]
-    rules.each_with_index do |(source_pattern, replacement), index|
-      described_class.create!(
-        priority: (index + 1) * 10,
-        source_pattern:,
-        replacement:
-      )
-    end
-  end
-
-  def youtube_url(video_id) = "https://www.youtube.com/watch?v=#{ video_id }"
-
-  def nico_url(video_id) = "https://www.nicovideo.jp/watch/#{ video_id }"
-end

backend/spec/tasks/nico_export_spec.rb

@@ -62,7 +62,7 @@ RSpec.describe 'nico:export' do
 
     it 'deduplicates video ids' do
       create_post('https://www.nicovideo.jp/watch/sm12345')
-      create_post('https://sp.nicovideo.jp/watch/sm12345')
+      create_post('https://www.nicovideo.jp/watch/sm12345?from=1')
 
       expect(Open3).to receive(:capture3) do |_env, *args, **_kwargs|
         expect(args.drop(3)).to eq(['sm12345'])

frontend/src/App.tsx

@@ -41,9 +41,6 @@ import NotFound from '@/pages/NotFound'
 import TOSPage from '@/pages/TOSPage.mdx'
 import PostDetailPage from '@/pages/posts/PostDetailPage'
 import PostHistoryPage from '@/pages/posts/PostHistoryPage'
-import PostImportResultPage from '@/pages/posts/PostImportResultPage'
-import PostImportReviewPage from '@/pages/posts/PostImportReviewPage'
-import PostImportSourcePage from '@/pages/posts/PostImportSourcePage'
 import PostListPage from '@/pages/posts/PostListPage'
 import PostNewPage from '@/pages/posts/PostNewPage'
 import PostSearchPage from '@/pages/posts/PostSearchPage'
@@ -78,9 +75,6 @@ const RouteTransitionWrapper = ({ animationMode, user, setUser }: {
 	    <Route path="/" element={<Navigate to="/posts" replace/>}/>
 	    <Route path="/posts" element={<PostListPage/>}/>
 	    <Route path="/posts/new" element={<PostNewPage user={user}/>}/>
-	    <Route path="/posts/import" element={<PostImportSourcePage user={user}/>}/>
-	    <Route path="/posts/import/:sessionId/review" element={<PostImportReviewPage user={user}/>}/>
-	    <Route path="/posts/import/:sessionId/result" element={<PostImportResultPage user={user}/>}/>
 	    <Route path="/posts/search" element={<PostSearchPage/>}/>
 	    <Route path="/posts/:id" element={<PostDetailRoute user={user}/>}/>
 	    <Route path="/posts/changes" element={<PostHistoryPage/>}/>
@@ -119,9 +113,6 @@ const RouteTransitionWrapper = ({ animationMode, user, setUser }: {
 	  <Route path="/" element={<Navigate to="/posts" replace/>}/>
 	  <Route path="/posts" element={<PostListPage/>}/>
 	  <Route path="/posts/new" element={<PostNewPage user={user}/>}/>
-	  <Route path="/posts/import" element={<PostImportSourcePage user={user}/>}/>
-	  <Route path="/posts/import/:sessionId/review" element={<PostImportReviewPage user={user}/>}/>
-	  <Route path="/posts/import/:sessionId/result" element={<PostImportResultPage user={user}/>}/>
 	  <Route path="/posts/search" element={<PostSearchPage/>}/>
 	  <Route path="/posts/:id" element={<PostDetailRoute user={user}/>}/>
 	  <Route path="/posts/changes" element={<PostHistoryPage/>}/>

frontend/src/components/PostOriginalCreatedTimeField.tsx

@@ -2,11 +2,10 @@ import DateTimeField from '@/components/common/DateTimeField'
 import FormField from '@/components/common/FormField'
 import { Button } from '@/components/ui/button'
 
-import type { FC, ReactNode } from 'react'
+import type { FC } from 'react'
 
 type Props = {
     disabled?:                boolean
-    labelAddon?:              ReactNode
     originalCreatedFrom:      string | null
     setOriginalCreatedFrom:   (x: string | null) => void
     originalCreatedBefore:    string | null
@@ -16,25 +15,18 @@ type Props = {
 
 const PostOriginalCreatedTimeField: FC<Props> = (
     { disabled,
-      labelAddon,
       originalCreatedFrom,
       setOriginalCreatedFrom,
       originalCreatedBefore,
       setOriginalCreatedBefore,
       errors }: Props) => (
-    <FormField
-	label={
-	    <span className="flex items-center gap-2">
-	      <span>オリジナルの作成日時</span>
-	      {labelAddon}
-	    </span>}
-	messages={errors}>
+    <FormField label="オリジナルの作成日時" messages={errors}>
       {({ describedBy, invalid }) => (
 	  <>
-	    <div className="my-1 flex flex-col gap-2 sm:flex-row sm:items-start">
-	      <div className="min-w-0 flex-1">
+	    <div className="my-1 flex">
+	      <div className="w-80">
 		<DateTimeField
-		    className="w-full"
+		    className="mr-2"
 		    disabled={disabled ?? false}
 		    aria-describedby={describedBy}
 		    aria-invalid={invalid}
@@ -57,7 +49,6 @@ const PostOriginalCreatedTimeField: FC<Props> = (
 	      </div>
 	      <div>
 		<Button
-		    type="button"
 		    className="bg-gray-600 text-white rounded"
 		    disabled={disabled}
 		    onClick={() => {
@@ -68,10 +59,10 @@ const PostOriginalCreatedTimeField: FC<Props> = (
 	      </div>
 	    </div>
 
-	    <div className="my-1 flex flex-col gap-2 sm:flex-row sm:items-start">
-	      <div className="min-w-0 flex-1">
+	    <div className="my-1 flex">
+	      <div className="w-80">
 		<DateTimeField
-		    className="w-full"
+		    className="mr-2"
 		    disabled={disabled}
 		    aria-describedby={describedBy}
 		    aria-invalid={invalid}
@@ -82,7 +73,6 @@ const PostOriginalCreatedTimeField: FC<Props> = (
 	      </div>
 	      <div>
 		<Button
-		    type="button"
 		    className="bg-gray-600 text-white rounded"
 		    disabled={disabled}
 		    onClick={() => {

frontend/src/components/TopNav.tsx

@@ -26,7 +26,7 @@ export const menuOutline = (
 	tag?: Tag | null
 	material?: Material | null
 	wikiId: number | null
-	user: User | null
+	user: User | null,
 	pathName: string },
 ): Menu => {
   const postCount = tag?.postCount ?? material?.tag?.postCount ?? 0
@@ -43,7 +43,6 @@ export const menuOutline = (
 	  { name: '一覧', to: '/posts' },
 	  { name: '検索', to: '/posts/search' },
 	  { name: '追加', to: '/posts/new' },
-	  { name: '取込', to: '/posts/import' },
 	  { name: '全体履歴', to: '/posts/changes' },
 	  { name: 'ヘルプ', to: '/wiki/ヘルプ:広場' }] },
       { name: 'タグ', to: '/tags', subMenu: [

frontend/src/components/common/FieldWarning.tsx

@@ -1,18 +0,0 @@
-import type { FC } from 'react'
-
-type Props = { id?:        string
-	       messages?:  string[] }
-
-
-export const FieldWarning: FC<Props> = ({ id, messages }: Props) => {
-  if (!(messages) || messages.length === 0)
-    return null
-
-  return (
-      <ul id={id} className="mt-1 space-y-1 text-amber-700 dark:text-amber-200">
-	{messages.map ((message, i) => <li key={i}>{message}</li>)}
-      </ul>)
-}
-
-
-export default FieldWarning

frontend/src/components/posts/import/PostImportRowDialog.tsx

@@ -1,262 +0,0 @@
-import PostOriginalCreatedTimeField from '@/components/PostOriginalCreatedTimeField'
-import FieldError from '@/components/common/FieldError'
-import FieldWarning from '@/components/common/FieldWarning'
-import FormField from '@/components/common/FormField'
-import PostImportStatusBadge from '@/components/posts/import/PostImportStatusBadge'
-import ThumbnailPreview from '@/components/posts/import/ThumbnailPreview'
-import { effectivePostImportStatus } from '@/components/posts/import/postImportRowStatus'
-import { Button } from '@/components/ui/button'
-import { Dialog,
-	 DialogContent,
-	 DialogDescription,
-	 DialogFooter,
-	 DialogHeader,
-	 DialogTitle } from '@/components/ui/dialog'
-import { inputClass } from '@/lib/utils'
-
-import type { FC } from 'react'
-import { useEffect, useState } from 'react'
-
-import type { PostImportOrigin,
-	      PostImportRow } from '@/lib/postImportSession'
-
-type Draft = {
-    url:                   string
-    title:                 string
-    thumbnailBase:         string
-    originalCreatedFrom:   string
-    originalCreatedBefore: string
-    duration:              string
-    tags:                  string
-    parentPostIds:         string }
-
-type Props = {
-    open:         boolean
-    row:          PostImportRow | null
-    saving:       boolean
-    onOpenChange: (open: boolean) => void
-    onSave:       (draft: Draft) => Promise<boolean> }
-
-const originOf = (
-    row:   PostImportRow,
-    field: string,
-): PostImportOrigin =>
-    row.provenance[field] ?? 'automatic'
-
-const originalCreatedOrigin = (row: PostImportRow): PostImportOrigin =>
-    originOf (row, 'originalCreatedFrom') === 'manual'
-    || originOf (row, 'originalCreatedBefore') === 'manual'
-    ? 'manual'
-    : 'automatic'
-
-const buildDraft = (row: PostImportRow): Draft => ({
-    url: row.url,
-    title: String (row.attributes.title ?? ''),
-    thumbnailBase: String (row.attributes.thumbnailBase ?? ''),
-    originalCreatedFrom: String (row.attributes.originalCreatedFrom ?? ''),
-    originalCreatedBefore: String (row.attributes.originalCreatedBefore ?? ''),
-    duration: String (row.attributes.duration ?? ''),
-    tags: String (row.attributes.tags ?? ''),
-    parentPostIds: String (row.attributes.parentPostIds ?? '') })
-
-const groupedMessages = (
-    ...values: Array<string[] | undefined>
-): string[] =>
-    values.flatMap (value => value ?? [])
-
-
-const PostImportRowDialog: FC<Props> = (
-    { open, row, saving, onOpenChange, onSave },
-) => {
-    const [draft, setDraft] = useState<Draft | null> (null)
-
-    useEffect (() => {
-	if (open && row)
-	  setDraft (buildDraft (row))
-    }, [open, row])
-
-    if (!(row) || !(draft))
-      return null
-
-    const update = <Key extends keyof Draft,> (
-	key:   Key,
-	value: Draft[Key],
-    ) => {
-	setDraft (current =>
-	    current ? { ...current, [key]: value } : current)
-    }
-
-    const save = async () => {
-	if (await onSave (draft))
-	  onOpenChange (false)
-    }
-
-    return (
-	<Dialog open={open} onOpenChange={onOpenChange}>
-	  <DialogContent className="flex max-h-[calc(100dvh-1rem)] max-w-3xl flex-col
-				   overflow-hidden p-0">
-	    <DialogHeader className="shrink-0 px-6 pb-4 pt-7">
-	      <DialogTitle>投稿を編輯</DialogTitle>
-	      <DialogDescription>
-		投稿 {row.sourceRow} の内容を確認し、必要な項目を編輯してください．
-	      </DialogDescription>
-	    </DialogHeader>
-
-	    <div className="min-h-0 flex-1 overflow-y-auto overscroll-contain px-6 pb-6">
-	      <div className="grid gap-6 md:grid-cols-[7rem_minmax(0,1fr)]">
-		<div className="space-y-3">
-		  <ThumbnailPreview
-		      url={draft.thumbnailBase}
-		      className="h-28 w-28"/>
-		  <div className="flex flex-wrap gap-2">
-		    <PostImportStatusBadge value={effectivePostImportStatus (row)}/>
-		  </div>
-		</div>
-
-		<div className="space-y-4">
-		  <DialogTextField
-		      label="URL"
-		      value={draft.url}
-		      origin={originOf (row, 'url')}
-		      warnings={row.fieldWarnings.url}
-		      errors={groupedMessages (row.validationErrors.url, row.importErrors?.url)}
-		      onChange={value => update ('url', value)}/>
-		  <DialogTextField
-		      label="タイトル"
-		      value={draft.title}
-		      origin={originOf (row, 'title')}
-		      warnings={row.fieldWarnings.title}
-		      errors={groupedMessages (row.validationErrors.title, row.importErrors?.title)}
-		      onChange={value => update ('title', value)}/>
-		  <DialogTextField
-		      label="サムネール基底 URL"
-		      value={draft.thumbnailBase}
-		      origin={originOf (row, 'thumbnailBase')}
-		      warnings={row.fieldWarnings.thumbnailBase}
-		      errors={groupedMessages (
-			  row.validationErrors.thumbnailBase,
-			  row.importErrors?.thumbnailBase,
-		      )}
-		      onChange={value => update ('thumbnailBase', value)}/>
-		  <PostOriginalCreatedTimeField
-		      labelAddon={<PostImportStatusBadge value={originalCreatedOrigin (row)}/>}
-		      originalCreatedFrom={draft.originalCreatedFrom || null}
-		      setOriginalCreatedFrom={value => update ('originalCreatedFrom', value ?? '')}
-		      originalCreatedBefore={draft.originalCreatedBefore || null}
-		      setOriginalCreatedBefore={value => update ('originalCreatedBefore', value ?? '')}
-		      errors={groupedMessages (
-			  row.validationErrors.originalCreatedAt,
-			  row.validationErrors.originalCreatedFrom,
-			  row.validationErrors.originalCreatedBefore,
-			  row.importErrors?.originalCreatedAt,
-			  row.importErrors?.originalCreatedFrom,
-			  row.importErrors?.originalCreatedBefore,
-		      )}/>
-		  <DialogTextField
-		      label="動画時間"
-		      value={draft.duration}
-		      origin={originOf (row, 'duration')}
-		      errors={groupedMessages (
-			  row.validationErrors.duration,
-			  row.validationErrors.videoMs,
-			  row.importErrors?.duration,
-			  row.importErrors?.videoMs,
-		      )}
-		      onChange={value => update ('duration', value)}/>
-		  <DialogAreaField
-		      label="タグ"
-		      value={draft.tags}
-		      origin={originOf (row, 'tags')}
-		      warnings={row.fieldWarnings.tags}
-		      errors={groupedMessages (row.validationErrors.tags, row.importErrors?.tags)}
-		      onChange={value => update ('tags', value)}/>
-		  <DialogTextField
-		      label="親投稿"
-		      value={draft.parentPostIds}
-		      origin={originOf (row, 'parentPostIds')}
-		      errors={groupedMessages (
-			  row.validationErrors.parentPostIds,
-			  row.importErrors?.parentPostIds,
-		      )}
-		      onChange={value => update ('parentPostIds', value)}/>
-		  <FieldWarning messages={row.baseWarnings}/>
-		  <FieldError messages={row.validationErrors.base}/>
-		  <FieldError messages={row.importErrors?.base}/>
-		</div>
-	      </div>
-	    </div>
-
-	    <DialogFooter className="shrink-0 px-6 pb-6 pt-4">
-	      <Button
-		  type="button"
-		  variant="outline"
-		  onClick={() => onOpenChange (false)}>
-		取消し
-	      </Button>
-	      <Button
-		  type="button"
-		  onClick={save}
-		  disabled={saving}>
-		編輯内容を保存
-	      </Button>
-	    </DialogFooter>
-	  </DialogContent>
-	</Dialog>)
-}
-
-const DialogTextField = (
-    { label, value, origin, warnings, errors, onChange }: {
-	label:    string
-	value:    string
-	origin:   PostImportOrigin
-	warnings?: string[]
-	errors?:   string[]
-	onChange: (value: string) => void },
-) => (
-    <FormField label={<DialogLabel label={label} origin={origin}/>} messages={errors}>
-      {({ describedBy, invalid }) => (
-	  <>
-	    <input
-		value={value}
-		onChange={ev => onChange (ev.target.value)}
-		aria-describedby={describedBy}
-		aria-invalid={invalid}
-		className={inputClass (invalid)}/>
-	    <FieldWarning messages={warnings}/>
-	  </>)}
-    </FormField>)
-
-const DialogAreaField = (
-    { label, value, origin, warnings, errors, onChange }: {
-	label:    string
-	value:    string
-	origin:   PostImportOrigin
-	warnings?: string[]
-	errors?:   string[]
-	onChange: (value: string) => void },
-) => (
-    <FormField label={<DialogLabel label={label} origin={origin}/>} messages={errors}>
-      {({ describedBy, invalid }) => (
-	  <>
-	    <textarea
-		value={value}
-		rows={4}
-		onChange={ev => onChange (ev.target.value)}
-		aria-describedby={describedBy}
-		aria-invalid={invalid}
-		className={inputClass (invalid)}/>
-	    <FieldWarning messages={warnings}/>
-	  </>)}
-    </FormField>)
-
-const DialogLabel = (
-    { label, origin }: {
-	label:   string
-	origin:  PostImportOrigin },
-) => (
-    <span className="flex items-center gap-2">
-      <span>{label}</span>
-      <PostImportStatusBadge value={origin}/>
-    </span>)
-
-export default PostImportRowDialog

frontend/src/components/posts/import/PostImportRowSummary.tsx

@@ -1,176 +0,0 @@
-import { Button } from '@/components/ui/button'
-import { cn } from '@/lib/utils'
-
-import PrefetchLink from '@/components/PrefetchLink'
-import PostImportStatusBadge from '@/components/posts/import/PostImportStatusBadge'
-import ThumbnailPreview from '@/components/posts/import/ThumbnailPreview'
-import { effectivePostImportStatus } from '@/components/posts/import/postImportRowStatus'
-
-import type { FC } from 'react'
-
-import type { PostImportRow } from '@/lib/postImportSession'
-
-type Props = {
-    row:     PostImportRow
-    onEdit:  () => void }
-
-const toneClass = (row: PostImportRow): string[] => {
-    const value = effectivePostImportStatus (row)
-    switch (value)
-      {
-      case 'created':
-	return [
-	    'border-sky-200 bg-sky-50',
-	    'dark:border-sky-900 dark:bg-sky-950/30']
-      case 'skipped':
-	return [
-	    'border-stone-200 bg-stone-50',
-	    'dark:border-stone-800 dark:bg-stone-900/60']
-      case 'failed':
-      case 'error':
-	return [
-	    'border-rose-200 bg-rose-50',
-	    'dark:border-rose-900 dark:bg-rose-950/30']
-      case 'warning':
-	return [
-	    'border-amber-200 bg-amber-50',
-	    'dark:border-amber-900 dark:bg-amber-950/30']
-      default:
-	return [
-	    'border-border bg-white',
-	    'dark:border-neutral-700 dark:bg-neutral-900']
-      }
-}
-
-const summaryError = (row: PostImportRow): string | null => {
-    const validation = Object.values (row.validationErrors ?? { }).flat ()[0]
-    if (validation)
-      return validation
-
-    return Object.values (row.importErrors ?? { }).flat ()[0] ?? null
-}
-
-const summaryWarning = (row: PostImportRow): string | null =>
-    Object.values (row.fieldWarnings ?? { }).flat ()[0]
-    ?? row.baseWarnings?.[0]
-    ?? null
-
-const summaryDate = (row: PostImportRow): string =>
-    [row.attributes.originalCreatedFrom, row.attributes.originalCreatedBefore]
-	.filter (_1 => typeof _1 === 'string' && _1 !== '')
-	.join (' ～ ')
-
-
-const PostImportRowSummary: FC<Props> = ({ row, onEdit }) => {
-    const error = summaryError (row)
-    const warning = error == null ? summaryWarning (row) : null
-    const effectiveStatus = effectivePostImportStatus (row)
-
-    return (
-	<>
-	  <div
-	      className={cn (
-		  'hidden items-center gap-4 rounded-lg border p-4 md:grid',
-		  'md:grid-cols-[4rem_5rem_minmax(0,1fr)_auto_auto_auto]',
-		  toneClass (row),
-		  'hover:bg-slate-50',
-		  'dark:hover:bg-neutral-800',
-	      )}>
-	    <div className="space-y-1">
-	      <div className="text-sm font-medium">#{row.sourceRow}</div>
-	    </div>
-	    <ThumbnailPreview
-		url={String (row.attributes.thumbnailBase ?? '')}
-		className="h-16 w-16"/>
-	    <div className="min-w-0 space-y-1">
-	      <div className="line-clamp-2 text-sm font-medium">
-		{String (row.attributes.title ?? '') || '（タイトル未取得）'}
-	      </div>
-	      <div className="truncate text-xs text-neutral-600 dark:text-neutral-300">
-		{row.url}
-	      </div>
-	      <div className="truncate text-xs text-neutral-500 dark:text-neutral-400">
-		{String (row.attributes.tags ?? '') || 'タグなし'}
-	      </div>
-	      <div className="text-xs text-neutral-500 dark:text-neutral-400">
-		{summaryDate (row) || '日時未取得'}
-		{row.attributes.duration ? ` / ${ row.attributes.duration }` : ''}
-	      </div>
-	      {row.createdPostId && (
-		  <PrefetchLink
-		      to={`/posts/${ row.createdPostId }`}
-		      className="inline-block text-xs text-sky-700 underline
-				 dark:text-sky-300">
-		    投稿 #{row.createdPostId}
-		  </PrefetchLink>)}
-	      {warning && (
-		  <div className="text-xs text-amber-700 dark:text-amber-200">
-		    {warning}
-		  </div>)}
-	      {error && (
-		  <div className="text-xs text-red-700 dark:text-red-200">
-		    {error}
-		  </div>)}
-	    </div>
-	    <div className="space-y-1">
-	      <PostImportStatusBadge value={effectiveStatus}/>
-	    </div>
-	    <div className="flex justify-end">
-	      <Button
-		  type="button"
-		  variant="outline"
-		  onClick={onEdit}
-		  disabled={row.importStatus === 'created'}>
-		編輯
-	      </Button>
-	    </div>
-	  </div>
-
-	  <div
-	      className={cn (
-		  'space-y-3 rounded-lg border p-4 md:hidden',
-		  toneClass (row),
-	      )}>
-	    <div className="flex items-start gap-3">
-	      <ThumbnailPreview
-		  url={String (row.attributes.thumbnailBase ?? '')}
-		  className="h-20 w-20 shrink-0"/>
-	      <div className="min-w-0 flex-1 space-y-2">
-		<div className="line-clamp-2 text-sm font-medium">
-		  {String (row.attributes.title ?? '') || '（タイトル未取得）'}
-		</div>
-		<div className="truncate text-xs text-neutral-600 dark:text-neutral-300">
-		  {row.url}
-		</div>
-		<div className="flex flex-wrap gap-2">
-		  <PostImportStatusBadge value={effectiveStatus}/>
-		</div>
-		{row.createdPostId && (
-		    <PrefetchLink
-			to={`/posts/${ row.createdPostId }`}
-			className="inline-block text-xs text-sky-700 underline
-				   dark:text-sky-300">
-		      投稿 #{row.createdPostId}
-		    </PrefetchLink>)}
-		{error && (
-		    <div className="text-xs text-red-700 dark:text-red-200">
-		      {error}
-		    </div>)}
-		{warning && (
-		    <div className="text-xs text-amber-700 dark:text-amber-200">
-		      {warning}
-		    </div>)}
-	      </div>
-	    </div>
-	    <Button
-		type="button"
-		variant="outline"
-		onClick={onEdit}
-		disabled={row.importStatus === 'created'}>
-	      編輯
-	    </Button>
-	  </div>
-	</>)
-}
-
-export default PostImportRowSummary

frontend/src/components/posts/import/PostImportStatusBadge.tsx

@@ -1,70 +0,0 @@
-import { cn } from '@/lib/utils'
-
-import type { FC } from 'react'
-
-import type { PostImportOrigin } from '@/lib/postImportSession'
-
-type BadgeValue =
-    'ready'
-    | 'warning'
-    | 'error'
-    | 'pending'
-    | 'created'
-    | 'skipped'
-    | 'failed'
-    | PostImportOrigin
-
-type Props = {
-    value: BadgeValue }
-
-const LABELS: Record<BadgeValue, string> = {
-    ready:     '登録可能',
-    warning:   '警告',
-    error:     '要修正',
-    pending:   '未登録',
-    created:   '登録済み',
-    skipped:   'スキップ',
-    failed:    '失敗',
-    automatic: '自動取得',
-    manual:    '手修正' }
-
-const STYLES: Record<BadgeValue, string[]> = {
-    ready: [
-	'border-emerald-300 bg-emerald-50 text-emerald-700',
-	'dark:border-emerald-900 dark:bg-emerald-950 dark:text-emerald-200'],
-    warning: [
-	'border-amber-300 bg-amber-50 text-amber-700',
-	'dark:border-amber-900 dark:bg-amber-950 dark:text-amber-200'],
-    error: [
-	'border-red-300 bg-red-50 text-red-700',
-	'dark:border-red-900 dark:bg-red-950 dark:text-red-200'],
-    pending: [
-	'border-slate-300 bg-slate-50 text-slate-700',
-	'dark:border-slate-700 dark:bg-slate-900 dark:text-slate-200'],
-    created: [
-	'border-sky-300 bg-sky-50 text-sky-700',
-	'dark:border-sky-900 dark:bg-sky-950 dark:text-sky-200'],
-    skipped: [
-	'border-stone-300 bg-stone-50 text-stone-700',
-	'dark:border-stone-700 dark:bg-stone-900 dark:text-stone-200'],
-    failed: [
-	'border-rose-300 bg-rose-50 text-rose-700',
-	'dark:border-rose-900 dark:bg-rose-950 dark:text-rose-200'],
-    automatic: [
-	'border-slate-300 bg-slate-50 text-slate-700',
-	'dark:border-slate-700 dark:bg-slate-900 dark:text-slate-200'],
-    manual: [
-	'border-purple-300 bg-purple-50 text-purple-700',
-	'dark:border-purple-900 dark:bg-purple-950 dark:text-purple-200'] }
-
-
-const PostImportStatusBadge: FC<Props> = ({ value }) => (
-    <span
-	className={cn (
-	    'inline-flex items-center rounded-full border px-2.5 py-1 text-xs font-medium',
-	    STYLES[value],
-	)}>
-      {LABELS[value]}
-    </span>)
-
-export default PostImportStatusBadge

frontend/src/components/posts/import/ThumbnailPreview.tsx

@@ -1,49 +0,0 @@
-import { useEffect, useState } from 'react'
-
-import type { FC } from 'react'
-
-
-type Props = {
-    url:       string
-    alt?:      string
-    className?: string }
-
-
-const ThumbnailPreview: FC<Props> = ({ url, alt = 'サムネール', className = 'h-16 w-16' }) => {
-    const [failed, setFailed] = useState (false)
-
-    useEffect (() => {
-	setFailed (false)
-    }, [url])
-
-    if (!(url))
-      {
-	return (
-	    <div
-		className={`${ className } flex items-center justify-center rounded border
-			    border-border bg-muted text-xs text-muted-foreground`}>
-	      なし
-	    </div>)
-      }
-
-    if (failed)
-      {
-	return (
-	    <div
-		className={`${ className } flex items-center justify-center rounded border
-			    border-amber-300 bg-amber-50 p-2 text-center text-xs
-			    text-amber-700 dark:border-amber-900 dark:bg-amber-950
-			    dark:text-amber-200`}>
-	      サムネールを表示できません
-	    </div>)
-      }
-
-    return (
-	<img
-	    src={url}
-	    alt={alt}
-	    className={`${ className } rounded border border-border object-cover`}
-	    onError={() => setFailed (true)}/>)
-}
-
-export default ThumbnailPreview

frontend/src/components/posts/import/postImportRowStatus.ts

@@ -1,24 +0,0 @@
-import type { PostImportRow } from '@/lib/postImportSession'
-
-export type PostImportEffectiveStatus =
-    'created'
-    | 'skipped'
-    | 'failed'
-    | 'error'
-    | 'warning'
-    | 'ready'
-
-
-export const effectivePostImportStatus = (
-    row: PostImportRow,
-): PostImportEffectiveStatus => {
-    switch (row.importStatus)
-      {
-      case 'created':
-      case 'skipped':
-      case 'failed':
-	return row.importStatus
-      default:
-	return row.status
-      }
-}

frontend/src/lib/postImportSession.ts

@@ -1,614 +0,0 @@
-export type PostImportOrigin = 'automatic' | 'manual'
-export type PostImportRepairMode = 'all' | 'failed'
-export type PostImportStatus =
-    'pending'
-    | 'created'
-    | 'skipped'
-    | 'failed'
-export type PostImportResultStatus = 'created' | 'skipped' | 'failed'
-export type PostImportAttributeValue = string | number
-
-export type PostImportRow = {
-    sourceRow:         number
-    url:               string
-    attributes:        Record<string, PostImportAttributeValue>
-    fieldWarnings:     Record<string, string[]>
-    baseWarnings:      string[]
-    validationErrors:  Record<string, string[]>
-    importErrors?:     Record<string, string[]>
-    provenance:        Record<string, PostImportOrigin>
-    tagSources?:       Record<PostImportOrigin, string>
-    status:            'ready' | 'warning' | 'error'
-    metadataUrl?:      string
-    createdPostId?:    number
-    importStatus?:     PostImportStatus }
-
-export type PostImportResultRow = {
-    sourceRow: number
-    status:    PostImportResultStatus
-    post?:     { id: number }
-    errors?:   Record<string, string[]> }
-
-export type PostImportSession = {
-    version:    number
-    savedAt:    string
-    source:     string
-    rows:       PostImportRow[]
-    repairMode: PostImportRepairMode }
-
-export type PostImportSourceIssue = {
-    sourceRow: number
-    message:   string
-    url:       string }
-
-type StorageErrorHandler = (message: string) => void
-
-const SESSION_VERSION = 2
-const SESSION_PREFIX = 'post-import-session:'
-const SOURCE_DRAFT_KEY = 'post-import-source-draft'
-const SESSION_MAX_AGE_MS = 24 * 60 * 60 * 1000
-const MAX_ROWS = 100
-const MAX_URL_BYTES = 20 * 1024
-
-
-const isPlainObject = (value: unknown): value is Record<string, unknown> =>
-    typeof value === 'object' && value != null && !(Array.isArray (value))
-
-
-const sessionKey = (sessionId: string): string => `${ SESSION_PREFIX }${ sessionId }`
-
-
-const readStorage = (
-    key:       string,
-    onError?:  StorageErrorHandler,
-): string | null => {
-    if (typeof window === 'undefined')
-      return null
-
-    try
-    {
-	return sessionStorage.getItem (key)
-    }
-    catch
-    {
-	onError?.('保存済みデータを読み込めませんでした．')
-	return null
-    }
-}
-
-
-const writeStorage = (
-    key:       string,
-    value:     string,
-    onError?:  StorageErrorHandler,
-): boolean => {
-    if (typeof window === 'undefined')
-      return false
-
-    try
-    {
-	sessionStorage.setItem (key, value)
-	return true
-    }
-    catch
-    {
-	onError?.('ブラウザへ保存できませんでした．')
-	return false
-    }
-}
-
-
-const removeStorage = (
-    key:       string,
-    onError?:  StorageErrorHandler,
-) => {
-    if (typeof window === 'undefined')
-      return
-
-    try
-    {
-	sessionStorage.removeItem (key)
-    }
-    catch
-    {
-	onError?.('保存済みデータを削除できませんでした．')
-    }
-}
-
-
-const truncateUrl = (value: string): string =>
-    value.length > 120 ? `${ value.slice (0, 117) }…` : value
-
-
-const bytesize = (value: string): number =>
-    new TextEncoder ().encode (value).length
-
-
-const normaliseImportUrl = (value: string): string | null => {
-    const trimmed = value.trim ()
-    if (!(trimmed))
-      return null
-
-    try
-    {
-	const url = new URL (trimmed)
-	if (!(url.protocol === 'http:' || url.protocol === 'https:'))
-	  return null
-	if (!(url.host))
-	  return null
-
-	url.hostname = url.hostname.toLowerCase ()
-	if (url.pathname.endsWith ('/'))
-	  url.pathname = url.pathname.replace (/\/+$/, '')
-	return url.toString ()
-    }
-    catch
-    {
-	return null
-    }
-}
-
-
-const ensureStringListRecord = (value: unknown): Record<string, string[]> | null => {
-    if (!(isPlainObject (value)))
-      return null
-
-    const result: Record<string, string[]> = { }
-    for (const [key, entry] of Object.entries (value))
-      {
-	if (!(Array.isArray (entry)) || !(entry.every (_1 => typeof _1 === 'string')))
-	  return null
-	result[key] = entry
-      }
-    return result
-}
-
-
-const isValidStatus = (
-    value: unknown,
-): value is PostImportRow['status'] =>
-    value === 'ready' || value === 'warning' || value === 'error'
-
-
-const isValidImportStatus = (
-    value: unknown,
-): value is PostImportStatus =>
-    value === 'pending'
-    || value === 'created'
-    || value === 'skipped'
-    || value === 'failed'
-
-
-const isValidOrigin = (
-    value: unknown,
-): value is PostImportOrigin =>
-    value === 'automatic' || value === 'manual'
-
-
-const sanitiseRow = (value: unknown): PostImportRow | null => {
-    if (!(isPlainObject (value)))
-      return null
-    if (!(Number.isInteger (value.sourceRow)) || Number (value.sourceRow) <= 0)
-      return null
-    if (typeof value.url !== 'string')
-      return null
-    if (!(isPlainObject (value.attributes)))
-      return null
-    if (!(isPlainObject (value.provenance)))
-      return null
-    if (!(isValidStatus (value.status)))
-      return null
-    if (value.importStatus != null && !(isValidImportStatus (value.importStatus)))
-      return null
-
-    const validationErrors = ensureStringListRecord (value.validationErrors)
-    const fieldWarnings = ensureStringListRecord (value.fieldWarnings)
-    if (validationErrors == null || fieldWarnings == null)
-      return null
-
-    const importErrors =
-	value.importErrors == null
-	? undefined
-	: ensureStringListRecord (value.importErrors)
-    if (value.importErrors != null && importErrors == null)
-      return null
-    if (!(Array.isArray (value.baseWarnings))
-	|| !(value.baseWarnings.every (_1 => typeof _1 === 'string')))
-      return null
-
-    const provenanceEntries = Object.entries (value.provenance)
-    if (!(provenanceEntries.every (([, origin]) => isValidOrigin (origin))))
-      return null
-
-    if (value.tagSources != null)
-      {
-	if (!(isPlainObject (value.tagSources)))
-	  return null
-	if (!(Object.values (value.tagSources).every (_1 => typeof _1 === 'string')))
-	  return null
-      }
-
-    return {
-	sourceRow: Number (value.sourceRow),
-	url: value.url,
-	attributes: value.attributes as Record<string, PostImportAttributeValue>,
-	fieldWarnings,
-	baseWarnings: value.baseWarnings,
-	validationErrors,
-	importErrors,
-	provenance: value.provenance as Record<string, PostImportOrigin>,
-	tagSources: value.tagSources as Record<PostImportOrigin, string> | undefined,
-	status: value.status,
-	metadataUrl: typeof value.metadataUrl === 'string' ? value.metadataUrl : undefined,
-	createdPostId:
-	    Number.isInteger (value.createdPostId) ? Number (value.createdPostId) : undefined,
-	importStatus: value.importStatus }
-}
-
-
-const isExpiredSession = (savedAt: string): boolean => {
-    const value = Date.parse (savedAt)
-    return Number.isNaN (value) || Date.now () - value > SESSION_MAX_AGE_MS
-}
-
-
-export const createPostImportSessionId = (): string =>
-    typeof crypto !== 'undefined' && 'randomUUID' in crypto
-    ? crypto.randomUUID ()
-    : `${ Date.now () }-${ Math.random ().toString (36).slice (2) }`
-
-
-export const cleanupExpiredPostImportSessions = (
-    onError?: StorageErrorHandler,
-) => {
-    if (typeof window === 'undefined')
-      return
-
-    try
-    {
-	for (let i = 0; i < sessionStorage.length; ++i)
-	  {
-	    const key = sessionStorage.key (i)
-	    if (key == null || !(key.startsWith (SESSION_PREFIX)))
-	      continue
-
-	    const raw = sessionStorage.getItem (key)
-	    if (raw == null)
-	      continue
-	    try
-	    {
-		const value = JSON.parse (raw) as { savedAt?: string }
-		if (typeof value.savedAt !== 'string' || isExpiredSession (value.savedAt))
-		  {
-		    sessionStorage.removeItem (key)
-		    --i
-		  }
-	    }
-	    catch
-	    {
-		sessionStorage.removeItem (key)
-		--i
-	    }
-	  }
-    }
-    catch
-    {
-	onError?.('保存済みデータを整理できませんでした．')
-    }
-}
-
-
-export const loadPostImportSourceDraft = (
-    onError?: StorageErrorHandler,
-): { source: string } => {
-    const raw = readStorage (SOURCE_DRAFT_KEY, onError)
-    if (raw == null)
-      return { source: '' }
-
-    try
-    {
-	const value = JSON.parse (raw) as { source?: string }
-	return { source: typeof value.source === 'string' ? value.source : '' }
-    }
-    catch
-    {
-	return { source: '' }
-    }
-}
-
-
-export const savePostImportSourceDraft = (
-    source:    string,
-    onError?:  StorageErrorHandler,
-): boolean =>
-    writeStorage (SOURCE_DRAFT_KEY, JSON.stringify ({ source }), onError)
-
-
-export const clearPostImportSourceDraft = (
-    onError?: StorageErrorHandler,
-) => {
-    removeStorage (SOURCE_DRAFT_KEY, onError)
-}
-
-
-export const savePostImportSession = (
-    sessionId: string,
-    session:   Omit<PostImportSession, 'version' | 'savedAt'>,
-    onError?:  StorageErrorHandler,
-): boolean =>
-    writeStorage (
-	sessionKey (sessionId),
-	JSON.stringify ({
-	    ...session,
-	    version: SESSION_VERSION,
-	    savedAt: new Date ().toISOString () }),
-	onError,
-    )
-
-
-export const loadPostImportSession = (
-    sessionId: string,
-    onError?: StorageErrorHandler,
-): PostImportSession | null => {
-    const raw = readStorage (sessionKey (sessionId), onError)
-    if (raw == null)
-      return null
-
-    try
-    {
-	const value = JSON.parse (raw) as Partial<PostImportSession>
-	if (value.version !== SESSION_VERSION || !(Array.isArray (value.rows)))
-	  return null
-	if (typeof value.savedAt !== 'string' || isExpiredSession (value.savedAt))
-	  {
-	    removeStorage (sessionKey (sessionId), onError)
-	    return null
-	  }
-
-	const rows = value.rows.map (sanitiseRow)
-	if (rows.some (_1 => _1 == null))
-	  return null
-
-	return {
-	    version: SESSION_VERSION,
-	    savedAt: value.savedAt,
-	    source: typeof value.source === 'string' ? value.source : '',
-	    rows: rows as PostImportRow[],
-	    repairMode: value.repairMode === 'failed' ? 'failed' : 'all' }
-    }
-    catch
-    {
-	return null
-    }
-}
-
-
-const rowChanged = (
-    previous: PostImportRow,
-    next:     PostImportRow,
-): boolean =>
-    previous.url !== next.url
-    || JSON.stringify (previous.attributes) !== JSON.stringify (next.attributes)
-    || JSON.stringify (previous.provenance) !== JSON.stringify (next.provenance)
-    || JSON.stringify (previous.tagSources ?? { }) !== JSON.stringify (next.tagSources ?? { })
-
-
-export const mergeValidatedImportRows = (
-    current:   PostImportRow[],
-    validated: PostImportRow[],
-): PostImportRow[] => {
-    const validatedMap = new Map (validated.map (row => [row.sourceRow, row]))
-    return current.map (previous => {
-	if (previous.importStatus === 'created')
-	  return previous
-
-	const row = validatedMap.get (previous.sourceRow)
-	if (row == null)
-	  return previous
-
-	const fieldWarnings =
-	    Object.keys (row.fieldWarnings).length > 0 || row.metadataUrl !== previous.metadataUrl
-	    ? { ...row.fieldWarnings }
-	    : { ...previous.fieldWarnings }
-	for (const [field, origin] of Object.entries (row.provenance))
-	  {
-	    if (origin === 'manual')
-	      delete fieldWarnings[field]
-	  }
-
-	return {
-	    ...previous,
-	    url: row.url,
-	    attributes: row.attributes,
-	    provenance: row.provenance,
-	    tagSources: row.tagSources,
-	    fieldWarnings,
-	    baseWarnings:
-		row.baseWarnings.length > 0 || row.metadataUrl !== previous.metadataUrl
-		? row.baseWarnings
-		: previous.baseWarnings,
-	    validationErrors: row.validationErrors,
-	    status: row.status,
-	    metadataUrl: row.metadataUrl }
-    })
-}
-
-
-export const mergePreviewImportRows = (
-    current: PostImportRow[],
-    preview: PostImportRow[],
-): PostImportRow[] => {
-    const currentMap = new Map (current.map (row => [row.sourceRow, row]))
-    return preview.map (row => {
-	const previous = currentMap.get (row.sourceRow)
-	if (previous == null)
-	  return row
-	if (previous.importStatus === 'created')
-	  return previous
-
-	const mergedAttributes = { ...row.attributes }
-	const mergedProvenance = { ...row.provenance }
-	for (const [field, origin] of Object.entries (previous.provenance))
-	  {
-	    if (origin !== 'manual' || field === 'url')
-	      continue
-	    if (field in previous.attributes)
-	      mergedAttributes[field] = previous.attributes[field]
-	    mergedProvenance[field] = 'manual'
-	  }
-
-	const mergedTagSources =
-	    previous.provenance.tags === 'manual'
-	    ? {
-		automatic: row.tagSources?.automatic ?? '',
-		manual: previous.tagSources?.manual ?? String (previous.attributes.tags ?? '') }
-	    : row.tagSources
-
-	const nextRow = {
-	    ...row,
-	    attributes: mergedAttributes,
-	    provenance: mergedProvenance,
-	    tagSources: mergedTagSources,
-	    createdPostId: previous.createdPostId,
-	    importStatus: previous.importStatus,
-	    importErrors: previous.importErrors }
-
-	if (rowChanged (previous, nextRow))
-	  {
-	    nextRow.importStatus = 'pending'
-	    nextRow.importErrors = undefined
-	  }
-	return nextRow
-    })
-}
-
-
-export const mergeImportResults = (
-    rows:    PostImportRow[],
-    results: PostImportResultRow[],
-): PostImportRow[] => {
-    const resultMap = new Map (results.map (row => [row.sourceRow, row]))
-    return rows.map (row => {
-	const result = resultMap.get (row.sourceRow)
-	return result
-	    ? {
-		...row,
-		importStatus: result.status,
-		createdPostId: result.post?.id,
-		importErrors: result.errors }
-	    : row
-    })
-}
-
-
-export const retryImportRow = (
-    rows:      PostImportRow[],
-    sourceRow: number,
-): PostImportRow[] =>
-    rows.map (row =>
-	row.sourceRow === sourceRow && row.importStatus === 'failed'
-	? { ...row, importStatus: 'pending', importErrors: undefined }
-	: row)
-
-
-export const countImportSourceLines = (source: string): number =>
-    source
-	.split (/\r\n|\n|\r/)
-	.map (_1 => _1.trim ())
-	.filter (_1 => _1 !== '')
-	.length
-
-
-export const validateImportSource = (
-    source: string,
-): PostImportSourceIssue[] => {
-    const lines = source.split (/\r\n|\n|\r/)
-    const issues: PostImportSourceIssue[] = []
-    const seen = new Map<string, number> ()
-    let count = 0
-
-    lines.forEach ((rawLine, index) => {
-	const value = rawLine.trim ()
-	if (!(value))
-	  return
-
-	++count
-	const sourceRow = index + 1
-	const displayUrl = truncateUrl (value)
-	const normalised = normaliseImportUrl (value)
-	if (count > MAX_ROWS)
-	  {
-	    issues.push ({
-		sourceRow,
-		message: `取込件数は ${ MAX_ROWS } 件までです．`,
-		url: displayUrl })
-	    return
-	  }
-	if (!(value.startsWith ('http://') || value.startsWith ('https://')))
-	  {
-	    issues.push ({
-		sourceRow,
-		message: 'HTTP または HTTPS の URL ではありません．',
-		url: displayUrl })
-	    return
-	  }
-	if (bytesize (value) > MAX_URL_BYTES)
-	  {
-	    issues.push ({
-		sourceRow,
-		message: 'URL が長すぎます．',
-		url: displayUrl })
-	    return
-	  }
-	if (normalised == null)
-	  {
-	    issues.push ({
-		sourceRow,
-		message: 'URL の形式が不正です．',
-		url: displayUrl })
-	    return
-	  }
-	const duplicateRow = seen.get (normalised)
-	if (duplicateRow != null)
-	  {
-	    issues.push ({
-		sourceRow,
-		message: `${ duplicateRow } 行目と同じ URL です．`,
-		url: displayUrl })
-	    return
-	  }
-	seen.set (normalised, sourceRow)
-    })
-
-    return issues
-}
-
-
-const hasSkipWarning = (row: PostImportRow): boolean =>
-    (row.fieldWarnings.url ?? []).includes ('既存投稿のためスキップします．')
-
-
-export const submittableImportRows = (rows: PostImportRow[]): PostImportRow[] =>
-    rows.filter (row => {
-	if (row.importStatus === 'created')
-	  return false
-	if (row.importStatus === 'skipped')
-	  return false
-	if (hasSkipWarning (row))
-	  return false
-	if (row.importStatus === 'failed')
-	  return false
-	return row.importStatus == null || row.importStatus === 'pending'
-    })
-
-
-export const reviewSummaryCounts = (rows: PostImportRow[]) => ({
-    total: rows.length,
-    submittable: rows.filter (row =>
-	submittableImportRows ([row]).length > 0
-	&& Object.keys (row.validationErrors ?? { }).length === 0).length,
-    invalid: rows.filter (row => Object.keys (row.validationErrors ?? { }).length > 0).length,
-    skipPlanned: rows.filter (row =>
-	hasSkipWarning (row) && row.importStatus !== 'created').length,
-    created: rows.filter (row => row.importStatus === 'created').length,
-    failed: rows.filter (row => row.importStatus === 'failed').length })

frontend/src/pages/posts/PostImportResultPage.tsx

@@ -1,274 +0,0 @@
-import { useEffect, useMemo, useState } from 'react'
-import { Helmet } from 'react-helmet-async'
-import { useNavigate,
-	 useParams } from 'react-router-dom'
-
-import FieldError from '@/components/common/FieldError'
-import PageTitle from '@/components/common/PageTitle'
-import PrefetchLink from '@/components/PrefetchLink'
-import MainArea from '@/components/layout/MainArea'
-import PostImportStatusBadge from '@/components/posts/import/PostImportStatusBadge'
-import { Button } from '@/components/ui/button'
-import { toast } from '@/components/ui/use-toast'
-import { SITE_TITLE } from '@/config'
-import { apiPost } from '@/lib/api'
-import { canEditContent } from '@/lib/users'
-import { clearPostImportSourceDraft,
-	 loadPostImportSession,
-	 mergeImportResults,
-	 retryImportRow,
-	 savePostImportSession,
-	 type PostImportResultRow,
-	 type PostImportSession } from '@/lib/postImportSession'
-import Forbidden from '@/pages/Forbidden'
-
-import type { FC } from 'react'
-
-import type { User } from '@/types'
-
-type Props = { user: User | null }
-
-const resultToneClass = (status: string | undefined): string[] => {
-    switch (status)
-      {
-      case 'created':
-	return [
-	    'border-sky-200 bg-sky-50',
-	    'dark:border-sky-900 dark:bg-sky-950/30']
-      case 'skipped':
-	return [
-	    'border-stone-200 bg-stone-50',
-	    'dark:border-stone-800 dark:bg-stone-900/60']
-      case 'failed':
-	return [
-	    'border-rose-200 bg-rose-50',
-	    'dark:border-rose-900 dark:bg-rose-950/30']
-      default:
-	return [
-	    'border-border bg-white',
-	    'dark:border-neutral-700 dark:bg-neutral-900']
-      }
-}
-
-
-const PostImportResultPage: FC<Props> = ({ user }) => {
-    const editable = canEditContent (user)
-    const navigate = useNavigate ()
-    const { sessionId } = useParams ()
-
-    const [session, setSession] = useState<PostImportSession | null> (null)
-    const [missing, setMissing] = useState (false)
-    const [loadingRow, setLoadingRow] = useState<number | null> (null)
-
-    useEffect (() => {
-	if (!(sessionId))
-	  return
-
-	const loaded = loadPostImportSession (sessionId, message =>
-	    toast ({ title: '取込状態を復元できませんでした', description: message }))
-	setSession (loaded)
-	setMissing (loaded == null)
-    }, [sessionId])
-
-    useEffect (() => {
-	if (!(sessionId) || !(session))
-	  return
-
-	savePostImportSession (sessionId, session, message =>
-	    toast ({ title: '取込状態を保存できませんでした', description: message }))
-    }, [session, sessionId])
-
-    const counts = useMemo (() => ({
-	created: session?.rows.filter (_1 => _1.importStatus === 'created').length ?? 0,
-	skipped: session?.rows.filter (_1 => _1.importStatus === 'skipped').length ?? 0,
-	failed: session?.rows.filter (_1 => _1.importStatus === 'failed').length ?? 0 }), [session])
-
-    const retry = async (sourceRow: number) => {
-	if (!(session))
-	  return
-
-	setLoadingRow (sourceRow)
-	try
-	{
-	    const pendingRows = retryImportRow (session.rows, sourceRow)
-	    setSession ({ ...session, rows: pendingRows })
-	    const target = pendingRows.find (_1 => _1.sourceRow === sourceRow)
-	    if (target == null)
-	      return
-
-	    const result = await apiPost<{
-		created: number
-		skipped: number
-		failed:  number
-		rows:    PostImportResultRow[] }> ('/posts/import', {
-		    rows: [{
-			sourceRow: target.sourceRow,
-			url: target.url,
-			attributes: target.attributes,
-			provenance: target.provenance,
-			tagSources: target.tagSources,
-			metadataUrl: target.metadataUrl }] })
-	    setSession (current =>
-		current
-		? { ...current, rows: mergeImportResults (current.rows, result.rows) }
-		: current)
-	}
-	catch
-	{
-	    setSession (session)
-	    toast ({ title: '再試行に失敗しました' })
-	}
-	finally
-	{
-	    setLoadingRow (null)
-	}
-    }
-
-    const openRepair = (sourceRow: number) => {
-	const nextSession = { ...session, repairMode: 'failed' as const }
-	setSession (nextSession)
-	if (sessionId)
-	  {
-	    const saved = savePostImportSession (sessionId, nextSession, message =>
-		toast ({ title: '取込状態を保存できませんでした', description: message }))
-	    if (!(saved))
-	      return
-	  }
-	navigate (`/posts/import/${ sessionId }/review?edit=${ sourceRow }`)
-    }
-
-    if (!(editable))
-      return <Forbidden/>
-
-    if (missing || !(sessionId) || !(session))
-      {
-	return (
-	    <MainArea>
-	      <div className="mx-auto max-w-4xl space-y-4 p-4">
-		<PageTitle>投稿インポート結果</PageTitle>
-		<FieldError messages={['取込状態が見つかりません．']}/>
-		<Button type="button" onClick={() => navigate ('/posts/import')}>
-		  URL リスト入力へ戻る
-		</Button>
-	      </div>
-	    </MainArea>)
-      }
-
-    return (
-	<MainArea>
-	  <Helmet>
-	    <title>{`投稿インポート結果 | ${ SITE_TITLE }`}</title>
-	  </Helmet>
-
-	  <div className="mx-auto max-w-5xl space-y-4 p-4">
-	    <PageTitle>登録結果</PageTitle>
-
-	    <div className="rounded-lg border bg-white p-4 dark:border-neutral-700
-			    dark:bg-neutral-900">
-	      <div className="flex flex-wrap gap-2">
-		<SummaryChip label="登録成功" value={counts.created} badge="created"/>
-		<SummaryChip label="スキップ" value={counts.skipped} badge="skipped"/>
-		<SummaryChip label="失敗" value={counts.failed} badge="failed"/>
-	      </div>
-	    </div>
-
-	    <div className="space-y-3">
-	      {session.rows.map (row => (
-		  <div
-		      key={row.sourceRow}
-		      className={[
-			  'rounded-lg border p-4',
-			  ...resultToneClass (row.importStatus)].join (' ')}>
-		    <div className="flex flex-col gap-3 md:flex-row md:items-start
-				    md:justify-between">
-		      <div className="space-y-2">
-			<div className="flex flex-wrap items-center gap-2">
-			  <span className="text-sm font-medium">行 {row.sourceRow}</span>
-			  <PostImportStatusBadge value={row.importStatus ?? 'pending'}/>
-			</div>
-			<div className="text-sm text-neutral-700 dark:text-neutral-200">
-			  {String (row.attributes.title ?? '') || row.url}
-			</div>
-			<div className="text-xs text-neutral-500 dark:text-neutral-400">
-			  {row.url}
-			</div>
-			{row.createdPostId && (
-			    <PrefetchLink
-				to={`/posts/${ row.createdPostId }`}
-				className="inline-block text-xs text-sky-700 underline
-					   dark:text-sky-300">
-			      投稿 #{row.createdPostId}
-			    </PrefetchLink>)}
-			<FieldError messages={Object.values (row.importErrors ?? { }).flat ()}/>
-		      </div>
-
-		      <div className="flex flex-col gap-2 sm:flex-row">
-			{row.createdPostId && (
-			    <Button type="button" variant="outline" asChild>
-			      <PrefetchLink to={`/posts/${ row.createdPostId }`}>
-				投稿を開く
-			      </PrefetchLink>
-			    </Button>)}
-			{row.importStatus === 'failed' && (
-			    <>
-			      <Button
-				  type="button"
-				  variant="outline"
-				  onClick={() => openRepair (row.sourceRow)}>
-				編輯
-			      </Button>
-			      <Button
-				  type="button"
-				  onClick={() => retry (row.sourceRow)}
-				  disabled={loadingRow === row.sourceRow}>
-				再試行
-			      </Button>
-			    </>)}
-		      </div>
-		    </div>
-		  </div>))}
-	    </div>
-
-	    <div className="flex flex-col gap-2 sm:flex-row">
-	      <Button
-		  type="button"
-		  variant="outline"
-		  onClick={() => {
-		      const nextSession = { ...session, repairMode: 'all' as const }
-		      setSession (nextSession)
-		      const saved = savePostImportSession (sessionId, nextSession, message =>
-			  toast ({ title: '取込状態を保存できませんでした', description: message }))
-		      if (!(saved))
-			return
-		      navigate (`/posts/import/${ sessionId }/review`)
-		  }}>
-		確認画面へ戻る
-	      </Button>
-	      <Button
-		  type="button"
-		  variant="outline"
-		  onClick={() => {
-		      clearPostImportSourceDraft (message =>
-			  toast ({ title: '入力内容を削除できませんでした', description: message }))
-		      navigate ('/posts/import')
-		  }}>
-		新しい URL リストを入力
-	      </Button>
-	    </div>
-	  </div>
-	</MainArea>)
-}
-
-const SummaryChip = (
-    { label, value, badge }: {
-	label: string
-	value: number
-	badge: 'created' | 'skipped' | 'failed' },
-) => (
-    <div className="flex items-center gap-2 rounded-full border border-border
-		    bg-background px-3 py-1 text-sm">
-      <PostImportStatusBadge value={badge}/>
-      <span>{label} {value}</span>
-    </div>)
-
-export default PostImportResultPage

frontend/src/pages/posts/PostImportReviewPage.tsx

@@ -1,336 +0,0 @@
-import { useEffect, useMemo, useState } from 'react'
-import { Helmet } from 'react-helmet-async'
-import { useNavigate,
-	 useParams,
-	 useSearchParams } from 'react-router-dom'
-
-import PageTitle from '@/components/common/PageTitle'
-import MainArea from '@/components/layout/MainArea'
-import PostImportRowDialog from '@/components/posts/import/PostImportRowDialog'
-import PostImportRowSummary from '@/components/posts/import/PostImportRowSummary'
-import PostImportStatusBadge from '@/components/posts/import/PostImportStatusBadge'
-import { Button } from '@/components/ui/button'
-import { toast } from '@/components/ui/use-toast'
-import { SITE_TITLE } from '@/config'
-import { apiPost } from '@/lib/api'
-import { canEditContent } from '@/lib/users'
-import { loadPostImportSession,
-	 mergeImportResults,
-	 mergeValidatedImportRows,
-	 reviewSummaryCounts,
-	 savePostImportSession,
-	 submittableImportRows,
-	 type PostImportResultRow,
-	 type PostImportRow,
-	 type PostImportSession } from '@/lib/postImportSession'
-import Forbidden from '@/pages/Forbidden'
-
-import type { FC } from 'react'
-
-import type { User } from '@/types'
-
-type Props = { user: User | null }
-
-type Draft = {
-    url:                   string
-    title:                 string
-    thumbnailBase:         string
-    originalCreatedFrom:   string
-    originalCreatedBefore: string
-    duration:              string
-    tags:                  string
-    parentPostIds:         string }
-
-
-const PostImportReviewPage: FC<Props> = ({ user }) => {
-    const editable = canEditContent (user)
-    const navigate = useNavigate ()
-    const { sessionId } = useParams ()
-    const [searchParams, setSearchParams] = useSearchParams ()
-
-    const [session, setSession] = useState<PostImportSession | null> (null)
-    const [loading, setLoading] = useState (false)
-    const [missing, setMissing] = useState (false)
-    const [savingRow, setSavingRow] = useState<number | null> (null)
-
-    useEffect (() => {
-	if (!(sessionId))
-	  return
-
-	const loaded = loadPostImportSession (sessionId, message =>
-	    toast ({ title: '取込状態を復元できませんでした', description: message }))
-	setSession (loaded)
-	setMissing (loaded == null)
-    }, [sessionId])
-
-    useEffect (() => {
-	if (!(sessionId) || !(session))
-	  return
-
-	savePostImportSession (sessionId, session, message =>
-	    toast ({ title: '取込状態を保存できませんでした', description: message }))
-    }, [session, sessionId])
-
-    const rows = session?.rows ?? []
-    const editingSourceRow = Number (searchParams.get ('edit') ?? '')
-    const editingRow =
-	Number.isFinite (editingSourceRow)
-	? rows.find (_1 => _1.sourceRow === editingSourceRow) ?? null
-	: null
-    const counts = useMemo (() => reviewSummaryCounts (rows), [rows])
-    const submittable = useMemo (
-	() => submittableImportRows (rows).filter (row =>
-	    Object.keys (row.validationErrors ?? { }).length === 0),
-	[rows],
-    )
-    const reviewRows =
-	session?.repairMode === 'failed'
-	? [...rows].sort ((a, b) => {
-	    const aFailed = a.importStatus === 'failed' ? 0 : 1
-	    const bFailed = b.importStatus === 'failed' ? 0 : 1
-	    return aFailed - bFailed || a.sourceRow - b.sourceRow
-	})
-	: rows
-
-    useEffect (() => {
-	if (editingRow == null || session?.repairMode !== 'failed')
-	  return
-
-	const element = document.getElementById (`post-import-row-${ editingRow.sourceRow }`)
-	element?.scrollIntoView ({ block: 'center', behavior: 'smooth' })
-    }, [editingRow, session?.repairMode])
-
-    const updateSessionRows = (nextRows: PostImportRow[]) =>
-	setSession (current =>
-	    current ? { ...current, rows: nextRows } : current)
-
-    const saveDraft = async (draft: Draft): Promise<boolean> => {
-	if (!(session))
-	  return false
-	if (editingRow == null)
-	  return false
-
-	const urlChanged = draft.url !== editingRow.url
-	const nextProvenance = { ...editingRow.provenance }
-	const nextAttributes = { ...editingRow.attributes }
-	const nextTagSources = {
-	    automatic: editingRow.tagSources?.automatic ?? '',
-	    manual: editingRow.tagSources?.manual ?? '' }
-	const draftFields = [
-	    ['title', draft.title],
-	    ['thumbnailBase', draft.thumbnailBase],
-	    ['originalCreatedFrom', draft.originalCreatedFrom],
-	    ['originalCreatedBefore', draft.originalCreatedBefore],
-	    ['duration', draft.duration],
-	    ['parentPostIds', draft.parentPostIds],
-	] as const
-	draftFields.forEach (([field, value]) => {
-	    nextAttributes[field] = value
-	    nextProvenance[field] =
-		value !== String (editingRow.attributes[field] ?? '')
-		? 'manual'
-		: (editingRow.provenance[field] ?? 'automatic')
-	})
-	nextAttributes.tags = draft.tags
-	if (draft.tags !== String (editingRow.attributes.tags ?? ''))
-	  {
-	    nextProvenance.tags = 'manual'
-	    nextTagSources.manual = draft.tags
-	  }
-	else
-	  {
-	    nextProvenance.tags = editingRow.provenance.tags ?? 'automatic'
-	    nextTagSources.manual = editingRow.tagSources?.manual ?? ''
-	  }
-
-	setSavingRow (editingRow.sourceRow)
-	const nextRows = session.rows.map (row =>
-	    row.sourceRow === editingRow.sourceRow
-	    ? {
-		...row,
-		url: draft.url,
-		attributes: nextAttributes,
-		provenance: {
-		    ...nextProvenance,
-		    url: urlChanged ? 'manual' : (editingRow.provenance.url ?? 'manual') },
-		tagSources: nextTagSources,
-		importStatus: row.importStatus === 'created' ? 'created' : 'pending',
-		importErrors: undefined }
-	    : row)
-	try
-	{
-	    const validated = await apiPost<{ rows: PostImportRow[] }> ('/posts/import/validate', {
-		rows: nextRows
-		    .filter (row => row.importStatus !== 'created')
-		    .map (row => ({
-			sourceRow: row.sourceRow,
-			url: row.url,
-			attributes: row.attributes,
-			provenance: row.provenance,
-			tagSources: row.tagSources,
-			metadataUrl: row.metadataUrl })),
-		changed_row: urlChanged ? editingRow.sourceRow : -1 })
-	    updateSessionRows (mergeValidatedImportRows (nextRows, validated.rows))
-	    setSearchParams ({ })
-	    return true
-	}
-	catch
-	{
-	    toast ({ title: '行の再検証に失敗しました' })
-	    return false
-	}
-	finally
-	{
-	    setSavingRow (null)
-	}
-    }
-
-    const submit = async () => {
-	if (!(sessionId) || !(session) || submittable.length === 0)
-	  return
-
-	setLoading (true)
-	try
-	{
-	    const result = await apiPost<{
-		created: number
-		skipped: number
-		failed:  number
-		rows:    PostImportResultRow[] }> ('/posts/import', {
-		    rows: submittable.map (row => ({
-			sourceRow: row.sourceRow,
-			url: row.url,
-			attributes: row.attributes,
-			provenance: row.provenance,
-			tagSources: row.tagSources,
-			metadataUrl: row.metadataUrl })) })
-	    const nextRows = mergeImportResults (session.rows, result.rows)
-	    const nextSession = { ...session, rows: nextRows, repairMode: 'all' as const }
-	    setSession (nextSession)
-	    const saved = savePostImportSession (sessionId, nextSession, message =>
-		toast ({ title: '取込状態を保存できませんでした', description: message }))
-	    if (!(saved))
-	      return
-	    navigate (`/posts/import/${ sessionId }/result`)
-	}
-	catch
-	{
-	    toast ({ title: '登録に失敗しました' })
-	}
-	finally
-	{
-	    setLoading (false)
-	}
-    }
-
-    if (!(editable))
-      return <Forbidden/>
-
-    if (missing || !(sessionId) || !(session))
-      {
-	return (
-	    <MainArea>
-	      <div className="mx-auto max-w-4xl space-y-4 p-4">
-		<PageTitle>投稿インポート</PageTitle>
-		<div className="text-red-700 dark:text-red-300">取込状態が見つかりません．</div>
-		<Button type="button" onClick={() => navigate ('/posts/import')}>
-		  URL リスト入力へ戻る
-		</Button>
-	      </div>
-	    </MainArea>)
-      }
-
-    return (
-	<>
-	  <Helmet>
-	    <title>{`投稿インポート確認 | ${ SITE_TITLE }`}</title>
-	  </Helmet>
-
-	  <MainArea className="min-h-0">
-	    <div className="mx-auto max-w-6xl space-y-4 p-4">
-	      <PageTitle>投稿情報の確認・編輯</PageTitle>
-
-	      <div className="rounded-lg border bg-white p-4 dark:border-neutral-700
-			      dark:bg-neutral-900">
-		<div className="flex flex-wrap items-center gap-2">
-		  <SummaryChip label="全件" value={counts.total}/>
-		  <SummaryChip label="登録対象" value={counts.submittable}/>
-		  <SummaryChip label="要修正" value={counts.invalid}/>
-		  <SummaryChip label="スキップ予定" value={counts.skipPlanned}/>
-		  <SummaryChip label="登録済み" value={counts.created}/>
-		  <SummaryChip label="失敗" value={counts.failed}/>
-		</div>
-	      </div>
-
-	      <div className="space-y-3">
-		{reviewRows.map (row => (
-		    <div key={row.sourceRow} id={`post-import-row-${ row.sourceRow }`}>
-		      <PostImportRowSummary
-			  row={row}
-			  onEdit={() => {
-			      setSearchParams ({ edit: String (row.sourceRow) })
-			  }}/>
-		    </div>))}
-	      </div>
-	    </div>
-	  </MainArea>
-
-	  <PostImportFooter
-	      loading={loading}
-	      invalidCount={counts.invalid}
-	      submittableCount={submittable.length}
-	      onBack={() => navigate ('/posts/import')}
-	      onSubmit={submit}/>
-
-	  <PostImportRowDialog
-	      open={editingRow != null}
-	      row={editingRow}
-	      saving={savingRow != null}
-	      onOpenChange={open => {
-		  if (!(open))
-		    setSearchParams ({ })
-	      }}
-	      onSave={saveDraft}/>
-	</>)
-}
-
-const PostImportFooter = (
-    { loading, invalidCount, submittableCount, onBack, onSubmit }: {
-	loading:           boolean
-	invalidCount:      number
-	submittableCount:  number
-	onBack:            () => void
-	onSubmit:          () => void },
-) => (
-    <div
-	className="shrink-0 border-t bg-white/95 p-4 backdrop-blur
-		   dark:border-neutral-700 dark:bg-neutral-950/95">
-      <div className="mx-auto flex max-w-6xl flex-col gap-3 md:flex-row
-		      md:items-center md:justify-between">
-	<div className="flex flex-wrap items-center gap-2 text-sm">
-	  <PostImportStatusBadge value="pending"/>
-	  <span>登録対象 {submittableCount} 件</span>
-	  <PostImportStatusBadge value="error"/>
-	  <span>要修正 {invalidCount} 件</span>
-	</div>
-	<div className="flex flex-col gap-2 sm:flex-row">
-	  <Button type="button" variant="outline" onClick={onBack}>
-	    URL リスト入力へ戻る
-	  </Button>
-	  <Button
-	      type="button"
-	      onClick={onSubmit}
-	      disabled={loading || submittableCount === 0}>
-	    有効な投稿を一括登録
-	  </Button>
-	</div>
-      </div>
-    </div>)
-
-const SummaryChip = ({ label, value }: { label: string
-					  value: number }) => (
-    <div className="rounded-full border border-border bg-background px-3 py-1 text-sm">
-      {label} {value}
-    </div>)
-
-export default PostImportReviewPage

frontend/src/pages/posts/PostImportSourcePage.tsx

@@ -1,180 +0,0 @@
-import { useEffect, useMemo, useRef, useState } from 'react'
-import { Helmet } from 'react-helmet-async'
-import { useNavigate } from 'react-router-dom'
-
-import FieldError from '@/components/common/FieldError'
-import FormField from '@/components/common/FormField'
-import PageTitle from '@/components/common/PageTitle'
-import MainArea from '@/components/layout/MainArea'
-import { Button } from '@/components/ui/button'
-import { toast } from '@/components/ui/use-toast'
-import { SITE_TITLE } from '@/config'
-import { apiPost, isApiError } from '@/lib/api'
-import { canEditContent } from '@/lib/users'
-import { inputClass } from '@/lib/utils'
-import { countImportSourceLines,
-	 cleanupExpiredPostImportSessions,
-	 createPostImportSessionId,
-	 loadPostImportSourceDraft,
-	 savePostImportSession,
-	 savePostImportSourceDraft,
-	 validateImportSource,
-	 type PostImportRow } from '@/lib/postImportSession'
-import Forbidden from '@/pages/Forbidden'
-
-import type { FC } from 'react'
-
-import type { User } from '@/types'
-
-type Props = { user: User | null }
-
-const MAX_ROWS = 100
-
-
-const PostImportSourcePage: FC<Props> = ({ user }) => {
-    const editable = canEditContent (user)
-    const navigate = useNavigate ()
-    const draft = useMemo (() => loadPostImportSourceDraft (message =>
-	toast ({ title: '保存済み入力を復元できませんでした', description: message })), [])
-
-    const [source, setSource] = useState (draft.source)
-    const [loading, setLoading] = useState (false)
-    const [sourceIssues, setSourceIssues] = useState<ReturnType<typeof validateImportSource>> ([])
-    const [sourceError, setSourceError] = useState<string | null> (null)
-    const saveTimer = useRef<number | null> (null)
-
-    const lineCount = countImportSourceLines (source)
-    const messages = sourceError ? [sourceError] : []
-
-    useEffect (() => {
-	cleanupExpiredPostImportSessions (message =>
-	    toast ({ title: '保存済みデータを整理できませんでした', description: message }))
-    }, [])
-
-    useEffect (() => {
-	if (saveTimer.current != null)
-	  window.clearTimeout (saveTimer.current)
-	saveTimer.current = window.setTimeout (() => {
-	    savePostImportSourceDraft (source, message =>
-		toast ({ title: '入力内容を保存できませんでした', description: message }))
-	}, 300)
-	return () => {
-	    if (saveTimer.current != null)
-	      window.clearTimeout (saveTimer.current)
-	}
-    }, [source])
-
-    const preview = async () => {
-	if (lineCount === 0)
-	  {
-	    setSourceIssues ([])
-	    setSourceError ('URL を入力してください．')
-	    return
-	  }
-
-	const issues = validateImportSource (source)
-	if (issues.length > 0)
-	  {
-	    setSourceIssues (issues)
-	    setSourceError (null)
-	    return
-	  }
-
-	setLoading (true)
-	setSourceIssues ([])
-	setSourceError (null)
-	try
-	{
-	    const data = await apiPost<{ rows: PostImportRow[] }> ('/posts/import/preview', {
-		source })
-	    const sessionId = createPostImportSessionId ()
-	    const saved = savePostImportSession (sessionId, {
-		source,
-		rows: data.rows,
-		repairMode: 'all' }, message =>
-		toast ({ title: '取込状態を保存できませんでした', description: message }))
-	    if (!(saved))
-	      return
-	    navigate (`/posts/import/${ sessionId }/review`)
-	}
-	catch (requestError)
-	{
-	    const message =
-		isApiError<{ message?: string, baseErrors?: string[] }> (requestError)
-		? requestError.response?.data?.message
-		    ?? requestError.response?.data?.baseErrors?.[0]
-		: undefined
-	    setSourceError (message ?? '入力を確認してください．')
-	    toast ({
-		title: '投稿情報の取得に失敗しました',
-		description: message ?? '入力を確認してください．' })
-	}
-	finally
-	{
-	    setLoading (false)
-	}
-    }
-
-    if (!(editable))
-      return <Forbidden/>
-
-    return (
-	<MainArea>
-	  <Helmet>
-	    <title>{`投稿インポート | ${ SITE_TITLE }`}</title>
-	  </Helmet>
-
-	  <div className="mx-auto max-w-4xl space-y-4 p-4">
-	    <PageTitle>投稿インポート</PageTitle>
-	    <div className="rounded-lg border bg-white p-4 dark:border-neutral-700
-			    dark:bg-neutral-900 md:p-6">
-	      <div className="space-y-4">
-		<FormField label="URL リスト">
-		  {() => (
-		      <textarea
-			  value={source}
-			  rows={14}
-			  className={inputClass (
-			      messages.length > 0 || sourceIssues.length > 0,
-			      'font-mono text-sm',
-			  )}
-			  onBlur={() => {
-			      savePostImportSourceDraft (source, message =>
-				  toast ({
-				      title: '入力内容を保存できませんでした',
-				      description: message }))
-			  }}
-			  onChange={ev => {
-			      setSource (ev.target.value)
-			      setSourceError (null)
-			      setSourceIssues ([])
-			  }}/>)}
-		</FormField>
-		<FieldError messages={messages}/>
-		<ul className="space-y-2 text-sm text-red-700 dark:text-red-300">
-		  {sourceIssues.map (issue => (
-		      <li key={`${ issue.sourceRow }-${ issue.message }-${ issue.url }`}>
-			<div>{issue.sourceRow} 行目: {issue.message}</div>
-			<div className="break-all font-mono text-xs">{issue.url}</div>
-		      </li>))}
-		</ul>
-
-		<div className="flex items-center justify-between gap-3">
-		  <div className="text-sm text-neutral-600 dark:text-neutral-300">
-		    入力行数 {lineCount} / {MAX_ROWS}
-		  </div>
-		  <Button
-		      type="button"
-		      className="shrink-0"
-		      onClick={preview}
-		      disabled={loading}>
-		    次へ
-		  </Button>
-		</div>
-	      </div>
-	    </div>
-	  </div>
-	</MainArea>)
-}
-
-export default PostImportSourcePage

frontend/src/pages/posts/PostNewPage.tsx

@@ -25,13 +25,7 @@ import type { User } from '@/types'
 type Props = { user: User | null }
 
 type PostFormField =
-    'url'
-    | 'title'
-    | 'tags'
-    | 'parentPostIds'
-    | 'videoMs'
-    | 'originalCreatedAt'
-    | 'thumbnail'
+    'url' | 'title' | 'tags' | 'parentPostIds' | 'videoMs' | 'originalCreatedAt' | 'thumbnail'
 
 
 const PostNewPage: FC<Props> = ({ user }) => {
@@ -42,10 +36,8 @@ const PostNewPage: FC<Props> = ({ user }) => {
   const { baseErrors, fieldErrors, clearValidationErrors, applyValidationError } =
       useValidationErrors<PostFormField> ()
 
-  const [originalCreatedBefore, setOriginalCreatedBefore] =
-      useState<string | null> (null)
-  const [originalCreatedFrom, setOriginalCreatedFrom] =
-      useState<string | null> (null)
+  const [originalCreatedBefore, setOriginalCreatedBefore] = useState<string | null> (null)
+  const [originalCreatedFrom, setOriginalCreatedFrom] = useState<string | null> (null)
   const [parentPostIds, setParentPostIds] = useState ('')
   const [tags, setTags] = useState ('')
   const [duration, setDuration] = useState ('')
@@ -58,10 +50,8 @@ const PostNewPage: FC<Props> = ({ user }) => {
 
   const thumbnailPreviewRef = useRef ('')
   const videoFlg =
-      useMemo (() =>
-	  tags.split (/\s+/).some (
-	      tag => tag.replace (/\[.*\]$/, '') === '動画'),
-	       [tags])
+      useMemo (() => tags.split (/\s+/).some (tag => tag.replace (/\[.*\]$/, '') === '動画'),
+               [tags])
 
   const handleSubmit = async () => {
     clearValidationErrors ()
@@ -82,15 +72,14 @@ const PostNewPage: FC<Props> = ({ user }) => {
 
     try
     {
-      await apiPost ('/posts', formData,
-		     { headers: { 'Content-Type': 'multipart/form-data' } })
+      await apiPost ('/posts', formData, { headers: { 'Content-Type': 'multipart/form-data' } })
       toast ({ title: '投稿成功!' })
       navigate ('/posts')
     }
     catch (e)
     {
       applyValidationError (e)
-      toast ({ title: '投稿失敗', description: '入力を確認してください．' })
+      toast ({ title: '投稿失敗', description: '入力を確認してください。' })
     }
   }
 
@@ -98,8 +87,7 @@ const PostNewPage: FC<Props> = ({ user }) => {
     setTitleLoading (true)
     try
     {
-      const data = await apiGet<{ title: string }> ('/preview/title',
-						    { params: { url } })
+      const data = await apiGet<{ title: string }> ('/preview/title', { params: { url } })
       setTitle (data.title || '')
     }
     finally
@@ -117,8 +105,7 @@ const PostNewPage: FC<Props> = ({ user }) => {
     try
     {
       const data = await apiGet<Blob> ('/preview/thumbnail',
-				       { params: { url },
-					 responseType: 'blob' })
+				       { params: { url }, responseType: 'blob' })
       const imageURL = URL.createObjectURL (data)
       setThumbnailPreview (imageURL)
       setThumbnailFile (new File ([data],
@@ -176,7 +163,7 @@ const PostNewPage: FC<Props> = ({ user }) => {
 		    <Button
 			type="button"
 			variant="outline"
-			onClick={fetchTitle}
+			onClick={() => void fetchTitle ()}
 			disabled={!(url) || titleLoading}>
 		      取得
 		    </Button>
@@ -193,7 +180,7 @@ const PostNewPage: FC<Props> = ({ user }) => {
 		    <Button
 			type="button"
 			variant="outline"
-			onClick={fetchThumbnail}
+			onClick={() => void fetchThumbnail ()}
 			disabled={!(url) || thumbnailLoading}>
 		      取得
 		    </Button>