/*
 * Copyright 2013 Canonical Ltd.
 *
 * This program is free software: you can redistribute it and/or modify it
 * under the terms of the GNU General Public License version 3, as published
 * by the Free Software Foundation.
 *
 * This program is distributed in the hope that it will be useful, but
 * WITHOUT ANY WARRANTY; without even the implied warranties of
 * MERCHANTABILITY, SATISFACTORY QUALITY, or FITNESS FOR A PARTICULAR
 * PURPOSE.  See the GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License along
 * with this program.  If not, see <http://www.gnu.org/licenses/>.
 *
 * Authors:
 *   Charles Kerr <charles.kerr@canonical.com>
 */

#include <datetime/clock.h>
#include <datetime/clock-mock.h>
#include <datetime/timezones.h>

#include <notifications/dbus-shared.h>

#include "test-dbus-fixture.h"

/***
****
***/

using namespace unity::indicator::datetime;

class ClockFixture: public TestDBusFixture
{
  private:
    typedef TestDBusFixture super;
};

TEST_F(ClockFixture, MinuteChangedSignalShouldTriggerOncePerMinute)
{
    // start up a live clock
    std::shared_ptr<Timezones> zones(new Timezones);
    zones->timezone.set("America/New_York");
    LiveClock clock(zones);
    wait_msec(500); // wait for the bus to set up

    // count how many times clock.minute_changed() is emitted over the next minute
    const DateTime now = clock.localtime();
    const auto gnow = now.get();
    auto gthen = g_date_time_add_minutes(gnow, 1);
    int count = 0;
    clock.minute_changed.connect([&count](){count++;});
    const auto msec = g_date_time_difference(gthen,gnow) / 1000;
    wait_msec(msec);
    EXPECT_EQ(1, count);
    g_date_time_unref(gthen);
}

/***
****
***/

#define TIMEZONE_FILE (SANDBOX"/timezone")

TEST_F(ClockFixture, HelloFixture)
{
    std::shared_ptr<Timezones> zones(new Timezones);
    zones->timezone.set("America/New_York");
    LiveClock clock(zones);
}


TEST_F(ClockFixture, TimezoneChangeTriggersSkew)
{
    std::shared_ptr<Timezones> zones(new Timezones);
    zones->timezone.set("America/New_York");
    LiveClock clock(zones);

    auto tz_nyc = g_time_zone_new("America/New_York");
    auto now_nyc = g_date_time_new_now(tz_nyc);
    auto now = clock.localtime();
    EXPECT_EQ(g_date_time_get_utc_offset(now_nyc), g_date_time_get_utc_offset(now.get()));
    EXPECT_LE(abs(g_date_time_difference(now_nyc,now.get())), G_USEC_PER_SEC);
    g_date_time_unref(now_nyc);
    g_time_zone_unref(tz_nyc);

    /// change the timezones!
    clock.minute_changed.connect([this](){
                   g_main_loop_quit(loop);
               });
    g_idle_add([](gpointer gs){
                   static_cast<Timezones*>(gs)->timezone.set("America/Los_Angeles");
                   return G_SOURCE_REMOVE;
               }, zones.get());
    g_main_loop_run(loop);

    auto tz_la = g_time_zone_new("America/Los_Angeles");
    auto now_la = g_date_time_new_now(tz_la);
    now = clock.localtime();
    EXPECT_EQ(g_date_time_get_utc_offset(now_la), g_date_time_get_utc_offset(now.get()));
    EXPECT_LE(abs(g_date_time_difference(now_la,now.get())), G_USEC_PER_SEC);
    g_date_time_unref(now_la);
    g_time_zone_unref(tz_la);
}

/***
****
***/

namespace
{
  void on_login1_name_acquired(GDBusConnection * connection,
                               const gchar     * /*name*/,
                               gpointer          /*user_data*/)
  {
      g_dbus_connection_emit_signal(connection,
                                    nullptr,
                                    "/org/freedesktop/login1", // object path
                                    "org.freedesktop.login1.Manager", // interface
                                    "PrepareForSleep", // signal name
                                    g_variant_new("(b)", FALSE),
                                    nullptr);
  }
}


/**
 * Confirm that a "PrepareForSleep" event wil trigger a skew event
 */
TEST_F(ClockFixture, SleepTriggersSkew)
{
    std::shared_ptr<Timezones> zones(new Timezones);
    zones->timezone.set("America/New_York");
    LiveClock clock(zones);
    wait_msec(250); // wait for the bus to set up

    bool skewed = false;
    clock.minute_changed.connect([&skewed, this](){
                    skewed = true;
                    g_main_loop_quit(loop);
                    return G_SOURCE_REMOVE;
                });

    auto name_tag = g_bus_own_name(G_BUS_TYPE_SYSTEM,
                                   "org.freedesktop.login1",
                                   G_BUS_NAME_OWNER_FLAGS_NONE,
                                   nullptr /* bus acquired */,
                                   on_login1_name_acquired,
                                   nullptr /* name lost */,
                                   nullptr /* user_data */,
                                   nullptr /* user_data closure */);
    g_main_loop_run(loop);
    EXPECT_TRUE(skewed);

    g_bus_unown_name(name_tag);
}

namespace
{
  void on_powerd_name_acquired(GDBusConnection * /*connection*/,
                               const gchar     * /*name*/,
                               gpointer          is_owned)
  {
    *static_cast<bool*>(is_owned) = true;
  }
}

/**
 * Confirm that powerd's SysPowerStateChange triggers
 * a timestamp change
 */
TEST_F(ClockFixture, SysPowerStateChange)
{
  // set up the mock clock
  bool minute_changed = false;
  auto clock = std::make_shared<MockClock>(DateTime::NowLocal());
  clock->minute_changed.connect([&minute_changed]() {
    minute_changed = true;
  });
  
  // control test -- minute_changed shouldn't get triggered
  // when the clock is silently changed
  gboolean is_owned = false;
  auto tag = g_bus_own_name_on_connection(system_bus,
                                          BUS_POWERD_NAME,
                                          G_BUS_NAME_OWNER_FLAGS_NONE,
                                          on_powerd_name_acquired,
                                          nullptr,
                                          &is_owned /* user_data */,
                                          nullptr /* user_data closure */);
  const DateTime not_now {DateTime::Local(1999, 12, 31, 23, 59, 59)};
  clock->set_localtime_quietly(not_now);
  wait_msec();
  ASSERT_TRUE(is_owned);
  ASSERT_FALSE(minute_changed);

  // now for the actual test,
  // confirm that SysPowerStateChange triggers a minute_changed() signal
  GError * error = nullptr;
  auto emitted = g_dbus_connection_emit_signal(system_bus,
                                               nullptr,
                                               BUS_POWERD_PATH,
                                               BUS_POWERD_INTERFACE,
                                               "SysPowerStateChange",
                                               g_variant_new("(i)", 1),
                                               &error);
  wait_msec();
  EXPECT_TRUE(emitted);
  EXPECT_EQ(nullptr, error);
  EXPECT_TRUE(minute_changed);

  // cleanup
  g_bus_unown_name(tag);
}