Skip to content

Commit 9fc7087

Browse files
authored
Merge pull request #1506 from RoboSats/revert-1429-store-status-notifications
Revert "Store status notifications"
2 parents 0749d31 + 7d7a3a3 commit 9fc7087

File tree

15 files changed

+139
-181
lines changed

15 files changed

+139
-181
lines changed

api/admin.py

+6
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@
1111
from api.logics import Logics
1212
from api.models import Currency, LNPayment, MarketTick, OnchainPayment, Order, Robot
1313
from api.utils import objects_to_hyperlinks
14+
from api.tasks import send_notification
1415

1516
admin.site.unregister(Group)
1617
admin.site.unregister(User)
@@ -163,6 +164,9 @@ def cancel_public_order(self, request, queryset):
163164
f"Order {order.id} successfully closed",
164165
messages.SUCCESS,
165166
)
167+
send_notification.delay(
168+
order_id=order.id, message="coordinator_cancelled"
169+
)
166170
else:
167171
self.message_user(
168172
request,
@@ -206,6 +210,7 @@ def maker_wins(self, request, queryset):
206210
f"Dispute of order {order.id} solved successfully on favor of the maker",
207211
messages.SUCCESS,
208212
)
213+
send_notification.delay(order_id=order.id, message="dispute_closed")
209214

210215
else:
211216
self.message_user(
@@ -244,6 +249,7 @@ def taker_wins(self, request, queryset):
244249
f"Dispute of order {order.id} solved successfully on favor of the taker",
245250
messages.SUCCESS,
246251
)
252+
send_notification.delay(order_id=order.id, message="dispute_closed")
247253

248254
else:
249255
self.message_user(

api/lightning/cln.py

+4-4
Original file line numberDiff line numberDiff line change
@@ -617,10 +617,10 @@ def handle_response():
617617
]
618618
)
619619

620+
order.update_status(Order.Status.FAI)
620621
order.expires_at = timezone.now() + timedelta(
621622
seconds=order.t_to_expire(Order.Status.FAI)
622623
)
623-
order.update_status(Order.Status.FAI)
624624
order.save(update_fields=["expires_at"])
625625

626626
print(
@@ -646,10 +646,10 @@ def handle_response():
646646
)
647647
lnpayment.preimage = response.payment_preimage.hex()
648648
lnpayment.save(update_fields=["status", "fee", "preimage"])
649+
order.update_status(Order.Status.SUC)
649650
order.expires_at = timezone.now() + timedelta(
650651
seconds=order.t_to_expire(Order.Status.SUC)
651652
)
652-
order.update_status(Order.Status.SUC)
653653
order.save(update_fields=["expires_at"])
654654

655655
order.log(
@@ -697,10 +697,10 @@ def handle_response():
697697
]
698698
)
699699

700+
order.update_status(Order.Status.FAI)
700701
order.expires_at = timezone.now() + timedelta(
701702
seconds=order.t_to_expire(Order.Status.FAI)
702703
)
703-
order.update_status(Order.Status.FAI)
704704
order.save(update_fields=["expires_at"])
705705

706706
print(
@@ -737,10 +737,10 @@ def handle_response():
737737
"in_flight",
738738
]
739739
)
740+
order.update_status(Order.Status.FAI)
740741
order.expires_at = timezone.now() + timedelta(
741742
seconds=order.t_to_expire(Order.Status.FAI)
742743
)
743-
order.update_status(Order.Status.FAI)
744744
order.save(update_fields=["expires_at"])
745745

746746
order.log(

api/lightning/lnd.py

+4-3
Original file line numberDiff line numberDiff line change
@@ -594,10 +594,11 @@ def handle_response(response, was_in_transit=False):
594594
]
595595
)
596596

597+
order.update_status(Order.Status.FAI)
598+
597599
order.expires_at = timezone.now() + timedelta(
598600
seconds=order.t_to_expire(Order.Status.FAI)
599601
)
600-
order.update_status(Order.Status.FAI)
601602
order.save(update_fields=["expires_at"])
602603

603604
str_failure_reason = cls.payment_failure_context[
@@ -624,10 +625,10 @@ def handle_response(response, was_in_transit=False):
624625
lnpayment.preimage = response.payment_preimage
625626
lnpayment.save(update_fields=["status", "fee", "preimage"])
626627

628+
order.update_status(Order.Status.SUC)
627629
order.expires_at = timezone.now() + timedelta(
628630
seconds=order.t_to_expire(Order.Status.SUC)
629631
)
630-
order.update_status(Order.Status.SUC)
631632
order.save(update_fields=["expires_at"])
632633

633634
order.log(
@@ -670,10 +671,10 @@ def handle_response(response, was_in_transit=False):
670671
update_fields=["status", "last_routing_time", "in_flight"]
671672
)
672673

674+
order.update_status(Order.Status.FAI)
673675
order.expires_at = timezone.now() + timedelta(
674676
seconds=order.t_to_expire(Order.Status.FAI)
675677
)
676-
order.update_status(Order.Status.FAI)
677678
order.save(update_fields=["expires_at"])
678679

679680
order.log(

0 commit comments

Comments
 (0)