module ASF::MLIST

# File lib/whimsy/asf/mlist.rb, line 313
def self.archiver_type(email, dom, list)
  case email
    when ARCH_MBOX_PUB then return [:MBOX, 'public']
    when ARCH_MBOX_PRV then return [:MBOX, 'private']
    when ARCH_MBOX_RST then return [:MBOX, 'restricted']
    when ARCH_PONY_PUB then return [:PONY, 'public']
    when ARCH_PONY_PRV then return [:PONY, 'private']
    when ARCH_EXT_MAIL_ARCHIVE then return [:MAIL_ARCH, 'public']
    # normal archiver routed via .qmail-[tlp-]list-archive
    when "#{list}-archive@#{dom}" then return [:MINO, 'alias']
    # Direct mail to minotaur
    when "apmail-#{dom.split('.').first}-#{list}-archive@www.apache.org" then return [:MINO, 'direct']
    # Unexpected archiver email commits-archive@incubator.apache.org for commits.deprecated@incubator.apache.org
    # INFRA-21658
    when "#{list.chomp('.deprecated')}-archive@#{dom}" then return [:MINO, 'alias']
    else
      return [:MARKMAIL, 'public'] if is_markmail_archiver?(email)
      # Whimsy currently only 'archives' private lists
      return [:WHIMSY, 'private'] if is_whimsy_archiver?(email)
  end
  raise "Unexpected archiver email #{email} for #{list}@#{dom}" # Should not happen?
end

# File lib/whimsy/asf/mlist.rb, line 29
def self.board_subscribers(archivers=true)
  return list_filter('sub', 'apache.org', 'board', archivers), File.mtime(LIST_TIME)
end

# File lib/whimsy/asf/mlist.rb, line 121
def self.digests(emails, response = {})

  response[:digests] = []
  response[:digtime] = File.mtime(LIST_TIME)

  emailslc = emails.map {|email| ASF::Mail.to_canonical(email.downcase)}
  list_parse('dig') do |dom, list, subs|
    subs.each do |sub|
      if emailslc.include? ASF::Mail.to_canonical(sub.downcase)
        response[:digests] << ["#{list}@#{dom}", sub]
      end
    end
  end
  response
end

# File lib/whimsy/asf/mlist.rb, line 271
def self.domain_lists(project, show_all)
  lists = {}
  list_types(show_all) do |dom, list, type|
    if matches_list?(project, dom, list)
      lists["#{list}@#{dom}"] = type
    end
  end
  lists
end

# File lib/whimsy/asf/mlist.rb, line 361
def self.downcase(array)
  array.map(&:downcase)
end

# File lib/whimsy/asf/mlist.rb, line 282
def self.each_list
  Find.find(LIST_CACHE) do |path|
    parts = path.split('/')
    if parts[-1] == 'sub'
      yield [parts[-3], parts[-2]]
    end
  end
end

# File lib/whimsy/asf/mlist.rb, line 365
def self.isRecent(file)
  return File.exist?(file) && (Time.now - File.mtime(file)) < 60 * 60 * 5
end

# File lib/whimsy/asf/mlist.rb, line 351
def self.is_archiver?(e)
  ARCHIVERS.include?(e) or is_mino_archiver?(e) or is_whimsy_archiver?(e) or is_markmail_archiver?(e)
end

# File lib/whimsy/asf/mlist.rb, line 347
def self.is_markmail_archiver?(e)
  e =~ ARCH_EXT_MARKMAIL_RE
end

# File lib/whimsy/asf/mlist.rb, line 337
def self.is_mino_archiver?(e)
  e =~ /.-archive@([^.]+\.)?(apache\.org|apachecon\.com)$/
end

# File lib/whimsy/asf/mlist.rb, line 355
def self.is_private_archiver?(e)
  [ARCH_MBOX_PRV, ARCH_PONY_PRV].include?(e) or
    e =~ /^security-archive@.*\.apache\.org$/ or
    e =~ /^apmail-\w+-security-archive@www.apache.org/ # direct subscription
end

# File lib/whimsy/asf/mlist.rb, line 342
def self.is_whimsy_archiver?(e)
  e =~ /@whimsy[-\da-z]*\.apache\.org$/
end

