// Copyright (c) 2017, Baidu.com, 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.

#include "exec/csv_scanner.h"
#include "util/logging.h"

#include <gtest/gtest.h>

namespace palo {

class CsvScannerTest : public testing::Test {
public:
    CsvScannerTest() {
    }

protected:
    virtual void SetUp() {
        init();
    }
    virtual void TearDown() {
        system("rm -rf ./test_run");
    }

    void init();

    void init_desc_tbl();

private:
    std::vector<std::string> _file_paths;
};

void CsvScannerTest::init() {
    system("mkdir -p ./test_run");
    system("pwd");
    system("cp -r ./be/test/exec/test_data/csv_scanner ./test_run/.");

    _file_paths.push_back("./test_run/csv_scanner/csv_file1");
    _file_paths.push_back("./test_run/csv_scanner/csv_file2");
}

TEST_F(CsvScannerTest, normal_use) {
    CsvScanner scanner(_file_paths);
    Status status = scanner.open();
    ASSERT_TRUE(status.ok());

    std::string line_str;
    bool eos = false;
    status = scanner.get_next_row(&line_str, &eos);
    ASSERT_TRUE(status.ok());

    while (!eos) {
        status = scanner.get_next_row(&line_str, &eos);

        if (eos) {
            break;
        }
        ASSERT_TRUE(status.ok());

        LOG(WARNING) << line_str;
    }
}

TEST_F(CsvScannerTest, no_exist_files) {
    std::vector<std::string> no_exist_files;
    no_exist_files.push_back("no_exist_files1");
    no_exist_files.push_back("no_exist_files2");

    CsvScanner scanner(no_exist_files);
    Status status = scanner.open();
    // check until 'get_next_row()'
    ASSERT_TRUE(status.ok());

    std::string line_str;
    bool eos = false;
    status = scanner.get_next_row(&line_str, &eos);
    ASSERT_FALSE(status.ok());
}

} // end namespace palo

int main(int argc, char** argv) {
    // std::string conffile = std::string(getenv("PALO_HOME")) + "/conf/be.conf";
    // if (!palo::config::init(conffile.c_str(), false)) {
    //     fprintf(stderr, "error read config file. \n");
    //     return -1;
    // }
    palo::init_glog("be-test");
    ::testing::InitGoogleTest(&argc, argv);
    return RUN_ALL_TESTS();
}