peerplays_migrated/libraries/plugins/bookie/bookie_api.cpp

/*
 * Copyright (c) 2018 Peerplays Blockchain Standards Association, and contributors.
 *
 * The MIT License
 *
 * Permission is hereby granted, free of charge, to any person obtaining a copy
 * of this software and associated documentation files (the "Software"), to deal
 * in the Software without restriction, including without limitation the rights
 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
 * copies of the Software, and to permit persons to whom the Software is
 * furnished to do so, subject to the following conditions:
 *
 * The above copyright notice and this permission notice shall be included in
 * all copies or substantial portions of the Software.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 * THE SOFTWARE.
 */
#include <fc/filesystem.hpp>
#include <fc/optional.hpp>
#include <fc/variant_object.hpp>

#include <graphene/app/application.hpp>

#include <graphene/chain/block_database.hpp>
#include <graphene/chain/database.hpp>
#include <graphene/chain/betting_market_object.hpp>

#include <graphene/chain/witness_object.hpp>

#include <graphene/utilities/key_conversion.hpp>

#include <graphene/bookie/bookie_api.hpp>
#include <graphene/bookie/bookie_plugin.hpp>
#include <graphene/bookie/bookie_objects.hpp>

namespace graphene { namespace bookie {

namespace detail {

class bookie_api_impl
{
   public:
      bookie_api_impl(graphene::app::application& _app);

