cre-ne-jp/log-archiver

class Channel < ApplicationRecord
  extend FriendlyId
  friendly_id :identifier
 
  include RankedModel
  ranks :row_order
 
  # 発言以外のメッセージ
  has_many :messages
  # 発言のメッセージ
  has_many :conversation_messages
 
  has_many :joins
  has_many :parts
  has_many :quits
  has_many :kicks
  has_many :nicks
  has_many :topics
  has_many :privmsgs
  has_many :notices
 
  # 発言のある日
  has_many :message_dates
 
  # チャンネルと最終発言の関係
  has_one :channel_last_speech
  # 最終発言
  has_one :last_speech, through: :channel_last_speech, source: :conversation_message
 
  validates(
    :name,
    presence: true,
    uniqueness: {
      case_sensitive: false
    },
    format: { with: /\A[^# ,:]+[^ ,:]*\z/ }
  )
  validates(
    :identifier,
    presence: true,
    uniqueness: {
      case_sensitive: false
    },
    format: { with: /\A[A-Za-z][-_A-Za-z0-9]*\z/ }
  )
 
  # ログ記録が有効なチャンネル
  scope :logging_enabled, -> { where(logging_enabled: true) }
  # ログ記録が無効なチャンネル
  scope :logging_disabled, -> { where(logging_enabled: false) }
 
  # 一覧表示の順序で並び替える
  scope :order_for_list, -> { rank(:row_order) }
 
  # ログ記録が有効なチャンネル名の配列を返す
  # @param [Boolean] lowercase 小文字に変換するかどうか
  # @return [Array<String>]
  def self.logging_enabled_names_with_prefix(lowercase: false)
    names = logging_enabled.pluck(:name)
    modifier =
      if lowercase
        ->(channel_name) { "##{channel_name.downcase}" }
      else
        ->(channel_name) { "##{channel_name}" }
      end
 
    names.map(&modifier)
  end
 
  # チャンネル名と識別子のペアの配列を返す
  # @return [Array<Array<String, String>>]
  def self.name_identifier_pairs
    order_for_list.
      map { |channel| [channel.name_with_prefix, channel.identifier] }
  end
 
  # チャンネル一覧用の順序のチャンネル配列を返す
  # @return [Array<Channel>]
Method `for_channels_index` has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.
  def self.for_channels_index
    last_speech_timestamp =
      ->(channel) { channel.last_speech&.timestamp || DateTime.new }
 
    all.
      includes(:last_speech).
      sort { |a, b|
        a_timestamp = last_speech_timestamp[a]
        b_timestamp = last_speech_timestamp[b]
 
        comp_timestamp = (b_timestamp <=> a_timestamp)
        next comp_timestamp unless comp_timestamp.zero?
 
        comp_row_order = (a.row_order <=> b.row_order)
        next comp_row_order unless comp_row_order.zero?
 
        a.id <=> b.id
      }
  end
 
  # Cinch::Message から該当するチャンネルを検索する
  # @param [Cinch::Message] m IRC メッセージ
  # @return [Channel, nil]
  def self.from_cinch_message(m)
    find_by(name: m.channel.name[1..-1])
  end
 
  # 接頭辞付きのチャンネル名を返す
  # @return [String]
  def name_with_prefix
    "##{name}"
  end
 
  # 小文字の接頭辞付きチャンネル名を返す
  # @return [String]
  def lowercase_name_with_prefix
    name_with_prefix.downcase
  end
 
  # 現在の（キャッシュされていない）最終発言を求める
  # @return [ConversationMessage]
  def current_last_speech
    conversation_messages
      .order(timestamp: :desc)
      .first
  end
 
  # canonical 属性の URL テンプレートを、日付を入れた URL にして返す
  # @param [Integer/String] year
  # @param [Integer/String] month
  # @param [Integer/String] day
  # @return [String]
  def canonical_url(year: nil, month: nil, day: nil)
    date = {'year' => year, 'month' => month, 'day' => day}.compact
    result = canonical_url_template
    pattern = /:(#{date.keys.join('|')})/
 
    while(result.match(pattern)) do
      result.gsub!(":#{$1}", sprintf('%02d', date[$1])) if date[$1].instance_of?(Integer)
    end
 
    canonical_base_url(result)
  end
 
  # canonical 属性の URL の埋め込みがない部分を返す
  # @param [String] url 埋め込み部分を含む URL
  # @return [String]
  def canonical_base_url(url = canonical_url_template)
    url.gsub(/:(year|month|day).*/, '')
  end
end