From 7ba2fcc921ed988c90c839aae3721a4d4abc5635 Mon Sep 17 00:00:00 2001
From: Reckless_Satoshi <reckless.satoshi@protonmail.com>
Date: Sun, 16 Jan 2022 04:31:25 -0800
Subject: [PATCH] Add celery background and scheduled tasks. Add user cleansing
 task

---
 .gitignore                                    |   3 +
 api/admin.py                                  |   2 +-
 api/logics.py                                 |   6 +
 api/models.py                                 |  16 +-
 api/nick_generator/dicts/en/nouns.py          |   2 +-
 api/tasks.py                                  |  57 +++++++
 api/views.py                                  |   2 +-
 chat/templates/chatroom.html                  |  82 ----------
 .../static/assets/misc/unknown_avatar.png     | Bin 5347 -> 0 bytes
 requirements.txt                              | 140 ++++++++++++++++++
 robosats/__init__.py                          |   7 +
 robosats/celery/__init__.py                   |  37 +++++
 robosats/celery/conf.py                       |   2 +
 robosats/settings.py                          |   3 +
 setup.md                                      |  12 +-
 15 files changed, 280 insertions(+), 91 deletions(-)
 create mode 100644 api/tasks.py
 delete mode 100644 chat/templates/chatroom.html
 delete mode 100644 frontend/static/assets/misc/unknown_avatar.png
 create mode 100644 requirements.txt
 create mode 100644 robosats/celery/__init__.py
 create mode 100644 robosats/celery/conf.py

diff --git a/.gitignore b/.gitignore
index 07c2094f..f3a0f6bc 100755
--- a/.gitignore
+++ b/.gitignore
@@ -639,6 +639,9 @@ FodyWeavers.xsd
 *migrations*
 frontend/static/frontend/main*
 
+# Celery
+django
+
 # robosats
 frontend/static/assets/avatars*
 api/lightning/lightning*
diff --git a/api/admin.py b/api/admin.py
index 9d8ab64f..6cba65a7 100644
--- a/api/admin.py
+++ b/api/admin.py
@@ -38,7 +38,7 @@ class LNPaymentAdmin(AdminChangeLinksMixin, admin.ModelAdmin):
 
 @admin.register(Profile)
 class UserProfileAdmin(AdminChangeLinksMixin, admin.ModelAdmin):
-    list_display = ('avatar_tag','id','user_link','total_ratings','avg_rating','num_disputes','lost_disputes')
+    list_display = ('avatar_tag','id','user_link','total_contracts','total_ratings','avg_rating','num_disputes','lost_disputes')
     list_display_links = ('avatar_tag','id')
     change_links =['user']
     readonly_fields = ['avatar_tag']
diff --git a/api/logics.py b/api/logics.py
index cee59d8a..1a4994e9 100644
--- a/api/logics.py
+++ b/api/logics.py
@@ -339,6 +339,12 @@ class Logics():
             order.taker_bond.status = LNPayment.Status.LOCKED
             order.taker_bond.save()
 
+            # Both users profile have one more contract done
+            order.maker.profile.total_contracts = order.maker.profile.total_contracts + 1
+            order.taker.profile.total_contracts = order.taker.profile.total_contracts + 1
+            order.maker.profile.save()
+            order.taker.profile.save()
+
             # Log a market tick
             MarketTick.log_a_tick(order) 
 
diff --git a/api/models.py b/api/models.py
index 9ad4be95..1505b303 100644
--- a/api/models.py
+++ b/api/models.py
@@ -159,12 +159,12 @@ class Order(models.Model):
         return (f'Order {self.id}: {self.Types(self.type).label} BTC for {float(self.amount)} {self.currency_dict[str(self.currency)]}')
 
 @receiver(pre_delete, sender=Order)
-def delete_HTLCs_at_order_deletion(sender, instance, **kwargs):
+def delete_lnpayment_at_order_deletion(sender, instance, **kwargs):
     to_delete = (instance.maker_bond, instance.buyer_invoice, instance.taker_bond, instance.trade_escrow)
 
-    for htlc in to_delete:
+    for lnpayment in to_delete:
         try:
-            htlc.delete()
+            lnpayment.delete()
         except:
             pass
 
@@ -172,6 +172,9 @@ class Profile(models.Model):
 
     user = models.OneToOneField(User,on_delete=models.CASCADE)
 
+    # Total trades
+    total_contracts = models.PositiveIntegerField(null=False, default=0) 
+
     # Ratings stored as a comma separated integer list
     total_ratings = models.PositiveIntegerField(null=False, default=0) 
     latest_ratings = models.CharField(max_length=999, null=True, default=None, validators=[validate_comma_separated_integer_list], blank=True) # Will only store latest ratings
