class Github::Client::Activity::Notifications

def create(*args)
  arguments(args, required: [:id])
  put_request("/notifications/threads/#{arguments.id}/subscription", arguments.params)
end

def delete(*args)
  arguments(args, required: [:id])
  delete_request("/notifications/threads/#{arguments.id}/subscription", arguments.params)
end

def get(*args)
  arguments(args, required: [:id])
  response = get_request("/notifications/threads/#{arguments.id}", arguments.params)
  return response unless block_given?
  response.each { |el| yield el }
end

def list(*args)
  arguments(args) do
    permit %w[ all participating since user repo]
  end
  params = arguments.params
  response = if ( (user_name = params.delete("user")) &&
                  (repo_name = params.delete("repo")) )
    get_request("/repos/#{user_name}/#{repo_name}/notifications", params)
  else
    get_request("/notifications", params)
  end
  return response unless block_given?
  response.each { |el| yield el }
end

def mark(*args)
  arguments(args) do
    permit %w[ unread read last_read_at user repo id]
  end
  params = arguments.params
  if ( (user_name = params.delete("user")) &&
       (repo_name = params.delete("repo")) )
    put_request("/repos/#{user_name}/#{repo_name}/notifications", params)
  elsif (thread_id = params.delete("id"))
    patch_request("/notifications/threads/#{thread_id}", params)
  else
    put_request("/notifications", params)
  end
end

def subscribed?(*args)
  arguments(args, required: [:id])
  get_request("/notifications/threads/#{arguments.id}/subscription", arguments.params)
end