Plugable coins API

Dockerfile

@@ -34,7 +34,7 @@ WORKDIR $APP_HOME
 # Install dependencies defined in Gemfile.
 COPY Gemfile Gemfile.lock $APP_HOME/
 RUN mkdir -p /opt/vendor/bundle \
- && chown -R app:app /opt/vendor \
+ && chown -R app:app /opt/vendor $APP_HOME \
  && su app -s /bin/bash -c "bundle install --path /opt/vendor/bundle"
 
 # Copy application sources.
@@ -62,7 +62,7 @@ CMD ["bundle", "exec", "puma", "--config", "config/puma.rb"]
 FROM base
 
 # Copy Gemfile.plugin for installing plugins.
-COPY Gemfile.plugin $APP_HOME
+COPY Gemfile.plugin Gemfile.lock $APP_HOME/
 
 # Install plugins.
 RUN bundle install --path /opt/vendor/bundle

Gemfile

@@ -35,6 +35,7 @@ gem 'grape_logging', '~> 1.8.0'
 gem 'rack-attack', '~> 5.4.2'
 gem 'easy_table', '~> 0.0.10'
 gem 'faraday', '~> 0.15.4'
+gem 'better-faraday', '~> 1.0.5'
 gem 'jwt', '~> 2.1.0'
 gem 'email_validator', '~> 1.6.0'
 gem 'validate_url', '~> 1.0.4'
@@ -51,7 +52,7 @@ gem 'jwt-multisig', '~> 1.0.0'
 gem 'cash-addr', '~> 0.2.0', require: 'cash_addr'
 gem 'digest-sha3', '~> 1.1.0'
 gem 'scout_apm', '~> 2.4', require: false
-gem 'peatio', '~> 0.4.5'
+gem 'peatio', '~> 0.6.0'
 gem 'rack-cors', '~> 1.0.2', require: false
 gem 'env-tweaks', '~> 1.0.0'
 gem 'vault', '~> 0.12', require: false

Gemfile.lock

@@ -1,3 +1,14 @@
+GIT
+  remote: https://github.com/rubykube/peatio-litecoin
+  revision: cfaccc9c8b98c439a62b2ebc961c66b0932582d3
+  specs:
+    peatio-litecoin (0.1.0)
+      activesupport (~> 5.2.3)
+      better-faraday (~> 1.0.5)
+      faraday (~> 0.15.4)
+      memoist (~> 0.16.0)
+      peatio (~> 0.6.0)
+
 GEM
   remote: https://rubygems.org/
   specs:
@@ -69,6 +80,9 @@ GEM
       ice_nine (~> 0.11.0)
       thread_safe (~> 0.3, >= 0.3.1)
     base58 (0.2.3)
+    better-faraday (1.0.5)
+      activesupport (>= 4.0, < 6.0)
+      faraday (~> 0.12)
     bootsnap (1.4.2)
       msgpack (~> 1.0)
     bootstrap (4.3.1)
@@ -80,7 +94,7 @@ GEM
       activesupport (>= 3.0.0)
       uniform_notifier (~> 1.11)
     bump (0.8.0)
-    bunny (2.14.1)
+    bunny (2.14.2)
       amq-protocol (~> 2.3, >= 2.3.0)
     byebug (11.0.0)
     cancancan (2.3.0)
@@ -220,7 +234,7 @@ GEM
       metaclass (~> 0.0.1)
     msgpack (1.2.9)
     multi_json (1.13.1)
-    multipart-post (2.0.0)
+    multipart-post (2.1.1)
     mustermann (1.0.3)
     mustermann-grape (1.0.0)
       mustermann (~> 1.0.0)
@@ -232,7 +246,8 @@ GEM
     parser (2.6.0.0)
       ast (~> 2.4.0)
     passgen (1.0.2)
-    peatio (0.4.5)
+    peatio (0.6.0)
+      activemodel (~> 5.2.3)
       amqp
       bunny
       clamp
@@ -400,6 +415,7 @@ DEPENDENCIES
   annotate (~> 2.7.4)
   api-pagination (~> 4.8.2)
   arel-is-blank (~> 1.0.0)
+  better-faraday (~> 1.0.5)
   bootsnap (>= 1.1.0)
   bootstrap (~> 4.3.1)
   bullet (~> 5.9)
@@ -441,7 +457,8 @@ DEPENDENCIES
   mocha (~> 1.8)
   mysql2 (~> 0.5.2)
   passgen (~> 1.0.2)
-  peatio (~> 0.4.5)
+  peatio (~> 0.6.0)
+  peatio-litecoin!
   pry-byebug (~> 3.7)
   puma (~> 3.12.0)
   rack-attack (~> 5.4.2)

Gemfile.plugin

@@ -2,3 +2,6 @@ source 'https://rubygems.org'
 git_source(:github) { |repo_slug| "https://github.com/#{repo_slug}" }
 
 # List your plugins here.
