class Github::Client::Activity::Notifications

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

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

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

def list(*args)
  arguments(args)
  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)
  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: [:thread_id])
  get_request("/notifications/threads/#{arguments.thread_id}/subscription", arguments.params)
end