# File lib/whimsy/asf/mlist.rb, line 248
def self.list_archivers
  list_parse('sub') do |dom, list, subs|
    yield [dom, list, subs.select {|s| is_archiver? s}.map {|m| [m, archiver_type(m, dom, list)].flatten}]
  end
end

# File lib/whimsy/asf/mlist.rb, line 377
def self.list_filter(type, matchdom, matchlist, archivers=true)
  list = File.join(LIST_CACHE, matchdom, matchlist, type)
  if File.exist? list
    if archivers
      return File.read(list).split("\n")
    else
      return File.read(list).split("\n").reject {|e| is_archiver?(e)}
    end
  end
  return nil
end

# File lib/whimsy/asf/mlist.rb, line 171
def self.list_moderators(mail_domain)

  moderators = {}
  list_parse('mod') do |dom, list, subs|

    # drop infra test lists
    next if list =~ /^infra-[a-z]$/
    next if dom == 'incubator.apache.org' && list =~ /^infra-dev2?$/

    # does the list match our target?
    next unless mail_domain.nil? or matches_list?(mail_domain, dom, list)

    moderators["#{list}@#{dom}"] = subs.sort
  end
  return moderators.to_h, File.mtime(LIST_TIME)
end

# File lib/whimsy/asf/mlist.rb, line 395
def self.list_parse(type, &block)
  case type
  when 'dig'
    type = 'digest'
  when 'sub', 'mod'
    # pass
  else
    raise ArgumentError.new('type: expecting dig, mod or sub')
  end
  ctime = @@file_times[type] || 0
  mtime = File.mtime(LIST_TIME).to_i
  if mtime <= ctime
    cached = @@file_parsed[type]
    if cached
      begin
        cached.each do |d, l, m|
          block.call d, l, m # these are already frozen
        end
        return
      rescue WeakRef::RefError
        @@file_times[type] = 0
      end
    end
  else
    @@file_parsed[type] = nil
  end

  cache = [] # see if this preserves mod cache
  Find.find(LIST_CACHE) do |path|
    parts = path.split('/')
    if parts[-1] == type
      dom = parts[-3].downcase.freeze
      list = parts[-2].downcase.freeze
      begin
        # During mail migration links are used - allow for broken ones
        mails = File.read(path).split("\n")
        cache << [dom, list, mails]
        yield [dom, list, mails]
      rescue StandardError => e
        Wunderbar.warn e
      end
    end
  end
  @@file_parsed[type] = WeakRef.new(cache)
  @@file_times[type] = mtime
  nil # don't return file contents
end

# File lib/whimsy/asf/mlist.rb, line 239
def self.list_subs(mail_domain, podling=false, list_subs=false)
  self.list_subscribers(mail_domain, podling, list_subs, true)
end

# File lib/whimsy/asf/mlist.rb, line 202
def self.list_subscribers(mail_domain, _podling=false, list_subs=false, skip_archivers=false)

  subscribers = {}
  list_parse('sub') do |dom, list, subs|

    # drop infra test lists
    next if list =~ /^infra-[a-z]$/
    next if dom == 'incubator.apache.org' && list =~ /^infra-dev2?$/

    # normal tlp style:
    #/home/apmail/lists/commons.apache.org/dev/mod

    # does the list match our target?
    next unless matches_list?(mail_domain, dom, list)

    if skip_archivers
      subscribers["#{list}@#{dom}"] = list_subs ? subs.reject {|sub| is_archiver?(sub)}.sort : subs.reject {|sub| is_archiver?(sub)}.size
    else
      subscribers["#{list}@#{dom}"] = list_subs ? subs.sort : subs.size
    end
  end
  return subscribers.to_h, File.mtime(LIST_TIME)
end

# File lib/whimsy/asf/mlist.rb, line 244
def self.list_time
  File.mtime(LIST_TIME)
end

# File lib/whimsy/asf/mlist.rb, line 256
def self.list_types(show_all=false)
  list_archivers do |dom, list, subs|
    types = {}
    subs.each do |sub|
      type = sub[2]
      types[type] = 1 unless %w(alias direct).include? type
    end
    type = types.keys.sort.join(',')
    yield [dom, list, type] if show_all || type == 'public'
  end
end

