// Licensed to the Apache Software Foundation (ASF) under one
// or more contributor license agreements.  See the NOTICE file
// distributed with this work for additional information
// regarding copyright ownership.  The ASF licenses this file
// to you 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.

#include <pthread.h>
#include <cstddef>
#include <memory>
#include <list>
#include <iostream>
#include <sstream>
#include <butil/time.h>
#include <butil/macros.h>
#include <gflags/gflags.h>
#include <gtest/gtest.h>
#include "bvar/bvar.h"
#include "bvar/window.h"

class WindowTest : public testing::Test {
protected:
    void SetUp() {}
    void TearDown() {}
};

TEST_F(WindowTest, window) {
    const int window_size = 2;
    // test bvar::Adder
    bvar::Adder<int> adder;
    bvar::Window<bvar::Adder<int> > window_adder(&adder, window_size);
    bvar::PerSecond<bvar::Adder<int> > per_second_adder(&adder, window_size);
    bvar::WindowEx<bvar::Adder<int>, 2> window_ex_adder("window_ex_adder");
    bvar::PerSecondEx<bvar::Adder<int>, window_size> per_second_ex_adder("per_second_ex_adder");

    // test bvar::Maxer
    bvar::Maxer<int> maxer;
    bvar::Window<bvar::Maxer<int> > window_maxer(&maxer, window_size);
    bvar::WindowEx<bvar::Maxer<int>, window_size> window_ex_maxer;

    // test bvar::Miner
    bvar::Miner<int> miner;
    bvar::Window<bvar::Miner<int> > window_miner(&miner, window_size);
    bvar::WindowEx<bvar::Miner<int>, window_size> window_ex_miner;

    // test bvar::IntRecorder
    bvar::IntRecorder recorder;
    bvar::Window<bvar::IntRecorder> window_int_recorder(&recorder, window_size);
    bvar::WindowEx<bvar::IntRecorder, window_size> window_ex_int_recorder("window_ex_int_recorder");

    adder << 10;
    window_ex_adder << 10;
    per_second_ex_adder << 10;

    maxer << 10;
    window_ex_maxer << 10;
    miner << 10;
    window_ex_miner << 10;

    recorder << 10;
    window_ex_int_recorder << 10;

    sleep(1);
    adder << 2;
    window_ex_adder << 2;
    per_second_ex_adder << 2;

    maxer << 2;
    window_ex_maxer << 2;
    miner << 2;
    window_ex_miner << 2;

    recorder << 2;
    window_ex_int_recorder << 2;
    sleep(1);

    ASSERT_EQ(window_adder.get_value(), window_ex_adder.get_value());
    ASSERT_EQ(per_second_adder.get_value(), per_second_ex_adder.get_value());

    ASSERT_EQ(window_maxer.get_value(), window_ex_maxer.get_value());
    ASSERT_EQ(window_miner.get_value(), window_ex_miner.get_value());

    bvar::Stat recorder_stat = window_int_recorder.get_value();
    bvar::Stat window_ex_recorder_stat = window_ex_int_recorder.get_value();
    ASSERT_EQ(recorder_stat.get_average_int(), window_ex_recorder_stat.get_average_int());
    ASSERT_DOUBLE_EQ(recorder_stat.get_average_double(), window_ex_recorder_stat.get_average_double());
}