+
+gem 'peatio-litecoin', github: 'rubykube/peatio-litecoin'
+# gem 'peatio-litecoin', '~> 0.1.1'

README.md

@@ -44,6 +44,7 @@ You must know what you're doing, there's no shortcut. Please get prepared before
 * Designed as high performance crypto currency exchange
 * Built-in high performance matching-engine
 * Built-in multiple wallet support (e.g. deposit, hot, warm and cold)
+* Built-in [plugable coin API](docs/coins/development.md)
 * Build-in Management API - server-to-server API with high privileges
 * Build-in RabbitMQ Event API
 * Usability and scalability

app/controllers/admin/blockchains_controller.rb

@@ -49,6 +49,7 @@ def permitted_blockchain_attributes
           client
           server
           height
+          step
           min_confirmations
           explorer_address
           explorer_transaction

app/models/blockchain.rb

@@ -7,10 +7,20 @@ class Blockchain < ApplicationRecord
 
   validates :key, :name, :client, presence: true
   validates :status, inclusion: { in: %w[active disabled] }
-  validates :height, numericality: { greater_than_or_equal_to: 1, only_integer: true }
-  validates :min_confirmations, numericality: { greater_than_or_equal_to: 1, only_integer: true }
+  validates :height,
+            :min_confirmations,
+            :step,
+            numericality: { greater_than_or_equal_to: 1, only_integer: true }
   validates :server, url: { allow_blank: true }
 
+  scope :active,   -> { where(status: :active) }
+
+  class << self
+    def clients
+      Peatio::Blockchain.registry.adapters.keys
+    end
+  end
+
   def explorer=(hash)
     write_attribute(:explorer_address, hash.fetch('address'))
     write_attribute(:explorer_transaction, hash.fetch('transaction'))
@@ -21,12 +31,12 @@ def status
   end
 
   def blockchain_api
-    BlockchainClient[key]
+    BlockchainService.new(self)
   end
 end
 
 # == Schema Information
-# Schema version: 20180708171446
+# Schema version: 20190502103256
 #
 # Table name: blockchains
 #
@@ -36,6 +46,7 @@ def blockchain_api
 #  client               :string(255)      not null
 #  server               :string(255)
 #  height               :integer          not null
+#  step                 :integer          default(6), not null
 #  explorer_address     :string(255)
 #  explorer_transaction :string(255)
 #  min_confirmations    :integer          default(6), not null

app/models/currency.rb

@@ -83,7 +83,7 @@ def types
   # Allows to dynamically check value of code:
   #
   #   code.btc? # true if code equals to "btc".
-  #   code.xrp? # true if code equals to "xrp".
+  #   code.eth? # true if code equals to "eth".
   #
   def code
     id&.inquiry
@@ -101,6 +101,15 @@ def as_json(*)
       fiat: fiat? }
   end
 
+  def to_blockchain_api_settings
+    # We pass options are available as top-level hash keys and via options for
+    # compatibility with Wallet#to_wallet_api_settings.
+    opt = options.compact.deep_symbolize_keys
+    opt.deep_symbolize_keys.merge(id:          id,
+                                  base_factor: base_factor,
+                                  options:     opt)
+  end
+
   def summary
     locked  = Account.with_currency(code).sum(:locked)
     balance = Account.with_currency(code).sum(:balance)

app/models/deposit.rb

@@ -4,6 +4,8 @@
 class Deposit < ApplicationRecord
   STATES = %i[submitted canceled rejected accepted collected].freeze
 
+  serialize :spread, Array
+
   include AASM
   include AASM::Locking
   include BelongsToCurrency
@@ -50,6 +52,22 @@ class Deposit < ApplicationRecord
     end
   end
 
+  def spread_to_transactions
+    spread.map { |s| Peatio::Transaction.new(s) }
+  end
+
+  def spread_between_wallets!
+    return false if spread.present?
+
+    deposit_wallet = Wallet.active.deposit.find_by(currency_id: currency_id)
+    spread = WalletService.new(deposit_wallet).spread_deposit(self)
+    update!(spread: spread.map(&:as_json))
+  end
+
+  def spread
+    super.map(&:symbolize_keys)
+  end
+
   def account
     member&.ac(currency)
   end
@@ -85,12 +103,12 @@ def plus_funds
   end
 
   def collect!(collect_fee = true)
-    if coin?
-      if currency.is_erc20? && collect_fee
-        AMQPQueue.enqueue(:deposit_collection_fees, id: id)
-      else
-        AMQPQueue.enqueue(:deposit_collection, id: id)
-      end
+    return unless coin?
+
+    if collect_fee
+      AMQPQueue.enqueue(:deposit_collection_fees, id: id)
+    else
+      AMQPQueue.enqueue(:deposit_collection, id: id)
     end
   end
 
