2022-10-20 20:57:46 +00:00
import ast
import math
2022-01-17 23:11:41 +00:00
from datetime import timedelta
2022-10-20 20:57:46 +00:00
import gnupg
from decouple import config
2022-06-07 22:14:56 +00:00
from django . db . models import Q , Sum
2022-10-20 20:57:46 +00:00
from django . utils import timezone
2022-01-06 16:54:37 +00:00
2022-10-20 20:57:46 +00:00
from api . lightning . node import LNNode
from api . models import Currency , LNPayment , MarketTick , OnchainPayment , Order , User
2022-02-23 16:15:48 +00:00
from api . tasks import send_message
2022-06-13 22:27:09 +00:00
from api . utils import validate_onchain_address
2022-01-06 16:54:37 +00:00
2022-02-17 19:50:10 +00:00
FEE = float ( config ( " FEE " ) )
2022-03-03 15:40:56 +00:00
MAKER_FEE_SPLIT = float ( config ( " MAKER_FEE_SPLIT " ) )
2022-02-17 19:50:10 +00:00
ESCROW_USERNAME = config ( " ESCROW_USERNAME " )
PENALTY_TIMEOUT = int ( config ( " PENALTY_TIMEOUT " ) )
2022-01-06 16:54:37 +00:00
2022-02-17 19:50:10 +00:00
MIN_TRADE = int ( config ( " MIN_TRADE " ) )
MAX_TRADE = int ( config ( " MAX_TRADE " ) )
2022-01-06 21:36:22 +00:00
2022-02-17 19:50:10 +00:00
EXP_MAKER_BOND_INVOICE = int ( config ( " EXP_MAKER_BOND_INVOICE " ) )
EXP_TAKER_BOND_INVOICE = int ( config ( " EXP_TAKER_BOND_INVOICE " ) )
2022-01-06 20:33:40 +00:00
2022-07-21 13:19:47 +00:00
BLOCK_TIME = float ( config ( " BLOCK_TIME " ) )
2022-10-20 09:56:10 +00:00
MAX_MINING_NETWORK_SPEEDUP_EXPECTED = float (
config ( " MAX_MINING_NETWORK_SPEEDUP_EXPECTED " )
)
2022-01-06 16:54:37 +00:00
2022-02-17 19:50:10 +00:00
INVOICE_AND_ESCROW_DURATION = int ( config ( " INVOICE_AND_ESCROW_DURATION " ) )
FIAT_EXCHANGE_DURATION = int ( config ( " FIAT_EXCHANGE_DURATION " ) )
2022-01-10 12:10:32 +00:00
2022-05-30 13:20:39 +00:00
2022-10-20 09:56:10 +00:00
class Logics :
2022-02-03 21:51:42 +00:00
@classmethod
def validate_already_maker_or_taker ( cls , user ) :
2022-02-17 19:50:10 +00:00
""" Validates if a use is already not part of an active order """
active_order_status = [
Order . Status . WFB ,
Order . Status . PUB ,
2022-04-29 18:54:20 +00:00
Order . Status . PAU ,
2022-02-17 19:50:10 +00:00
Order . Status . TAK ,
Order . Status . WF2 ,
Order . Status . WFE ,
Order . Status . WFI ,
Order . Status . CHA ,
Order . Status . FSE ,
Order . Status . DIS ,
Order . Status . WFR ,
]
""" Checks if the user is already partipant of an active order """
2022-10-20 09:56:10 +00:00
queryset = Order . objects . filter ( maker = user , status__in = active_order_status )
2022-01-06 16:54:37 +00:00
if queryset . exists ( ) :
2022-02-17 19:50:10 +00:00
return (
False ,
2022-10-20 09:56:10 +00:00
{ " bad_request " : " You are already maker of an active order " } ,
2022-02-17 19:50:10 +00:00
queryset [ 0 ] ,
)
2022-01-17 23:22:44 +00:00
2022-10-20 09:56:10 +00:00
queryset = Order . objects . filter ( taker = user , status__in = active_order_status )
2022-01-06 16:54:37 +00:00
if queryset . exists ( ) :
2022-02-17 19:50:10 +00:00
return (
False ,
2022-10-20 09:56:10 +00:00
{ " bad_request " : " You are already taker of an active order " } ,
2022-02-17 19:50:10 +00:00
queryset [ 0 ] ,
)
2022-02-03 21:51:42 +00:00
# Edge case when the user is in an order that is failing payment and he is the buyer
2022-10-20 09:56:10 +00:00
queryset = Order . objects . filter (
Q ( maker = user ) | Q ( taker = user ) ,
status__in = [ Order . Status . FAI , Order . Status . PAY ] ,
)
2022-02-03 21:51:42 +00:00
if queryset . exists ( ) :
order = queryset [ 0 ]
if cls . is_buyer ( order , user ) :
2022-02-17 19:50:10 +00:00
return (
False ,
{
2022-10-20 09:56:10 +00:00
" bad_request " : " You are still pending a payment from a recent order "
2022-02-17 19:50:10 +00:00
} ,
order ,
)
2022-02-03 21:51:42 +00:00
2022-01-29 19:51:26 +00:00
return True , None , None
2022-01-06 16:54:37 +00:00
2022-05-30 13:20:39 +00:00
def validate_pgp_keys ( pub_key , enc_priv_key ) :
2022-10-20 09:56:10 +00:00
""" Validates PGP valid keys. Formats them in a way understandable by the frontend """
2022-05-30 13:20:39 +00:00
gpg = gnupg . GPG ( )
2022-05-30 23:30:47 +00:00
# Standarize format with linux linebreaks '\n'. Windows users submitting their own keys have '\r\n' breaking communication.
2022-10-20 09:56:10 +00:00
enc_priv_key = enc_priv_key . replace ( " \r \n " , " \n " )
pub_key = pub_key . replace ( " \r \n " , " \n " )
2022-05-30 13:20:39 +00:00
2022-06-01 23:49:27 +00:00
# Try to import the public key
import_pub_result = gpg . import_keys ( pub_key )
if not import_pub_result . imported == 1 :
2023-03-03 19:00:08 +00:00
# If a robot is deleted and it is rebuilt with the same pubKey, the key will not be imported again
# so we assert that the import error is "Not actually changed"
if " Not actually changed " not in import_pub_result . results [ 0 ] [ " text " ] :
return (
False ,
{
" bad_request " : " Your PGP public key does not seem valid. \n "
+ f " Stderr: { str ( import_pub_result . stderr ) } \n "
+ f " ReturnCode: { str ( import_pub_result . returncode ) } \n "
+ f " Summary: { str ( import_pub_result . summary ) } \n "
+ f " Results: { str ( import_pub_result . results ) } \n "
+ f " Imported: { str ( import_pub_result . imported ) } \n "
} ,
None ,
None ,
)
2022-06-01 23:49:27 +00:00
# Exports the public key again for uniform formatting.
pub_key = gpg . export_keys ( import_pub_result . fingerprints [ 0 ] )
2022-05-30 13:20:39 +00:00
# Try to import the encrypted private key (without passphrase)
2022-06-01 23:49:27 +00:00
import_priv_result = gpg . import_keys ( enc_priv_key )
if not import_priv_result . sec_imported == 1 :
2023-03-03 19:00:08 +00:00
if " Not actually changed " not in import_priv_result . results [ 0 ] [ " text " ] :
return (
False ,
{
" bad_request " : " Your PGP encrypted private key does not seem valid. \n "
+ f " Stderr: { str ( import_priv_result . stderr ) } \n "
+ f " ReturnCode: { str ( import_priv_result . returncode ) } \n "
+ f " Summary: { str ( import_priv_result . summary ) } \n "
+ f " Results: { str ( import_priv_result . results ) } \n "
+ f " Sec Imported: { str ( import_priv_result . sec_imported ) } \n "
} ,
None ,
None ,
)
2022-05-30 13:20:39 +00:00
return True , None , pub_key , enc_priv_key
2022-03-21 23:27:36 +00:00
@classmethod
def validate_order_size ( cls , order ) :
""" Validates if order size in Sats is within limits at t0 """
if not order . has_range :
if order . t0_satoshis > MAX_TRADE :
return False , {
2022-10-20 09:56:10 +00:00
" bad_request " : " Your order is too big. It is worth "
+ " {:,} " . format ( order . t0_satoshis )
+ " Sats now, but the limit is "
+ " {:,} " . format ( MAX_TRADE )
+ " Sats "
2022-03-21 23:27:36 +00:00
}
if order . t0_satoshis < MIN_TRADE :
return False , {
2022-10-20 09:56:10 +00:00
" bad_request " : " Your order is too small. It is worth "
+ " {:,} " . format ( order . t0_satoshis )
+ " Sats now, but the limit is "
+ " {:,} " . format ( MIN_TRADE )
+ " Sats "
2022-03-21 23:27:36 +00:00
}
elif order . has_range :
2022-10-20 09:56:10 +00:00
min_sats = cls . calc_sats (
order . min_amount , order . currency . exchange_rate , order . premium
)
max_sats = cls . calc_sats (
order . max_amount , order . currency . exchange_rate , order . premium
)
if min_sats > max_sats / 1.5 :
2022-03-21 23:27:36 +00:00
return False , {
2022-10-20 09:56:10 +00:00
" bad_request " : " Maximum range amount must be at least 50 percent higher than the minimum amount "
2022-03-21 23:27:36 +00:00
}
elif max_sats > MAX_TRADE :
return False , {
2022-10-20 09:56:10 +00:00
" bad_request " : " Your order maximum amount is too big. It is worth "
+ " {:,} " . format ( int ( max_sats ) )
+ " Sats now, but the limit is "
+ " {:,} " . format ( MAX_TRADE )
+ " Sats "
2022-03-21 23:27:36 +00:00
}
elif min_sats < MIN_TRADE :
return False , {
2022-10-20 09:56:10 +00:00
" bad_request " : " Your order minimum amount is too small. It is worth "
+ " {:,} " . format ( int ( min_sats ) )
+ " Sats now, but the limit is "
+ " {:,} " . format ( MIN_TRADE )
+ " Sats "
2022-03-21 23:27:36 +00:00
}
2022-10-20 09:56:10 +00:00
elif min_sats < max_sats / 8 :
2022-03-21 23:27:36 +00:00
return False , {
2022-10-20 20:53:51 +00:00
" bad_request " : " Your order amount range is too large. Max amount can only be 8 times bigger than min amount "
2022-03-21 23:27:36 +00:00
}
2022-01-06 21:36:22 +00:00
return True , None
2022-01-10 12:10:32 +00:00
2022-03-22 17:49:57 +00:00
def validate_amount_within_range ( order , amount ) :
if amount > float ( order . max_amount ) or amount < float ( order . min_amount ) :
return False , {
2022-10-20 09:56:10 +00:00
" bad_request " : " The amount specified is outside the range specified by the maker "
2022-03-22 17:49:57 +00:00
}
return True , None
2022-02-03 18:06:30 +00:00
def user_activity_status ( last_seen ) :
if last_seen > ( timezone . now ( ) - timedelta ( minutes = 2 ) ) :
2022-02-17 19:50:10 +00:00
return " Active "
2022-02-03 18:06:30 +00:00
elif last_seen > ( timezone . now ( ) - timedelta ( minutes = 10 ) ) :
2022-02-17 19:50:10 +00:00
return " Seen recently "
2022-02-03 18:06:30 +00:00
else :
2022-02-17 19:50:10 +00:00
return " Inactive "
2022-02-03 18:06:30 +00:00
2022-02-17 19:50:10 +00:00
@classmethod
2022-03-22 17:49:57 +00:00
def take ( cls , order , user , amount = None ) :
2022-01-10 12:10:32 +00:00
is_penalized , time_out = cls . is_penalized ( user )
if is_penalized :
2022-02-17 19:50:10 +00:00
return False , {
" bad_request " ,
f " You need to wait { time_out } seconds to take an order " ,
}
2022-01-10 12:10:32 +00:00
else :
2022-03-22 17:49:57 +00:00
if order . has_range :
2022-10-20 09:56:10 +00:00
order . amount = amount
2022-01-10 12:10:32 +00:00
order . taker = user
order . status = Order . Status . TAK
2022-02-17 19:50:10 +00:00
order . expires_at = timezone . now ( ) + timedelta (
2022-10-20 09:56:10 +00:00
seconds = order . t_to_expire ( Order . Status . TAK )
)
2022-01-10 12:10:32 +00:00
order . save ( )
return True , None
2022-01-06 16:54:37 +00:00
def is_buyer ( order , user ) :
is_maker = order . maker == user
is_taker = order . taker == user
2022-02-17 19:50:10 +00:00
return ( is_maker and order . type == Order . Types . BUY ) or (
2022-10-20 09:56:10 +00:00
is_taker and order . type == Order . Types . SELL
)
2022-01-06 16:54:37 +00:00
def is_seller ( order , user ) :
is_maker = order . maker == user
is_taker = order . taker == user
2022-02-17 19:50:10 +00:00
return ( is_maker and order . type == Order . Types . SELL ) or (
2022-10-20 09:56:10 +00:00
is_taker and order . type == Order . Types . BUY
)
2022-02-17 19:50:10 +00:00
2022-03-21 23:27:36 +00:00
def calc_sats ( amount , exchange_rate , premium ) :
exchange_rate = float ( exchange_rate )
premium_rate = exchange_rate * ( 1 + float ( premium ) / 100 )
2022-10-20 09:56:10 +00:00
return ( float ( amount ) / premium_rate ) * 100 * 1000 * 1000
2022-03-21 23:27:36 +00:00
@classmethod
def satoshis_now ( cls , order ) :
2022-02-17 19:50:10 +00:00
""" checks trade amount in sats """
2022-01-06 16:54:37 +00:00
if order . is_explicit :
satoshis_now = order . satoshis
else :
2022-10-20 20:53:51 +00:00
amount = order . amount if order . amount is not None else order . max_amount
2022-10-20 09:56:10 +00:00
satoshis_now = cls . calc_sats (
amount , order . currency . exchange_rate , order . premium
)
2022-01-06 16:54:37 +00:00
2022-01-07 11:31:33 +00:00
return int ( satoshis_now )
2022-01-10 01:12:58 +00:00
def price_and_premium_now ( order ) :
2022-02-17 19:50:10 +00:00
""" computes order price and premium with current rates """
2022-01-16 16:06:53 +00:00
exchange_rate = float ( order . currency . exchange_rate )
2022-01-10 01:12:58 +00:00
if not order . is_explicit :
premium = order . premium
2022-02-17 19:50:10 +00:00
price = exchange_rate * ( 1 + float ( premium ) / 100 )
2022-01-10 01:12:58 +00:00
else :
2022-03-25 00:09:55 +00:00
amount = order . amount if not order . has_range else order . max_amount
order_rate = float ( amount ) / ( float ( order . satoshis ) / 100000000 )
2022-01-10 01:12:58 +00:00
premium = order_rate / exchange_rate - 1
2022-02-17 19:50:10 +00:00
premium = int ( premium * 10000 ) / 100 # 2 decimals left
2022-01-10 01:12:58 +00:00
price = order_rate
2022-01-11 14:36:43 +00:00
2022-01-14 21:40:54 +00:00
significant_digits = 5
2022-02-17 19:50:10 +00:00
price = round (
2022-10-20 09:56:10 +00:00
price , significant_digits - int ( math . floor ( math . log10 ( abs ( price ) ) ) ) - 1
)
2022-02-17 19:50:10 +00:00
2022-01-10 01:12:58 +00:00
return price , premium
2022-01-16 18:32:34 +00:00
@classmethod
def order_expires ( cls , order ) :
2022-02-17 19:50:10 +00:00
""" General cases when time runs out. """
2022-01-16 18:32:34 +00:00
2022-01-16 21:54:42 +00:00
# Do not change order status if an order in any with
# any of these status is sent to expire here
2022-02-17 19:50:10 +00:00
does_not_expire = [
Order . Status . UCA ,
Order . Status . EXP ,
Order . Status . TLD ,
Order . Status . DIS ,
Order . Status . CCA ,
Order . Status . PAY ,
Order . Status . SUC ,
Order . Status . FAI ,
Order . Status . MLD ,
]
2022-01-16 21:54:42 +00:00
2022-06-20 17:56:08 +00:00
# in any case, if order is_swap and there is an onchain_payment, cancel it.
2022-10-20 20:53:51 +00:00
if order . status not in does_not_expire :
2022-06-20 17:56:08 +00:00
cls . cancel_onchain_payment ( order )
2022-01-20 20:50:25 +00:00
if order . status in does_not_expire :
2022-01-16 21:54:42 +00:00
return False
elif order . status == Order . Status . WFB :
2022-01-16 18:32:34 +00:00
order . status = Order . Status . EXP
2022-04-29 18:54:20 +00:00
order . expiry_reason = Order . ExpiryReasons . NMBOND
2022-01-17 18:11:44 +00:00
cls . cancel_bond ( order . maker_bond )
2022-01-16 18:32:34 +00:00
order . save ( )
2022-01-16 21:54:42 +00:00
return True
2022-02-17 19:50:10 +00:00
2022-04-29 18:54:20 +00:00
elif order . status in [ Order . Status . PUB , Order . Status . PAU ] :
2022-01-16 18:32:34 +00:00
cls . return_bond ( order . maker_bond )
order . status = Order . Status . EXP
2022-04-29 18:54:20 +00:00
order . expiry_reason = Order . ExpiryReasons . NTAKEN
2022-01-16 18:32:34 +00:00
order . save ( )
2022-10-20 09:56:10 +00:00
send_message . delay ( order . id , " order_expired_untaken " )
2022-01-16 21:54:42 +00:00
return True
elif order . status == Order . Status . TAK :
2022-01-17 18:11:44 +00:00
cls . cancel_bond ( order . taker_bond )
2022-01-16 21:54:42 +00:00
cls . kick_taker ( order )
return True
elif order . status == Order . Status . WF2 :
2022-02-17 19:50:10 +00:00
""" Weird case where an order expires and both participants
2022-01-16 21:54:42 +00:00
did not proceed with the contract . Likely the site was
down or there was a bug . Still bonds must be charged
2022-02-17 19:50:10 +00:00
to avoid service DDOS . """
2022-01-16 21:54:42 +00:00
cls . settle_bond ( order . maker_bond )
cls . settle_bond ( order . taker_bond )
2022-01-17 23:11:41 +00:00
cls . cancel_escrow ( order )
2022-01-16 21:54:42 +00:00
order . status = Order . Status . EXP
2022-04-29 18:54:20 +00:00
order . expiry_reason = Order . ExpiryReasons . NESINV
2022-01-16 21:54:42 +00:00
order . save ( )
return True
elif order . status == Order . Status . WFE :
maker_is_seller = cls . is_seller ( order , order . maker )
# If maker is seller, settle the bond and order goes to expired
if maker_is_seller :
cls . settle_bond ( order . maker_bond )
2022-01-17 18:11:44 +00:00
cls . return_bond ( order . taker_bond )
2022-02-21 10:05:19 +00:00
# If seller is offline the escrow LNpayment does not exist
2022-10-20 09:56:10 +00:00
try :
2022-02-20 14:38:29 +00:00
cls . cancel_escrow ( order )
2022-10-20 20:53:51 +00:00
except Exception :
2022-02-20 14:38:29 +00:00
pass
2022-01-16 21:54:42 +00:00
order . status = Order . Status . EXP
2022-04-29 18:54:20 +00:00
order . expiry_reason = Order . ExpiryReasons . NESCRO
2022-01-16 21:54:42 +00:00
order . save ( )
2022-03-07 21:46:52 +00:00
# Reward taker with part of the maker bond
cls . add_slashed_rewards ( order . maker_bond , order . taker . profile )
2022-01-16 21:54:42 +00:00
return True
# If maker is buyer, settle the taker's bond order goes back to public
else :
cls . settle_bond ( order . taker_bond )
2022-02-21 10:05:19 +00:00
# If seller is offline the escrow LNpayment does not even exist
2022-10-20 09:56:10 +00:00
try :
2022-02-20 14:38:29 +00:00
cls . cancel_escrow ( order )
2022-10-20 20:53:51 +00:00
except Exception :
2022-02-20 14:38:29 +00:00
pass
2022-03-07 21:46:52 +00:00
taker_bond = order . taker_bond
2022-01-16 21:54:42 +00:00
order . taker = None
order . taker_bond = None
2022-01-17 23:11:41 +00:00
order . trade_escrow = None
2022-04-16 18:34:30 +00:00
order . payout = None
2022-01-18 15:23:57 +00:00
cls . publish_order ( order )
2022-10-20 09:56:10 +00:00
send_message . delay ( order . id , " order_published " )
2022-03-07 21:46:52 +00:00
# Reward maker with part of the taker bond
cls . add_slashed_rewards ( taker_bond , order . maker . profile )
2022-01-16 21:54:42 +00:00
return True
elif order . status == Order . Status . WFI :
# The trade could happen without a buyer invoice. However, this user
2022-01-17 23:11:41 +00:00
# is likely AFK; will probably desert the contract as well.
2022-01-16 21:54:42 +00:00
maker_is_buyer = cls . is_buyer ( order , order . maker )
# If maker is buyer, settle the bond and order goes to expired
if maker_is_buyer :
cls . settle_bond ( order . maker_bond )
2022-01-17 18:11:44 +00:00
cls . return_bond ( order . taker_bond )
2022-01-17 23:11:41 +00:00
cls . return_escrow ( order )
2022-01-16 21:54:42 +00:00
order . status = Order . Status . EXP
2022-04-29 18:54:20 +00:00
order . expiry_reason = Order . ExpiryReasons . NINVOI
2022-01-16 21:54:42 +00:00
order . save ( )
2022-03-07 21:46:52 +00:00
# Reward taker with part of the maker bond
cls . add_slashed_rewards ( order . maker_bond , order . taker . profile )
2022-01-16 21:54:42 +00:00
return True
2022-01-17 18:11:44 +00:00
# If maker is seller settle the taker's bond, order goes back to public
2022-01-16 21:54:42 +00:00
else :
cls . settle_bond ( order . taker_bond )
2022-01-17 23:11:41 +00:00
cls . return_escrow ( order )
2022-03-07 21:46:52 +00:00
taker_bond = order . taker_bond
2022-01-16 21:54:42 +00:00
order . taker = None
order . taker_bond = None
2022-01-17 23:11:41 +00:00
order . trade_escrow = None
2022-01-18 15:23:57 +00:00
cls . publish_order ( order )
2022-10-20 09:56:10 +00:00
send_message . delay ( order . id , " order_published " )
2022-03-07 21:46:52 +00:00
# Reward maker with part of the taker bond
cls . add_slashed_rewards ( taker_bond , order . maker . profile )
2022-01-16 21:54:42 +00:00
return True
2022-02-17 19:50:10 +00:00
2022-01-19 20:55:24 +00:00
elif order . status in [ Order . Status . CHA , Order . Status . FSE ] :
# Another weird case. The time to confirm 'fiat sent or received' expired. Yet no dispute
2022-02-17 19:50:10 +00:00
# was opened. Hint: a seller-scammer could persuade a buyer to not click "fiat
2022-01-17 23:11:41 +00:00
# sent", we assume this is a dispute case by default.
2022-01-16 21:54:42 +00:00
cls . open_dispute ( order )
return True
2022-01-06 16:54:37 +00:00
2022-01-18 15:23:57 +00:00
@classmethod
def kick_taker ( cls , order ) :
2022-02-17 19:50:10 +00:00
""" The taker did not lock the taker_bond. Now he has to go """
2022-01-12 00:02:17 +00:00
# Add a time out to the taker
2022-01-18 18:40:56 +00:00
if order . taker :
profile = order . taker . profile
2022-02-17 19:50:10 +00:00
profile . penalty_expiration = timezone . now ( ) + timedelta (
2022-10-20 09:56:10 +00:00
seconds = PENALTY_TIMEOUT
)
2022-01-18 18:40:56 +00:00
profile . save ( )
2022-01-12 00:02:17 +00:00
2022-01-17 18:11:44 +00:00
# Make order public again
order . taker = None
order . taker_bond = None
2022-01-18 15:23:57 +00:00
cls . publish_order ( order )
2022-01-17 18:11:44 +00:00
return True
2022-01-12 00:02:17 +00:00
2022-01-16 21:54:42 +00:00
@classmethod
def open_dispute ( cls , order , user = None ) :
2022-10-20 09:56:10 +00:00
# Always settle escrow and bonds during a dispute. Disputes
# can take long to resolve, it might trigger force closure
# for unresolved HTLCs) Dispute winner will have to submit a
2022-02-20 11:39:28 +00:00
# new invoice for value of escrow + bond.
2022-01-17 23:11:41 +00:00
2022-05-25 07:46:57 +00:00
valid_status_open_dispute = [
2022-05-16 06:47:22 +00:00
Order . Status . CHA ,
Order . Status . FSE ,
]
2022-05-25 07:46:57 +00:00
if order . status not in valid_status_open_dispute :
2022-10-20 09:56:10 +00:00
return False , {
" bad_request " : " You cannot open a dispute of this order at this stage "
}
2022-01-16 21:54:42 +00:00
if not order . trade_escrow . status == LNPayment . Status . SETLED :
2022-02-17 19:50:10 +00:00
cls . settle_escrow ( order )
2022-02-20 11:39:28 +00:00
cls . settle_bond ( order . maker_bond )
cls . settle_bond ( order . taker_bond )
2022-02-17 19:50:10 +00:00
2022-01-16 21:54:42 +00:00
order . is_disputed = True
order . status = Order . Status . DIS
2022-02-17 19:50:10 +00:00
order . expires_at = timezone . now ( ) + timedelta (
2022-10-20 09:56:10 +00:00
seconds = order . t_to_expire ( Order . Status . DIS )
)
2022-01-16 21:54:42 +00:00
order . save ( )
# User could be None if a dispute is open automatically due to weird expiration.
2022-10-20 20:53:51 +00:00
if user is not None :
2022-01-16 21:54:42 +00:00
profile = user . profile
profile . num_disputes = profile . num_disputes + 1
2022-10-20 20:53:51 +00:00
if profile . orders_disputes_started is None :
2022-01-20 17:30:29 +00:00
profile . orders_disputes_started = [ str ( order . id ) ]
else :
2022-02-17 19:50:10 +00:00
profile . orders_disputes_started = list (
2022-10-20 09:56:10 +00:00
profile . orders_disputes_started
) . append ( str ( order . id ) )
2022-01-16 21:54:42 +00:00
profile . save ( )
2022-10-20 09:56:10 +00:00
send_message . delay ( order . id , " dispute_opened " )
2022-01-16 21:54:42 +00:00
return True , None
2022-01-17 23:11:41 +00:00
2022-01-16 21:54:42 +00:00
def dispute_statement ( order , user , statement ) :
2022-02-17 19:50:10 +00:00
""" Updates the dispute statements """
2022-01-27 14:40:14 +00:00
2022-01-17 16:41:55 +00:00
if not order . status == Order . Status . DIS :
2022-02-17 19:50:10 +00:00
return False , {
2022-10-20 09:56:10 +00:00
" bad_request " : " Only orders in dispute accept dispute statements "
2022-02-17 19:50:10 +00:00
}
2022-01-16 21:54:42 +00:00
2023-03-14 17:23:11 +00:00
if len ( statement ) > 10000 :
2022-02-17 19:50:10 +00:00
return False , {
2023-03-14 17:23:11 +00:00
" bad_statement " : " The statement is longer than 10000 characters "
2022-02-17 19:50:10 +00:00
}
2022-10-20 09:56:10 +00:00
2022-02-24 20:47:46 +00:00
if len ( statement ) < 100 :
return False , {
" bad_statement " : " The statement is too short. Make sure to be thorough. "
}
2022-01-17 16:41:55 +00:00
2022-01-16 21:54:42 +00:00
if order . maker == user :
order . maker_statement = statement
else :
order . taker_statement = statement
2022-02-17 19:50:10 +00:00
2022-01-17 16:41:55 +00:00
# If both statements are in, move status to wait for dispute resolution
2022-10-20 09:56:10 +00:00
if order . maker_statement not in [ None , " " ] and order . taker_statement not in [
None ,
" " ,
] :
2022-01-16 21:54:42 +00:00
order . status = Order . Status . WFR
2022-02-17 19:50:10 +00:00
order . expires_at = timezone . now ( ) + timedelta (
2022-10-20 09:56:10 +00:00
seconds = order . t_to_expire ( Order . Status . WFR )
)
2022-01-16 21:54:42 +00:00
order . save ( )
return True , None
2022-06-06 20:37:51 +00:00
def compute_swap_fee_rate ( balance ) :
2022-06-07 22:14:56 +00:00
2022-10-20 09:56:10 +00:00
shape = str ( config ( " SWAP_FEE_SHAPE " ) )
2022-06-06 20:37:51 +00:00
if shape == " linear " :
2022-10-20 09:56:10 +00:00
MIN_SWAP_FEE = float ( config ( " MIN_SWAP_FEE " ) )
MIN_POINT = float ( config ( " MIN_POINT " ) )
MAX_SWAP_FEE = float ( config ( " MAX_SWAP_FEE " ) )
MAX_POINT = float ( config ( " MAX_POINT " ) )
2022-06-11 13:12:09 +00:00
if float ( balance . onchain_fraction ) > MIN_POINT :
2022-06-06 20:37:51 +00:00
swap_fee_rate = MIN_SWAP_FEE
else :
slope = ( MAX_SWAP_FEE - MIN_SWAP_FEE ) / ( MAX_POINT - MIN_POINT )
2022-10-20 09:56:10 +00:00
swap_fee_rate = (
slope * ( balance . onchain_fraction - MAX_POINT ) + MAX_SWAP_FEE
)
2022-06-06 20:37:51 +00:00
2022-06-07 22:14:56 +00:00
elif shape == " exponential " :
2022-10-20 09:56:10 +00:00
MIN_SWAP_FEE = float ( config ( " MIN_SWAP_FEE " ) )
MAX_SWAP_FEE = float ( config ( " MAX_SWAP_FEE " ) )
SWAP_LAMBDA = float ( config ( " SWAP_LAMBDA " ) )
swap_fee_rate = MIN_SWAP_FEE + ( MAX_SWAP_FEE - MIN_SWAP_FEE ) * math . exp (
- SWAP_LAMBDA * float ( balance . onchain_fraction )
)
2022-06-07 22:14:56 +00:00
2022-06-11 13:12:09 +00:00
return swap_fee_rate * 100
2022-06-06 20:37:51 +00:00
@classmethod
2022-06-11 13:12:09 +00:00
def create_onchain_payment ( cls , order , user , preliminary_amount ) :
2022-10-20 09:56:10 +00:00
"""
2022-06-06 20:37:51 +00:00
Creates an empty OnchainPayment for order . payout_tx .
It sets the fees to be applied to this order if onchain Swap is used .
If the user submits a LN invoice instead . The returned OnchainPayment goes unused .
2022-10-20 09:56:10 +00:00
"""
2022-06-17 11:36:27 +00:00
# Make sure no invoice payout is attached to order
order . payout = None
# Create onchain_payment
2022-06-11 13:12:09 +00:00
onchain_payment = OnchainPayment . objects . create ( receiver = user )
2022-10-20 09:56:10 +00:00
2022-06-07 22:14:56 +00:00
# Compute a safer available onchain liquidity: (confirmed_utxos - reserve - pending_outgoing_txs))
# Accounts for already committed outgoing TX for previous users.
confirmed = onchain_payment . balance . onchain_confirmed
2023-01-14 12:12:10 +00:00
reserve = 300000 # We assume a reserve of 300K Sats (3 times higher than LND's default anchor reserve)
2022-10-20 09:56:10 +00:00
pending_txs = OnchainPayment . objects . filter (
2023-03-14 17:23:11 +00:00
status__in = [ OnchainPayment . Status . VALID , OnchainPayment . Status . QUEUE ]
2022-10-20 09:56:10 +00:00
) . aggregate ( Sum ( " num_satoshis " ) ) [ " num_satoshis__sum " ]
2022-10-20 20:53:51 +00:00
if pending_txs is None :
2022-06-11 13:12:09 +00:00
pending_txs = 0
2022-10-20 09:56:10 +00:00
2022-06-07 22:14:56 +00:00
available_onchain = confirmed - reserve - pending_txs
2022-10-20 09:56:10 +00:00
if (
preliminary_amount > available_onchain
) : # Not enough onchain balance to commit for this swap.
2022-06-07 22:14:56 +00:00
return False
2023-03-17 20:55:49 +00:00
suggested_mining_fee_rate = LNNode . estimate_fee (
amount_sats = preliminary_amount , target_conf = 2
) [ " mining_fee_rate " ]
2022-06-11 13:12:09 +00:00
2023-02-13 13:57:00 +00:00
# Hardcap mining fee suggested at 100 sats/vbyte
if suggested_mining_fee_rate > 100 :
suggested_mining_fee_rate = 100
2022-06-11 13:12:09 +00:00
2022-10-20 09:56:10 +00:00
onchain_payment . suggested_mining_fee_rate = max (
2023-02-13 13:57:00 +00:00
2.05 , LNNode . estimate_fee ( amount_sats = preliminary_amount ) [ " mining_fee_rate " ]
2022-10-20 09:56:10 +00:00
)
onchain_payment . swap_fee_rate = cls . compute_swap_fee_rate (
onchain_payment . balance
)
2022-06-06 20:37:51 +00:00
onchain_payment . save ( )
order . payout_tx = onchain_payment
order . save ( )
2022-06-07 22:14:56 +00:00
return True
2022-06-06 20:37:51 +00:00
2022-01-07 11:31:33 +00:00
@classmethod
2022-01-25 14:46:02 +00:00
def payout_amount ( cls , order , user ) :
2022-02-17 19:50:10 +00:00
""" Computes buyer invoice amount. Uses order.last_satoshis,
2022-06-06 20:37:51 +00:00
that is the final trade amount set at Taker Bond time
Adds context for onchain swap .
"""
if not cls . is_buyer ( order , user ) :
return False , None
2022-01-07 11:31:33 +00:00
2022-03-03 15:40:56 +00:00
if user == order . maker :
fee_fraction = FEE * MAKER_FEE_SPLIT
elif user == order . taker :
fee_fraction = FEE * ( 1 - MAKER_FEE_SPLIT )
fee_sats = order . last_satoshis * fee_fraction
2022-10-20 09:56:10 +00:00
reward_tip = int ( config ( " REWARD_TIP " ) ) if user . profile . is_referred else 0
2022-03-05 20:51:16 +00:00
2022-06-06 20:37:51 +00:00
context = { }
# context necessary for the user to submit a LN invoice
2022-10-20 09:56:10 +00:00
context [ " invoice_amount " ] = round (
order . last_satoshis - fee_sats - reward_tip
) # Trading fee to buyer is charged here.
2022-06-06 20:37:51 +00:00
# context necessary for the user to submit an onchain address
2023-03-14 19:54:31 +00:00
MIN_SWAP_AMOUNT = config ( " MIN_SWAP_AMOUNT " , cast = int , default = 20000 )
MAX_SWAP_AMOUNT = config ( " MAX_SWAP_AMOUNT " , cast = int , default = 500000 )
2022-06-06 20:37:51 +00:00
if context [ " invoice_amount " ] < MIN_SWAP_AMOUNT :
context [ " swap_allowed " ] = False
2022-10-20 09:56:10 +00:00
context [
" swap_failure_reason "
2023-03-14 19:54:31 +00:00
] = f " Order amount is smaller than the minimum swap available of { MIN_SWAP_AMOUNT } Sats "
return True , context
elif context [ " invoice_amount " ] > MAX_SWAP_AMOUNT :
context [ " swap_allowed " ] = False
context [
" swap_failure_reason "
] = f " Order amount is bigger than the maximum swap available of { MAX_SWAP_AMOUNT } Sats "
2022-06-06 20:37:51 +00:00
return True , context
2023-03-14 19:54:31 +00:00
if config ( " DISABLE_ONCHAIN " , cast = bool , default = True ) :
2022-06-16 15:31:30 +00:00
context [ " swap_allowed " ] = False
context [ " swap_failure_reason " ] = " On-the-fly submarine swaps are dissabled "
return True , context
2022-10-20 20:53:51 +00:00
if order . payout_tx is None :
2022-06-07 22:14:56 +00:00
# Creates the OnchainPayment object and checks node balance
2022-10-20 09:56:10 +00:00
valid = cls . create_onchain_payment (
order , user , preliminary_amount = context [ " invoice_amount " ]
)
2022-06-07 22:14:56 +00:00
if not valid :
context [ " swap_allowed " ] = False
2022-10-20 09:56:10 +00:00
context [
" swap_failure_reason "
] = " Not enough onchain liquidity available to offer a swap "
2022-06-07 22:14:56 +00:00
return True , context
2022-06-06 20:37:51 +00:00
context [ " swap_allowed " ] = True
context [ " suggested_mining_fee_rate " ] = order . payout_tx . suggested_mining_fee_rate
context [ " swap_fee_rate " ] = order . payout_tx . swap_fee_rate
2022-01-07 11:31:33 +00:00
2022-06-06 20:37:51 +00:00
return True , context
2022-01-07 11:31:33 +00:00
2022-03-03 15:40:56 +00:00
@classmethod
def escrow_amount ( cls , order , user ) :
""" Computes escrow invoice amount. Uses order.last_satoshis,
2022-10-20 09:56:10 +00:00
that is the final trade amount set at Taker Bond time """
2022-03-03 15:40:56 +00:00
if user == order . maker :
fee_fraction = FEE * MAKER_FEE_SPLIT
elif user == order . taker :
fee_fraction = FEE * ( 1 - MAKER_FEE_SPLIT )
2022-10-20 09:56:10 +00:00
fee_sats = order . last_satoshis * fee_fraction
2022-03-05 20:51:16 +00:00
2022-10-20 09:56:10 +00:00
reward_tip = int ( config ( " REWARD_TIP " ) ) if user . profile . is_referred else 0
2022-03-03 15:40:56 +00:00
if cls . is_seller ( order , user ) :
2022-10-20 09:56:10 +00:00
escrow_amount = round (
order . last_satoshis + fee_sats + reward_tip
) # Trading fee to seller is charged here.
2022-03-03 15:40:56 +00:00
return True , { " escrow_amount " : escrow_amount }
2022-06-13 22:27:09 +00:00
@classmethod
def update_address ( cls , order , user , address , mining_fee_rate ) :
2022-10-20 09:56:10 +00:00
2022-06-13 22:27:09 +00:00
# Empty address?
if not address :
2022-10-20 09:56:10 +00:00
return False , { " bad_address " : " You submitted an empty invoice " }
2022-06-13 22:27:09 +00:00
# only the buyer can post a buyer address
if not cls . is_buyer ( order , user ) :
return False , {
2022-10-20 09:56:10 +00:00
" bad_request " : " Only the buyer of this order can provide a payout address. "
2022-06-13 22:27:09 +00:00
}
# not the right time to submit
2023-03-17 20:55:49 +00:00
if not (
order . taker_bond . status
== order . maker_bond . status
== LNPayment . Status . LOCKED
) or order . status not in [ Order . Status . WFI , Order . Status . WF2 ] :
return False , { " bad_request " : " You cannot submit an address now. " }
# not a valid address
2022-06-17 11:36:27 +00:00
valid , context = validate_onchain_address ( address )
if not valid :
return False , context
2023-03-17 20:55:49 +00:00
num_satoshis = cls . payout_amount ( order , user ) [ 1 ] [ " invoice_amount " ]
2022-06-13 22:27:09 +00:00
if mining_fee_rate :
# not a valid mining fee
2023-03-17 20:55:49 +00:00
min_mining_fee_rate = LNNode . estimate_fee (
amount_sats = num_satoshis , target_conf = 12
) [ " mining_fee_rate " ]
min_mining_fee_rate = max ( 2 , min_mining_fee_rate )
if float ( mining_fee_rate ) < min_mining_fee_rate :
2022-06-13 22:27:09 +00:00
return False , {
2023-03-17 20:55:49 +00:00
" bad_address " : f " The mining fee is too low. Must be higher than { min_mining_fee_rate } Sat/vbyte "
2022-06-13 22:27:09 +00:00
}
2023-02-13 13:57:00 +00:00
elif float ( mining_fee_rate ) > 100 :
2022-06-13 22:27:09 +00:00
return False , {
2023-02-13 13:57:00 +00:00
" bad_address " : " The mining fee is too high, must be less than 100 Sats/vbyte "
2022-06-13 22:27:09 +00:00
}
order . payout_tx . mining_fee_rate = float ( mining_fee_rate )
# If not mining ee provider use backend's suggested fee rate
else :
order . payout_tx . mining_fee_rate = order . payout_tx . suggested_mining_fee_rate
tx = order . payout_tx
tx . address = address
2023-02-13 13:57:00 +00:00
tx . mining_fee_sats = int ( tx . mining_fee_rate * 200 )
2023-03-17 20:55:49 +00:00
tx . num_satoshis = num_satoshis
2022-10-20 09:56:10 +00:00
tx . sent_satoshis = int (
float ( tx . num_satoshis )
- float ( tx . num_satoshis ) * float ( tx . swap_fee_rate ) / 100
- float ( tx . mining_fee_sats )
)
2022-06-13 22:27:09 +00:00
tx . status = OnchainPayment . Status . VALID
tx . save ( )
order . is_swap = True
order . save ( )
cls . move_state_updated_payout_method ( order )
return True , None
2022-01-06 16:54:37 +00:00
@classmethod
2022-11-24 17:42:30 +00:00
def update_invoice ( cls , order , user , invoice , routing_budget_ppm ) :
2022-10-20 09:56:10 +00:00
2022-05-28 13:05:26 +00:00
# Empty invoice?
if not invoice :
2022-10-20 09:56:10 +00:00
return False , { " bad_invoice " : " You submitted an empty invoice " }
2022-01-07 19:22:07 +00:00
# only the buyer can post a buyer invoice
if not cls . is_buyer ( order , user ) :
2022-02-17 19:50:10 +00:00
return False , {
2022-10-20 09:56:10 +00:00
" bad_request " : " Only the buyer of this order can provide a buyer invoice. "
2022-02-17 19:50:10 +00:00
}
2022-01-07 19:22:07 +00:00
if not order . taker_bond :
2022-02-17 19:50:10 +00:00
return False , { " bad_request " : " Wait for your order to be taken. " }
2022-10-20 09:56:10 +00:00
if (
2022-10-22 14:23:22 +00:00
not (
order . taker_bond . status
== order . maker_bond . status
== LNPayment . Status . LOCKED
)
2022-10-20 09:56:10 +00:00
and not order . status == Order . Status . FAI
) :
2022-02-17 19:50:10 +00:00
return False , {
2022-10-20 09:56:10 +00:00
" bad_request " : " You cannot submit a invoice while bonds are not locked. "
2022-02-17 19:50:10 +00:00
}
2022-03-20 23:32:25 +00:00
if order . status == Order . Status . FAI :
if order . payout . status != LNPayment . Status . EXPIRE :
return False , {
2022-10-20 09:56:10 +00:00
" bad_request " : " You cannot submit an invoice only after expiration or 3 failed attempts "
2022-03-20 23:32:25 +00:00
}
2022-02-17 19:50:10 +00:00
2022-06-17 11:36:27 +00:00
# cancel onchain_payout if existing
2022-06-20 17:56:08 +00:00
cls . cancel_onchain_payment ( order )
2022-06-17 11:36:27 +00:00
2022-02-17 19:50:10 +00:00
num_satoshis = cls . payout_amount ( order , user ) [ 1 ] [ " invoice_amount " ]
2022-11-24 17:42:30 +00:00
routing_budget_sats = float ( num_satoshis ) * (
float ( routing_budget_ppm ) / 1000000
)
num_satoshis = int ( num_satoshis - routing_budget_sats )
payout = LNNode . validate_ln_invoice ( invoice , num_satoshis , routing_budget_ppm )
2022-01-12 00:02:17 +00:00
2022-02-17 19:50:10 +00:00
if not payout [ " valid " ] :
2022-10-22 14:23:22 +00:00
return False , payout [ " context " ]
2022-01-06 22:39:59 +00:00
2022-01-25 14:46:02 +00:00
order . payout , _ = LNPayment . objects . update_or_create (
2022-02-17 19:50:10 +00:00
concept = LNPayment . Concepts . PAYBUYER ,
type = LNPayment . Types . NORM ,
sender = User . objects . get ( username = ESCROW_USERNAME ) ,
2022-10-20 09:56:10 +00:00
order_paid_LN = order , # In case this user has other payouts, update the one related to this order.
2022-02-17 19:50:10 +00:00
receiver = user ,
2022-11-24 17:42:30 +00:00
routing_budget_ppm = routing_budget_ppm ,
routing_budget_sats = routing_budget_sats ,
2022-01-06 22:39:59 +00:00
# if there is a LNPayment matching these above, it updates that one with defaults below.
defaults = {
2022-10-22 14:23:22 +00:00
" invoice " : invoice ,
" status " : LNPayment . Status . VALIDI ,
" num_satoshis " : num_satoshis ,
" description " : payout [ " description " ] ,
2022-02-17 19:50:10 +00:00
" payment_hash " : payout [ " payment_hash " ] ,
" created_at " : payout [ " created_at " ] ,
" expires_at " : payout [ " expires_at " ] ,
} ,
)
2022-01-06 22:39:59 +00:00
2022-06-13 22:27:09 +00:00
order . is_swap = False
order . save ( )
cls . move_state_updated_payout_method ( order )
return True , None
@classmethod
2022-10-20 09:56:10 +00:00
def move_state_updated_payout_method ( cls , order ) :
2022-01-12 00:02:17 +00:00
# If the order status is 'Waiting for invoice'. Move forward to 'chat'
2022-02-17 19:50:10 +00:00
if order . status == Order . Status . WFI :
2022-01-12 12:57:03 +00:00
order . status = Order . Status . CHA
2022-02-17 19:50:10 +00:00
order . expires_at = timezone . now ( ) + timedelta (
2022-10-20 09:56:10 +00:00
seconds = order . t_to_expire ( Order . Status . CHA )
)
send_message . delay ( order . id , " fiat_exchange_starts " )
2022-01-06 22:39:59 +00:00
2022-01-11 01:02:06 +00:00
# If the order status is 'Waiting for both'. Move forward to 'waiting for escrow'
2022-06-19 06:09:21 +00:00
elif order . status == Order . Status . WF2 :
2022-01-30 15:50:22 +00:00
# If the escrow does not exist, or is not locked move to WFE.
2022-10-20 20:53:51 +00:00
if order . trade_escrow is None :
2022-01-30 15:50:22 +00:00
order . status = Order . Status . WFE
# If the escrow is locked move to Chat.
elif order . trade_escrow . status == LNPayment . Status . LOCKED :
2022-01-12 12:57:03 +00:00
order . status = Order . Status . CHA
2022-02-17 19:50:10 +00:00
order . expires_at = timezone . now ( ) + timedelta (
2022-10-20 09:56:10 +00:00
seconds = order . t_to_expire ( Order . Status . CHA )
)
send_message . delay ( order . id , " fiat_exchange_starts " )
2022-01-06 22:39:59 +00:00
else :
order . status = Order . Status . WFE
2022-02-17 19:50:10 +00:00
2022-01-24 22:53:55 +00:00
# If the order status is 'Failed Routing'. Retry payment.
2022-06-19 06:09:21 +00:00
elif order . status == Order . Status . FAI :
2022-10-20 09:56:10 +00:00
if LNNode . double_check_htlc_is_settled ( order . trade_escrow . payment_hash ) :
2022-02-04 18:07:09 +00:00
order . status = Order . Status . PAY
order . payout . status = LNPayment . Status . FLIGHT
order . payout . routing_attempts = 0
order . payout . save ( )
2022-10-20 09:56:10 +00:00
2022-01-06 22:39:59 +00:00
order . save ( )
2022-06-13 22:27:09 +00:00
return True
2022-01-06 20:33:40 +00:00
2022-01-11 20:49:53 +00:00
def add_profile_rating ( profile , rating ) :
2022-02-17 19:50:10 +00:00
""" adds a new rating to a user profile """
2022-01-11 20:49:53 +00:00
2022-01-17 23:11:41 +00:00
# TODO Unsafe, does not update ratings, it adds more ratings everytime a new rating is clicked.
2022-01-20 17:30:29 +00:00
profile . total_ratings + = 1
2022-01-11 20:49:53 +00:00
latest_ratings = profile . latest_ratings
2022-10-20 20:53:51 +00:00
if latest_ratings is None :
2022-01-11 20:49:53 +00:00
profile . latest_ratings = [ rating ]
profile . avg_rating = rating
else :
2022-01-17 23:11:41 +00:00
latest_ratings = ast . literal_eval ( latest_ratings )
latest_ratings . append ( rating )
2022-01-11 20:49:53 +00:00
profile . latest_ratings = latest_ratings
2022-02-17 19:50:10 +00:00
profile . avg_rating = sum ( list ( map ( int , latest_ratings ) ) ) / len (
latest_ratings
) # Just an average, but it is a list of strings. Has to be converted to int.
2022-01-11 20:49:53 +00:00
profile . save ( )
2022-01-10 12:10:32 +00:00
def is_penalized ( user ) :
2022-02-17 19:50:10 +00:00
""" Checks if a user that is not participant of orders
has a limit on taking or making a order """
2022-01-10 12:10:32 +00:00
if user . profile . penalty_expiration :
if user . profile . penalty_expiration > timezone . now ( ) :
2022-10-20 09:56:10 +00:00
time_out = ( user . profile . penalty_expiration - timezone . now ( ) ) . seconds
2022-01-10 12:10:32 +00:00
return True , time_out
return False , None
2022-01-06 20:33:40 +00:00
@classmethod
2022-01-07 19:22:07 +00:00
def cancel_order ( cls , order , user , state = None ) :
2022-01-07 11:31:33 +00:00
2022-01-27 14:40:14 +00:00
# Do not change order status if an is in order
# any of these status
2022-02-17 19:50:10 +00:00
do_not_cancel = [
Order . Status . UCA ,
Order . Status . EXP ,
Order . Status . TLD ,
Order . Status . DIS ,
Order . Status . CCA ,
Order . Status . PAY ,
Order . Status . SUC ,
Order . Status . FAI ,
Order . Status . MLD ,
]
2022-01-20 20:50:25 +00:00
if order . status in do_not_cancel :
2022-02-17 19:50:10 +00:00
return False , { " bad_request " : " You cannot cancel this order " }
2022-01-20 20:50:25 +00:00
2022-01-07 11:31:33 +00:00
# 1) When maker cancels before bond
2022-10-20 20:53:51 +00:00
# The order never shows up on the book and order
# status becomes "cancelled"
2022-01-06 22:39:59 +00:00
if order . status == Order . Status . WFB and order . maker == user :
2022-02-17 02:45:18 +00:00
cls . cancel_bond ( order . maker_bond )
2022-01-06 22:39:59 +00:00
order . status = Order . Status . UCA
order . save ( )
2022-01-12 00:02:17 +00:00
return True , None
2022-01-06 22:39:59 +00:00
2022-10-20 20:53:51 +00:00
# 2.a) When maker cancels after bond
#
# The order dissapears from book and goes to cancelled. If strict, maker is charged the bond
# to prevent DDOS on the LN node and order book. If not strict, maker is returned
# the bond (more user friendly).
2022-10-20 09:56:10 +00:00
elif (
order . status in [ Order . Status . PUB , Order . Status . PAU ] and order . maker == user
) :
2022-02-23 16:15:48 +00:00
# Return the maker bond (Maker gets returned the bond for cancelling public order)
2022-10-20 09:56:10 +00:00
if cls . return_bond ( order . maker_bond ) :
2022-05-05 13:58:13 +00:00
order . status = Order . Status . UCA
order . save ( )
2022-10-20 09:56:10 +00:00
send_message . delay ( order . id , " public_order_cancelled " )
2022-05-05 13:58:13 +00:00
return True , None
2022-10-20 20:53:51 +00:00
# 2.b) When maker cancels after bond and before taker bond is locked
#
# The order dissapears from book and goes to cancelled.
# The bond maker bond is returned.
2022-05-05 13:58:13 +00:00
elif order . status == Order . Status . TAK and order . maker == user :
# Return the maker bond (Maker gets returned the bond for cancelling public order)
2022-10-20 09:56:10 +00:00
if cls . return_bond ( order . maker_bond ) :
2022-05-05 13:58:13 +00:00
cls . cancel_bond ( order . taker_bond )
2022-01-11 14:36:43 +00:00
order . status = Order . Status . UCA
order . save ( )
2022-10-20 09:56:10 +00:00
send_message . delay ( order . id , " public_order_cancelled " )
2022-01-12 00:02:17 +00:00
return True , None
2022-01-06 20:33:40 +00:00
2022-10-20 20:53:51 +00:00
# 3) When taker cancels before bond
# The order goes back to the book as public.
# LNPayment "order.taker_bond" is deleted()
2022-01-10 12:10:32 +00:00
elif order . status == Order . Status . TAK and order . taker == user :
# adds a timeout penalty
2022-01-17 18:11:44 +00:00
cls . cancel_bond ( order . taker_bond )
2022-01-14 14:19:25 +00:00
cls . kick_taker ( order )
2022-01-12 00:02:17 +00:00
return True , None
2022-01-06 20:33:40 +00:00
2022-10-20 20:53:51 +00:00
# 4) When taker or maker cancel after bond (before escrow)
#
# The order goes into cancelled status if maker cancels.
# The order goes into the public book if taker cancels.
# In both cases there is a small fee.
2022-02-17 19:50:10 +00:00
2022-10-20 20:53:51 +00:00
# 4.a) When maker cancel after bond (before escrow)
# The order into cancelled status if maker cancels.
2022-10-20 09:56:10 +00:00
elif (
order . status in [ Order . Status . WF2 , Order . Status . WFE ] and order . maker == user
) :
2022-06-20 17:56:08 +00:00
# cancel onchain payment if existing
cls . cancel_onchain_payment ( order )
2022-02-17 19:50:10 +00:00
# Settle the maker bond (Maker loses the bond for canceling an ongoing trade)
2022-01-16 21:54:42 +00:00
valid = cls . settle_bond ( order . maker_bond )
2022-02-17 19:50:10 +00:00
cls . return_bond ( order . taker_bond ) # returns taker bond
2022-06-20 17:56:08 +00:00
2022-01-11 14:36:43 +00:00
if valid :
order . status = Order . Status . UCA
order . save ( )
2022-03-07 21:46:52 +00:00
# Reward taker with part of the maker bond
cls . add_slashed_rewards ( order . maker_bond , order . taker . profile )
2022-01-12 00:02:17 +00:00
return True , None
2022-01-11 14:36:43 +00:00
2022-10-20 20:53:51 +00:00
# 4.b) When taker cancel after bond (before escrow)
# The order into cancelled status if mtker cancels.
2022-10-20 09:56:10 +00:00
elif (
order . status in [ Order . Status . WF2 , Order . Status . WFE ] and order . taker == user
) :
2022-06-20 17:56:08 +00:00
# cancel onchain payment if existing
cls . cancel_onchain_payment ( order )
2022-01-11 20:49:53 +00:00
# Settle the maker bond (Maker loses the bond for canceling an ongoing trade)
2022-01-16 21:54:42 +00:00
valid = cls . settle_bond ( order . taker_bond )
2022-01-11 14:36:43 +00:00
if valid :
order . taker = None
2022-04-16 18:34:30 +00:00
order . payout = None
order . trade_escrow = None
2022-01-18 15:23:57 +00:00
cls . publish_order ( order )
2022-10-20 09:56:10 +00:00
send_message . delay ( order . id , " order_published " )
2022-03-07 21:46:52 +00:00
# Reward maker with part of the taker bond
cls . add_slashed_rewards ( order . taker_bond , order . maker . profile )
2022-01-12 00:02:17 +00:00
return True , None
2022-01-11 14:36:43 +00:00
2022-10-20 20:53:51 +00:00
# 5) When trade collateral has been posted (after escrow)
#
# Always goes to CCA status. Collaboration is needed.
# When a user asks for cancel, 'order.m/t/aker_asked_cancel' goes True.
# When the second user asks for cancel. Order is totally cancelled.
# Must have a small cost for both parties to prevent node DDOS.
2022-10-20 09:56:10 +00:00
elif order . status in [ Order . Status . WFI , Order . Status . CHA ] :
2022-02-17 19:50:10 +00:00
2022-01-23 19:02:25 +00:00
# if the maker had asked, and now the taker does: cancel order, return everything
if order . maker_asked_cancel and user == order . taker :
cls . collaborative_cancel ( order )
return True , None
2022-02-17 19:50:10 +00:00
2022-01-23 19:02:25 +00:00
# if the taker had asked, and now the maker does: cancel order, return everything
elif order . taker_asked_cancel and user == order . maker :
cls . collaborative_cancel ( order )
return True , None
# Otherwise just make true the asked for cancel flags
elif user == order . taker :
order . taker_asked_cancel = True
order . save ( )
return True , None
2022-02-17 19:50:10 +00:00
2022-01-23 19:02:25 +00:00
elif user == order . maker :
order . maker_asked_cancel = True
order . save ( )
return True , None
2022-01-06 22:39:59 +00:00
else :
2022-02-17 19:50:10 +00:00
return False , { " bad_request " : " You cannot cancel this order " }
2022-01-06 20:33:40 +00:00
2022-01-23 19:02:25 +00:00
@classmethod
def collaborative_cancel ( cls , order ) :
2022-10-20 20:53:51 +00:00
if order . status not in [ Order . Status . WFI , Order . Status . CHA ] :
2022-06-04 21:26:53 +00:00
return
2022-06-20 17:56:08 +00:00
# cancel onchain payment if existing
cls . cancel_onchain_payment ( order )
2022-01-23 19:02:25 +00:00
cls . return_bond ( order . maker_bond )
cls . return_bond ( order . taker_bond )
cls . return_escrow ( order )
order . status = Order . Status . CCA
order . save ( )
2022-10-20 09:56:10 +00:00
send_message . delay ( order . id , " collaborative_cancelled " )
2022-01-23 19:02:25 +00:00
return
2022-03-30 20:01:26 +00:00
@classmethod
def publish_order ( cls , order ) :
2022-01-18 15:23:57 +00:00
order . status = Order . Status . PUB
2022-02-17 19:50:10 +00:00
order . expires_at = order . created_at + timedelta (
2022-10-20 09:56:10 +00:00
seconds = order . t_to_expire ( Order . Status . PUB )
)
2022-03-22 17:49:57 +00:00
if order . has_range :
order . amount = None
2022-03-30 20:01:26 +00:00
order . last_satoshis = cls . satoshis_now ( order )
2022-07-18 12:53:49 +00:00
order . last_satoshis_time = timezone . now ( )
2022-01-18 15:23:57 +00:00
order . save ( )
2022-03-11 15:55:55 +00:00
# send_message.delay(order.id,'order_published') # too spammy
2022-01-18 15:23:57 +00:00
return
2022-01-17 23:11:41 +00:00
2022-07-21 13:19:47 +00:00
def compute_cltv_expiry_blocks ( order , invoice_concept ) :
2022-10-20 09:56:10 +00:00
""" Computes timelock CLTV expiry of the last hop in blocks for hodl invoices
2022-07-21 13:19:47 +00:00
invoice_concepts ( str ) : maker_bond , taker_bond , trade_escrow
2022-10-20 09:56:10 +00:00
"""
2022-07-21 13:19:47 +00:00
# Every invoice_concept must be locked by at least the fiat exchange duration
2022-07-22 15:05:47 +00:00
# Every invoice must also be locked for deposit_time (order.escrow_duration or WFE status)
2022-07-21 13:19:47 +00:00
cltv_expiry_secs = order . t_to_expire ( Order . Status . CHA )
2022-07-22 15:05:47 +00:00
cltv_expiry_secs + = order . t_to_expire ( Order . Status . WFE )
2022-07-21 13:19:47 +00:00
# Maker bond must also be locked for the full public duration plus the taker bond locking time
if invoice_concept == " maker_bond " :
cltv_expiry_secs + = order . t_to_expire ( Order . Status . PUB )
cltv_expiry_secs + = order . t_to_expire ( Order . Status . TAK )
# Add a safety marging by multiplying by the maxium expected mining network speed up
safe_cltv_expiry_secs = cltv_expiry_secs * MAX_MINING_NETWORK_SPEEDUP_EXPECTED
# Convert to blocks using assummed average block time (~8 mins/block)
cltv_expiry_blocks = int ( safe_cltv_expiry_secs / ( BLOCK_TIME * 60 ) )
return cltv_expiry_blocks
2022-01-12 00:02:17 +00:00
@classmethod
def is_maker_bond_locked ( cls , order ) :
2022-01-18 13:20:19 +00:00
if order . maker_bond . status == LNPayment . Status . LOCKED :
return True
2022-01-25 14:46:02 +00:00
elif LNNode . validate_hold_invoice_locked ( order . maker_bond ) :
2022-01-17 23:11:41 +00:00
cls . publish_order ( order )
2022-10-20 09:56:10 +00:00
send_message . delay ( order . id , " order_published " )
2022-01-12 00:02:17 +00:00
return True
return False
2022-01-06 16:54:37 +00:00
@classmethod
2022-01-09 20:05:19 +00:00
def gen_maker_hold_invoice ( cls , order , user ) :
2022-01-06 16:54:37 +00:00
2022-01-12 00:02:17 +00:00
# Do not gen and cancel if order is older than expiry time
2022-01-06 16:54:37 +00:00
if order . expires_at < timezone . now ( ) :
cls . order_expires ( order )
2022-02-17 19:50:10 +00:00
return False , {
2022-10-20 09:56:10 +00:00
" bad_request " : " Invoice expired. You did not confirm publishing the order in time. Make a new order. "
2022-02-17 19:50:10 +00:00
}
2022-01-06 16:54:37 +00:00
2022-01-07 11:31:33 +00:00
# Return the previous invoice if there was one and is still unpaid
2022-01-06 16:54:37 +00:00
if order . maker_bond :
2022-01-12 00:02:17 +00:00
if cls . is_maker_bond_locked ( order ) :
2022-01-07 11:31:33 +00:00
return False , None
2022-01-12 00:02:17 +00:00
elif order . maker_bond . status == LNPayment . Status . INVGEN :
2022-02-17 19:50:10 +00:00
return True , {
" bond_invoice " : order . maker_bond . invoice ,
" bond_satoshis " : order . maker_bond . num_satoshis ,
}
2022-01-06 16:54:37 +00:00
2022-01-12 00:02:17 +00:00
# If there was no maker_bond object yet, generates one
2022-01-07 11:31:33 +00:00
order . last_satoshis = cls . satoshis_now ( order )
2022-07-18 12:53:49 +00:00
order . last_satoshis_time = timezone . now ( )
2022-10-20 09:56:10 +00:00
bond_satoshis = int ( order . last_satoshis * order . bond_size / 100 )
2022-01-11 14:36:43 +00:00
2022-08-12 17:41:06 +00:00
if user . profile . wants_stealth :
description = f " This payment WILL FREEZE IN YOUR WALLET, check on the website if it was successful. It will automatically return unless you cheat or cancel unilaterally. Payment reference: { order . reference } "
else :
description = f " RoboSats - Publishing ' { str ( order ) } ' - Maker bond - This payment WILL FREEZE IN YOUR WALLET, check on the website if it was successful. It will automatically return unless you cheat or cancel unilaterally. "
2022-01-06 20:33:40 +00:00
2022-01-09 20:05:19 +00:00
# Gen hold Invoice
2022-02-08 10:05:22 +00:00
try :
2022-02-17 19:50:10 +00:00
hold_payment = LNNode . gen_hold_invoice (
bond_satoshis ,
description ,
2022-03-18 21:21:13 +00:00
invoice_expiry = order . t_to_expire ( Order . Status . WFB ) ,
2022-10-20 09:56:10 +00:00
cltv_expiry_blocks = cls . compute_cltv_expiry_blocks ( order , " maker_bond " ) ,
2022-02-17 19:50:10 +00:00
)
2022-02-08 10:05:22 +00:00
except Exception as e :
2022-02-09 19:45:11 +00:00
print ( str ( e ) )
2022-02-17 19:50:10 +00:00
if " failed to connect to all addresses " in str ( e ) :
return False , {
2022-10-20 09:56:10 +00:00
" bad_request " : " The Lightning Network Daemon (LND) is down. Write in the Telegram group to make sure the staff is aware. "
2022-02-17 19:50:10 +00:00
}
2022-07-21 13:19:47 +00:00
elif " wallet locked " in str ( e ) :
2022-02-17 19:50:10 +00:00
return False , {
2022-10-20 09:56:10 +00:00
" bad_request " : " This is weird, RoboSats ' lightning wallet is locked. Check in the Telegram group, maybe the staff has died. "
2022-02-17 19:50:10 +00:00
}
2022-01-06 16:54:37 +00:00
order . maker_bond = LNPayment . objects . create (
2022-02-17 19:50:10 +00:00
concept = LNPayment . Concepts . MAKEBOND ,
type = LNPayment . Types . HOLD ,
sender = user ,
receiver = User . objects . get ( username = ESCROW_USERNAME ) ,
invoice = hold_payment [ " invoice " ] ,
preimage = hold_payment [ " preimage " ] ,
status = LNPayment . Status . INVGEN ,
num_satoshis = bond_satoshis ,
description = description ,
payment_hash = hold_payment [ " payment_hash " ] ,
created_at = hold_payment [ " created_at " ] ,
expires_at = hold_payment [ " expires_at " ] ,
cltv_expiry = hold_payment [ " cltv_expiry " ] ,
)
2022-01-06 16:54:37 +00:00
order . save ( )
2022-02-17 19:50:10 +00:00
return True , {
" bond_invoice " : hold_payment [ " invoice " ] ,
" bond_satoshis " : bond_satoshis ,
}
2022-01-06 16:54:37 +00:00
2022-01-11 20:49:53 +00:00
@classmethod
2022-01-17 23:11:41 +00:00
def finalize_contract ( cls , order ) :
2022-02-17 19:50:10 +00:00
""" When the taker locks the taker_bond
the contract is final """
# THE TRADE AMOUNT IS FINAL WITH THE CONFIRMATION OF THE TAKER BOND!
# (This is the last update to "last_satoshis", it becomes the escrow amount next)
order . last_satoshis = cls . satoshis_now ( order )
2022-07-18 12:53:49 +00:00
order . last_satoshis_time = timezone . now ( )
2022-02-17 19:50:10 +00:00
order . taker_bond . status = LNPayment . Status . LOCKED
order . taker_bond . save ( )
2022-10-20 09:56:10 +00:00
# With the bond confirmation the order is extended 'public_order_duration' hours
2022-03-05 12:21:01 +00:00
order . expires_at = timezone . now ( ) + timedelta (
2022-10-20 09:56:10 +00:00
seconds = order . t_to_expire ( Order . Status . WF2 )
)
2022-03-05 12:21:01 +00:00
order . status = Order . Status . WF2
order . save ( )
2022-02-17 19:50:10 +00:00
# Both users profiles are added one more contract // Unsafe can add more than once.
order . maker . profile . total_contracts + = 1
order . taker . profile . total_contracts + = 1
order . maker . profile . save ( )
order . taker . profile . save ( )
2022-10-20 09:56:10 +00:00
2022-03-05 12:19:56 +00:00
# Log a market tick
try :
MarketTick . log_a_tick ( order )
2022-10-20 20:53:51 +00:00
except Exception :
2022-03-05 12:19:56 +00:00
pass
2022-10-20 09:56:10 +00:00
send_message . delay ( order . id , " order_taken_confirmed " )
2022-02-17 19:50:10 +00:00
return True
2022-01-17 23:11:41 +00:00
@classmethod
def is_taker_bond_locked ( cls , order ) :
if order . taker_bond . status == LNPayment . Status . LOCKED :
return True
2022-01-25 14:46:02 +00:00
elif LNNode . validate_hold_invoice_locked ( order . taker_bond ) :
2022-01-17 23:11:41 +00:00
cls . finalize_contract ( order )
return True
2022-01-11 20:49:53 +00:00
return False
2022-01-06 16:54:37 +00:00
@classmethod
2022-01-09 20:05:19 +00:00
def gen_taker_hold_invoice ( cls , order , user ) :
2022-01-06 16:54:37 +00:00
2022-01-12 00:02:17 +00:00
# Do not gen and kick out the taker if order is older than expiry time
if order . expires_at < timezone . now ( ) :
2022-01-19 19:37:10 +00:00
cls . order_expires ( order )
2022-02-17 19:50:10 +00:00
return False , {
2022-10-20 09:56:10 +00:00
" bad_request " : " Invoice expired. You did not confirm taking the order in time. "
2022-02-17 19:50:10 +00:00
}
2022-01-12 00:02:17 +00:00
# Do not gen if a taker invoice exist. Do not return if it is already locked. Return the old one if still waiting.
2022-01-06 20:33:40 +00:00
if order . taker_bond :
2022-01-12 00:02:17 +00:00
if cls . is_taker_bond_locked ( order ) :
2022-01-07 11:31:33 +00:00
return False , None
2022-01-12 00:02:17 +00:00
elif order . taker_bond . status == LNPayment . Status . INVGEN :
2022-02-17 19:50:10 +00:00
return True , {
" bond_invoice " : order . taker_bond . invoice ,
" bond_satoshis " : order . taker_bond . num_satoshis ,
}
2022-01-06 16:54:37 +00:00
2022-01-12 00:02:17 +00:00
# If there was no taker_bond object yet, generates one
order . last_satoshis = cls . satoshis_now ( order )
2022-07-18 12:53:49 +00:00
order . last_satoshis_time = timezone . now ( )
2022-10-20 09:56:10 +00:00
bond_satoshis = int ( order . last_satoshis * order . bond_size / 100 )
2022-02-17 19:50:10 +00:00
pos_text = " Buying " if cls . is_buyer ( order , user ) else " Selling "
2022-08-12 17:41:06 +00:00
if user . profile . wants_stealth :
description = f " This payment WILL FREEZE IN YOUR WALLET, check on the website if it was successful. It will automatically return unless you cheat or cancel unilaterally. Payment reference: { order . reference } "
else :
description = (
f " RoboSats - Taking ' Order { order . id } ' { pos_text } BTC for { str ( float ( order . amount ) ) + Currency . currency_dict [ str ( order . currency . currency ) ] } "
2022-10-20 09:56:10 +00:00
+ " - Taker bond - This payment WILL FREEZE IN YOUR WALLET, check on the website if it was successful. It will automatically return unless you cheat or cancel unilaterally. "
2022-08-12 17:41:06 +00:00
)
2022-01-06 20:33:40 +00:00
2022-01-09 20:05:19 +00:00
# Gen hold Invoice
2022-02-08 10:05:22 +00:00
try :
2022-02-17 19:50:10 +00:00
hold_payment = LNNode . gen_hold_invoice (
bond_satoshis ,
description ,
2022-03-18 21:21:13 +00:00
invoice_expiry = order . t_to_expire ( Order . Status . TAK ) ,
2022-10-20 09:56:10 +00:00
cltv_expiry_blocks = cls . compute_cltv_expiry_blocks ( order , " taker_bond " ) ,
2022-02-17 19:50:10 +00:00
)
2022-02-08 10:05:22 +00:00
except Exception as e :
2022-02-17 19:50:10 +00:00
if " status = StatusCode.UNAVAILABLE " in str ( e ) :
return False , {
2022-10-20 09:56:10 +00:00
" bad_request " : " The Lightning Network Daemon (LND) is down. Write in the Telegram group to make sure the staff is aware. "
2022-02-17 19:50:10 +00:00
}
2022-01-06 20:33:40 +00:00
order . taker_bond = LNPayment . objects . create (
2022-02-17 19:50:10 +00:00
concept = LNPayment . Concepts . TAKEBOND ,
type = LNPayment . Types . HOLD ,
sender = user ,
receiver = User . objects . get ( username = ESCROW_USERNAME ) ,
invoice = hold_payment [ " invoice " ] ,
preimage = hold_payment [ " preimage " ] ,
status = LNPayment . Status . INVGEN ,
num_satoshis = bond_satoshis ,
description = description ,
payment_hash = hold_payment [ " payment_hash " ] ,
created_at = hold_payment [ " created_at " ] ,
expires_at = hold_payment [ " expires_at " ] ,
cltv_expiry = hold_payment [ " cltv_expiry " ] ,
)
order . expires_at = timezone . now ( ) + timedelta (
2022-10-20 09:56:10 +00:00
seconds = order . t_to_expire ( Order . Status . TAK )
)
2022-01-06 16:54:37 +00:00
order . save ( )
2022-02-17 19:50:10 +00:00
return True , {
" bond_invoice " : hold_payment [ " invoice " ] ,
" bond_satoshis " : bond_satoshis ,
}
2022-01-07 11:31:33 +00:00
2022-01-18 13:20:19 +00:00
def trade_escrow_received ( order ) :
2022-02-17 19:50:10 +00:00
""" Moves the order forward """
2022-01-18 13:20:19 +00:00
# If status is 'Waiting for both' move to Waiting for invoice
if order . status == Order . Status . WF2 :
order . status = Order . Status . WFI
# If status is 'Waiting for invoice' move to Chat
elif order . status == Order . Status . WFE :
order . status = Order . Status . CHA
2022-02-17 19:50:10 +00:00
order . expires_at = timezone . now ( ) + timedelta (
2022-10-20 09:56:10 +00:00
seconds = order . t_to_expire ( Order . Status . CHA )
)
send_message . delay ( order . id , " fiat_exchange_starts " )
2022-01-18 13:20:19 +00:00
order . save ( )
2022-01-12 00:02:17 +00:00
@classmethod
def is_trade_escrow_locked ( cls , order ) :
2022-01-18 13:20:19 +00:00
if order . trade_escrow . status == LNPayment . Status . LOCKED :
2022-08-18 18:13:20 +00:00
cls . trade_escrow_received ( order )
2022-01-18 13:20:19 +00:00
return True
2022-01-25 14:46:02 +00:00
elif LNNode . validate_hold_invoice_locked ( order . trade_escrow ) :
2022-01-18 13:20:19 +00:00
cls . trade_escrow_received ( order )
2022-01-12 00:02:17 +00:00
return True
return False
2022-01-07 11:31:33 +00:00
@classmethod
2022-01-09 20:05:19 +00:00
def gen_escrow_hold_invoice ( cls , order , user ) :
2022-01-12 00:02:17 +00:00
# Do not generate if escrow deposit time has expired
if order . expires_at < timezone . now ( ) :
2022-01-19 19:37:10 +00:00
cls . order_expires ( order )
2022-02-17 19:50:10 +00:00
return False , {
2022-10-20 09:56:10 +00:00
" bad_request " : " Invoice expired. You did not send the escrow in time. "
2022-02-17 19:50:10 +00:00
}
2022-01-12 00:02:17 +00:00
# Do not gen if an escrow invoice exist. Do not return if it is already locked. Return the old one if still waiting.
2022-01-07 11:31:33 +00:00
if order . trade_escrow :
# Check if status is INVGEN and still not expired
2022-01-12 00:02:17 +00:00
if cls . is_trade_escrow_locked ( order ) :
return False , None
elif order . trade_escrow . status == LNPayment . Status . INVGEN :
2022-02-17 19:50:10 +00:00
return True , {
" escrow_invoice " : order . trade_escrow . invoice ,
" escrow_satoshis " : order . trade_escrow . num_satoshis ,
}
2022-01-07 11:31:33 +00:00
2022-01-18 13:20:19 +00:00
# If there was no taker_bond object yet, generate one
2022-10-20 09:56:10 +00:00
escrow_satoshis = cls . escrow_amount ( order , user ) [ 1 ] [
" escrow_amount "
] # Amount was fixed when taker bond was locked, fee applied here
2022-08-12 17:41:06 +00:00
if user . profile . wants_stealth :
description = f " This payment WILL FREEZE IN YOUR WALLET, check on the website if it was successful. It will automatically return unless you cheat or cancel unilaterally. Payment reference: { order . reference } "
else :
description = f " RoboSats - Escrow amount for ' { str ( order ) } ' - It WILL FREEZE IN YOUR WALLET. It will be released to the buyer once you confirm you received the fiat. It will automatically return if buyer does not confirm the payment. "
2022-01-07 11:31:33 +00:00
2022-01-09 20:05:19 +00:00
# Gen hold Invoice
2022-02-08 10:05:22 +00:00
try :
2022-02-17 19:50:10 +00:00
hold_payment = LNNode . gen_hold_invoice (
escrow_satoshis ,
description ,
2022-03-18 21:21:13 +00:00
invoice_expiry = order . t_to_expire ( Order . Status . WF2 ) ,
2022-10-20 09:56:10 +00:00
cltv_expiry_blocks = cls . compute_cltv_expiry_blocks (
order , " trade_escrow "
) ,
2022-02-17 19:50:10 +00:00
)
2022-02-08 10:05:22 +00:00
except Exception as e :
2022-02-17 19:50:10 +00:00
if " status = StatusCode.UNAVAILABLE " in str ( e ) :
return False , {
2022-10-20 09:56:10 +00:00
" bad_request " : " The Lightning Network Daemon (LND) is down. Write in the Telegram group to make sure the staff is aware. "
2022-02-17 19:50:10 +00:00
}
2022-02-08 10:05:22 +00:00
2022-01-08 17:19:30 +00:00
order . trade_escrow = LNPayment . objects . create (
2022-02-17 19:50:10 +00:00
concept = LNPayment . Concepts . TRESCROW ,
type = LNPayment . Types . HOLD ,
sender = user ,
receiver = User . objects . get ( username = ESCROW_USERNAME ) ,
invoice = hold_payment [ " invoice " ] ,
preimage = hold_payment [ " preimage " ] ,
status = LNPayment . Status . INVGEN ,
num_satoshis = escrow_satoshis ,
description = description ,
payment_hash = hold_payment [ " payment_hash " ] ,
created_at = hold_payment [ " created_at " ] ,
expires_at = hold_payment [ " expires_at " ] ,
cltv_expiry = hold_payment [ " cltv_expiry " ] ,
)
2022-01-07 11:31:33 +00:00
order . save ( )
2022-02-17 19:50:10 +00:00
return True , {
" escrow_invoice " : hold_payment [ " invoice " ] ,
" escrow_satoshis " : escrow_satoshis ,
}
2022-01-07 18:22:52 +00:00
def settle_escrow ( order ) :
2022-02-17 19:50:10 +00:00
""" Settles the trade escrow hold invoice """
2022-01-12 00:02:17 +00:00
if LNNode . settle_hold_invoice ( order . trade_escrow . preimage ) :
2022-01-11 14:36:43 +00:00
order . trade_escrow . status = LNPayment . Status . SETLED
2022-01-12 00:02:17 +00:00
order . trade_escrow . save ( )
return True
2022-01-11 14:36:43 +00:00
2022-01-16 21:54:42 +00:00
def settle_bond ( bond ) :
2022-02-17 19:50:10 +00:00
""" Settles the bond hold invoice """
2022-01-16 21:54:42 +00:00
if LNNode . settle_hold_invoice ( bond . preimage ) :
bond . status = LNPayment . Status . SETLED
bond . save ( )
2022-01-11 20:49:53 +00:00
return True
2022-01-11 14:36:43 +00:00
2022-01-16 21:54:42 +00:00
def return_escrow ( order ) :
2022-02-17 19:50:10 +00:00
""" returns the trade escrow """
2022-01-16 21:54:42 +00:00
if LNNode . cancel_return_hold_invoice ( order . trade_escrow . payment_hash ) :
order . trade_escrow . status = LNPayment . Status . RETNED
2022-01-20 17:30:29 +00:00
order . trade_escrow . save ( )
2022-01-12 00:02:17 +00:00
return True
2022-01-16 21:54:42 +00:00
2022-01-17 23:11:41 +00:00
def cancel_escrow ( order ) :
2022-02-17 19:50:10 +00:00
""" returns the trade escrow """
2022-01-17 23:11:41 +00:00
# Same as return escrow, but used when the invoice was never LOCKED
if LNNode . cancel_return_hold_invoice ( order . trade_escrow . payment_hash ) :
order . trade_escrow . status = LNPayment . Status . CANCEL
2022-01-20 17:30:29 +00:00
order . trade_escrow . save ( )
2022-01-17 23:11:41 +00:00
return True
2022-01-12 12:57:03 +00:00
def return_bond ( bond ) :
2022-02-17 19:50:10 +00:00
""" returns a bond """
2022-10-20 20:53:51 +00:00
if bond is None :
2022-01-17 18:11:44 +00:00
return
try :
LNNode . cancel_return_hold_invoice ( bond . payment_hash )
2022-01-12 12:57:03 +00:00
bond . status = LNPayment . Status . RETNED
2022-01-20 17:30:29 +00:00
bond . save ( )
2022-01-12 12:57:03 +00:00
return True
2022-01-17 18:11:44 +00:00
except Exception as e :
2022-02-17 19:50:10 +00:00
if " invoice already settled " in str ( e ) :
2022-01-17 18:11:44 +00:00
bond . status = LNPayment . Status . SETLED
2022-01-20 17:30:29 +00:00
bond . save ( )
2022-01-17 18:11:44 +00:00
return True
2022-01-17 23:11:41 +00:00
else :
raise e
2022-01-17 18:11:44 +00:00
2022-06-20 17:56:08 +00:00
def cancel_onchain_payment ( order ) :
2022-10-20 09:56:10 +00:00
""" Cancel onchain_payment if existing """
2022-06-20 17:56:08 +00:00
if order . payout_tx :
order . payout_tx . status = OnchainPayment . Status . CANCE
order . payout_tx . save ( )
return True
else :
return False
2022-01-17 18:11:44 +00:00
def cancel_bond ( bond ) :
2022-02-17 19:50:10 +00:00
""" cancel a bond """
2022-01-17 23:11:41 +00:00
# Same as return bond, but used when the invoice was never LOCKED
2022-10-20 20:53:51 +00:00
if bond is None :
2022-01-17 18:11:44 +00:00
return True
try :
LNNode . cancel_return_hold_invoice ( bond . payment_hash )
bond . status = LNPayment . Status . CANCEL
2022-01-20 17:30:29 +00:00
bond . save ( )
2022-01-17 18:11:44 +00:00
return True
except Exception as e :
2022-02-17 19:50:10 +00:00
if " invoice already settled " in str ( e ) :
2022-01-17 18:11:44 +00:00
bond . status = LNPayment . Status . SETLED
2022-01-20 17:30:29 +00:00
bond . save ( )
2022-01-17 18:11:44 +00:00
return True
2022-01-17 23:11:41 +00:00
else :
raise e
2022-01-07 18:22:52 +00:00
2022-06-16 15:31:30 +00:00
@classmethod
def pay_buyer ( cls , order ) :
2022-10-20 09:56:10 +00:00
""" Pays buyer invoice or onchain address """
2022-06-16 20:01:10 +00:00
2022-06-16 15:31:30 +00:00
# Pay to buyer invoice
if not order . is_swap :
2022-10-20 20:53:51 +00:00
# Background process "follow_invoices" will try to pay this invoice until success
2022-06-16 15:31:30 +00:00
order . status = Order . Status . PAY
order . payout . status = LNPayment . Status . FLIGHT
order . payout . save ( )
order . save ( )
2022-10-20 09:56:10 +00:00
send_message . delay ( order . id , " trade_successful " )
2022-07-19 00:35:17 +00:00
order . contract_finalization_time = timezone . now ( )
order . save ( )
2022-06-16 15:31:30 +00:00
return True
# Pay onchain to address
else :
2022-06-17 11:36:27 +00:00
if not order . payout_tx . status == OnchainPayment . Status . VALID :
return False
2023-03-14 17:23:11 +00:00
else :
# Add onchain payment to queue
2022-06-16 15:31:30 +00:00
order . status = Order . Status . SUC
2023-03-14 17:23:11 +00:00
order . payout_tx . status = OnchainPayment . Status . QUEUE
order . payout_tx . save ( )
2022-06-16 15:31:30 +00:00
order . save ( )
2022-10-20 09:56:10 +00:00
send_message . delay ( order . id , " trade_successful " )
2022-07-19 00:35:17 +00:00
order . contract_finalization_time = timezone . now ( )
order . save ( )
2022-06-16 15:31:30 +00:00
return True
2022-01-07 18:22:52 +00:00
@classmethod
def confirm_fiat ( cls , order , user ) :
2022-02-17 19:50:10 +00:00
""" If Order is in the CHAT states:
2022-01-20 20:50:25 +00:00
If user is buyer : fiat_sent goes to true .
2022-02-17 19:50:10 +00:00
If User is seller and fiat_sent is true : settle the escrow and pay buyer invoice ! """
2022-10-20 09:56:10 +00:00
if order . status == Order . Status . CHA or order . status == Order . Status . FSE :
2022-01-07 18:22:52 +00:00
# If buyer, settle escrow and mark fiat sent
if cls . is_buyer ( order , user ) :
2022-01-19 19:37:10 +00:00
order . status = Order . Status . FSE
order . is_fiat_sent = True
2022-01-07 18:22:52 +00:00
2022-01-20 20:50:25 +00:00
# If seller and fiat was sent, SETTLE ESCROW AND PAY BUYER INVOICE
2022-01-07 18:22:52 +00:00
elif cls . is_seller ( order , user ) :
if not order . is_fiat_sent :
2022-02-17 19:50:10 +00:00
return False , {
2022-10-20 09:56:10 +00:00
" bad_request " : " You cannot confirm to have received the fiat before it is confirmed to be sent by the buyer. "
2022-02-17 19:50:10 +00:00
}
2022-01-19 19:37:10 +00:00
2022-02-17 19:50:10 +00:00
# Make sure the trade escrow is at least as big as the buyer invoice
2022-10-20 09:56:10 +00:00
num_satoshis = (
order . payout_tx . num_satoshis
if order . is_swap
else order . payout . num_satoshis
)
2022-06-16 15:31:30 +00:00
if order . trade_escrow . num_satoshis < = num_satoshis :
2022-02-17 19:50:10 +00:00
return False , {
2022-10-20 09:56:10 +00:00
" bad_request " : " Woah, something broke badly. Report in the public channels, or open a Github Issue. "
2022-02-17 19:50:10 +00:00
}
2022-10-20 09:56:10 +00:00
2022-06-16 15:31:30 +00:00
# !!! KEY LINE - SETTLES THE TRADE ESCROW !!!
2022-10-20 09:56:10 +00:00
if cls . settle_escrow ( order ) :
2022-01-19 19:37:10 +00:00
order . trade_escrow . status = LNPayment . Status . SETLED
2022-02-17 19:50:10 +00:00
2022-01-07 18:22:52 +00:00
# Double check the escrow is settled.
2022-06-16 15:31:30 +00:00
if LNNode . double_check_htlc_is_settled ( order . trade_escrow . payment_hash ) :
2022-10-20 09:56:10 +00:00
# RETURN THE BONDS
2022-01-29 19:51:26 +00:00
cls . return_bond ( order . taker_bond )
cls . return_bond ( order . maker_bond )
2022-10-20 20:53:51 +00:00
# !!! KEY LINE - PAYS THE BUYER INVOICE !!!
2022-06-16 15:31:30 +00:00
cls . pay_buyer ( order )
2022-03-05 18:43:15 +00:00
# Add referral rewards (safe)
try :
2022-03-07 21:46:52 +00:00
cls . add_rewards ( order )
2022-10-20 20:53:51 +00:00
except Exception :
2022-03-05 18:43:15 +00:00
pass
2022-02-04 01:37:24 +00:00
return True , None
2022-02-22 17:50:01 +00:00
2022-01-07 18:22:52 +00:00
else :
2022-02-17 19:50:10 +00:00
return False , {
2022-10-20 09:56:10 +00:00
" bad_request " : " You cannot confirm the fiat payment at this stage "
2022-02-17 19:50:10 +00:00
}
2022-01-07 18:22:52 +00:00
order . save ( )
2022-01-12 00:02:17 +00:00
return True , None
2022-10-20 09:56:10 +00:00
def pause_unpause_public_order ( order , user ) :
2022-04-29 18:54:20 +00:00
if not order . maker == user :
return False , {
2022-10-20 09:56:10 +00:00
" bad_request " : " You cannot pause or unpause an order you did not make "
2022-04-29 18:54:20 +00:00
}
else :
if order . status == Order . Status . PUB :
order . status = Order . Status . PAU
elif order . status == Order . Status . PAU :
order . status = Order . Status . PUB
else :
return False , {
2022-10-20 09:56:10 +00:00
" bad_request " : " You can only pause/unpause an order that is either public or paused "
2022-04-29 18:54:20 +00:00
}
order . save ( )
return True , None
2022-01-12 00:02:17 +00:00
@classmethod
def rate_counterparty ( cls , order , user , rating ) :
2022-10-20 09:56:10 +00:00
"""
2022-04-29 18:54:20 +00:00
Not in use
2022-10-20 09:56:10 +00:00
"""
2022-02-17 19:50:10 +00:00
rating_allowed_status = [
Order . Status . PAY ,
Order . Status . SUC ,
Order . Status . FAI ,
Order . Status . MLD ,
Order . Status . TLD ,
]
2022-01-12 00:02:17 +00:00
# If the trade is finished
2022-01-27 14:40:14 +00:00
if order . status in rating_allowed_status :
2022-01-12 00:02:17 +00:00
# if maker, rates taker
2022-10-20 20:53:51 +00:00
if order . maker == user and order . maker_rated is False :
2022-01-12 00:02:17 +00:00
cls . add_profile_rating ( order . taker . profile , rating )
2022-01-17 23:11:41 +00:00
order . maker_rated = True
order . save ( )
2022-01-12 00:02:17 +00:00
# if taker, rates maker
2022-10-20 20:53:51 +00:00
if order . taker == user and order . taker_rated is False :
2022-01-12 00:02:17 +00:00
cls . add_profile_rating ( order . maker . profile , rating )
2022-01-17 23:11:41 +00:00
order . taker_rated = True
order . save ( )
2022-01-12 00:02:17 +00:00
else :
2022-10-20 09:56:10 +00:00
return False , { " bad_request " : " You cannot rate your counterparty yet. " }
2022-01-12 00:02:17 +00:00
2022-02-04 18:07:09 +00:00
return True , None
@classmethod
def rate_platform ( cls , user , rating ) :
user . profile . platform_rating = rating
user . profile . save ( )
2022-02-13 16:43:49 +00:00
return True , None
2022-02-21 23:41:36 +00:00
2022-03-05 18:43:15 +00:00
@classmethod
def add_rewards ( cls , order ) :
2022-10-20 09:56:10 +00:00
"""
This function is called when a trade is finished .
2022-03-05 20:51:16 +00:00
If participants of the order were referred , the reward is given to the referees .
2022-10-20 09:56:10 +00:00
"""
2022-03-05 20:51:16 +00:00
2022-03-05 18:43:15 +00:00
if order . maker . profile . is_referred :
2022-03-05 20:51:16 +00:00
profile = order . maker . profile . referred_by
2022-10-20 09:56:10 +00:00
profile . pending_rewards + = int ( config ( " REWARD_TIP " ) )
2022-03-05 20:51:16 +00:00
profile . save ( )
2022-10-20 09:56:10 +00:00
2022-03-05 18:43:15 +00:00
if order . taker . profile . is_referred :
2022-03-05 20:51:16 +00:00
profile = order . taker . profile . referred_by
2022-10-20 09:56:10 +00:00
profile . pending_rewards + = int ( config ( " REWARD_TIP " ) )
2022-03-05 20:51:16 +00:00
profile . save ( )
2022-03-05 18:43:15 +00:00
return
2022-03-07 21:46:52 +00:00
@classmethod
def add_slashed_rewards ( cls , bond , profile ) :
2022-10-20 09:56:10 +00:00
"""
2022-03-07 21:46:52 +00:00
When a bond is slashed due to overtime , rewards the user that was waiting .
If participants of the order were referred , the reward is given to the referees .
2022-10-20 09:56:10 +00:00
"""
reward_fraction = float ( config ( " SLASHED_BOND_REWARD_SPLIT " ) )
reward = int ( bond . num_satoshis * reward_fraction )
2022-03-07 21:46:52 +00:00
profile . earned_rewards + = reward
profile . save ( )
return
2022-03-06 16:08:28 +00:00
@classmethod
def withdraw_rewards ( cls , user , invoice ) :
# only a user with positive withdraw balance can use this
if user . profile . earned_rewards < 1 :
return False , { " bad_invoice " : " You have not earned rewards " }
num_satoshis = user . profile . earned_rewards
2022-03-09 11:35:50 +00:00
2023-01-14 12:38:27 +00:00
routing_budget_sats = int (
2022-11-28 16:23:37 +00:00
max (
num_satoshis * float ( config ( " PROPORTIONAL_ROUTING_FEE_LIMIT " ) ) ,
float ( config ( " MIN_FLAT_ROUTING_FEE_LIMIT_REWARD " ) ) ,
)
) # 1000 ppm or 10 sats
2023-01-14 12:38:27 +00:00
routing_budget_ppm = ( routing_budget_sats / float ( num_satoshis ) ) * 1000000
2022-11-28 16:23:37 +00:00
reward_payout = LNNode . validate_ln_invoice (
2023-01-14 12:38:27 +00:00
invoice , num_satoshis , routing_budget_ppm
2022-11-28 16:23:37 +00:00
)
2022-03-06 16:08:28 +00:00
if not reward_payout [ " valid " ] :
return False , reward_payout [ " context " ]
2022-03-09 11:35:50 +00:00
try :
lnpayment = LNPayment . objects . create (
2022-10-20 09:56:10 +00:00
concept = LNPayment . Concepts . WITHREWA ,
type = LNPayment . Types . NORM ,
sender = User . objects . get ( username = ESCROW_USERNAME ) ,
status = LNPayment . Status . VALIDI ,
2022-03-09 11:35:50 +00:00
receiver = user ,
2022-10-20 09:56:10 +00:00
invoice = invoice ,
num_satoshis = num_satoshis ,
description = reward_payout [ " description " ] ,
payment_hash = reward_payout [ " payment_hash " ] ,
created_at = reward_payout [ " created_at " ] ,
expires_at = reward_payout [ " expires_at " ] ,
2022-03-09 11:35:50 +00:00
)
# Might fail if payment_hash already exists in DB
2022-10-20 20:53:51 +00:00
except Exception :
2022-03-09 11:35:50 +00:00
return False , { " bad_invoice " : " Give me a new invoice " }
2022-03-06 16:08:28 +00:00
2022-03-09 11:35:50 +00:00
user . profile . earned_rewards = 0
user . profile . save ( )
# Pays the invoice.
paid , failure_reason = LNNode . pay_invoice ( lnpayment )
2022-10-20 09:56:10 +00:00
if paid :
2022-03-06 16:08:28 +00:00
user . profile . earned_rewards = 0
user . profile . claimed_rewards + = num_satoshis
user . profile . save ( )
2022-03-09 11:35:50 +00:00
return True , None
2022-03-06 16:08:28 +00:00
2022-03-09 11:35:50 +00:00
# If fails, adds the rewards again.
2022-10-20 09:56:10 +00:00
else :
2022-03-09 11:35:50 +00:00
user . profile . earned_rewards = num_satoshis
user . profile . save ( )
context = { }
2022-10-20 09:56:10 +00:00
context [ " bad_invoice " ] = failure_reason
2022-03-09 11:35:50 +00:00
return False , context
2022-07-16 11:15:00 +00:00
@classmethod
def summarize_trade ( cls , order , user ) :
2022-10-20 09:56:10 +00:00
"""
2022-07-16 11:15:00 +00:00
Summarizes a finished order . Returns a dict with
amounts , fees , costs , etc , for buyer and seller .
2022-10-20 09:56:10 +00:00
"""
2022-10-20 20:53:51 +00:00
if order . status not in [ Order . Status . SUC , Order . Status . PAY , Order . Status . FAI ] :
2022-10-20 09:56:10 +00:00
return False , { " bad_summary " : " Order has not finished yet " }
2022-07-16 11:15:00 +00:00
context = { }
2022-10-20 09:56:10 +00:00
users = { " taker " : order . taker , " maker " : order . maker }
2022-07-16 11:15:00 +00:00
for order_user in users :
summary = { }
2022-10-20 09:56:10 +00:00
summary [ " trade_fee_percent " ] = (
FEE * MAKER_FEE_SPLIT
if order_user == " maker "
else FEE * ( 1 - MAKER_FEE_SPLIT )
)
summary [ " bond_size_sats " ] = (
order . maker_bond . num_satoshis
if order_user == " maker "
else order . taker_bond . num_satoshis
)
summary [ " bond_size_percent " ] = order . bond_size
summary [ " is_buyer " ] = cls . is_buyer ( order , users [ order_user ] )
2022-07-16 11:15:00 +00:00
2022-10-20 09:56:10 +00:00
if summary [ " is_buyer " ] :
summary [ " sent_fiat " ] = order . amount
2022-07-16 11:15:00 +00:00
if order . is_swap :
2022-10-20 09:56:10 +00:00
summary [ " received_sats " ] = order . payout_tx . sent_satoshis
2022-07-16 11:15:00 +00:00
else :
2022-10-20 09:56:10 +00:00
summary [ " received_sats " ] = order . payout . num_satoshis
summary [ " trade_fee_sats " ] = round (
2022-11-24 17:42:30 +00:00
order . last_satoshis
- summary [ " received_sats " ]
2022-12-01 18:17:25 +00:00
- ( order . payout . routing_budget_sats if not order . is_swap else 0 )
2022-10-20 09:56:10 +00:00
)
2022-07-16 11:15:00 +00:00
# Only add context for swap costs if the user is the swap recipient. Peer should not know whether it was a swap
if users [ order_user ] == user and order . is_swap :
2022-10-20 09:56:10 +00:00
summary [ " is_swap " ] = order . is_swap
summary [ " received_onchain_sats " ] = order . payout_tx . sent_satoshis
summary [ " mining_fee_sats " ] = order . payout_tx . mining_fee_sats
summary [ " swap_fee_sats " ] = round (
order . payout_tx . num_satoshis
- order . payout_tx . mining_fee_sats
- order . payout_tx . sent_satoshis
)
summary [ " swap_fee_percent " ] = order . payout_tx . swap_fee_rate
summary [ " trade_fee_sats " ] = round (
order . last_satoshis
- summary [ " received_sats " ]
- summary [ " mining_fee_sats " ]
- summary [ " swap_fee_sats " ]
)
2022-07-16 11:15:00 +00:00
else :
2022-10-20 09:56:10 +00:00
summary [ " sent_sats " ] = order . trade_escrow . num_satoshis
summary [ " received_fiat " ] = order . amount
summary [ " trade_fee_sats " ] = round (
summary [ " sent_sats " ] - order . last_satoshis
)
context [ f " { order_user } _summary " ] = summary
2022-07-16 11:15:00 +00:00
platform_summary = { }
2022-10-20 09:56:10 +00:00
platform_summary [ " contract_exchange_rate " ] = float ( order . amount ) / (
float ( order . last_satoshis ) / 100000000
)
2022-10-20 20:53:51 +00:00
if order . last_satoshis_time is not None :
2022-10-20 09:56:10 +00:00
platform_summary [ " contract_timestamp " ] = order . last_satoshis_time
2022-11-26 00:06:40 +00:00
if order . contract_finalization_time is None :
order . contract_finalization_time = timezone . now ( )
order . save ( )
2022-10-20 09:56:10 +00:00
platform_summary [ " contract_total_time " ] = (
order . contract_finalization_time - order . last_satoshis_time
)
2022-07-16 11:15:00 +00:00
if not order . is_swap :
2022-11-24 17:42:30 +00:00
platform_summary [ " routing_budget_sats " ] = order . payout . routing_budget_sats
2023-02-13 13:57:00 +00:00
# Start Deprecated after v0.3.1
platform_summary [ " routing_fee_sats " ] = order . payout . fee
# End Deprecated after v0.3.1
2022-10-20 09:56:10 +00:00
platform_summary [ " trade_revenue_sats " ] = int (
order . trade_escrow . num_satoshis
- order . payout . num_satoshis
2023-02-13 13:57:00 +00:00
# Start Deprecated after v0.3.1 (will be `- order.payout.routing_budget_sats`)
- (
order . payout . fee
if order . payout . routing_budget_sats == 0
else order . payout . routing_budget_sats
)
# End Deprecated after v0.3.1
2022-10-20 09:56:10 +00:00
)
2022-07-16 11:15:00 +00:00
else :
2022-10-20 09:56:10 +00:00
platform_summary [ " routing_fee_sats " ] = 0
platform_summary [ " trade_revenue_sats " ] = int (
order . trade_escrow . num_satoshis - order . payout_tx . num_satoshis
)
context [ " platform_summary " ] = platform_summary
2022-03-06 16:08:28 +00:00
2022-10-20 09:56:10 +00:00
return True , context