Merge remote-tracking branch 'upstream/stable'

Author: thelostone-mc

app/app/urls.py

@@ -97,6 +97,7 @@
     # kudos
     re_path(r'^kudos/?$', kudos.views.about, name='kudos_main'),
     re_path(r'^kudos/about/?$', kudos.views.about, name='kudos_about'),
+    re_path(r'^kudos/sync/?$', kudos.views.sync, name='kudos_sync'),
     re_path(r'^kudos/marketplace/?$', kudos.views.marketplace, name='kudos_marketplace'),
     re_path(r'^kudos/mint/?$', kudos.views.mint, name='kudos_mint'),
     re_path(r'^kudos/send/?$', kudos.views.send_2, name='kudos_send'),

app/assets/onepager/js/receive.js

@@ -164,7 +164,7 @@ $(document).ready(function() {
             gasLimit = new web3.utils.BN(gasLimit);
             var send_amount = holderBalance.sub(gasLimit.mul(gas_price_wei)).sub(buffer);
 
-            if (document.override_send_amount) {
+            if (document.override_send_amount && (document.override_send_amount * 10 ** 18) < send_amount) {
               send_amount = document.override_send_amount * 10 ** 18; // TODO: decimals
             }
 

app/assets/v2/js/pages/profile.js

@@ -10,6 +10,34 @@ $(document).ready(function() {
       }
     });
   }
+  $('#kudos-section').on('click', '.fa-sync', function(e) {
+    e.preventDefault();
+    e.stopPropagation();
+    if ($(this).data('owned') == 'False') {
+      _alert('To re-issue this kudos, please contact the sender and have them re-send it.', 'error');
+      return;
+    }
+    let url = '/kudos/sync/?pk=' + $(this).data('id');
+    let $target = $(this).parents('.flip-card__extra-data').find('.block_explorer_link');
+
+    $.get(url, function(response) {
+      let block_ex_url = response['url'];
+      let txid = response['txid'];
+
+      $target.attr('href', block_ex_url);
+      let txid_trunc = txid.substring(0, 5) + '...' + txid.substring(txid.length - 10, txid.length);
+
+      $target.text(txid_trunc);
+      $target.css('color', 'grey');
+      setTimeout(function() {
+        $target.css('color', 'white');
+      }, 1000);
+      _alert('Sync re-submitted to chain.', 'info', 1000);
+    });
+    $(this).remove();
+
+  });
+
 
   $('#kudos-section').on('click keypress', '.flip-card', e => {
     if ($(e.target).is('a')) {

app/dashboard/models.py

@@ -3160,6 +3160,13 @@ def kudos_authored(self):
         from kudos.models import Token
         return Token.objects.filter(artist=self.handle, num_clones_allowed__gt=1, hidden=False)
 
+    @property
+    def get_failed_kudos(self):
+        from kudos.models import KudosTransfer
+        pks = list(self.get_my_kudos.values_list('pk', flat=True)) + list(self.get_sent_kudos.values_list('pk', flat=True))
+        qs = KudosTransfer.objects.filter(pk__in=pks)
+        return qs.filter(Q(txid='pending_celery') | Q(tx_status__in=['dropped', 'unknown']))
+
     @property
     def get_my_kudos(self):
         from kudos.models import KudosTransfer
@@ -3175,7 +3182,8 @@ def get_my_kudos(self):
         kudos_transfers = kudos_transfers.filter(
             kudos_token_cloned_from__contract__network__in=[settings.KUDOS_NETWORK, 'xdai']
         )
-        kudos_transfers = kudos_transfers.send_success() | kudos_transfers.send_pending() | kudos_transfers.not_submitted()
+        # Multiple support requests for kudos not showing on profile were caused by this
+        # kudos_transfers = kudos_transfers.send_success() | kudos_transfers.send_pending() | kudos_transfers.not_submitted()
 
         # remove this line IFF we ever move to showing multiple kudos transfers on a profile
         kudos_transfers = kudos_transfers.distinct('id')
@@ -3191,7 +3199,8 @@ def get_sent_kudos(self):
         kt_sender_profile = KudosTransfer.objects.filter(sender_profile=self)
 
         kudos_transfers = kt_address | kt_sender_profile
-        kudos_transfers = kudos_transfers.send_success() | kudos_transfers.send_pending() | kudos_transfers.not_submitted()
+        # Multiple support requests for kudos not showing on profile were caused by this
+        # kudos_transfers = kudos_transfers.send_success() | kudos_transfers.send_pending() | kudos_transfers.not_submitted()
         kudos_transfers = kudos_transfers.filter(
             kudos_token_cloned_from__contract__network__in=[settings.KUDOS_NETWORK, 'xdai']
         )

app/dashboard/views.py

@@ -2883,6 +2883,8 @@ def get_profile_tab(request, profile, tab, prev_context):
         kudos_limit = 8
         context['kudos'] = owned_kudos[0:kudos_limit]
         context['sent_kudos'] = sent_kudos[0:kudos_limit]
+        if request.GET.get('failed', 0):
+            context['kudos'] = profile.get_failed_kudos
         context['kudos_count'] = owned_kudos.count()
         context['sent_kudos_count'] = sent_kudos.count()
     elif tab == 'ptokens':

app/kudos/helpers.py

@@ -99,3 +99,73 @@ def reconcile_kudos_preferred_wallet(profile):
         profile.save()
 
     return profile.preferred_kudos_wallet
+
+
+def re_send_kudos_transfer(kt, override_with_xdai_okay):
+    from dashboard.utils import get_web3, has_tx_mined
+    from gas.utils import recommend_min_gas_price_to_confirm_in_time
+    from kudos.utils import kudos_abi
+    from web3 import Web3
+    from kudos.models import KudosTransfer
+    from django.utils import timezone
+
+    gas_clear_within_mins = 1
+    gas_multiplier = 1.2
+
+    if not kt.kudos_token_cloned_from.is_owned_by_gitcoin:
+        print(f'{kt.id} => not owned by gitcoin')
+        return
+
+    network = kt.network
+    if network == 'mainnet':
+        if kt.kudos_token_cloned_from.on_xdai and override_with_xdai_okay:
+            network = 'xdai'
+            kt.network = 'xdai'
+            kt.kudos_token_cloned_from = kt.kudos_token_cloned_from.on_xdai
+            kt.save()
+    w3 = get_web3(network)
+    kudos_contract_address = Web3.toChecksumAddress(settings.KUDOS_CONTRACT_MAINNET)
+    if network == 'xdai':
+        kudos_contract_address = Web3.toChecksumAddress(settings.KUDOS_CONTRACT_XDAI)
+    kudos_owner_address = Web3.toChecksumAddress(settings.KUDOS_OWNER_ACCOUNT)
+    nonce = w3.eth.getTransactionCount(kudos_owner_address)
+
+    token_id = kt.kudos_token_cloned_from.token_id
+    address = kt.receive_address
+    if not address:
+        address = kt.recipient_profile.preferred_payout_address
+    if not address:
+        address = kt.recipient_profile.last_observed_payout_address
+    price_finney = kt.kudos_token_cloned_from.price_finney
+
+    try:
+
+        contract = w3.eth.contract(Web3.toChecksumAddress(kudos_contract_address), abi=kudos_abi())
+        gasPrice = int(gas_multiplier * float(recommend_min_gas_price_to_confirm_in_time(gas_clear_within_mins)) * 10**9)
+        if network == 'xdai':
+            gasPrice = 1 * 10**9
+        tx = contract.functions.clone(Web3.toChecksumAddress(address), token_id, 1).buildTransaction({
+            'nonce': nonce,
+            'gas': 500000,
+            'gasPrice': gasPrice,
+            'value': int(price_finney / 1000.0 * 10**18),
+        })
+
+        signed = w3.eth.account.signTransaction(tx, settings.KUDOS_PRIVATE_KEY)
+        txid = w3.eth.sendRawTransaction(signed.rawTransaction).hex()
+        nonce += 1
+        print(f'sent tx nonce:{nonce} for kt:{kt.id} on {network}')
+        kt.txid = txid
+        kt.receive_txid = txid
+        kt.tx_status = 'pending'
+        kt.receive_tx_status = 'pending'
+        kt.network = network
+        kt.tx_time = timezone.now()
+        kt.receive_tx_time = timezone.now()
+        kt.save()
+        return txid
+
+    except Exception as e:
+        print(e)
+        error = "Could not redeem your kudos.  Please try again soon."
+    return None

app/kudos/management/commands/process_pending_kudos_distributions.py

@@ -46,7 +46,7 @@ def handle(self, *args, **options):
         _async = options['async']
         override_gas_price = options['override_gas_price']
         order_by = options['order_by'].replace('_', '-')
-        delay_if_gas_prices_gt_redeem = 300
+        delay_if_gas_prices_gt_redeem = 200
         send_notif_email = True
         send_on_xdai = True
         gitcoin_owner_addr = '0x6239FF1040E412491557a7a02b2CBcC5aE85dc8F'

app/kudos/tasks.py

@@ -67,8 +67,10 @@ def redeem_bulk_kudos(self, kt_id, delay_if_gas_prices_gt_redeem= 50, override_g
         with redis.lock("tasks:all_kudos_requests", timeout=LOCK_TIMEOUT):
             with redis.lock("tasks:redeem_bulk_kudos:%s" % kt_id, timeout=override_lock_timeout):
                 multiplier = 1
-                # high gas prices, 5 hour gas limit - DL
-                gas_price = int(float(recommend_min_gas_price_to_confirm_in_time(300)) * multiplier)
+                gas_price = int(float(recommend_min_gas_price_to_confirm_in_time(1)) * multiplier * 10**9)
+                if network == 'xdai':
+                    gas_price = 1 * 10**9
+
                 if override_gas_price:
                     gas_price = override_gas_price
                 if gas_price > delay_if_gas_prices_gt_redeem:

app/kudos/templates/shared/kudos_card_hover_content.html

@@ -47,9 +47,15 @@
       <a href="{{kt.github_url}}" target="_blank">{% trans 'Issue url' %}</a>
     {% endif %}
     {% if kt.receive_txid == 'pending_celery' %}
-      Pending Issuance on Chain
+      Pending Issuance on Chain 
     {% else %}
-      <a title="{% trans 'tx on block explroer' %}" href="{{kt.receive_tx_blockexplorer_link}}" target="_blank" class="mb-1">{{ kt.receive_txid|humanize_address }}</a>
+      <a title="{% trans 'tx on block explorer' %}" href="{{kt.receive_tx_blockexplorer_link}}" target="_blank" class="mb-1 block_explorer_link">{{ kt.receive_txid|humanize_address }}</a>
     {% endif %}
+    {% if kt.receive_txid == 'pending_celery' or kt.receive_tx_status == 'dropped'  or kt.receive_tx_status == 'unknown' %}
+      {% if github_handle == kt.username or github_handle == kt.from_username or 1 %}
+        <div><i class="fas fa-sync" data-id="{{kt.id}}" data-owned='{{kt.kudos_token_cloned_from.is_owned_by_gitcoin}}'></i></div> 
+      {% endif %}
+    {% endif %}
+
   </div>
 {% endfor %}

app/kudos/views.py

@@ -83,6 +83,29 @@ def get_profile(handle):
     return to_profile
 
 
+def sync(request):
+    response = {}
+    try:
+        kt_id = request.GET.get('pk')
+        kt = KudosTransfer.objects.get(pk=kt_id)
+        response['txid'] = kt.txid
+        if kt.kudos_token_cloned_from.is_owned_by_gitcoin:
+            if request.user.is_authenticated:
+                if request.user.profile.handle in [kt.username.replace('@',''), kt.from_username.replace('@','')] or settings.DEBUG:
+                    authd = not kt.tx_time or kt.tx_time < (timezone.now() - timezone.timedelta(minutes=30))
+                    authd = authd and (kt.receive_txid == 'pending_celery' or kt.receive_tx_status == 'dropped' or kt.receive_tx_status == 'unknown')
+                    if authd:
+                        from kudos.helpers import re_send_kudos_transfer
+                        response['txid'] = re_send_kudos_transfer(kt, True)
+        from dashboard.utils import tx_id_to_block_explorer_url
+        response['url'] = tx_id_to_block_explorer_url(kt.txid, kt.network)
+        response['success'] = 1
+    except Exception as e:
+        response['error'] = str(e)
+
+    return JsonResponse(response)
+
+
 def about(request):
     """Render the Kudos 'about' page."""
     activity_limit = 5