@@ -126,7 +144,7 @@ def record_complete_operations!
 end
 
 # == Schema Information
-# Schema version: 20180925123806
+# Schema version: 20190426145506
 #
 # Table name: deposits
 #
@@ -142,6 +160,7 @@ def record_complete_operations!
 #  block_number :integer
 #  type         :string(30)       not null
 #  tid          :string(64)       not null
+#  spread       :string(1000)
 #  created_at   :datetime         not null
 #  updated_at   :datetime         not null
 #  completed_at :datetime

app/models/deposits/coin.rb

@@ -32,7 +32,7 @@ def as_json_for_event_api
 end
 
 # == Schema Information
-# Schema version: 20180925123806
+# Schema version: 20190426145506
 #
 # Table name: deposits
 #
@@ -48,6 +48,7 @@ def as_json_for_event_api
 #  block_number :integer
 #  type         :string(30)       not null
 #  tid          :string(64)       not null
+#  spread       :string(1000)
 #  created_at   :datetime         not null
 #  updated_at   :datetime         not null
 #  completed_at :datetime

app/models/deposits/fiat.rb

@@ -14,7 +14,7 @@ def charge!
 end
 
 # == Schema Information
-# Schema version: 20180925123806
+# Schema version: 20190426145506
 #
 # Table name: deposits
 #
@@ -30,6 +30,7 @@ def charge!
 #  block_number :integer
 #  type         :string(30)       not null
 #  tid          :string(64)       not null
+#  spread       :string(1000)
 #  created_at   :datetime         not null
 #  updated_at   :datetime         not null
 #  completed_at :datetime

app/models/wallet.rb

@@ -11,7 +11,6 @@ class Wallet < ApplicationRecord
   ENUMERIZED_KINDS = { deposit: 100, fee: 200, hot: 310, warm: 320, cold: 330 }.freeze
   enumerize :kind, in: ENUMERIZED_KINDS, scope: true
 
-  GATEWAYS = %w[bitcoind bitcoincashd litecoind parity geth dashd rippled bitgo].freeze
   SETTING_ATTRIBUTES = %i[ uri
                            secret
                            bitgo_test_net
@@ -20,6 +19,8 @@ class Wallet < ApplicationRecord
                            bitgo_rest_api_root
                            bitgo_rest_api_access_token ].freeze
 
+  NOT_AVAILABLE = 'N/A'.freeze
+
   include BelongsToCurrency
 
   store :settings, accessors: SETTING_ATTRIBUTES, coder: JSON
@@ -30,7 +31,8 @@ class Wallet < ApplicationRecord
   validates :address, presence: true
 
   validates :status,  inclusion: { in: %w[active disabled] }
-  validates :gateway, inclusion: { in: GATEWAYS }
+
+  validates :gateway, inclusion: { in: ->(_){ Wallet.gateways.map(&:to_s) } }
 
   validates :nsig,        numericality: { greater_than_or_equal_to: 1, only_integer: true }
   validates :max_balance, numericality: { greater_than_or_equal_to: 0 }
@@ -48,6 +50,10 @@ class Wallet < ApplicationRecord
   end
 
   class << self
+    def gateways
+      Peatio::Wallet.registry.adapters.keys
+    end
+
     def kinds(options={})
       ENUMERIZED_KINDS
         .yield_self do |kinds|
@@ -75,6 +81,16 @@ def kinds(options={})
     end
   end
 
+  def current_balance
+    WalletService.new(self).load_balance!
+  rescue BlockchainService::BalanceLoadError
+    NOT_AVAILABLE
+  end
+
+  def to_wallet_api_settings
+    settings.compact.deep_symbolize_keys.merge(address: address)
+  end
+
   def wallet_url
     blockchain.explorer_address.gsub('#{address}', address) if blockchain
   end

app/models/withdraws/coin.rb

@@ -23,15 +23,17 @@ class Coin < Withdraw
     end
 
     def audit!
-      wallet = Wallet.active.deposit.find_by(currency_id: currency_id)
-      inspection = WalletClient[wallet].inspect_address!(rid)
+      # TODO: Revert this inspection with WalletService/BlockchainService v2.
+      # wallet = Wallet.active.deposit.find_by(currency_id: currency_id)
+      # inspection = WalletClient[wallet].inspect_address!(rid)
 
-      if inspection[:is_valid] == false
-        Rails.logger.info { "#{self.class.name}##{id} uses invalid address: #{rid.inspect}" }
-        reject!
-      else
-        super
-      end
+      # if inspection[:is_valid] == false
+      #   Rails.logger.info { "#{self.class.name}##{id} uses invalid address: #{rid.inspect}" }
+      #   reject!
+      # else
+      #   super
+      # end
+      super
     end
 
     def as_json(*)