// Copyright (c) 2014-2018 Zano Project
// Distributed under the MIT/X11 software license, see the accompanying
// file COPYING or http://www.opensource.org/licenses/mit-license.php.

#include <iostream>
#include <vector>
#include <algorithm>
#include <boost/algorithm/string.hpp>
#include <boost/tokenizer.hpp>

#include "include_base_utils.h"
using namespace epee;
#include "misc_language.h"
#include "wallet/plain_wallet_api.h"
#include "wallet/wallet_helpers.h"
#include "wallet/plain_wallet_api_defs.h"


struct try_pull_result_open_response
{
  bool delivered;
  epee::json_rpc::response<view::open_wallet_response, epee::json_rpc::dummy_error> result;
  BEGIN_KV_SERIALIZE_MAP()
    KV_SERIALIZE(delivered)
    KV_SERIALIZE(result)
  END_KV_SERIALIZE_MAP()
};


void run_plain_wallet_api_test()
{
  LOG_PRINT_L0("Creating instance...");
  std::string s = plain_wallet::init("195.201.107.230", "11211");

  LOG_PRINT_L0("Generating wallet...");
  view::open_wallet_request owr = AUTO_VAL_INIT(owr);
  owr.path = "E:\\tmp\\zano_testwallet_745ss65030.zan";
  owr.pass = "";
  std::string job_id_str = plain_wallet::async_call("open", 0, epee::serialization::store_t_to_json(owr));


  try_pull_result_open_response rsp = AUTO_VAL_INIT(rsp);

  while (true)
  {
    std::string res = plain_wallet::try_pull_result(1);
    LOG_PRINT_L0("[try_pull_result] RESPONSE:" << ENDL << res);

    if (!epee::serialization::load_t_from_json(rsp, res))
    {
      LOG_ERROR("Failed to parse try_pull_result response: " << res);
      return;
    }
    epee::misc_utils::sleep_no_w(1000);
    if(!rsp.delivered)
      continue;
    break;
  }



  //std::string rsp = plain_wallet::open(std::string("E:\\tmp\\zano_testwallet_745ss65030.zan"), "");
  //LOG_PRINT_L0("RESPONSE:" << ENDL << rsp);
  //epee::json_rpc::response<view::open_wallet_response, epee::json_rpc::dummy_error> ok_response = AUTO_VAL_INIT(ok_response);
  //epee::serialization::load_t_from_json(ok_response, rsp);

  size_t count = 0;
  while (count < 10)
  {
    std::string prog = plain_wallet::get_wallet_status(rsp.result.result.wallet_id);
    LOG_PRINT_L0("Progress: " << ENDL << prog);
    view::wallet_sync_status_info wsi = AUTO_VAL_INIT(wsi);
    if (!epee::serialization::load_t_from_json(wsi, prog))
    {
      LOG_ERROR("Failed to get_wallet_status()");
      return;
    }
    if (!wsi.is_in_long_refresh)
      break;
    epee::misc_utils::sleep_no_w(1000);
  }

  std::string job_id_str2 = plain_wallet::async_call("close", rsp.result.result.wallet_id, "");
  try_pull_result_open_response rsp2 = AUTO_VAL_INIT(rsp2);

  while (true)
  {
    std::string res = plain_wallet::try_pull_result(2);
    LOG_PRINT_L0("[try_pull_result] RESPONSE:" << ENDL << res);

    if (!epee::serialization::load_t_from_json(rsp2, res))
    {
      LOG_ERROR("Failed to parse try_pull_result response: " << res);
      return;
    }
    epee::misc_utils::sleep_no_w(1000);
    if (!rsp2.delivered)
      continue;
    break;
  }


  LOG_PRINT_L0("OK");

}

