module ASF::Subreq

# File lib/whimsy/asf/subreq.rb, line 24
def self.create_request(user, email, list)
  {
    version: FORMAT_NUMBER,
    availid: user.id,
    addr: email,
    listkey: list,
    member_p: user.asf_member?, # does not appear to be used
    chair_p: ASF.pmc_chairs.include?(user), # does not appear to be used
  }
end

# File lib/whimsy/asf/subreq.rb, line 41
def self.queue_request(reqtype, request, wbar, credentials)
  raise Exception.new("Unexpected reqtype: #{reqtype}") unless %w{sub unsub}.include? reqtype

  queue_url = ASF::SVN.svnpath!('subreq') # only this URL is defined
  queue_url.sub! '/subreq', '/unsubreq' if reqtype == 'unsub'

  # subreq/unsubreq now accept name@dom
  # Keep the key for the file name
  list = request[:listkey]
  listkey = ASF::Mail.listdom2listkey(list)
  userid = request[:availid]

  content = JSON.pretty_generate(request) + "\n"

  # Each user can only (un)subscribe once to each list in each timeslot
  fn = "#{userid}-#{listkey}.json"

  Dir.mktmpdir do |tmpdir|

    if wbar
      ASF::SVN.svn_!('checkout', [queue_url, tmpdir], wbar, credentials)
    else
      ASF::SVN.svn!('checkout', [queue_url, tmpdir], credentials)
    end
    path = File.join(tmpdir, fn)
    if File.exist? path
      File.write(path, content) # overwrite
    else
      File.write(path, content) # new
      ASF::SVN.svn('add', path)
    end

    if reqtype == 'unsub'
      message = "#{list} -= #{userid}"
    else
      message = "#{list} += #{userid}"
    end

    options = credentials.merge({msg: message})
    if wbar
      ASF::SVN.svn_!('commit', path, wbar, options)
    else
      ASF::SVN.svn!('commit', path, options)
    end
  end
  return nil
end