From 467791ee09985c33e2a34452df0ff272120c2d0e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=80=BF=E4=BC=A6=E4=BC=A6?= <gll19920817@gmail.com>
Date: Tue, 30 Nov 2021 22:46:09 +0800
Subject: [PATCH] 1

---
 config/settings.yml                          |   2 +-
 scripts/__pycache__/watcher.cpython-39.pyc   | Bin 1323 -> 1509 bytes
 scripts/__pycache__/webdriver.cpython-39.pyc | Bin 1013 -> 1013 bytes
 scripts/watcher.py                           |  10 ++++++++--
 4 files changed, 9 insertions(+), 3 deletions(-)

diff --git a/config/settings.yml b/config/settings.yml
index 1a903ff..fe8e75a 100644
--- a/config/settings.yml
+++ b/config/settings.yml
@@ -8,4 +8,4 @@ webdriver:
 mongo:
   uri : 'mongodb://localhost:27017/'
   dbname: 'tiktok'
-  enabled: 0
+  enabled: 'on' 
diff --git a/scripts/__pycache__/watcher.cpython-39.pyc b/scripts/__pycache__/watcher.cpython-39.pyc
index 76ee4293fd97bf158928c2f9b2cb52904cab5154..309aac4dff749c851cfbcd1a371e5000e283ef0e 100644
GIT binary patch
delta 665
zcmYLFJ#Q015Z&3mZ{OMASZNR_LXm}q1V%~=0s(>oMIbDqYy-x-PVAiT;=R2nMNkS;
z(I9kx;I5&8hK3(=O)4silyrz$+Y&pP*?Bv=GyC4R;8!CWMo~a;{oeUHy!;YfACD0T
zA|NJwwF9S1%s9iH#@5W{HkcZVotewsWp2gZ%;!E3$;zN2yzz_(TR0zya2Aw@h+N?z
z@}#?9Jo<5ZAD~tIgxgJq13mP|=-H>@5^kM8)b`XV-HLqP`asWU>1kgFWuqb$1+s^u
zEwlv#GVk6a*_%FrrR`&!clSuLxx!~;3T0T~={`wlpDb}?upqBVkL?b6Q2R=ba+OU^
zWUpDf&xeVKiz9mDJQ$@37L-ghcgMNTmCSg1aH!-^yiC*h=_$U`sp3wSzn@LCvhe>k
z%xiWab!}xjJ+7^3I!Ss=`B>tSJi%UX56uLrxF^>QR0FH45SkWD<;e!=pcrk01RUr<
zKq(Djr?{X)2#ZJT#h`_y5ts|>WpX3sQpRmekS$SxVQP2_IHGDx(~=>wDp+ekcey)4
zN?MAZU0kqhz8T8dajuKMtPk78UF+QgGwddMW;lA3f-)zlm!&5&$=m;>y0cbFUBwIB
op64=`#dqt;2De|CT$%RDHlbDgvAUfrn0kPQ{6ZR1k2W{|0rk9<wEzGB

delta 486
zcmXX@%`OB%5bmn!`Ps3v*@&M5>mVT}E*=0E5*IeYhUg2E?M^H+v-Hf0gWGZ^{Q@Ks
z2PYSIFW>>@?%*Xv_0pZH`o5~}>iW`OW3OS9L{Z3S?Os18orkE^ZWEDALdt}Vm_mjE
z!D1(MGA{TC^VH2e;Q`xX(v{vVlim=8Pt2DAu|V;mBZ9a4HGt53!g2$tu}8K+RtV$c
z(oVB<A3f<j0kF%(LzYhgv-^gf!K42~=!oUG^2Y<qCEI5)Z+Bv-YFc#%y69c0Z<jj8
zHS>ZC2fXZMs&b1|sf&siWuN?6zn90TYjjFP>PqG1@oAFFRB1g%xj$DYR5^N(HwY9>
zatu6}fDjRz=GaNVHy_USo~?Ajmj9Q<R@z9`JOP@X>CjGUbx1fzJy#-OXGl6n3a~Bw
zu2xB@WXw&%XE>*e=8mtxoO$ObE&IwWSz+@5B50e5YkHi5>A0J|wxV^@{P5{k6|81`
UIY`yI9j37V89*KCSjWcXFMCm5X8-^I

diff --git a/scripts/__pycache__/webdriver.cpython-39.pyc b/scripts/__pycache__/webdriver.cpython-39.pyc
index 9710a7ba64e6b5a48f98c07938677d0d02b4c691..94d2a3f41e4e9c723e6ca153a384427ce4f85e3b 100644
GIT binary patch
delta 19
Zcmey${*|38k(ZZ?0SL}XZsdB+3;;D41sDJT

delta 19
Zcmey${*|38k(ZZ?0SKOnZ{&K-3;;Er1ug&p

diff --git a/scripts/watcher.py b/scripts/watcher.py
index f2b4977..5623741 100644
--- a/scripts/watcher.py
+++ b/scripts/watcher.py
@@ -1,9 +1,14 @@
 import time
+import concurrent.futures
+import queue
+
 from watchdog.observers import Observer
 from watchdog.events import FileSystemEventHandler
 
 from messages.utils import unpackMsgBin
 
+q = queue.Queue()
+
 class Watcher:
     DIRECTORY_TO_WATCH = ""
 
@@ -18,7 +23,8 @@ class Watcher:
 
         try:
             while True:
-                time.sleep(5)
+                with concurrent.futures.ThreadPoolExecutor() as executor:
+                    executor.submit(unpackMsgBin, q.get())
         except:
             self.observer.stop()
 
@@ -33,5 +39,5 @@ class Handler(FileSystemEventHandler):
             return None
 
         elif event.event_type == 'created':
-            unpackMsgBin(event.src_path)
+            q.put(event.src_path)