Class: Glueby::UtxoProvider::Tasks

Inherits:
Object
  • Object
show all
Defined in:
lib/glueby/utxo_provider/tasks.rb

Constant Summary collapse

STATUS = 
{
  # UtxoProvider is ready to pay tpcs.
  ready: 'Ready',
  # UtxoProvider is ready to pay tpcs, but it doesn't have enough amount to fill the UTXO pool by UTXOs which is for paying tpcs.
  insufficient_amount: 'Insufficient Amount',
  # UtxoProvider is not ready to pay tpcs. It has no UTXOs for paying amounts.
  not_ready: 'Not Ready'
}

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Tasks

Returns a new instance of Tasks.



15
16
17
 
# File 'lib/glueby/utxo_provider/tasks.rb', line 15

def initialize
  @utxo_provider = Glueby::UtxoProvider.new
end

Instance Attribute Details

#utxo_provider ⇒ Object (readonly)

Returns the value of attribute utxo_provider.



4
5
6
 
# File 'lib/glueby/utxo_provider/tasks.rb', line 4

def utxo_provider
  @utxo_provider
end

Instance Method Details

#manage_utxo_pool ⇒ Object

Create UTXOs for paying tpc

UtxoProvider have the UTXO pool. the pool is manged to keep some number of UTXOs that have fixed value. The value is configurable by :default_value. This method do the management to the pool.



23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
 
# File 'lib/glueby/utxo_provider/tasks.rb', line 23

def manage_utxo_pool
  txb = Tapyrus::TxBuilder.new
  fee_estimator = utxo_provider.fee_estimator_for_manage

  sum, utxos = collect_outputs
  return if utxos.empty?

  utxos.each { |utxo| txb.add_utxo(utxo) }

  shortage = [utxo_provider.utxo_pool_size - utxo_provider.current_utxo_pool_size, 0].max
  return if shortage == 0

  added_outputs = 0
  shortage.times do
    fee = fee_estimator.fee(Contract::FeeEstimator.dummy_tx(txb.build))
    break if (sum - fee) < utxo_provider.default_value
    txb.pay(utxo_provider.address, utxo_provider.default_value)
    sum -= utxo_provider.default_value
    added_outputs += 1
  end

  return if added_outputs == 0

  fee = fee_estimator.fee(Contract::FeeEstimator.dummy_tx(txb.build))
  fee += (sum - fee) if sum - fee < DUST_LIMIT

  tx = txb.change_address(utxo_provider.address)
          .fee(fee)
          .build
  tx = utxo_provider.wallet.sign_tx(tx)
  utxo_provider.wallet.broadcast(tx)
ensure
  status
end

#print_address ⇒ Object

Show the address of Utxo Provider



90
91
92
 
# File 'lib/glueby/utxo_provider/tasks.rb', line 90

def print_address
  puts utxo_provider.address
end

#status ⇒ Object

Show the status of the UTXO pool



59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
 
# File 'lib/glueby/utxo_provider/tasks.rb', line 59

def status
  status = :ready

  if utxo_provider.current_utxo_pool_size < utxo_provider.utxo_pool_size
    if utxo_provider.tpc_amount < utxo_provider.value_to_fill_utxo_pool
      status = :insufficient_amount
      message = <<~MESSAGE
      1. Please replenishment TPC which is for paying tpc to UtxoProvider. 
        UtxoProvider needs #{utxo_provider.value_to_fill_utxo_pool} tapyrus in UTXO pool. 
        UtxoProvider wallet's address is '#{utxo_provider.address}'
      2. Then create UTXOs for paying in UTXO pool with 'rake glueby:utxo_provider:manage_utxo_pool'
      MESSAGE
    else
      message = "Please create UTXOs for paying in UTXO pool with 'rake glueby:utxo_provider:manage_utxo_pool'\n"
    end
  end

  status = :not_ready if utxo_provider.current_utxo_pool_size == 0

  puts <<~EOS
  Status: #{STATUS[status]}
  TPC amount: #{delimit(utxo_provider.tpc_amount)}
  UTXO pool size: #{delimit(utxo_provider.current_utxo_pool_size)}
  #{"\n" if message}#{message}
  Configuration:
    default_value = #{delimit(utxo_provider.default_value)}
    utxo_pool_size = #{delimit(utxo_provider.utxo_pool_size)}
  EOS
end