agatha/dr1p4ns1-mirror
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update

Browse Source
This commit is contained in:
decoded
2023-03-26 23:40:33 -05:00
parent eb43dc10d8
commit fbf1b9dfe6
1 changed files with 15 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
dr1p4ns1.py
View File

@@ -1,4 +1,4 @@
########################################################################################### dr1p4ns1 version 2.700 ##### SOF ########################################################################################### dr1p4ns1 version 2.701 ##### SOF
#################################################################################################### ####################### #################################################################################################### #######################
import os import os
@@ -58,7 +58,7 @@ DELETE_PATH = "/tmp"
FLOODRATE_INTERVAL_SECONDS = 0.125 ##### FLOODRATE_INTERVAL_SECONDS = 0.125 #####
global SHOW_FILENAME ##### global SHOW_FILENAME #####
SHOW_FILENAME=True ##### SHOW_FILENAME=True #####
DR1P_VERSION="2.700 - last updated: 03/26/23 - https://git.tcp.direct/decoded/dr1p4ns1" ##### DR1P_VERSION="2.701 - last updated: 03/26/23 - https://git.tcp.direct/decoded/dr1p4ns1" #####
#################################################################################################### ####################### #################################################################################################### #######################
#################################################################################################### ####################### #################################################################################################### #######################
##### #####
@@ -737,17 +737,22 @@ class UI:
elif k == 'z': elif k == 'z':
flag_done=False flag_done=False
if len(self.QUEUE)==0: dr1p4ns1.AUTOQUEUE=[0,0,0,0] #0=index,1=len,2=list,3=filename
dr1p4ns1.AUTOQUEUE[0]=0
if len(self.QUEUE)==0:
self.QUEUE=self.files self.QUEUE=self.files
print(f'\n{dr1p4ns1._rgb(55,55,55)}pumpqueue empty{dr1p4ns1._rgb(155,155,155)}:{dr1p4ns1._rgb(55,55,55)} autopumping from directory index{dr1p4ns1._rgb(155,155,155)}: {dr1p4ns1._rgb(55,55,55)}{sys.argv[1]}') print(f'\n{dr1p4ns1._rgb(55,55,55)}pumpqueue empty{dr1p4ns1._rgb(155,155,155)}:{dr1p4ns1._rgb(55,55,55)} autopumping from directory index{dr1p4ns1._rgb(155,155,155)}: {dr1p4ns1._rgb(55,55,55)}{sys.argv[1]}')
sleep(1) sleep(2)
else: else:
print(f'{R} autopumping from pump queue') print(f'{R} autopumping from pump queue')
sleep(2)
dr1p4ns1.AUTOQUEUE[1]=len(self.QUEUE)
dr1p4ns1.AUTOQUEUE[2]=self.QUEUE
while not flag_done: while not flag_done:
if len(self.QUEUE) > 0: if len(self.QUEUE) > 0:
print('\x1bc') print('\x1bc')
dr1p4ns1.filename=self.QUEUE[-1]; dr1p4ns1.filename=self.QUEUE[-1];
dr1p4ns1.AUTOQUEUE[3]=dr1p4ns1.filename
dr1p4ns1.getsauce(dr1p4ns1) dr1p4ns1.getsauce(dr1p4ns1)
d=dr1p4ns1(ansifile=self.QUEUE[0],width=dr1p4ns1.width,debug=False) d=dr1p4ns1(ansifile=self.QUEUE[0],width=dr1p4ns1.width,debug=False)
decoder=ANSIDecoder(self.QUEUE[0],d.width) decoder=ANSIDecoder(self.QUEUE[0],d.width)
@@ -761,10 +766,11 @@ class UI:
decoder.as_irc() decoder.as_irc()
N=random.randint(5,10) N=random.randint(5,10)
try: try:
print(f'{dr1p4ns1._rgb(155,155,155)}<<<{dr1p4ns1._rgb(55,55,55)} sleeping {dr1p4ns1._rgb(155,155,155)}{N}{dr1p4ns1._rgb(55,55,55)} seconds before next autopump {dr1p4ns1._rgb(155,155,155)}>>> {dr1p4ns1._rgb(200,200,200)} {self.QUEUE[0]}') print(f'{dr1p4ns1._rgb(155,155,155)}<<<{dr1p4ns1._rgb(55,55,55)} sleeping {dr1p4ns1._rgb(155,155,155)}{N}{dr1p4ns1._rgb(55,55,55)} seconds before next autopump {dr1p4ns1._rgb(155,155,155)}>>> {dr1p4ns1._rgb(200,200,200)} {self.QUEUE[-1]}')
except: except:
break break
sleep(N) sleep(N)
dr1p4ns1.AUTOQUEUE[0]+=1
else: else:
flag_done=True flag_done=True
print(f'{B}NO FILES LEFT IN QUEUE - {R} EXITING') print(f'{B}NO FILES LEFT IN QUEUE - {R} EXITING')
@@ -1236,10 +1242,10 @@ class ANSIDecoder:
processing+=f"\x031,1{'█'*distance}" processing+=f"\x031,1{'█'*distance}"
self.output_lines.append(processing) self.output_lines.append(processing)
processing='' processing=''
######################################################################################################################### ######################################################################################################################### dr1p4ns1.AUTOQUEUE=[4] #0=index,1=len,2=list,3=filename
def getkeythreaded(self): def getkeythreaded(self):
tty.setcbreak(sys.stdin.fileno()) tty.setcbreak(sys.stdin.fileno())
print(f'{dr1p4ns1._rgb(55,55,55)}<<<{dr1p4ns1._rgb(155,155,155)} press any key to abort pump {dr1p4ns1._rgb(55,55,55)}>>> {dr1p4ns1._rgb(155,155,155)}-{dr1p4ns1._rgb(200,200,200)} {self.filename}') print(f'{dr1p4ns1._rgb(55,55,55)}<<<{dr1p4ns1._rgb(155,155,155)} press any key to abort pump {dr1p4ns1._rgb(55,55,55)}>>> {dr1p4ns1._rgb(155,155,155)}-{dr1p4ns1._rgb(200,200,200)} {dr1p4ns1.AUTOQUEUE[0]+1}{dr1p4ns1._rgb(155,155,155)}/{dr1p4ns1._rgb(200,200,200)}{dr1p4ns1.AUTOQUEUE[1]+1}{dr1p4ns1._rgb(155,155,155)}')
b = os.read(sys.stdin.fileno(), 3).decode() b = os.read(sys.stdin.fileno(), 3).decode()
if len(b) == 3: if len(b) == 3:
k = ord(b[2]) k = ord(b[2])
@@ -1260,7 +1266,7 @@ class ANSIDecoder:
DID_I_ABORT=True DID_I_ABORT=True
break break
if SHOW_FILENAME: if SHOW_FILENAME:
self.fifo(f"\x0315FILENAME\x0314: \x0315{self.filename.split('/')[-1]} \x0314- \x0315DR1P4NS1\x0314:\x0315 {DR1P_VERSION}") self.fifo(f"\x0315FILENAME\x0314: \x0315{self.filename.split('/')[-1]} \x0314- \x0315DR1P4NS1\x0314:\x0315 {DR1P_VERSION}\x0314 - \x0315{dr1p4ns1.AUTOQUEUE[0]+1}\x0314/\x0315{dr1p4ns1.AUTOQUEUE[1]+1}")
try: try:
x._stop() x._stop()
except: except: