// Copyright 2014 Google Inc. All Rights Reserved.
//
// Licensed under the Apache License, Version 2.0 (the 'License');
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an 'AS IS' BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

library quiver.time.clock_test;

import 'package:quiver/testing/async.dart';
import 'package:quiver/async.dart';
import 'package:quiver/time.dart';
import 'package:test/test.dart';

main() {
  group("Metronome", () {
    test("delivers events as expected", () {
      new FakeAsync().run((async) {
        int callbacks = 0;
        DateTime lastTime;
        var sub = new Metronome.epoch(aMinute,
                clock: async.getClock(DateTime.parse("2014-05-05 20:00:30")))
            .listen((d) {
          callbacks++;
          lastTime = d;
        });
        expect(callbacks, 0, reason: "Should be no callbacks at start");
        async.elapse(aSecond * 15);
        expect(callbacks, 0, reason: "Should be no callbacks before trigger");
        async.elapse(aSecond * 15);
        expect(callbacks, 1, reason: "Calledback on rollover");
        expect(lastTime, DateTime.parse("2014-05-05 20:01:00"),
            reason: "And that time was correct");
        async.elapse(aMinute * 1);
        expect(callbacks, 2, reason: "Callback is repeated");
        expect(lastTime, DateTime.parse("2014-05-05 20:02:00"),
            reason: "And that time was correct");
        sub.cancel();
        async.elapse(aMinute * 2);
        expect(callbacks, 2, reason: "No callbacks after subscription cancel");
      });
    });

    test("can be re-listened to", () {
      new FakeAsync().run((async) {
        int callbacks = 0;
        var clock = new Metronome.epoch(aMinute,
            clock: async.getClock(DateTime.parse("2014-05-05 20:00:30")));
        var sub = clock.listen((d) {
          callbacks++;
        });
        async.elapse(aMinute);
        expect(callbacks, 1);
        sub.cancel();
        async.elapse(aMinute);
        expect(callbacks, 1);
        sub = clock.listen((d) {
          callbacks++;
        });
        async.elapse(aMinute);
        expect(callbacks, 2);
      });
    });

    test("supports multiple listeners joining and leaving", () {
      new FakeAsync().run((async) {
        List<int> callbacks = [0, 0];
        var clock = new Metronome.epoch(aMinute,
            clock: async.getClock(DateTime.parse("2014-05-05 20:00:30")));
        List subs = [
          clock.listen((d) {
            callbacks[0]++;
          }),
          clock.listen((d) {
            callbacks[1]++;
          })
        ];

        async.elapse(aMinute);
        expect(callbacks, [1, 1]);
        subs[0].cancel();
        async.elapse(aMinute);
        expect(callbacks, [1, 2]);
      });
    });

    test("can be anchored at any time", () {
      new FakeAsync().run((async) {
        List<DateTime> times = [];
        DateTime start = DateTime.parse("2014-05-05 20:06:00");
        Clock clock = async.getClock(start);
        new Metronome.periodic(aMinute * 10,
            clock: clock, anchor: clock.minutesAgo(59)).listen((d) {
          times.add(d);
        });
        async.elapse(anHour);
        expect(times, [
          DateTime.parse("2014-05-05 20:07:00"),
          DateTime.parse("2014-05-05 20:17:00"),
          DateTime.parse("2014-05-05 20:27:00"),
          DateTime.parse("2014-05-05 20:37:00"),
          DateTime.parse("2014-05-05 20:47:00"),
          DateTime.parse("2014-05-05 20:57:00"),
        ]);
      });
    });

    test("can be anchored in the future", () {
      new FakeAsync().run((async) {
        List<DateTime> times = [];
        DateTime start = DateTime.parse("2014-05-05 20:06:00");
        Clock clock = async.getClock(start);
        new Metronome.periodic(aMinute * 10,
            clock: clock, anchor: clock.minutesFromNow(61)).listen((d) {
          times.add(d);
        });
        async.elapse(anHour);
        expect(times, [
          DateTime.parse("2014-05-05 20:07:00"),
          DateTime.parse("2014-05-05 20:17:00"),
          DateTime.parse("2014-05-05 20:27:00"),
          DateTime.parse("2014-05-05 20:37:00"),
          DateTime.parse("2014-05-05 20:47:00"),
          DateTime.parse("2014-05-05 20:57:00"),
        ]);
      });
    });

    test("can be a periodic timer", () {
      new FakeAsync().run((async) {
        List<DateTime> times = [];
        DateTime start = DateTime.parse("2014-05-05 20:06:00.004");
        new Metronome.periodic(aMillisecond * 100,
            clock: async.getClock(start), anchor: start).listen((d) {
          times.add(d);
        });
        async.elapse(aMillisecond * 304);
        expect(times, [
          DateTime.parse("2014-05-05 20:06:00.104"),
          DateTime.parse("2014-05-05 20:06:00.204"),
          DateTime.parse("2014-05-05 20:06:00.304"),
        ]);
      });
    });

    test("resyncs when workers taking some time", () {
      new FakeAsync().run((async) {
        List<DateTime> times = [];
        DateTime start = DateTime.parse("2014-05-05 20:06:00.004");
        new Metronome.periodic(aMillisecond * 100,
            clock: async.getClock(start), anchor: start).listen((d) {
          times.add(d);
          async.elapseBlocking(const Duration(milliseconds: 80));
        });
        async.elapse(aMillisecond * 304);
        expect(times, [
          DateTime.parse("2014-05-05 20:06:00.104"),
          DateTime.parse("2014-05-05 20:06:00.204"),
          DateTime.parse("2014-05-05 20:06:00.304"),
        ]);
      });
    });

    test("drops time when workers taking longer than interval", () {
      new FakeAsync().run((async) {
        List<DateTime> times = [];
        DateTime start = DateTime.parse("2014-05-05 20:06:00.004");
        new Metronome.periodic(aMillisecond * 100,
            clock: async.getClock(start), anchor: start).listen((d) {
          times.add(d);
          async.elapseBlocking(const Duration(milliseconds: 105));
        });
        async.elapse(aMillisecond * 504);
        expect(times, [
          DateTime.parse("2014-05-05 20:06:00.104"),
          DateTime.parse("2014-05-05 20:06:00.304"),
          DateTime.parse("2014-05-05 20:06:00.504"),
        ]);
      });
    });
  });
}