From 93d87b51b429f72e99a4fc81da46a37cbb740923 Mon Sep 17 00:00:00 2001
From: Oxi <oxitheman>
Date: Sun, 9 Oct 2022 11:37:08 +0530
Subject: [PATCH] Added logging and cleaned code

---
 __pycache__/msg.cpython-310.pyc | Bin 0 -> 5406 bytes
 nglspam.py                      | 117 +++++++++++++++++++-------------
 2 files changed, 70 insertions(+), 47 deletions(-)
 create mode 100644 __pycache__/msg.cpython-310.pyc

diff --git a/__pycache__/msg.cpython-310.pyc b/__pycache__/msg.cpython-310.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..ce6e771505dbd5087babe891793763f9f6e33cee
GIT binary patch
literal 5406
zcmZ`-&yO5O6<!C45VN*pukBs0W4qRCXT2iXb%IYQ(EJiO5;8(TipZ^|ySlqPJyor)
zsvS=qP$Vu~A_M}73$ldFAqP$f5%@DW<{16}eCEXWUUm1(teus;+OB%_>ec)4y|2oi
zJ9l;iKmT5QJO9_t#>Ri>WA*11e0&%G-6noj8^y+-&wR8|ocUnm@Rh^Q!aWR1;Z)u!
zFBUe4scO9_J3FJVPPDR9#yj!+>2E)dn^KztFN_s)xrnbxvk<NFE{oS8#jB;5$b1TY
z(u<<gC#uV$7$)<^Iwj`X*K4}7xIIWz))*-&m?DLjK5h*Yk3&(Z87z@aygdvy)=ssl
zgtwxQUI}Ms${Hm)6E6-j&UaE*wa?=2Fa#aLGMoSlvUubBx~i1(qEm$^8(BF~+73ok
zx@&N}$qUok&}>*_@xpSlf)lgwI$S!j#X{sZ7!S|=@o!nYm`fw(N=)dV^IEyMmv=Ja
z4=-AsPeUsj4dZ<c*UfD=RYex}3SF>YYk8ssH0YVEw2|EcA=1h~<mMnUmp-pWC1*<5
z5^6e}454|wup)@GUKF;1DLfJoiWV}k(ZwAMQSjA?GB9HbU*@&7IQnis(<_+iqG*&b
z*d>ei*5;55c|a7BVab88rI|^4N(-fpR$Y$R!N6;)T6`Da5A9qa+pqRhjm7DajEyc;
zCZ5D|{kSu>gB>@A&sNDPykvc?AS_K4WQF-R`uVv;IHtOAe9nM8Xb?XrL%0#`Tv94;
z7Zy^DB8QVJjj*jUs)%QcPRW^gY$vc8j_L%m6^=qK;Xs9MTbw70=V@x;Yf4Nz#dj%B
zY^TXF)*@aP#_yRu(PZ6^1_2&87XAeFgXlU=<Wbz!c8(DwMV|}{VU#Z${RCN?BlQi6
zKwIOoEZ$lbd5J{aVS#{+5by~O#uYJ<MF50s@Fe8}e4$Xs0S<cp^pju3I}gb%eWrBC
zWUMYV7Y!kXOx`&f*Rz}Q8fc)3w|HG;y$47rQB!)t(Y6T(t6QceIDR3D(2*CVV8_6M
zXa9&d)^%5a7^=h?6{HZ%yQikH8|JxKOO5TygaxOx)UrU@EQAYPh2X_I>sowm10Y1m
zi47jMlTi~L_t&Mk{$O=2JCtWjJ9k;wqO;N8*xa?Y^BK<Zm%qn1D4GKzl}e%Z3CIe$
z5Z^isx3KEria?t9;!n^1``K^4`1q6OPe1)9VhjOb4^_KS9Zt|=@H+&E@7#~OBrv0M
zsV7LLz6i+ZEPi90!`V8de<@s}RGVT1{B0x*HpyFiqc9iGYBgaeQV3rRdpXsVl)Jr@
zmjDw9d`57VdYlhs313MAKx-WDYUjx9tE9&^%frYDJqJ)Tj6-ce_n|g{B%0U21@0F!
zcpW)|dLv0HZT3fqm)5?Kx+ss$ajX*|Za=j1gJc7_zp@mHEZd7$-XCx?2Q1Zu1y~>7
z?1yvIFS42whZLTw!npOmm>P`F3DLQlbP+FTq&%S+|LpC>vs%o6cdYrMh7v-hgu%4g
zSG93o0+zJ#9Ts+;ph`XIKLB6a3GD@dQ)M{XE<R1w0RK~?5wdOZVJWNbBCDn_R{>y`
z0_acAL|y|e0eA}-V~Ti*0A7$2VFPWaT-e6y0dS-#utYZvWiyDuE-;ti5K-YyEhZ?G
zdA&F~I*K<4LsC;93`c)6(=s&FU}^deO((b{AE8ZxVW1FCP}$5CP;=;67U&9aqZmwd
zR{*H5w5oH~$VU4G`GnX2hTm#|-RNzE3<TgSy_F7)P{;=C#c_{~cYvw^>84j8X&@-H
z7a9qwWs{^lw}as0s}2d$VEDXi;R2=|!Ydi~(l@ytpMAP?1dynuDS~_yFMEX*<Xce&
z>Kl*kRK+XH(GIQ!l9n>}@d0USECPe|USkzJbbw<myARn)rcrZ1&!7hMHm#ajEK#!w
zszN%lcj@9$0fBp#Hkm8<l$l5)^OtOcGUtSnL@VqJI7^@7sxf?{ZbE#N?aiOBiGfNo
zogp#WJ?^s_Oa76?i9WqGfqS+p#58Z!3EY7!?X=WHeU|Hu-PBuhxSXeq5Ch#>Rfay*
z0YMIyqNuVk0pFp_tStHn93dTo2O!Mi<$yeQ3vw;eNvSClvfH6fB|i`|;=;rxxy_cq
z)hup-3HF&sY!u<@RJ_GNK`2hV8}x<pbyf3~QGo23!&(mb4iD$H!5$FDTqjbL?(ocD
zN8&H3iLJu>K1+?wj5;)WW})z#_ypMw{P~bdXHXB@aR42WKi7HnEI6GHnBSn&LW8$)
zn<rc9^}}T9KZiWQIX#$HGG?bP^rCr5G_lm+0)r$Xf_O{_^$%Fz9I>I`5yPgIgVIDL
z5$2HL@E7oL6oi*RvwJ~Gm3V)gV;`<FFSHtlfA}2{>N8;HLwE(f1G*rM2%~zlOuYBa
zc!P8SnGMaM@q1k&QEUs7z<P&iGM3LeR**p9WbrtyrfIawR&#AGWky0WrsBo4V6X#F
z7%#02;WB2Xab1iG<&+pRty5xTalE{yjVLM*C&hO-{wm8|iu0&pW*Tmzg(N-f;Njwg
z7N>G>J>WPv-tXhp6`7Q@z&Hn(Tp1^KCq5PLt_+(nn}C^9zLD94!M*e2g%vTUD--uP
zq(jc6F!UfR@<b+3$cXyOMH;3XNW3qVn1e^9bVP<;8wFExjZFch2UC<&J%6LiH##G3
z25aNXyEq8|@#g62{Tia;$Yi>$4)?Eko90(YA3CAIJ%(I@Q#yyMQ3Q01GR#8AT<RTU
z?l|K?H~1hl0~$wDYd$GLkuZ`Z`QG}12%CnJqcbLvdxHqOBM~fAOMk&k*Uxl$WFu+6
z(~b+*IiC_J_-@fZ9dQ39S`zkOm_M<65d%;f@$UV1A0+yMFx!M2oCS$kFz64~Zm|T)
zi~XF~Ogujfvh^8Xora+VEx0&>Qh{OpnjP97fj0qh$16#f*PI&Io=?Y9&d3&FM39-X
zfkz>Z%HdiHWyw=~M+YI`*B0piE4l}RS-L7g*FY2cYYF($oS6=$5`O@FF6R?kM+9gb
zrpFidAa3~Lm*P>}UkapKF&p~9Pr0W_k*h{c;=QGi1MV(x0njB_m2`N=VCBS8-WK2c
z=qvL@5jXJ*Xo$Ag0Y!Ef7BB~FB>luya4=*ksBjU#PKM!rXJ=Z)2cwmQg}CbTg$x}f
z5ge4zL^B;Ez5=`Wz7?<1Ds(ldaRxVCV%G*Y^DP?ZwpS5jaDLIK_$m!TN8F}A`W`(#
zNO^0+9+GNht|g{L{Tty-H=pNEfA@!YjYQ@eo~71L(8FFpvx}E7bpZL*RJ!yF>e>S!
zmfWg#Ah#S_f+W~5&#>oHK7fnx(ActSJDK3dMSF5<O4y9YJX{~jG)hlYcqw3sly*H}
z@<@-G04M(JuO-ssIW70#WxWk4>1y~L!0;xErlD1Gj>`qD0zbvWSDwYQB&Ybb=+WVs
z&o3m-`!hWG@cYH58y&q_@~{6L9wYSX*gnz6KU8jtEIIxG9%wp^8wSY9@uMIA<ap+)
YqjvH6*WR1iA~fndXRz9lip`Dx1Ff>2)Bpeg

literal 0
HcmV?d00001

diff --git a/nglspam.py b/nglspam.py
index 19d9b36..07dadb3 100644
--- a/nglspam.py
+++ b/nglspam.py
@@ -1,23 +1,45 @@
-import json
-import random
-import time
+import json, random, time, httpx, sys, os
 from concurrent.futures import ThreadPoolExecutor
+import threading
 from msg import randomQuestions
-try:
-    import colorama
-    import httpx
-except:
-    print('Please install colorama by doing pip3 install colorama or pip3 install httpx')
-    exit()
-errored = 0
-sent = 0
+from colorama import Fore, Style
+from time import strftime, gmtime
+
+
+sent, errored = 0,0
+class Console:  
+    @staticmethod
+    def get_time() -> str:
+        return time.strftime("%H:%M:%S", time.gmtime()) 
+   
+    @staticmethod
+    def logger(*content: tuple, status: bool) -> None:
+        lock = threading.Lock()
+        time = Console.get_time()
+
+        green = '['+Fore.GREEN + Style.BRIGHT + '+' + Style.RESET_ALL + '] '
+        red = '['+Fore.RED + Style.BRIGHT + '-' + Style.RESET_ALL + '] ' 
+        yellow = '['+Fore.YELLOW + Style.BRIGHT + '!' + Style.RESET_ALL + '] '
+        with lock:
+            if status == 'g':
+                sys.stdout.write(
+                    f'{Fore.YELLOW}[{time}]{Style.RESET_ALL}{green}{" ".join(content)}\n')
+            elif status == 'r':
+                sys.stdout.write(
+                    f'{Fore.YELLOW}[{time}]{Style.RESET_ALL}{red}{" ".join(content)}\n')
+            elif status == 'y':
+                sys.stdout.write(
+                    f'{Fore.YELLOW}[{time}]{Style.RESET_ALL}{yellow}{" ".join(content)}\n')
+
+    @staticmethod
+    def clear() -> None:
+        os.system('cls' if os.name == 'nt' else 'clear')
+
 
 def main(username, message, deviceid, proxy, proxystatus):
     global errored
     global sent
-    green = '['+colorama.Fore.GREEN + colorama.Style.BRIGHT + '+' + colorama.Style.RESET_ALL + '] '
-    red = '['+colorama.Fore.RED + colorama.Style.BRIGHT + '-' + colorama.Style.RESET_ALL + '] ' 
-    yellow = '['+colorama.Fore.YELLOW + colorama.Style.BRIGHT + '!' + colorama.Style.RESET_ALL + '] ' 
+ 
     headers = {'Content-Type': 'application/x-www-form-urlencoded', 'Accept-Language':'en-US,en;q=0.5', 'Accept':'text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,*/*;q=0.8', 'User-Agent':'Mozilla/5.0 (X11; Ubuntu; Linux x86_64; rv:104.0) Gecko/20100101 Firefox/104.0'}
 
     with httpx.Client(headers=headers) as client:
@@ -32,55 +54,56 @@ def main(username, message, deviceid, proxy, proxystatus):
             postresp = client.post(f"https://ngl.link/{username}", data={'question': message + 'TROLLEDLOL ' + message, 'deviceId':deviceid})
             if postresp.status_code == 302:
                 sent += 1
-                print(green + f"Sent {message} to victim, Sent {sent} messages, Errored {errored} messages")
+                Console.logger(f"Sent {message} to victim, Sent {sent} messages, Errored {errored} messages", status='g')
                 
             elif postresp.status_code == 404:
-                print(red + f"User {username} does not exist")
+                Console.logger(f"User {username} does not exist", status='r')
                 exit()
             elif postresp.status_code == 429:
-                print(red + f"User {username} is rate limited")
+                Console.logger(f"User {username} is rate limited", status='r')
                 
                 
         except Exception as e:
             errored+=1
-            print(yellow + f'Error: {e}')
+            Console.logger(f'Error: {e}', status='y')
             main(username, messages(), deviceid(), proxy())
+
+
 def messages():
     return random.choice(randomQuestions)
+    
 def proxy():
     return 'http://' + random.choice(list(open('proxy.txt')))
+
 def deviceid():
     return ''.join(random.choice('0123456789abcdefghijklmnopqrstuvwxyz-') for i in range(36))
 
-question = '[' + colorama.Fore.YELLOW + '?' + colorama.Back.YELLOW + colorama.Style.BRIGHT + colorama.Style.RESET_ALL + '] '
-info = question = '[' + colorama.Fore.YELLOW + '!' + colorama.Back.YELLOW + colorama.Style.BRIGHT + colorama.Style.RESET_ALL + '] '
-print(colorama.Fore.LIGHTRED_EX + '''
-▒█▄░▒█ ▒█▀▀█ ▒█░░░ 　 ▒█▀▀▀█ ▒█▀▀█ ░█▀▀█ ▒█▀▄▀█ 
-▒█▒█▒█ ▒█░▄▄ ▒█░░░ 　 ░▀▀▀▄▄ ▒█▄▄█ ▒█▄▄█ ▒█▒█▒█ 
-▒█░░▀█ ▒█▄▄█ ▒█▄▄█ 　 ▒█▄▄▄█ ▒█░░░ ▒█░▒█ ▒█░░▒█
-''' + colorama.Fore.GREEN + 'Made by https://github.com/oxitheman' +  '\nStar the repository on github if you like it!' + colorama.Style.RESET_ALL)
-
-print(colorama.Fore.GREEN  + colorama.Style.RESET_ALL)
-print(info + 'If you would like to send random questions or use proxies edit config.json to true.')
-username = str(input( question +"Enter username: "))
-threadcount = int(input(question+"Enter thread count: "))
-with open('config.json') as config:
-    data = json.load(config)
-    proxystatus = data['proxy']
-    messagestatus = data['random_messages']
-    delay = data['delay']
-if messagestatus == True:
-    with ThreadPoolExecutor(max_workers=threadcount) as executor:
-        for x in range(threadcount):
-            executor.submit(main, username, messages(), deviceid(), proxy(), proxystatus)
-else:
-    message = str(input(question+"Enter message: "))
-    with ThreadPoolExecutor(max_workers=threadcount) as executor:
-        for x in range(threadcount):
-            executor.submit(main, username, message, deviceid(), proxy(), proxystatus)
-            time.sleep(delay)
-
+def handler():
+    print(Fore.LIGHTRED_EX + '''
+    ▒█▄░▒█ ▒█▀▀█ ▒█░░░ 　 ▒█▀▀▀█ ▒█▀▀█ ░█▀▀█ ▒█▀▄▀█ 
+    ▒█▒█▒█ ▒█░▄▄ ▒█░░░ 　 ░▀▀▀▄▄ ▒█▄▄█ ▒█▄▄█ ▒█▒█▒█ 
+    ▒█░░▀█ ▒█▄▄█ ▒█▄▄█ 　 ▒█▄▄▄█ ▒█░░░ ▒█░▒█ ▒█░░▒█
+    ''' + Fore.GREEN + 'Made by https://github.com/oxitheman' +  '\nStar the repository on github if you like it!' + ' If you would like to send random questions or use proxies edit config.json to true.' + Style.RESET_ALL)
 
+    username = str(input("Enter username (Along with numbers in their NGL link): "))
+    threadcount = int(input("Enter thread count: "))
+    with open('config.json') as config:
+        data = json.load(config)
+        proxystatus = data['proxy']
+        messagestatus = data['random_messages']
+        delay = data['delay']
+    if messagestatus == True:
+        with ThreadPoolExecutor(max_workers=threadcount) as executor:
+            for x in range(threadcount):
+                executor.submit(main, username, messages(), deviceid(), proxy(), proxystatus)
+    else:
+        message = str(input("Enter message: "))
+        with ThreadPoolExecutor(max_workers=threadcount) as executor:
+            for x in range(threadcount):
+                executor.submit(main, username, message, deviceid(), proxy(), proxystatus)
+                time.sleep(delay)
 
+    Console.logger(f'Sent {sent} messages to {username}.', status='g')
 
-print(info + f'Sent {sent} messages to {username}.')
\ No newline at end of file
+if __name__ == '__main__':
+    handler()
\ No newline at end of file