# File lib/whimsy/asf/mlist.rb, line 156
def self.matches_list?(mail_domain, dom, list)
  # normal tlp style (now also podlings):
  #/home/apmail/lists/commons.apache.org/dev/mod
  #Apache lists (e.g. some non-PMCs)
  #/home/apmail/lists/apache.org/list/mod
  return "#{mail_domain}.apache.org" == dom ||
          (dom == 'apache.org' &&
          (list == mail_domain || list.start_with?("#{mail_domain}-"))
          ) || "#{list}@#{dom}" == mail_domain # e.g. planners@apachecon.com
end

# File lib/whimsy/asf/mlist.rb, line 39
def self.members_notify_subscribers(archivers=true)
  return list_filter('sub', 'apache.org', 'members-notify', archivers), File.mtime(LIST_TIME)
end

# File lib/whimsy/asf/mlist.rb, line 34
def self.members_subscribers(archivers=true)
  return list_filter('sub', 'apache.org', 'members', archivers), File.mtime(LIST_TIME)
end

# File lib/whimsy/asf/mlist.rb, line 142
def self.moderates(user_emails, response = {})

  response[:moderates] = {}
  response[:modtime] = File.mtime(LIST_TIME)
  umails = user_emails.map {|m| ASF::Mail.to_canonical(m.downcase)} # outside loop
  list_parse('mod') do |dom, list, emails|
    matching = emails.select {|m| umails.include? ASF::Mail.to_canonical(m.downcase)}
    response[:moderates]["#{list}@#{dom}"] = matching unless matching.empty?
  end
  response
end

# File lib/whimsy/asf/mlist.rb, line 295
def self.parse_markers
  hash = Hash.new {|h,k| h[k] = Hash.new}
  File.open(File.join(LIST_BASE, 'list-modsub')).each do |line|
    hash[line.chomp][:modsub] = 1
  end
  File.open(File.join(LIST_BASE, 'list-modpost')).each do |line|
    hash[line.chomp][:modpost] = 1
  end
  File.open(File.join(LIST_BASE, 'list-remote')).each do |line|
    hash[line.chomp][:remote] = 1
  end
  hash
end

# File lib/whimsy/asf/mlist.rb, line 60
  def self.private_subscribers(pmc, archivers=false)
    return [] unless Dir.exist? LIST_BASE
    parts = pmc.split('@', 3) # want to detect trailing '@'
    if parts.length == 1
      dom = "#{pmc}.apache.org"
      list = 'private'
    elsif parts.length == 2 && %w{apache.org apachecon.com}.include?(parts[1])
      dom = parts[1]
      list = parts[0]
    else
      raise "Unexpected parameter: #{pmc}"
    end
    subs = list_filter('sub', dom, list, archivers)
    digs = list_filter('digest', dom, list, archivers)
    if subs.nil?
      subs = digs # may also be nil
    elsif !digs.nil? # i.e. neither nil, so merge
      subs = (subs + digs).uniq
    end
    return subs, File.mtime(LIST_TIME)
end

# File lib/whimsy/asf/mlist.rb, line 83
def self.security_subscribers(pmc, archivers=false)
  return [] unless Dir.exist? LIST_BASE
  subs = list_filter('sub', "#{pmc}.apache.org", 'security', archivers)
  digs = list_filter('digest', "#{pmc}.apache.org", 'security', archivers)
  if subs.nil?
    subs = digs # may also be nil
  elsif !digs.nil? # i.e. neither nil, so merge
    subs = (subs + digs).uniq
  end
  return subs, File.mtime(LIST_TIME)
end

# File lib/whimsy/asf/mlist.rb, line 44
def self.sub_digest(dom, list, archivers=false)
  subs = list_filter('sub', dom, list, archivers)
  digs = list_filter('digest', dom, list, archivers)
  if subs.nil?
    subs = digs # may also be nil
  elsif !digs.nil? # i.e. neither nil, so merge
    subs = (subs + digs).uniq
  end
  return subs, File.mtime(LIST_TIME)
end

# File lib/whimsy/asf/mlist.rb, line 100
def self.subscriptions(emails, response = {})

  response[:subscriptions] = []
  response[:subtime] = File.mtime(LIST_TIME)

  emailslc = emails.map {|email| ASF::Mail.to_canonical(email.downcase)}
  list_parse('sub') do |dom, list, subs|
    subs.each do |sub|
      if emailslc.include? ASF::Mail.to_canonical(sub.downcase)
        response[:subscriptions] << ["#{list}@#{dom}", sub]
      end
    end
  end
  response
end