      binned_order_book get_binned_order_book(graphene::chain::betting_market_id_type betting_market_id, int32_t precision);
      std::shared_ptr<graphene::bookie::bookie_plugin> get_plugin();
      asset get_total_matched_bet_amount_for_betting_market_group(betting_market_group_id_type group_id);
      std::vector<event_object> get_events_containing_sub_string(const std::string& sub_string, const std::string& language);
      fc::variants get_objects(const vector<object_id_type>& ids) const;
      std::vector<matched_bet_object> get_matched_bets_for_bettor(account_id_type bettor_id) const;
      std::vector<matched_bet_object> get_all_matched_bets_for_bettor(account_id_type bettor_id, bet_id_type start, unsigned limit) const;
      graphene::app::application& app;
};

bookie_api_impl::bookie_api_impl(graphene::app::application& _app) : app(_app)
{}


binned_order_book bookie_api_impl::get_binned_order_book(graphene::chain::betting_market_id_type betting_market_id, int32_t precision)
{
    std::shared_ptr<graphene::chain::database> db = app.chain_database();
    const auto& bet_odds_idx = db->get_index_type<graphene::chain::bet_object_index>().indices().get<graphene::chain::by_odds>();
    const chain_parameters& current_params = db->get_global_properties().parameters;

    graphene::chain::bet_multiplier_type bin_size = GRAPHENE_BETTING_ODDS_PRECISION;
    if (precision > 0)
        for (int32_t i = 0; i < precision; ++i) {
            FC_ASSERT(bin_size > (GRAPHENE_BETTING_MIN_MULTIPLIER - GRAPHENE_BETTING_ODDS_PRECISION), "invalid precision");
            bin_size /= 10;
        }
    else if (precision < 0)
        for (int32_t i = 0; i > precision; --i) {
            FC_ASSERT(bin_size < (GRAPHENE_BETTING_MAX_MULTIPLIER - GRAPHENE_BETTING_ODDS_PRECISION), "invalid precision");
            bin_size *= 10;
        }

    binned_order_book result; 

    // use a bet_object here for convenience. we really only use it to track the amount, odds, and back_or_lay
    fc::optional<bet_object> current_bin;

    auto flush_current_bin = [&current_bin, &result]()
    {
        if (current_bin) // do nothing if the current bin is empty
        {
            order_bin current_order_bin;

            current_order_bin.backer_multiplier = current_bin->backer_multiplier;
            current_order_bin.amount_to_bet = current_bin->amount_to_bet.amount;
            //idump((*current_bin)(current_order_bin));
            if (current_bin->back_or_lay == bet_type::back)
                result.aggregated_back_bets.emplace_back(std::move(current_order_bin));
            else // current_bin is aggregating back positions
                result.aggregated_lay_bets.emplace_back(std::move(current_order_bin));

            current_bin.reset();
        }
    };

    // iterate through both sides of the order book (backs at increasing odds then lays at decreasing odds)
    for (auto bet_odds_iter = bet_odds_idx.lower_bound(std::make_tuple(betting_market_id));
         bet_odds_iter != bet_odds_idx.end() && betting_market_id == bet_odds_iter->betting_market_id;
         ++bet_odds_iter)
    {
        if (current_bin && 
            (bet_odds_iter->back_or_lay != current_bin->back_or_lay /* we have switched from back to lay bets */ ||
             (bet_odds_iter->back_or_lay == bet_type::back ? bet_odds_iter->backer_multiplier > current_bin->backer_multiplier :
                                                             bet_odds_iter->backer_multiplier < current_bin->backer_multiplier)))
            flush_current_bin();

        if (!current_bin)
        {
            // if there is no current bin, create one appropriate for the bet we're processing
            current_bin = graphene::chain::bet_object();

            // for back bets, we want to group all bets with odds from 3.0001 to 4 into the "4" bin
            // for lay bets, we want to group all bets with odds from 3 to 3.9999 into the "3" bin
            if (bet_odds_iter->back_or_lay == bet_type::back)
            {
               current_bin->backer_multiplier = (bet_odds_iter->backer_multiplier + bin_size - 1) / bin_size * bin_size;
               current_bin->backer_multiplier = std::min<graphene::chain::bet_multiplier_type>(current_bin->backer_multiplier, current_params.max_bet_multiplier());
               current_bin->back_or_lay = bet_type::back;
            }
            else
            {
               current_bin->backer_multiplier = bet_odds_iter->backer_multiplier / bin_size * bin_size;
               current_bin->backer_multiplier = std::max<graphene::chain::bet_multiplier_type>(current_bin->backer_multiplier, current_params.min_bet_multiplier());
               current_bin->back_or_lay = bet_type::lay;
            }

            current_bin->amount_to_bet.amount = 0;
        }

        current_bin->amount_to_bet.amount += bet_odds_iter->amount_to_bet.amount;
    }
    if (current_bin)
        flush_current_bin();

    return result;
}

fc::variants bookie_api_impl::get_objects(const vector<object_id_type>& ids) const
{
   std::shared_ptr<graphene::chain::database> db = app.chain_database();
   fc::variants result;
   result.reserve(ids.size());

   std::transform(ids.begin(), ids.end(), std::back_inserter(result),
                  [this, &db](object_id_type id) -> fc::variant {
      switch (id.type())
      {
      case event_id_type::type_id:
         {
            const auto &idx = db->get_index_type<event_object_index>();
            const auto &aidx = dynamic_cast<const base_primary_index &>(idx);
            const auto &refs = aidx.get_secondary_index<detail::persistent_event_index>();
            auto iter = refs.ephemeral_event_object.find(id.as<event_id_type>());
            if (iter != refs.ephemeral_event_object.end())
               return iter->second.to_variant();
            else
               return {};
         }
      case bet_id_type::type_id:
         {
            const auto &idx = db->get_index_type<bet_object_index>();
            const auto &aidx = dynamic_cast<const base_primary_index &>(idx);
            const auto &refs = aidx.get_secondary_index<detail::persistent_bet_index>();
            auto iter = refs.internal.find(id.as<bet_id_type>());
            if (iter != refs.internal.end())
               return iter->second.ephemeral_bet_object.to_variant();
            else
               return {};
         }
      case betting_market_object::type_id:
         {
            const auto &idx = db->get_index_type<betting_market_object_index>();
            const auto &aidx = dynamic_cast<const base_primary_index &>(idx);
            const auto &refs = aidx.get_secondary_index<detail::persistent_betting_market_index>();
            auto iter = refs.ephemeral_betting_market_object.find(id.as<betting_market_id_type>());
            if (iter != refs.ephemeral_betting_market_object.end())
               return iter->second.to_variant();
            else
               return {};
         }
      case betting_market_group_object::type_id:
         {
            const auto &idx = db->get_index_type<betting_market_group_object_index>();
            const auto &aidx = dynamic_cast<const base_primary_index &>(idx);
            const auto &refs = aidx.get_secondary_index<detail::persistent_betting_market_group_index>();
            auto iter = refs.internal.find(id.as<betting_market_group_id_type>());
            if (iter != refs.internal.end())
               return iter->second.ephemeral_betting_market_group_object.to_variant();
            else
               return {};
         }
      default:
         return {};
      }
   });

   return result;
}

std::vector<matched_bet_object> bookie_api_impl::get_matched_bets_for_bettor(account_id_type bettor_id) const
{
   std::vector<matched_bet_object> result;
   std::shared_ptr<graphene::chain::database> db = app.chain_database();
   const auto &idx = db->get_index_type<bet_object_index>();
   const auto &aidx = dynamic_cast<const base_primary_index &>(idx);
   const auto &refs = aidx.get_secondary_index<detail::persistent_bet_index>();

   for( const auto& bet_pair : refs.internal )
   {
      const auto& bet = bet_pair.second;
      if( bet.get_bettor_id() == bettor_id && bet.is_matched() )
      {
         matched_bet_object match;
         match.id = bet.ephemeral_bet_object.id;
         match.bettor_id = bet.ephemeral_bet_object.bettor_id;
         match.betting_market_id = bet.ephemeral_bet_object.betting_market_id;
         match.amount_to_bet = bet.ephemeral_bet_object.amount_to_bet;
         match.back_or_lay = bet.ephemeral_bet_object.back_or_lay;
         match.end_of_delay = bet.ephemeral_bet_object.end_of_delay;
         match.amount_matched = bet.amount_matched;
         match.associated_operations = bet.associated_operations;
         result.emplace_back(std::move(match));
      }
   }

   return result;
}

std::vector<matched_bet_object> bookie_api_impl::get_all_matched_bets_for_bettor(account_id_type bettor_id, bet_id_type start, unsigned limit) const
{
   FC_ASSERT(limit <= 1000, "You may request at most 1000 matched bets at a time");

   std::vector<matched_bet_object> result;
   std::shared_ptr<graphene::chain::database> db = app.chain_database();
   const auto &idx = db->get_index_type<bet_object_index>();
   const auto &aidx = dynamic_cast<const base_primary_index &>(idx);
   const auto &refs = aidx.get_secondary_index<detail::persistent_bet_index>();

   for( const auto& bet_pair : refs.internal )
   {
      const auto& bet_id = bet_pair.first;
      const auto& bet = bet_pair.second;
      if( bet.get_bettor_id() == bettor_id &&
          bet.is_matched() &&
          bet_id > start &&
          result.size() < limit )
      {
         matched_bet_object match;
         match.id = bet.ephemeral_bet_object.id;
         match.bettor_id = bet.ephemeral_bet_object.bettor_id;
         match.betting_market_id = bet.ephemeral_bet_object.betting_market_id;
         match.amount_to_bet = bet.ephemeral_bet_object.amount_to_bet;
         match.back_or_lay = bet.ephemeral_bet_object.back_or_lay;
         match.end_of_delay = bet.ephemeral_bet_object.end_of_delay;
         match.amount_matched = bet.amount_matched;
         match.associated_operations = bet.associated_operations;
         result.emplace_back(std::move(match));
      }
   }

   return result;
}

std::shared_ptr<graphene::bookie::bookie_plugin> bookie_api_impl::get_plugin()
{
   return app.get_plugin<graphene::bookie::bookie_plugin>("bookie");
}

asset bookie_api_impl::get_total_matched_bet_amount_for_betting_market_group(betting_market_group_id_type group_id)
{
    return get_plugin()->get_total_matched_bet_amount_for_betting_market_group(group_id);
}

std::vector<event_object> bookie_api_impl::get_events_containing_sub_string(const std::string& sub_string, const std::string& language)
{
   return get_plugin()->get_events_containing_sub_string(sub_string, language);
}

} // detail

bookie_api::bookie_api(graphene::app::application& app) :
   my(std::make_shared<detail::bookie_api_impl>(app))
{
}

binned_order_book bookie_api::get_binned_order_book(graphene::chain::betting_market_id_type betting_market_id, int32_t precision)
{
   return my->get_binned_order_book(betting_market_id, precision);
}

asset bookie_api::get_total_matched_bet_amount_for_betting_market_group(betting_market_group_id_type group_id)
{
    return my->get_total_matched_bet_amount_for_betting_market_group(group_id);
}

std::vector<event_object> bookie_api::get_events_containing_sub_string(const std::string& sub_string, const std::string& language)
{
   return my->get_events_containing_sub_string(sub_string, language);
}

fc::variants bookie_api::get_objects(const vector<object_id_type>& ids) const
{
   return my->get_objects(ids);
}

std::vector<matched_bet_object> bookie_api::get_matched_bets_for_bettor(account_id_type bettor_id) const
{
   return my->get_matched_bets_for_bettor(bettor_id);
}

std::vector<matched_bet_object> bookie_api::get_all_matched_bets_for_bettor(account_id_type bettor_id, 
                                                                            bet_id_type start /* = bet_id_type() */, 
                                                                            unsigned limit /* = 1000 */) const
{
   return my->get_all_matched_bets_for_bettor(bettor_id, start, limit);
}

} } // graphene::bookie