// Copyright 2015 MongoDB Inc.
//
// 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 <iostream>
#include <thread>
#include <chrono>
#include <string>

#include <bsoncxx/builder/stream/document.hpp>
#include <bsoncxx/json.hpp>

#include <mongocxx/client.hpp>
#include <mongocxx/options/find.hpp>
#include <mongocxx/instance.hpp>
#include <mongocxx/uri.hpp>
#include <mongocxx/pool.hpp>

using bsoncxx::builder::stream::document;
using bsoncxx::builder::stream::open_document;
using bsoncxx::builder::stream::close_document;
using bsoncxx::builder::stream::open_array;
using bsoncxx::builder::stream::close_array;
using bsoncxx::builder::stream::finalize;

char c[] = "\\|/-*";
int  cm = sizeof c;

void create(mongocxx::pool *a_pool){

    for(int i=0;i<10000;i++) try {
    //mongocxx::client conn{mongocxx::uri{}};
    auto conn = a_pool->acquire();
    auto db = (*conn)["test"];
    // @begin: cpp-insert-a-document
    bsoncxx::document::value restaurant_doc =
        document{} << "address" << open_document << "street"
                   << "2 Avenue"
                   << "zipcode"
                   << "10075"
                   << "building"
                   << "1480"
                   << "coord" << open_array << -73.9557413 << 40.7720266 << close_array
                   << close_document << "borough"
                   << "Manhattan"
                   << "cuisine"
                   << "Italian"
                   << "grades" << open_array << open_document << "date"
                   << bsoncxx::types::b_date{std::chrono::milliseconds{12323}} << "grade"
                   << "A"
                   << "score" << 11 << close_document << open_document << "date"
                   << bsoncxx::types::b_date{std::chrono::milliseconds{121212}} << "grade"
                   << "B"
                   << "score" << 17 << close_document << close_array << "name"
                   << "Vella"
                   << "restaurant_id"
                   << "41704620" << finalize;

        // We choose to move in our document here, which transfers ownership to insert_one()
        auto res = db["restaurants"].insert_one(std::move(restaurant_doc));
        // @end: cpp-insert-a-document
        std::this_thread::sleep_for(std::chrono::milliseconds(50));
        fprintf(stdout, "\b%c", c[i%cm]);
        fflush(stdout); 
    } catch(std::exception& ex){
       std::cout << "err: "<< ex.what() << std::endl;
    }

}

int main(int argc, char* argv[]) {
 try {
     mongocxx::instance inst{};
     std::cout << argv[1] << std::endl;
     const auto uri = mongocxx::uri{(argc >= 2) ? argv[1] : mongocxx::uri::k_default_uri};
     mongocxx::options::client client_options;
     mongocxx::pool pool(uri, client_options);

     std::cout << "start" << std::endl;
     create(&pool);
     std::cout << "stop" << std::endl;
 }catch(std::exception& ex){
       std::cout << ex.what() << std::endl;

 }
}