//   LOG_PRINT_L0("Creating instance..." << std::hex << hw);
// 
//   LOG_PRINT_L0("Generating wallet...");
//   std::string rsp = plain_wallet::open(hw, std::string("E:\\tmp\\zano_testwallet_74565030.zan"), "");
//   LOG_PRINT_L0("RESPONSE:" << ENDL << rsp);
//   epee::json_rpc::response<plain_wallet::open_wallet_response, epee::json_rpc::dummy_error> ok_response = AUTO_VAL_INIT(ok_response);
//   epee::serialization::load_t_from_json(ok_response, rsp);
// 
//   plain_wallet::start_sync_thread(hw);
//   LOG_PRINT_L0("Started sync thread.");
// 
//   while (true)
//   {
//     std::string prog = plain_wallet::get_sync_status(hw);
//     plain_wallet::sync_status_response ssr = AUTO_VAL_INIT(ssr);
//     epee::serialization::load_t_from_json(ssr, prog);
//     LOG_PRINT_L0("Progress: " << ssr.progress << "Finished: " << ssr.finished);
//     if (ssr.finished)
//       break;
//     epee::misc_utils::sleep_no_w(1000);
//   }
//   LOG_PRINT_L0("Sync finished OK");
// 
//   {
//     //request get wallet info: 
//     epee::json_rpc::request<tools::wallet_public::COMMAND_RPC_GET_WALLET_INFO::request> gbreq = AUTO_VAL_INIT(gbreq);
//     gbreq.method = "get_wallet_info";
//     epee::json_rpc::response<tools::wallet_public::COMMAND_RPC_GET_WALLET_INFO::response, epee::json_rpc::error> gbres = AUTO_VAL_INIT(gbres);
//     std::string req_str = epee::serialization::store_t_to_json(gbreq);
// 
//     std::string res = plain_wallet::invoke(hw, req_str);
//     epee::serialization::load_t_from_json(gbres, res);
// 
//     LOG_PRINT_L0("Balance request returned: code [" << gbres.error.code << "], str_response: "
//       << ENDL << res);
//   }
// 
//   {
//     //request balance
//     epee::json_rpc::request<tools::wallet_public::COMMAND_RPC_GET_BALANCE::request> gbreq = AUTO_VAL_INIT(gbreq);
//     gbreq.method = "getbalance";
//     epee::json_rpc::response<tools::wallet_public::COMMAND_RPC_GET_BALANCE::response, epee::json_rpc::error> gbres = AUTO_VAL_INIT(gbres);
//     std::string req_str = epee::serialization::store_t_to_json(gbreq);
// 
//     std::string res = plain_wallet::invoke(hw, req_str);
//     epee::serialization::load_t_from_json(gbres, res);
// 
//     LOG_PRINT_L0("Balance request returned: code [" << gbres.error.code << "], balance: "
//       << gbres.result.balance << ", unlocked_balance: " << gbres.result.unlocked_balance);
//   }
// 
//   {
//     //request balance
//     epee::json_rpc::request<tools::wallet_public::COMMAND_RPC_STORE::request> gbreq = AUTO_VAL_INIT(gbreq);
//     gbreq.method = "store";
//     epee::json_rpc::response<tools::wallet_public::COMMAND_RPC_STORE::response, epee::json_rpc::error> gbres = AUTO_VAL_INIT(gbres);
//     std::string req_str = epee::serialization::store_t_to_json(gbreq);
// 
//     std::string res = plain_wallet::invoke(hw, req_str);
//     epee::serialization::load_t_from_json(gbres, res);
// 
//     LOG_PRINT_L0("Balance request returned: code [" << gbres.error.code << "], str_response: "
//       << ENDL << res); 
//   }
// 
//   plain_wallet::destroy_instance(hw);
// 
// 
//   return;
//   //-------
//   {
//     LOG_PRINT_L0("Creating instance...");
//     plain_wallet::hwallet hw = plain_wallet::create_instance("127.0.0.1", "11211");
//     LOG_PRINT_L0("Creating instance..." << std::hex << hw);
// 
//     LOG_PRINT_L0("Generating wallet...");
//     std::string rsp = plain_wallet::generate(hw, std::string("E:\\tmp\\zano_testwallet_") + std::to_string(epee::misc_utils::get_tick_count()) + ".zan", "");
//     LOG_PRINT_L0("RESPONSE:" << ENDL << rsp);
//     epee::json_rpc::response<plain_wallet::open_wallet_response, epee::json_rpc::dummy_error> ok_response = AUTO_VAL_INIT(ok_response);
//     epee::serialization::load_t_from_json(ok_response, rsp);
// 
//     plain_wallet::start_sync_thread(hw);
//     LOG_PRINT_L0("Started sync thread.");
// 
//     while (true)
//     {
//       std::string prog = plain_wallet::get_sync_status(hw);
//       plain_wallet::sync_status_response ssr = AUTO_VAL_INIT(ssr);
//       epee::serialization::load_t_from_json(ssr, prog);
//       LOG_PRINT_L0("Progress: " << ssr.progress << "Finished: " << ssr.finished);
//       if (ssr.finished)
//         break;
//       epee::misc_utils::sleep_no_w(1000);
//     }
//     LOG_PRINT_L0("Sync finished OK");
// 
//     {
//       //request get wallet info: 
//       epee::json_rpc::request<tools::wallet_public::COMMAND_RPC_GET_WALLET_INFO::request> gbreq = AUTO_VAL_INIT(gbreq);
//       gbreq.method = "get_wallet_info";
//       epee::json_rpc::response<tools::wallet_public::COMMAND_RPC_GET_WALLET_INFO::response, epee::json_rpc::error> gbres = AUTO_VAL_INIT(gbres);
//       std::string req_str = epee::serialization::store_t_to_json(gbreq);
// 
//       std::string res = plain_wallet::invoke(hw, req_str);
//       epee::serialization::load_t_from_json(gbres, res);
// 
//       LOG_PRINT_L0("Balance request returned: code [" << gbres.error.code << "], str_response: "
//         << ENDL << res);
//     }
// 
//     {
//       //request balance
//       epee::json_rpc::request<tools::wallet_public::COMMAND_RPC_GET_BALANCE::request> gbreq = AUTO_VAL_INIT(gbreq);
//       gbreq.method = "getbalance";
//       epee::json_rpc::response<tools::wallet_public::COMMAND_RPC_GET_BALANCE::response, epee::json_rpc::error> gbres = AUTO_VAL_INIT(gbres);
//       std::string req_str = epee::serialization::store_t_to_json(gbreq);
// 
//       std::string res = plain_wallet::invoke(hw, req_str);
//       epee::serialization::load_t_from_json(gbres, res);
// 
//       LOG_PRINT_L0("Balance request returned: code [" << gbres.error.code << "], balance: "
//         << gbres.result.balance << ", unlocked_balance: " << gbres.result.unlocked_balance);
//     }
// 
//     {
//       //request balance
//       epee::json_rpc::request<tools::wallet_public::COMMAND_RPC_STORE::request> gbreq = AUTO_VAL_INIT(gbreq);
//       gbreq.method = "store";
//       epee::json_rpc::response<tools::wallet_public::COMMAND_RPC_STORE::response, epee::json_rpc::error> gbres = AUTO_VAL_INIT(gbres);
//       std::string req_str = epee::serialization::store_t_to_json(gbreq);
// 
//       std::string res = plain_wallet::invoke(hw, req_str);
//       epee::serialization::load_t_from_json(gbres, res);
// 
//       LOG_PRINT_L0("Balance request returned: code [" << gbres.error.code << "], str_response: "
//         << ENDL << res);
//     }
//  }}