// Copyright 2014 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#include "services/ui/ws/animation_runner.h"

#include "base/memory/scoped_vector.h"
#include "services/ui/ws/animation_runner_observer.h"
#include "services/ui/ws/scheduled_animation_group.h"
#include "services/ui/ws/server_window.h"

namespace ui {
namespace ws {
namespace {

bool ConvertWindowAndAnimationPairsToScheduledAnimationGroups(
    const std::vector<AnimationRunner::WindowAndAnimationPair>& pairs,
    AnimationRunner::AnimationId id,
    base::TimeTicks now,
    std::vector<std::unique_ptr<ScheduledAnimationGroup>>* groups) {
  for (const auto& window_animation_pair : pairs) {
    DCHECK(window_animation_pair.first);
    DCHECK(window_animation_pair.second);
    std::unique_ptr<ScheduledAnimationGroup> group(
        ScheduledAnimationGroup::Create(window_animation_pair.first, now, id,
                                        *(window_animation_pair.second)));
    if (!group.get())
      return false;
    groups->push_back(std::move(group));
  }
  return true;
}

}  // namespace

AnimationRunner::AnimationRunner(base::TimeTicks now)
    : next_id_(1), last_tick_time_(now) {}

AnimationRunner::~AnimationRunner() {}

void AnimationRunner::AddObserver(AnimationRunnerObserver* observer) {
  observers_.AddObserver(observer);
}

void AnimationRunner::RemoveObserver(AnimationRunnerObserver* observer) {
  observers_.RemoveObserver(observer);
}

AnimationRunner::AnimationId AnimationRunner::Schedule(
    const std::vector<WindowAndAnimationPair>& pairs,
    base::TimeTicks now) {
  DCHECK_GE(now, last_tick_time_);

  const AnimationId animation_id = next_id_++;
  std::vector<std::unique_ptr<ScheduledAnimationGroup>> groups;
  if (!ConvertWindowAndAnimationPairsToScheduledAnimationGroups(
          pairs, animation_id, now, &groups)) {
    return 0;
  }

  // Cancel any animations for the affected windows. If the cancelled animations
  // also animated properties that are not animated by the new group - instantly
  // set those to the target value.
  for (auto& group : groups) {
    ScheduledAnimationGroup* current_group =
        window_to_animation_map_[group->window()].get();
    if (current_group)
      current_group->SetValuesToTargetValuesForPropertiesNotIn(*group.get());

    CancelAnimationForWindowImpl(group->window(), CANCEL_SOURCE_SCHEDULE);
  }

  // Update internal maps
  for (auto& group : groups) {
    group->ObtainStartValues();
    ServerWindow* window = group->window();
    window_to_animation_map_[window] = std::move(group);
    DCHECK(!id_to_windows_map_[animation_id].count(window));
    id_to_windows_map_[animation_id].insert(window);
  }

  for (auto& observer : observers_)
    observer.OnAnimationScheduled(animation_id);
  return animation_id;
}

void AnimationRunner::CancelAnimation(AnimationId id) {
  if (id_to_windows_map_.count(id) == 0)
    return;

  std::set<ServerWindow*> windows(id_to_windows_map_[id]);
  for (ServerWindow* window : windows)
    CancelAnimationForWindow(window);
}

void AnimationRunner::CancelAnimationForWindow(ServerWindow* window) {
  CancelAnimationForWindowImpl(window, CANCEL_SOURCE_CANCEL);
}

void AnimationRunner::Tick(base::TimeTicks time) {
  DCHECK(time >= last_tick_time_);
  last_tick_time_ = time;
  if (window_to_animation_map_.empty())
    return;

  // The animation ids of any windows whose animation completes are added here.
  // We notify after processing all windows so that if an observer mutates us in
  // some way we're aren't left in a weird state.
  std::set<AnimationId> animations_completed;
  for (WindowToAnimationMap::iterator i = window_to_animation_map_.begin();
       i != window_to_animation_map_.end();) {
    bool animation_done = i->second->Tick(time);
    if (animation_done) {
      const AnimationId animation_id = i->second->id();
      ServerWindow* window = i->first;
      ++i;
      bool animation_completed = RemoveWindowFromMaps(window);
      if (animation_completed)
        animations_completed.insert(animation_id);
    } else {
      ++i;
    }
  }
  for (const AnimationId& id : animations_completed) {
    for (auto& observer : observers_)
      observer.OnAnimationDone(id);
  }
}

void AnimationRunner::CancelAnimationForWindowImpl(ServerWindow* window,
                                                   CancelSource source) {
  if (!window_to_animation_map_[window])
    return;

  const AnimationId animation_id = window_to_animation_map_[window]->id();
  if (RemoveWindowFromMaps(window)) {
    // This was the last window in the group.
    if (source == CANCEL_SOURCE_CANCEL) {
      for (auto& observer : observers_)
        observer.OnAnimationCanceled(animation_id);
    } else {
      for (auto& observer : observers_)
        observer.OnAnimationInterrupted(animation_id);
    }
  }
}

bool AnimationRunner::RemoveWindowFromMaps(ServerWindow* window) {
  DCHECK(window_to_animation_map_[window]);

  const AnimationId animation_id = window_to_animation_map_[window]->id();
  window_to_animation_map_.erase(window);

  DCHECK(id_to_windows_map_.count(animation_id));
  id_to_windows_map_[animation_id].erase(window);
  if (!id_to_windows_map_[animation_id].empty())
    return false;

  id_to_windows_map_.erase(animation_id);
  return true;
}

}  // namespace ws
}  // namespace ui