@@ -198,8 +201,11 @@ class Profile(models.Model):
 
     @receiver(pre_delete, sender=User)
     def del_avatar_from_disk(sender, instance, **kwargs):
-        avatar_file=Path('frontend/' + instance.profile.avatar.url)
-        avatar_file.unlink() # FIX deleting user fails if avatar is not found
+        try:
+            avatar_file=Path('frontend/' + instance.profile.avatar.url)
+            avatar_file.unlink()
+        except:
+            pass
 
     def __str__(self):
         return self.user.username
diff --git a/api/nick_generator/dicts/en/nouns.py b/api/nick_generator/dicts/en/nouns.py
index e48a739d..ae3243e8 100755
--- a/api/nick_generator/dicts/en/nouns.py
+++ b/api/nick_generator/dicts/en/nouns.py
@@ -3633,7 +3633,7 @@ nouns = [
     "Fever",
     "Few",
     "Fiance",
-    "Fiancé",
+    "Fiance",
     "Fiasco",
     "Fiat",
     "Fiber",
diff --git a/api/tasks.py b/api/tasks.py
new file mode 100644
index 00000000..8876b84d
--- /dev/null
+++ b/api/tasks.py
@@ -0,0 +1,57 @@
+from celery import shared_task
+
+from .lightning.node import LNNode
+from django.contrib.auth.models import User
+from .models import LNPayment, Order
+from .logics import Logics
+from django.db.models import Q
+
+from datetime import timedelta
+from django.utils import timezone
+
+from decouple import config
+
+@shared_task(name="users_cleansing")
+def users_cleansing():
+    '''
+    Deletes users never used 12 hours after creation
+    '''
+    # Users who's last login has not been in the last 12 hours
+    active_time_range = (timezone.now() - timedelta(hours=12), timezone.now())
+    queryset = User.objects.filter(~Q(last_login__range=active_time_range))
+    
+    # And do not have an active trade or any pass finished trade.
+    deleted_users = []
+    for user in queryset:
+        if user.username == str(config('ESCROW_USERNAME')): # Do not delete admin user by mistake
+            continue
+        if not user.profile.total_contracts == 0:
+            continue
+        valid, _ = Logics.validate_already_maker_or_taker(user)
+        if valid:
+            deleted_users.append(str(user))
+            user.delete()
+
+    results = {
+        'num_deleted': len(deleted_users),
+        'deleted_users': deleted_users,
+    }
+
+    return results
+
+
+@shared_task
+def orders_expire():
+    pass
+
+@shared_task
+def follow_lnd_payment():
+    pass
+
+@shared_task
+def query_all_lnd_invoices():
+    pass
+
+@shared_task
+def cache_market():
+    pass
\ No newline at end of file
diff --git a/api/views.py b/api/views.py
index e779498f..d6a2ee0d 100644
--- a/api/views.py
+++ b/api/views.py
@@ -422,7 +422,7 @@ class InfoView(ListAPIView):
         context['num_public_sell_orders'] = len(Order.objects.filter(type=Order.Types.SELL, status=Order.Status.PUB))
         
         # Number of active users (logged in in last 30 minutes)
-        active_user_time_range = (timezone.now() - timedelta(minutes=30), timezone.now())
+        active_user_time_range = (timezone.now() - timedelta(minutes=120), timezone.now())
         context['num_active_robotsats'] = len(User.objects.filter(last_login__range=active_user_time_range))
 
         # Compute average premium and volume of today
diff --git a/chat/templates/chatroom.html b/chat/templates/chatroom.html
deleted file mode 100644
index f638de64..00000000
--- a/chat/templates/chatroom.html
+++ /dev/null
@@ -1,82 +0,0 @@
-<html lang="en">
-
-<head>
-    <!-- Required meta tags -->
-    <meta charset="utf-8">
-    <meta name="viewport" content="width=device-width, initial-scale=1, shrink-to-fit=no">
-
-    <!-- Bootstrap CSS -->
-    <link rel="stylesheet" href="https://stackpath.bootstrapcdn.com/bootstrap/4.5.2/css/bootstrap.min.css"
-        integrity="sha384-JcKb8q3iqJ61gNV9KGb8thSsNjpSL0n8PARn9HuZOnIxN0hoP+VmmDGMN5t9UJ0Z" crossorigin="anonymous">
-
-    <title>Hello, world!</title>
-</head>
-
-<body>
-
-    <div class="container">
-        <div class="row d-flex justify-content-center">
-            <div class="col-6">
-                <form>
-                    <div class="form-group">
-                        <label for="exampleFormControlTextarea1" class="h4 pt-5">Chatroom</label>
-                        <textarea class="form-control" id="chat-text" rows="10"></textarea><br>
-                    </div>
-                    <div class="form-group">
-                        <input class="form-control" id="input" type="text"></br>
-                    </div>
-                    <input class="btn btn-secondary btn-lg btn-block" id="submit" type="button" value="Send">
-                </form>
-            </div>
-        </div>
-    </div>
-
-    {{ request.user.username|json_script:"user_username" }}
-    {{ order_id|json_script:"order-id" }}
-    
-    <script>
-        const user_username = JSON.parse(document.getElementById('user_username').textContent);
-        document.querySelector('#submit').onclick = function (e) {
-            const messageInputDom = document.querySelector('#input');
-            const message = messageInputDom.value;
-            chatSocket.send(JSON.stringify({
-                'message': message,
-                'username': user_username,
-            }));
-            messageInputDom.value = '';
-        };
-
-
-
-
-        const orderId = JSON.parse(document.getElementById('order-id').textContent);
-
-        const chatSocket = new WebSocket(
-            'ws://' +
-            window.location.host +
-            '/ws/chat/' +
-            orderId +
-            '/'
-        );
-
-        chatSocket.onmessage = function (e) {
-            const data = JSON.parse(e.data);
-            console.log(data)
-            document.querySelector('#chat-text').value += (data.username + ': ' + data.message + '\n')
-        }
-    </script>
-
-    <!-- Optional JavaScript -->
-    <!-- jQuery first, then Popper.js, then Bootstrap JS -->
-    <script src="https://code.jquery.com/jquery-3.5.1.slim.min.js"
-        integrity="sha384-DfXdz2htPH0lsSSs5nCTpuj/zy4C+OGpamoFVy38MVBnE+IbbVYUew+OrCXaRkfj" crossorigin="anonymous">
-    </script>
-    <script src="https://cdn.jsdelivr.net/npm/popper.js@1.16.1/dist/umd/popper.min.js"
-        integrity="sha384-9/reFTGAW83EW2RDu2S0VKaIzap3H66lZH81PoYlFhbGU+6BZp6G7niu735Sk7lN" crossorigin="anonymous">
-    </script>
-    <script src="https://stackpath.bootstrapcdn.com/bootstrap/4.5.2/js/bootstrap.min.js"
-        integrity="sha384-B4gt1jrGC7Jh4AgTPSdUtOBvfO8shuf57BaghqFfPlYxofvL8/KUEfYiJOMMV+rV" crossorigin="anonymous">
-    </script>
-</body>
-
-</html>
\ No newline at end of file
diff --git a/frontend/static/assets/misc/unknown_avatar.png b/frontend/static/assets/misc/unknown_avatar.png
deleted file mode 100644
index 9e19b6a9857296d12ca124efe8c1f61aa0fa5431..0000000000000000000000000000000000000000
GIT binary patch
literal 0
HcmV?d00001

literal 5347
zcmaKwXE+;P*v9R>E5xc*wRe?JwDzVX#2&GC#A>bDE2zCGs%lG7yRDH>TBAj&m?2b2
z5o%Q1xBvJ1`+hjrxv%G3_qopbJ?G20(=E*O8R@v`NJvN+4GnZGNk~Yg{u?wD|0<tD
z_5P5Mus0d%JOD?2J#_SPfj}0AWFLL2(G_Q9l{3i7a3j}Yv0#}{^IN@@p^_n{g7nbg
zb-g7P>sJ0i13(>mQ28+RAu4`4jgo$ev|h}haIL)Y$FKN{n*70YwzYwCEaKemEqc4H
zu=9M`t2#!?Sb&9wf-L_2|1~iQuy=Guvaf9E45(4plyD+|vYV9QX<o;-y7Uo?%p&h2
z*v68G`OqBcV2<|fnCNt3Z^a69GQ|3NB%}x~YICgkCOcIw<M#n<*+OKh=LVSE&P40B
z8cd}DuJHw-ED6k>G$L&3#g2*w10Hv1<cU{X2D7NQT5y|f^Mmr6q1=g;O)!x1hGVve
z@?x>9L`O+dojh;`&ey!}-KcGgZjH_#EgfgSeElYwu9i~oh%Ycl`~V%;wpuX*_f7@V
zA~h(uadd;@j_|Jenrm8T_#Gnn{+q5K3x7fCU1H3i0s$*NcP>sidwE)4^b?`XMiu(c
zed;nGNGJivljLarW^j(ic4C;nSE>yJIn5ihTT6GC?DsfelH+o`G$(}3g5Of;esGO@
zkxoU`2Kg`&+!i86Vm;1SGI9Hr`JLttmW_vl$vlpV3#5ddIu+|_PE)#sad^L^;L+Rf
z#GqHr(u)eDl<!q4`CnO*+w+N4%jnk3?+o!%B&wtmyHJo4S8G=QwW4;{acE%jpKD7=
zd%g`irsM<Gp^SLLz409x0=Y0;y<Mltd;6onQnhjSodwds&7D`ikAnDtF3i)PL%UTc
z_@M$mgX2%kt_?=9`#lb0vAUMgM<y&?V8meKrEgfrMF&konwt}CBB*y@S{h^4nWvcB
ztaFEXNdoXCq*>n|;8{}Nt9`ZItq*@f>F{09KA8)D*Ga^1aIu5jfAq3yqAm90kGZI4
zr+z-XRGliNJ5`;KlEP@dERoNjy2qY=7{+cru;-iT!X!OsYyb8*j7{_WW$Oq7Lg~uV
z*Y2yxA&27S6R!-0h15~54*-!c`b3Ujk#`wxZZkPqN%<9dVkS5Jb5<li$Q8dze14?r
zVe^1t=O#H4f*xRDS3k3Dw>#FPTKc#ARy)?570mon;BN~Wl78|0=-iTE>i5d2dxuQ>
zzdJO~4nTDl-dU466(1enoL(!d@|}XvGqRmKOe;@VQybNPs@v&r&4Z&Je*cfVOGwRp
zr^DSv)(W4JR;Dhg9&WL%e&3c@hoEODBM`g7#)_`J$4M-+L+ML;XIS>$_bQYs9F_Z;
z4x#>w2@vo2st}#4$GZ*IEXM!T>YLuTq?EkT9@)VNvW^{r>A*NGTsA3Y9Lrxi-pE4!
zMR*Jujd-NoCTLP?n-sDJ1iC{TBd1;dBYp1<pt8~#Wydohd~c%iz)4I?jeeze%WO0Y
zfDa298u@m=1XIqq#(Hx*GdV=$gDXr4-;DW(D`-ipD|``p=|CWd1#E(9yE`!wKj(Ey
zRh4Itn#e%N@OkK8m;<NvSw)8b!<9ZuZPmY<^!CXh>W?}>yNk`9*Gr-pyBgK>wP~(q
zb(>#f&~o|vr{OZ};k&WbKtJVnj-g6>RP62^Pb1-`?z;46-U`LV$hu$Lu^+tx8sDgS
zwou0eS0J8t&Ka;rQ2dtuaGKRRa$WFI7ojgFmW7CMZ}|bQ@FvjAvtEyAVn%L<4SEwy
zQWg@{ue{M;jZ3#TEC9`|vZ_3>;wnq(ItVXh7}=ML_t1i`1KODV5&nOEIwRaat(wIX
z<Iyr)+oy=xpZxenVG;dL4vY}0;v}AhWBS2&B0SNmiRIBAEt&tji-hvUB$P7^KMnlu
z-bO4$`OjgwU^|Gy_I>DYU4&QO`8^q8E^2bg^iBi@st?c2L3Z;v{^wkn{VdzKSj3Yn
zTc(ykpBO!(kFmqtt?d);9T{QZ@4h{g8v0cAwQL1m7&gRMdO?5|DNXD5g#IDrnmQ~&
zrCi{hTqy~KS1%Em{mpz^MOOkEIJW|Vg`Jo-uipiUhkk;7yeu_Gb~80({zEQV-hMF#
zrC+u@4WEXRVt4aTe*<ocKUTAS-=8-S?b`BI!D>GI6V&Th?Q(mC@HQ=}evO@LjV%81
z4A5HXh~hp5@dN$jZ-qsu#F%eFi8J)_ncx0B0m&jt&3m6hMRzVq#=o@O#VCu}urQ>3
zVj4A5{!{v5VNXm|jh`Xk)~y$X@2J^3P|1+`xv5bXw2PIDpRH8-?j7sVfeN>v8XV~I
zq`Z9ICz=9%a&K;_wQ`e&ARmr?oN%V=+LPc)Eu%DV9i=h|Rgn6EgyiG^?c$tAm}=Yo
zfGqEJumSEVN_=NJ&dOg}e(Fs}%kI`c9p$yjDjXK4;{L8SsVFMLBl(0BLpf@6&!#}=
zYkxqi1I}r2nYlFoKqG^^Vj`ptc}8iM-lke$H~>7OFcK%YSb!IXp=Xza4;EUK_C(5j
z<7+r%x2<7FB}WX$xBPd?JANrkzM=(r^v+*_k`u-s_dbp|h$vTgPj=b?=gJ|;-|PF#
zB^hXssK{SjOM6y@p8F(|a-3Xb?b6rv0N&Hqgb&M24BXS$4NAWUc-GK;a@k!hYwjYX
zsH4kRV<|T|5Tz}3KWfgxnBBffN#ppSb(if$M#|M<r{3c`Gj<=s*-2MN1^g_=RGD+e
z-l|6i_A<wDgJDCCBEs5D_OxS^qzfcEKP-}jnODfv&)q@+yBj5Cv32o9`%lF8#vf~=
z$!HBfChjFr_r@!-9M6(x9d(Vjp#pb1%BZ!3XkoS($hGrpeu0LxW8H^rE5w^^?joaD
zw!<v<ij<&xVMwA%PTJ8**Y#ybQ=W08FwtM$rh@I{R@cT^s)I@Ewh2VjXxUZe{4oZ)
zj?;m_sL<eS&u@ZJ<H^8bsysMfTcgyA4gbND^5q!&Wyw#qVcE&TpebSTXpra<Yc@QR
zSM%y)94gsr8FWiuGfZFXox|F@!UgCyEx_Zh=vD9#CjobqSoS%5%8dorWE(Zrcb}1Y
zK}}!EGU~MFsTuk&FB=up&h1l3?i7<aZ^Pdk<QJs7XUJ3g(5<{OI`)ce#R3PmW)B*M
z4%(ot9HqM>;7#!`or1VJkkjm7t|!0oQ$S59+qSb1R<mhC2<f6O-i$$Rkq|E<3rKZ&
zES40v-j3V~Ux@nGSKMA%Txu<eDnhs5>Wj6Rd%hdW#H1O*P1h&jE7Ft^)a;r2SL8M>
zf;;EHDgHC7U`40k%?wv^%gIs|tF}yC$pk8}Vo@*x834BtbTb`)UGhFk=`dm`BUb|C
zwi8IxGuBIbQ8jvK^6g&hvNeZ2&Xte`Du_;ju>|~{!tro>+G)bMh4E?Ol5eas6W&uH
znUomPlbg(!AR1n%mb*#<*jk0!LaBN23-Ey5FUj2M9&qDe;xE5P0S6j)I5~fxJA2bz
zz4}Q7P5dLl(jBs1uIU}NeNCyl9G@2F7V|y$sT0O#dAO+Ty8VyV=U_q3c|mu`mPZ(P
zUdzuS3n?Fj7_pX2Hwa?kfcj5=`5qc*F}$n-F*N;CY|b?%;$Sl_T(a6Lcy*vwh^8$&
zU{>B@PFoVsU?`ebV7Tcf9sT?<$NMG^+oEI>hj0}>Ff^-ej{J%5lX4~C>JXnzs*q>0
z1TAOqs_RaWF_`~R;ew^@wQ$@$EExFlO24zco_j+!%!zhubQL)MVWKc3bi^k0QM40U
z_ujzlOse{%gvll#)u&l*6q`6_kn<-_`-TSIP5;`-<UyT*NW50&a`Y`G(+tS<Ji+Q<
z9b#OM(5b*Mx9Zho2zK7LG7A?MAZ+XCfmXW|<y6gfuo5!(K8=_s_v_(6WlXC=mjxfc
zm7WcMT=ozJk8<Fsx2Nvq`-H(;*{vFo>mo1qtDprpw&8lXKc;!(v;P=yq`fKU7`x}f
z;{s4V(sS3>5bhv97*2-&Zj`vZt2XT1%t3xI8HAG}Xk?=lVJoR83e@Wxwv(>O52vXQ
zNbGT|z5MEhL}zbYgG3aY*~TD+L2tV7VM*W(MJ~tVH{_i~k}Ackwdz18_hsn|H!ZU}
zQ^&G+j;m4YL@E4neNr?=qU}D7Au8Fe3zv_r+DQ6s8=Cfq_>7C+04n&LA^$+iIn=+=
z-^36qX$*L~k&fB{pgGD<9=Dm4v@Ra&;W>1FgS3`Q3TCb1r3c5TtppDQ+KrEHi2P`}
zP5@e21IB!!L8O{98q*`CHNcF5i7jc`A3*!*r<>#mhyvBE>z^hfYnGxIUuo!vO`2G?
z@ev=cw_Dx*2~e^SCS%^-lZWW`h4(iY*68gf#(y#SpBf)a*bDxI+$lViFZIJ&5ZktI
zU-MPwa(q62InI`fHvu0#!oLH<HVrg(W}B4((X`Tjh{^U(k*c?ezebn9V7N5@$a1(f
z(pk8?M|BB~s*ZE(FMUlH(vmnX4v1zHU6AP%Gjh{kn_%wkUTof%iOyDAMrR-IDZ9&a
z=JOFS&c?tJpJmeUu-=?b2E=@0x1WIcs{`;|eR=+^FIZOX@=#C&f~y)Wx7~OORX$_r
zP~s22E<{TVriSCWn&rJzG)!yQsyplttKS{^$Y(xcaAos?v-W`VqabkVVppaYAv9{Q
z;+sro8DEA+FBei(S(-pf^_H9D$VFt%w4^uDEyQshD!UW*Q=A9ysQn{lQR3aTv|Qe#
z&&w%izU$3gMjk=Y2VdXit@=&~AVyptJlWOj`&>RN>|)}M8|_OAv^Q~6NHlmrmq63>
z+=4GBe2&D1sHVKTv0>Gvgtye-4oPWN{Q2{Uv`Z%VvLY_{T_93zze7GPLS>NAR&UAI
z`-!kaAT3j81%E<dU=M_DdaGIK!!*3;`+agdl0%XeqP;X>+<(-)D-<@WF6W}W6B$s&
z*|w#h>lyN>{%cj%Ko^(NKy{E@(gB(17r)GJ2bgc%SQgbT7DVDM4@vhx@?gBxY|Xox
zFnSLAqua3!tEXu}k187MeM+={r&L4W;>NQ~v~T2F$h=cBLFQ9)8->@BuZ9NfD1$Y6
zd_X$hns2wm{NK-4rC%l*xe2pxg%M`M#|TEJjE|IfU$KT(IS!^GK-}Yu$S5d-k_Gt%
zgR+l$PhWz0UA%HYAu`iJR#8V*J395(a;oVT@rz$W2Owp$lA`C{__uz|p=E{{hc~$R
z86HnSM2O7oXKLjO-N`)-^_Fw&zb}+!UM?ibM#TNF_1^>8C+E$xm|w5{iCgS03WDF8
z>9kkmdjQzupQ7`SPj74zpVp=IL?mjjdLG+%P7|@@5)(V$tF9)fBaByiOM;H>R^$XW
zNplO=T?ud*S((n>9ExPD-Y&-0UT*v-yGR&clmfil;hvGqmbN&+hs2I7M>3rg?;_D+
z4#|@888|uGoK41Q9P`)Rr*pl9$v1ufNWKO$t)FZl3Y2VHD(bN_G1#dg?D%gf;@%Z_
z^~cZXZT+iLyLPG5xxam^f};#D_35*0l;v@+0iM<R$R`q)hZdl(>@&JWWQcPw7BX+K
z@d4sc0X=VRlWC8%$Yx+5=j{{rw|ex40TA{Lz)jgZ7dgM=+562?y<!GkOlpQTqege(
zNd&-oKC_=u-z;C7o_TA4()<>MAy$1tVU4^}baVxDZQ*|6Nj9_i_3J(_y%**pvd%)8
zQ2*u}S~^*N3w|ypd3h^rm8+HupP^H=qk#AM`uQE=h6a^o$%OT|o3!MS$*_)eyDBZL
z)l<DGv|^v6{j`_fZ_DlV!W?w9_rcilorohLdu^EGk0TRP*Xv(~4RYE&o~5DF1(u1s
zm!MF|{95VaOu04Y6tP)9ec*jfPJT21lUY9~{JapA_o#EijbeS#m(JAn_Bz``<OVn1
zx#ppbwwlb1he#I?J^dM1kdDaV1SXg*vHyU^O2y2G5yN{h81y~QqlUF1Qvef8c@id`
z{d&wsC`}$q>1g+7HkC)0C6OsSaB-W_2f65*(RUOKN>p{Ak~G@7^KDc?BF6b8I$e<G
z$dq+dEO2c3@dsb1lp7GO-fNx8@EttyRH+j>OikUt{(D;MeFqX({_@8g6oyMN*DCVq
z`m@4cHAjY^Y5Dfe9MJ*)<^=X>RzZdjuL@S;JGeMASTHCy*eX-fIHH@zbq&RIGb{?d
zzthNxNJ5>gCt`V76G$@MXUlT0KZO$qXPHjySceVT-1U{oU8#Psu_CvvPlFZN7e`@2
z3As{`8YdZUNqtowWI)yBP>5`dzE!Ls8*tM8+ZxW)U;3OjYiHeY@J3dCujMVd0@>jq
zubAa>%?yeZJe0rh;-|#KN1^x{j2*IWRdG=S`=1kVuw8{}E68-lgh=-f6vMJ|;eMD9
zVd{Rb7W?PxtI$B4OR>Mw{D|YHB7dm}*Ir|cgc*KF=m`ot{xDGK<MWU*8W*W4i!JMv
z!s%395}0jzdLV#D;j)*;B{)6Q(mCQqu28x8`(5Rdb3m_R7TANxb$LyND65pfu-$$J
zPw@#%){-xJAI;8{2cyN!jF*THXt|OhJqBP>_WRHm?NCCJR^eph$t5FRSjMqI%mA<c
zpH7^tbaXYR?=g-@93HF|59HfN!b<<0<cD>jx?HMXuMLIVIZJ<opZbqtD?PaJiU}D~
zsbocm%!=o?+@w0}Z1ZvMJBz?wU4r8a@2UEKP#m;5+vAkBHFe3fFG<V#J*CvrHZ6nY
z5attX&-*-EgfauR4`mg}1^bi8ilW5mT-eVuSzZ)!N2(<j4OlQ9JuNWIauavfxiJ;+
z@3#PWVOTQ{B%l@dT&Sgt$^8UV>v~P9iWLPsoRg3J?VcsJ#xkWD?xmqFo|b!<r0Gj{
z7ZM}sRTY;%(RY-L+*ZlKU9fB5xdZXxgsqzdTx?A^c3d5cKE!_LuE_C%=S$p|v2^vJ
zSDQ%L_YNJimD&z=$VBnZ&}y}+RKY+Q!q73N2`~DEmjY<E|2GEwKO#chaok(~`(F~i
Tc>aqpNk|NJ&2-wdToV2V*x4mB

diff --git a/requirements.txt b/requirements.txt
new file mode 100644
index 00000000..dbb03b5b
--- /dev/null
+++ b/requirements.txt
@@ -0,0 +1,140 @@
+aioredis==1.3.1
+aiorpcX==0.18.7
+amqp==5.0.9
+apturl==0.5.2
+asgiref==3.4.1
+async-timeout==4.0.2
+attrs==21.4.0
+autobahn==21.11.1
+Automat==20.2.0
+backports.zoneinfo==0.2.1
+bcrypt==3.1.7
+billiard==3.6.4.0
+blinker==1.4
+Brlapi==0.7.0
+celery==5.2.3
+certifi==2019.11.28
+cffi==1.15.0
+channels==3.0.4
+channels-redis==3.3.1
+chardet==3.0.4
+charge-lnd==0.2.4
+click==8.0.3
+click-didyoumean==0.3.0
+click-plugins==1.1.1
+click-repl==0.2.0
+colorama==0.4.4
+command-not-found==0.3
+constantly==15.1.0
+cryptography==36.0.1
+cupshelpers==1.0
+daphne==3.0.2
+dbus-python==1.2.16
+defer==1.0.6
+Deprecated==1.2.13
+distlib==0.3.4
+distro==1.4.0
+distro-info===0.23ubuntu1
+Django==3.2.11
+django-admin-relation-links==0.2.5
+django-celery-beat==2.2.1
+django-celery-results==2.2.0
+django-model-utils==4.2.0
+django-private-chat2==1.0.2
+django-redis==5.2.0
+django-timezone-field==4.2.3
+djangorestframework==3.13.1
+duplicity==0.8.12.0
+entrypoints==0.3
+fasteners==0.14.1
+filelock==3.4.2
+future==0.18.2
+googleapis-common-protos==1.53.0
+grpcio==1.39.0
+grpcio-tools==1.43.0
+hiredis==2.0.0
+httplib2==0.14.0
+hyperlink==21.0.0
+idna==2.8
+incremental==21.3.0
+keyring==18.0.1
+kombu==5.2.3
+language-selector==0.1
+launchpadlib==1.10.13
+lazr.restfulclient==0.14.2
+lazr.uri==1.0.3
+lockfile==0.12.2
+louis==3.12.0
+macaroonbakery==1.3.1
+Mako==1.1.0
+MarkupSafe==1.1.0
+monotonic==1.5
+msgpack==1.0.3
+natsort==8.0.2
+netifaces==0.10.4
+numpy==1.22.0
+oauthlib==3.1.0
+olefile==0.46
+packaging==21.3
+paramiko==2.6.0
+pbr==5.8.0
+pexpect==4.6.0
+Pillow==7.0.0
+platformdirs==2.4.1
+prompt-toolkit==3.0.24
+protobuf==3.17.3
+pyasn1==0.4.8
+pyasn1-modules==0.2.8
+pycairo==1.16.2
+pycparser==2.21
+pycups==1.9.73
+PyGObject==3.36.0
+PyJWT==1.7.1
+pymacaroons==0.13.0
+PyNaCl==1.3.0
+pyOpenSSL==21.0.0
+pyparsing==3.0.6
+pyRFC3339==1.1
+PySocks==1.7.1
+python-apt==2.0.0+ubuntu0.20.4.5
+python-crontab==2.6.0
+python-dateutil==2.7.3
+python-debian===0.1.36ubuntu1
+python-decouple==3.5
+pytz==2021.3
+pyxdg==0.26
+PyYAML==5.3.1
+redis==4.1.0
+reportlab==3.5.34
+requests==2.22.0
+requests-unixsocket==0.2.0
+ring==0.9.1
+robohash==1.1
+scipy==1.7.3
+SecretStorage==2.3.1
+service-identity==21.1.0
+simplejson==3.16.0
+six==1.16.0
+sqlparse==0.4.2
+stevedore==3.5.0
+systemd-python==234
+termcolor==1.1.0
+Twisted==21.7.0
+txaio==21.2.1
+typing-extensions==4.0.1
+ubuntu-advantage-tools==27.2
+ubuntu-drivers-common==0.0.0
+ufw==0.36
+unattended-upgrades==0.1
+urllib3==1.25.8
+usb-creator==0.3.7
+vine==5.0.0
+virtualenv==20.12.1
+virtualenv-clone==0.5.7
+virtualenvwrapper==4.8.4
+wadllib==1.3.3
+wcwidth==0.2.5
+wirerope==0.4.5
+wrapt==1.13.3
+xkit==0.0.0
+zope.interface==5.4.0
diff --git a/robosats/__init__.py b/robosats/__init__.py
index e69de29b..d128d39c 100644
--- a/robosats/__init__.py
+++ b/robosats/__init__.py
@@ -0,0 +1,7 @@
+from __future__ import absolute_import, unicode_literals
+
+# This will make sure the app is always imported when
+# Django starts so that shared_task will use this app.
+from .celery import app as celery_app
+
+__all__ = ('celery_app',)
\ No newline at end of file
diff --git a/robosats/celery/__init__.py b/robosats/celery/__init__.py
new file mode 100644
index 00000000..797aa2c9
--- /dev/null
+++ b/robosats/celery/__init__.py
@@ -0,0 +1,37 @@
+from __future__ import absolute_import, unicode_literals
+import os
+
+from celery import Celery
+from celery.schedules import crontab
+
+# You can use rabbitmq instead here.
+BASE_REDIS_URL = os.environ.get('REDIS_URL', 'redis://localhost:6379')
+
+# set the default Django settings module for the 'celery' program.
+os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'robosats.settings')
+
+app = Celery('robosats')
+
+# Using a string here means the worker doesn't have to serialize
+# the configuration object to child processes.
+# - namespace='CELERY' means all celery-related configuration keys
+#   should have a `CELERY_` prefix.
+app.config_from_object('django.conf:settings', namespace='CELERY')
+
+# Load task modules from all registered Django app configs.
+app.autodiscover_tasks()
+
+app.conf.broker_url = BASE_REDIS_URL
+
+# this allows schedule items in the Django admin.
+app.conf.beat_scheduler = 'django_celery_beat.schedulers:DatabaseScheduler'
+
+
+## Configure the periodic tasks
+app.conf.beat_schedule = {
+    'users-cleasing-every-hour': {
+        'task': 'users_cleansing',
+        'schedule': 60*60,
+    },
+}
+app.conf.timezone = 'UTC'
\ No newline at end of file
diff --git a/robosats/celery/conf.py b/robosats/celery/conf.py
new file mode 100644
index 00000000..6b1aa603
--- /dev/null
+++ b/robosats/celery/conf.py
@@ -0,0 +1,2 @@
+# This sets the django-celery-results backend
+CELERY_RESULT_BACKEND = 'django-db'
\ No newline at end of file
diff --git a/robosats/settings.py b/robosats/settings.py
index d41f249b..2bf7a7d3 100644
--- a/robosats/settings.py
+++ b/robosats/settings.py
@@ -40,10 +40,13 @@ INSTALLED_APPS = [
     'django.contrib.staticfiles',
     'rest_framework',
     'channels',
+    'django_celery_beat',
+    'django_celery_results',
     'api',
     'chat',
     'frontend.apps.FrontendConfig',
 ]
+from .celery.conf import *
 
 MIDDLEWARE = [
     'django.middleware.security.SecurityMiddleware',
diff --git a/setup.md b/setup.md
index 032a374f..ccc946aa 100644
--- a/setup.md
+++ b/setup.md
@@ -45,8 +45,18 @@ pip install channels
 pip install django-redis
 pip install channels-redis
 ```
+## Install Celery for Django tasks
+```
+pip install celery
+pip install django-celery-beat
+pip install django-celery-results
+```
 
-*Django 4.0 at the time of writting*
+Start up celery worker
+`celery -A robosats worker --beat -l info -S django`
+
+*Django 3.2.11 at the time of writting*
+*Celery 5.2.3*
 
 ### Launch the local development node