| from multiprocessing import Process ,Queue |
| import subprocess |
| import sys |
| import re |
| def hitozuma (O0O0O00OO0O0O00O0 ,OO0OO00O0OOO000OO ): |
| try : |
| OO000O0O000OOOOO0 =subprocess .run (['/home/studio-lab-user/.zrok/bin/zrok','enable',O0O0O00OO0O0O00O0 ],check =False ,stdout =subprocess .PIPE ,stderr =subprocess .STDOUT ,text =True ) |
| O0O0OOOOO0000OO00 =subprocess .Popen (["/home/studio-lab-user/.zrok/bin/zrok","share","public","localhost:8188","--headless"],stdout =subprocess .PIPE ,stderr =subprocess .STDOUT ,text =True ) |
| O000OO0O000OOOOOO =re .compile (r'https?://[^\s]*\.zrok\.io') |
| OOO0O0OOO000O0OOO =("◼◼◼◼◼◼◼◼◼◼◼◼◼◼◼◼◼◼◼◼◼◼◼◼◼◼◼◼◼") |
| if OO000O0O000OOOOO0 .returncode ==0 : |
| OO0OO00O0OOO000OO .put (f"\n{OOO0O0OOO000O0OOO}\n[ZROK] environment enabled.\n") |
| else : |
| if "enabled environment"in OO000O0O000OOOOO0 .stdout : |
| OO0OO00O0OOO000OO .put (f"\n{OOO0O0OOO000O0OOO}\n[ZROK] environment already enabled.\n") |
| else : |
| OO0OO00O0OOO000OO .put (OO000O0O000OOOOO0 .stdout ) |
| for O0O00O000O0O0O0O0 in O0O0OOOOO0000OO00 .stdout : |
| OO0O00O0000O0OOO0 =O000OO0O000OOOOOO .findall (O0O00O000O0O0O0O0 ) |
| for O0O0O00O0OO0O000O in OO0O00O0000O0OOO0 : |
| OO0OO00O0OOO000OO .put (f"[ZROK] {O0O0O00O0OO0O000O}\n{OOO0O0OOO000O0OOO}\n\n") |
| O0O0OOOOO0000OO00 .wait () |
| except : |
| pass |
| if __name__ =='__main__': |
| if len (sys .argv )!=2 : |
| sys .exit ("") |
| zrok_out =Queue () |
| process =Process (target =hitozuma ,args =(sys .argv [1 ],zrok_out )) |
| process .start () |
| while process .is_alive ()or not zrok_out .empty (): |
| while not zrok_out .empty (): |
| print (zrok_out .get (),end ='',flush =True ) |
| process .join () |