From b6e3e58a7be223268e09114156934d7ca2c0fc00 Mon Sep 17 00:00:00 2001
From: Andika Wasisto <andika@wasisto.com>
Date: Mon, 17 Aug 2020 05:03:36 +0700
Subject: [PATCH] Support Linux

---
 libqwqng-wrapper.so                           | Bin 0 -> 17560 bytes
 quanttp/__main__.py                           |   9 +-
 quanttp/data/qng_wrapper_linux.py             |  82 ++++++++++++++++++
 ...{qng_wrapper.py => qng_wrapper_windows.py} |   5 +-
 requirements.txt                              |   2 +-
 5 files changed, 89 insertions(+), 9 deletions(-)
 create mode 100644 libqwqng-wrapper.so
 create mode 100644 quanttp/data/qng_wrapper_linux.py
 rename quanttp/data/{qng_wrapper.py => qng_wrapper_windows.py} (97%)

diff --git a/libqwqng-wrapper.so b/libqwqng-wrapper.so
new file mode 100644
index 0000000000000000000000000000000000000000..d1c01cf2b8465364ef2edde0ed425c2aabdcfce6
GIT binary patch
literal 17560
zcmb<-^>JfjWMqH=W(GS3Fi!{~;sBu-By6D!1_lNP1`7sm1_uT?23fFL7K9WA>jpPO
z2u3pqK=>d#SV2rEA0`f?JE4ZcXqY%iA6QBOq?v(%0gZNHf{4RtWPNN53=A7|A@Uob
z{(;dip!z;QX_!6`7o_h5RNo1xJ{T<kQoz8#0HZk|#xsE22*N9%^5`_0vl-C!oq*~?
zr&XZl!)TBlAfe!=B`F{_x;-#HF8czY`q0A>#?Jv6&cMI`qd|6ngaV(Iq=3Q&#3lyA
zqB#g^AFg-^fchIogW?-xKFD5>8K5-d?ib3y#K3R>B*qMqWMBY?w+I6R1BefjKVE72
zsYGxypV7^C#|~s)e9y3^&=;f>BrnRq08Y0c_jkB!F*1lM@PNc585kI37#J9KEs{Rz
z<a+hZD!v7hyB|-g$uMH!yHOY+llipCNq}wfiJaIUJi>>(e}K%xg>@Ji7@%1QMF}Vz
zv5C7eFfb^gsDyA<;V>tS0lWGAIK-de5I>GXJOGEi8*r#M!lAwjmpBe{IB}>4#XT$y
zLqY~ZPRC&mDBWOFuY*)%Kumy;893~nghPB8*j_${1YwANSULHIk%2*gL4sihOaLOy
za09A-0aU#`RQx|!y(Gf|H1$bfd-)g&K#7`xfq@gM{xeiPy7{3{^A(`xn?uzrLCsNs
znqvqR_kxNiK*eF^|AU(I0BR1*oec5u>ACrN@x>*HMJ4g^4Dp^JzVRukMXBkT#U-gl
zA->Kz`FW`!iAg!B5IO8J@yQj5@oAZPi8+~7sSNI^C4uFIdFh^c#U+V($*BzSQF-OL
z4DnHZrh(yse(uhOu4N#LD=Oj(Qj3c7LE1_x<I4;f;-gY>0?Kk3;zRSwGxJj7gHnr2
zb5j|D67y0#^Gb}35N24y#ash&7~(-5NY0K=&d82WOU%px>j=%uOv^7qve(cMqzNkQ
z8ju23<(FTSo0x+z*w6r^2qFqo<5XFaS`6|<B9duf7l3741CnzXoO4nWix9?`g88mx
z3_+>IsU=9_U_QwIQGUTC7Mc0Q@kxorsV1IznI({L!4!9agcm4`6H8JnGD{e8GLs5H
zA*@%NuV)D26_=zWYionJW*}~Qa&mkzhzFKT2C>W-;!{%+OA;C4<CBVuLE%+Y!VsUD
zmjY4`HcYp?D6ya*wMefxpTXVPIo?>$fWh6z)5$sBNY4b$GSV|;aE^#@bn=Wh)H6n6
z>RCe6L`1|J>zOd<XXNLm>L=!<WM(JoyX2SW<>V)(6zjuWu4|}gg32i_O19E3EiTf}
z$xlwq0m(5ifa(JVW(H;kCU8vvswF@PorwWd#xpRmgE(MSj0~6%Bnc9|0?u2ICPjc+
zB{xW)1hhV4WME==1eG^nU|<l*%;aTYU}aEX0_ArGhEl0aPEhTm1y|3^a1^Q@Wd7y#
z*{lo<Yz$^l^_3UbbAxIvM<~BUa}o#07k*IvuyzToT_6C>k2|34516<Dv@$t>CVl}b
z-T^IFVCrG~8_<jm3Lj9N2y!C`KR^=a2MIv&3nXzts2GU)fFusJ5+uy<14$fO#DK*o
zK-~i>pLxL|5JCbf4vHy|97L3XK><k|8Z=-j4J2_;I{+-mz`$UDBo0djAUO*pagd)u
zVj%2*Bo4A0BnHABNaC=t1BnM9iNnfFkaz@=I2T9&iW88;p-o}1Oa_uT4_E|36d;N7
zL4?3$1(G<ZE(8lQFfcSAi9?eJOlp)K4S~@R7!3iuA@G@B?w3dN8xD_d)|>ha3?8iq
zN|^p%@Mu25aTu)czv&}=28K`nRUhj!F!0MWfYfJzWInxo`2YX^31B{`!2a~|BAgE@
zs6V|t2<L+;m`^V^!ug;A`_s#Xa6YJ@{`7JpoDV9XKfP>(^Famkr<a9rKBz$c^fD37
z2NlGhUIxPXpaS^QOGh{#RPcU!X$a?o3fxaG72$kPMfB;VAdLU%zv^B+kZ)ZW!2bR8
zU-c~-|0x>(E*k$T8viUB|0o(C-M+18@@vufOVRjq(fCu*_`PWSRv6!>^Z7mr1_p)~
z!T<mN_vn28;`IOj|I_sN<y%0J%m9vGaQf)A&C+9Fc+mq=)@{32mw^G4NIZH)o%9$O
zJbF!i^cWakzWax)nP1+4!K2sK5UhYz3q)D|C=vDOW=#WWZ#_`L`TqgGd;`d)!%*6z
z*On2au-Eh#NR8${kIoMs2jAIy9Q?uT!FbH$;=d9Rk8V~|kYwwD5{~~5()i_F7#Lvs
zLFusp>^z22?NE<q+fSe#pGW7@5+09k+iAKC3@;@A{r~?W<^TWx$5^N8GB7a49_E)v
z(f_ji|Ns9`_khfE4A~C~qEJvcypa9}3a8_qokw1L`1}7qC=h%)AH+Jw90n=%=sfyz
zB`6SJ0SFdsej}0M(aoZ&!N9=a(dnYXVR*o!w?u{Ih1|dY|GQmOSUkEzR5(&Rj77jo
zN?ARck4PMT@!;?O|2Xw`K6|m@@Bjaw_yt&0Ji1-L+95W;v@iS%&7U6F?C*T`;sSpC
zi7@?+p+3p)9794qI{*4~zJKxZ&;S2Eov%DP-+Oi*@#sAEBI7Se02Bs}v4_(Ti3b$_
zAossi|BDiyFU$Y_|IYx)Tc9ung(0N00i}ddJQ@O{Aut*OqaiRF0;3@?8UmvsFd71*
zAwa7TV3cOI2F*!=y2J_}{{Qa)&1HZ5{~t8Zr||Lr{}UjKKmGq7!pOj&@ag}55hex(
zh0p*0gC<ZDKL7up!^ps};Pe0g9gGYN4?h3@zXYW2%m4oe7#SE6zWo0Wnhz`Z^8Y`0
zfF3k%4l)lk|5_Eqz*r%`D9yvpF@ceR0W_ZtntPq_{{R0EAT@jfZhR76{M_Xn4Gi{D
zR$9g?;OSA&Sh5QP14G1z|NoK4K|$g%3=9kbAO8P;0MZY|ATvQs#;O1xu#N1q=gKoM
zNW<&}^$tOHOMLqOA2esiBG1Uc;KnD=!{o*%(Z=k;rx3!$C*i^;;Kaw_$PJkrKr_!5
zVIH4C8*>j6$St6*-jWah|AXe0S+0Y0Fff2Rk)UvU^YQ<G@UX21pF$BA#9WY^3?l=B
zz^DKJ!9(XBd<um~au$pX3?^9QK=y#*CgRio|KPbjH$H)0CRaX*9%e^Ag*KK1J_#qV
z<3aHX8ZTyKV95FO|37HR1mr4E7*1hiV8}oc1G#?%BLf4=hyVYLK#Dy01j6}1gDwmV
z|Nk>`2(U6RNV95#*eoD6NXaN34S~@R7!85Z5Eu=C(GVC7fzc2c4S~@RpneFz)&arR
z{lM1wfTmzUwrz(ppcHrw5=b1z2d!~J=7ZKWf%vesCM=-2TLuOOS&$$D149&)59%L+
zg+Lt!1_lPulqrZ`1L`a=Fff4D&Vu-`bxYD94z$k!VoHGs1_lP$Iwe@Y4AQG$VEFp)
ze?CYFZ2dK8N*Kh~0L=w6fL2a{cnk~<pt)oQ1_sa+FGyq_)P0~SUJxJDj{?z9WuV3C
zATF%?$pBi{3KD=i8@@7393;rVz|a9T7&PS!5}E<+D8bwb?wca5$AsDU??1%-98mTD
zp?sJ-K0x`$pa%Vf@<CJKAbSQ1!`88*+iw7kX9p-90HqV4bODrZfYKA7^a3co0ZJc$
z(ifog11S9gN;5zglfl-d!QA2Q>};i=5t>w*S5m5Asb{QbplfJQ3g#MVLIhw+anj5T
zj0~{#@5qXn8JHMg>*`U(nHgZ|4^^B6p6*b^Ss7sI6IGmz0T$1w;_M8t^nohQ!2nBV
zsN$UP^oT0X1zB{6EC^ov&ds0z3s)pLW(FPx0cbcQ2{SM=@G>Z173agcxSW}Rp8=NN
zQOyxR42&R2Ff#};6ku6|&CDRgU;rM?K~fBMzc2%={6LmrW)Ojw8>r%<4A{~yGlLid
zY<(lDdU1GpfGRG*fS&$9^2`j980)wp;;_;T#Dic^`O3oZ5j3q05rC4QHF-=7i0}lB
z2Z5wC!K+dE7+~c%c$|fSfx!zjHpU>yFcUmL1lgwmQXdK4<A7;?3e=ng<i(c^3=E+C
z0U&!Ppov#P)x+uykl7#%+Bd+6<X@0~K;rYj?!gTIqfm2T^$|!d2ww!N$Bai@?gy2p
zj0}PdI#|*Jw(tb4PX{M{v~(rN2ns9Ac$9;R!`7Wbi(dvSM$l?o%=GL47RStAZeVjT
z)0;n79CN*YG*}!ny%mDj-Gf336}N!JG4~VnfyM-}>?fECR*z~1h_{##`#zHWVD)?q
z==%>&gT+BQQSno-I3EN0zJd2(aa6S+9upJRB7*_6ei|(af|N5D;ZP4+|BOw20uJ@%
zU~xVM^nDDqP;vDA6V2fD)|mS(I>73|PD3FUK-Ht~w^)Ni{Y9`i9|QV6j7MN`6r;f$
zW@hZ+Cc})iNM*3Vp*{eI`gk1Tm0)xD7|{25w1CCIPD3H4;Sgs)-4T#nP=K+kLoYc$
zCxs#2-N)a_(I-B>xHKu=Gajrh9=4GHq%A%wxWvaIK0Y%)GcU7*A-SlexTG{KO)r@N
zvCSmDBsV@8w9%xPAwE7OKR!JtKPfRMKBXkTs5m~cw1OcyKer$!wInq~&%(ge61yVM
z{*%o3#G<0a%J|g0lA=n6w4%h^)cBOr+}uir_;@5<Jjf|1O5@|*f*gHa<6Zq+K)Yb#
z-Tgx2T|J<J9xg#3D~t2vGZOPsa#9&w!u5($)AZuw)3Iz}Nz2U3WB}X15bqM{=jiL{
z%n%<R;_D1E92#Q&Zf?P@A@L!OPCl;jkj*6y4&eP3&>a+@eJIdfFVLMEXd7ri8$w{4
zZlGG@jr2epG(cLR`&<~}!JBg+8%Hozfj6*#Y%kA+N<wXiZpCqMKy3EVvqbD;!PrZK
zz6A$r8hGyreCH2*R}5SPyo(0xOVB<Z@TM8qmKo6A6jXI!$AWj;plo8n+%W^%Ndt8N
z)H|4alCVS`vS*RJinb#N?;a_XjY|#=uzfVxwpn4_N(G8J$mS!215EMk83OGMLiH(w
zUU6k^Nn#R%UU5kggwBAm^72bk_0sc7^$Lpe3sQ?pDjD?PLP@2WIVrlCDGXo*8HvRi
z40<V*dBv5v5W1uYB2$)HRGgWghr)?3V$dr}%}E4lfU*j5N*MG&`HVrYAg4qxJ--CP
zC{9gg&?`x;C}Ge8=M=rv3~1KONGW1~^BD9%dzexyl2Z#x;!D8$&%mZZaxFwJjGa=M
zmzbNG%mA_kWEq1Vc%zeEQgJbZUUGhJZfaf$N~uRa2h{%s^&z3%Q+PiF)*nG@zQFhY
z!fe!I0PQ{kwNW4<u>J~+2F+PQWFRDZKhlwbf#KW#|M@WcVf`8y?E}#U-Yo@U!rDb3
zHVAt&Fff4n)G+<9em9JM0hIvt(?M-Tn0{D)I2hcXN4Ou>PlC~~emlr65C)k6qG33i
z0W{Z$a6ha+1*7et3Ss_+ItSj*2dz;D^~qu4uznYeo&ePkazCh#4s$<Ln4uip-bT0|
z)<1*Mpmr-rEzEwHewhCoq57Rbijc+?VB-t0aR`up(AWdI{%&wP8Zqtx+m8;TLFo%>
zG?)UJ17<*pHZ=XPej$v8xgV+=W-OeZh^8Obe}vO8jZhla?S#>@(DcLlnJ^l8jvizL
zOdpJ1jHVyHnHt(Stb|1@NHfwn6O_xa5=}p>-wLB)<5w{C=;5~>svm9*EW<)+(3%OD
zUJ#A0e=nMTSU(s>gVslY^uaJJ{$YI3zHCsQfY}f0FT-fq_!Ue&NG*&FqHi)VfO?(a
z{qP_@tX~b=cMl6^kQ@lZ?1#}$85kHq`~N_B10)X{w>tnm2LYxIBnQGUK8*ed9kYY!
zhxOB8=P1C=O916RWc@IAO@)RZOh2qYe?uRnnt=hd?g7GrkT82;^e;614AA~G18DOm
zC_h59!AY1t7|jgszkzmiLX^P92RfkoVeW*;GGLV7pndEhvtaIr^&e(H^@HSKdO<XL
z{P98Uhbjjt0b`hc^zt93ADM=w9k50yaR6#y1E_L>o_7Emdw{tIR(^qoF=1|pY6Vjc
i7GR2DH<~2OUWhCMcvufj30Ug4HJD-$N7I1DWdH#DXB>0@

literal 0
HcmV?d00001

diff --git a/quanttp/__main__.py b/quanttp/__main__.py
index cbaf2ae..2842c10 100644
--- a/quanttp/__main__.py
+++ b/quanttp/__main__.py
@@ -17,7 +17,7 @@
 # LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 # OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 # SOFTWARE.
-
+import os
 import threading
 
 from flask import Flask, request, Response
@@ -25,15 +25,14 @@ from flask_sockets import Sockets
 from gevent import pywsgi
 from geventwebsocket.handler import WebSocketHandler
 
-from quanttp.data.qng_wrapper import QngWrapper
-from quanttp.data.qng_wrapper_mock import QngWrapperMock
+from quanttp.data.qng_wrapper_linux import QngWrapperLinux
+from quanttp.data.qng_wrapper_windows import QngWrapperWindows
 
 
 app = Flask(__name__)
 sockets = Sockets(app)
 
-qng_wrapper = QngWrapper()
-# qng_wrapper = QngWrapperMock()
+qng_wrapper = QngWrapperWindows() if (os.name == 'nt') else QngWrapperLinux()
 
 
 @app.route('/api/randint32')
diff --git a/quanttp/data/qng_wrapper_linux.py b/quanttp/data/qng_wrapper_linux.py
new file mode 100644
index 0000000..4333974
--- /dev/null
+++ b/quanttp/data/qng_wrapper_linux.py
@@ -0,0 +1,82 @@
+# Copyright (c) 2020 Andika Wasisto
+#
+# Permission is hereby granted, free of charge, to any person obtaining a copy
+# of this software and associated documentation files (the "Software"), to deal
+# in the Software without restriction, including without limitation the rights
+# to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+# copies of the Software, and to permit persons to whom the Software is
+# furnished to do so, subject to the following conditions:
+#
+# The above copyright notice and this permission notice shall be included in all
+# copies or substantial portions of the Software.
+#
+# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+# IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+# FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+# AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+# LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+# SOFTWARE.
+
+from ctypes import cdll, c_void_p, c_int, c_double, POINTER, c_char
+
+
+class QngWrapperLinux:
+
+    def __init__(self):
+        self.libqwqng_wrapper = cdll.LoadLibrary('./libqwqng-wrapper.so')
+        self.libqwqng_wrapper.GetQwqngInstance.restype = c_void_p
+        self.libqwqng_wrapper.RandInt32.argtypes = [c_void_p]
+        self.libqwqng_wrapper.RandInt32.restype = c_int
+        self.libqwqng_wrapper.RandUniform.argtypes = [c_void_p]
+        self.libqwqng_wrapper.RandUniform.restype = c_double
+        self.libqwqng_wrapper.RandNormal.argtypes = [c_void_p]
+        self.libqwqng_wrapper.RandNormal.restype = c_double
+        self.libqwqng_wrapper.RandBytes.argtypes = [c_void_p, c_int]
+        self.libqwqng_wrapper.RandBytes.restype = POINTER(c_char)
+        self.libqwqng_wrapper.Clear.argtypes = [c_void_p]
+        self.libqwqng_wrapper.Reset.argtypes = [c_void_p]
+        self.qng = self.libqwqng_wrapper.GetQwqngInstance()
+
+    def randint32(self):
+        try:
+            return self.libqwqng_wrapper.RandInt32(self.qng)
+        except:
+            self.libqwqng_wrapper.Reset(self.qng)
+            return self.libqwqng_wrapper.RandInt32(self.qng)
+
+    def randuniform(self):
+        try:
+            return self.libqwqng_wrapper.RandUniform(self.qng)
+        except:
+            self.libqwqng_wrapper.Reset(self.qng)
+            return self.libqwqng_wrapper.RandUniform(self.qng)
+
+    def randnormal(self):
+        try:
+            return self.libqwqng_wrapper.RandNormal(self.qng)
+        except:
+            self.libqwqng_wrapper.Reset(self.qng)
+            return self.libqwqng_wrapper.RandNormal(self.qng)
+
+    def randbytes(self, length):
+        try:
+            return self._randbytes_arbitrary_length(length)
+        except:
+            self.libqwqng_wrapper.Reset(self.qng)
+            return self._randbytes_arbitrary_length(length)
+
+    def _randbytes_arbitrary_length(self, length):
+        if length <= 8192:
+            return self.libqwqng_wrapper.RandBytes(self.qng, length)[:length]
+        else:
+            data = bytearray()
+            for x in range(length // 8192):
+                data.extend(self.libqwqng_wrapper.RandBytes(self.qng, 8192)[:8192])
+            bytes_needed = length % 8192
+            if bytes_needed != 0:
+                data.extend(self.libqwqng_wrapper.RandBytes(self.qng, bytes_needed)[:bytes_needed])
+            return bytes(data)
+
+    def clear(self):
+        self.libqwqng_wrapper.Clear(self.qng)
diff --git a/quanttp/data/qng_wrapper.py b/quanttp/data/qng_wrapper_windows.py
similarity index 97%
rename from quanttp/data/qng_wrapper.py
rename to quanttp/data/qng_wrapper_windows.py
index 80710e5..8618567 100644
--- a/quanttp/data/qng_wrapper.py
+++ b/quanttp/data/qng_wrapper_windows.py
@@ -18,12 +18,11 @@
 # OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 # SOFTWARE.
 
-import win32com.client
 
-
-class QngWrapper:
+class QngWrapperWindows:
 
     def __init__(self):
+        import win32com.client
         self.qng = win32com.client.Dispatch("QWQNG.QNG")
 
     def randint32(self):
diff --git a/requirements.txt b/requirements.txt
index 850fa69..4f072ce 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -2,4 +2,4 @@ Flask==1.1.2
 Flask-Sockets==0.2.1
 gevent==20.5.0
 gevent-websocket==0.10.1
-pywin32==227
\ No newline at end of file
+pywin32==227; platform_system == 'Windows'