Update for version v7.1.12

app.py

@@ -1,108 +1,136 @@
+l='REQUEST_METHOD'
+k='Content-Type'
+j='wsgi.input'
+i='CONTENT_LENGTH'
+h='proxy-connection'
+g='upgrade'
+f='connection'
+e='HTTP_'
+d='PATH_INFO'
+c='embykeeperweb'
+b='embykeeper'
 W='/ek'
-V='embykeeperweb'
-U='embykeeper'
-Q='install'
-P='pip'
-O='-m'
-L=set
-N=Exception
+V=None
+U='install'
+T='pip'
+S='-m'
+R=set
+Q=Exception
+L='CONTENT_TYPE'
 G=False
-F=int
+D=int
 B=print
 A=True
 import eventlet as H
 H.monkey_patch()
-import os as C,sys as I,tempfile as X,subprocess as D,shutil as E
+import os as C,sys as I,tempfile as m,subprocess as E,shutil as F
 from pathlib import Path
-import threading as R
-from appdirs import user_data_dir as Y
-import socketio as K,eventlet as H,requests as Z
-J='7.1.11'
-a=Path(Y(U))
-M=a/'hf'/'version'
-def b():
+import threading as X
+from appdirs import user_data_dir as n
+import socketio as M,eventlet as H,requests as Y
+J='7.1.12'
+o=Path(n(b))
+N=o/'hf'/'version'
+def p():
 	try:
-		M.mkdir(parents=A,exist_ok=A);R=M/f"emby-keeper-{J}";H=M/f"emby-keeper-{J}.tar.gz"
-		if R.exists():B(f"Using cached version from {R}",flush=A);return A
-		K=X.mkdtemp();B('Downloading EK...',flush=A);F=C.path.join(K,'embykeeper.tar.gz')
-		if H.exists():B(f"Using cached tarball from {H}",flush=A);E.copy2(H,F)
-		else:S=f"https://github.com/emby-keeper/emby-keeper/archive/refs/tags/v{J}.tar.gz";D.run(['wget','-q',S,'-O',F],check=A);E.copy2(F,H)
-		D.run(['tar','xf',F,'-C',K],check=A);C.remove(F);L=C.path.join(K,f"emby-keeper-{J}");B('Obfuscating code...',flush=A)
-		if not c(L):raise N('Obfuscation failed')
-		B('Installing dependencies...',flush=A);D.run([I.executable,O,P,Q,'-r',C.path.join(L,'requirements.txt')],check=A);D.run([I.executable,O,P,Q,L],check=A);E.copytree(L,R,dirs_exist_ok=A);E.rmtree(K);return A
-	except N as T:B(f"Error setting up EK: {T}",flush=A);return G
-def c(package_path):
-	T='dist';S='pyarmor';J=package_path
+		N.mkdir(parents=A,exist_ok=A);M=N/f"emby-keeper-{J}";H=N/f"emby-keeper-{J}.tar.gz"
+		if M.exists():B(f"Using cached version from {M}",flush=A);return A
+		K=m.mkdtemp();B('Downloading EK...',flush=A);D=C.path.join(K,'embykeeper.tar.gz')
+		if H.exists():B(f"Using cached tarball from {H}",flush=A);F.copy2(H,D)
+		else:O=f"https://github.com/emby-keeper/emby-keeper/archive/refs/tags/v{J}.tar.gz";E.run(['wget','-q',O,'-O',D],check=A);F.copy2(D,H)
+		E.run(['tar','xf',D,'-C',K],check=A);C.remove(D);L=C.path.join(K,f"emby-keeper-{J}");B('Obfuscating code...',flush=A)
+		if not q(L):raise Q('Obfuscation failed')
+		B('Installing dependencies...',flush=A);E.run([I.executable,S,T,U,'-r',C.path.join(L,'requirements.txt')],check=A);E.run([I.executable,S,T,U,L],check=A);F.copytree(L,M,dirs_exist_ok=A);F.rmtree(K);return A
+	except Q as P:B(f"Error setting up EK: {P}",flush=A);return G
+def q(package_path):
+	P='dist';O='pyarmor';J=package_path
 	try:
-		D.run([I.executable,O,P,Q,S],check=A)
-		for K in[U,V]:
-			F=C.path.join(J,K)
-			if not C.path.exists(F):B(f"Package directory not found: {F}",flush=A);continue
-			B(f"Obfuscating {K}...",flush=A);D.run([S,'gen','--recursive','--output',C.path.join(J,T),F],check=A);H=C.path.join(J,T)
+		E.run([I.executable,S,T,U,O],check=A)
+		for K in[b,c]:
+			D=C.path.join(J,K)
+			if not C.path.exists(D):B(f"Package directory not found: {D}",flush=A);continue
+			B(f"Obfuscating {K}...",flush=A);E.run([O,'gen','--recursive','--output',C.path.join(J,P),D],check=A);H=C.path.join(J,P)
 			if C.path.exists(H):
 				for M in C.listdir(H):
-					L=C.path.join(H,M);R=C.path.join(F,M)
-					if C.path.isdir(L):E.copytree(L,R,dirs_exist_ok=A)
-					else:E.copy2(L,R)
-				E.rmtree(H)
+					L=C.path.join(H,M);N=C.path.join(D,M)
+					if C.path.isdir(L):F.copytree(L,N,dirs_exist_ok=A)
+					else:F.copy2(L,N)
+				F.rmtree(H)
 			else:B(f"Dist directory not found after obfuscation for {K}",flush=A);return G
 		return A
-	except N as W:B(f"Error during obfuscation: {W}",flush=A);return G
-def d():
-	I='Prompt Generator v0.2(More tags)';H='Prompt Generator v0.1(Better quality)';import gradio as C,random as N;from time import time,ctime
-	def E(choice,num,artist):
-		M='art by';J=choice;D=artist;C=num;O=time();B(ctime(O))
+	except Q as R:B(f"Error during obfuscation: {R}",flush=A);return G
+def O():
+	with H.listen(('',0))as A:return A.getsockname()[1]
+def r():
+	I='Prompt Generator v0.2(More tags)';H='Prompt Generator v0.1(Better quality)';import gradio as C,random as M;from time import time,ctime
+	def J(choice,num,artist):
+		L='art by';J=choice;E=artist;C=num;N=time();B(ctime(N))
 		if J==H:G=open('pr1.txt').read().splitlines()
 		elif J==I:G=open('pr2.txt').read().splitlines()
-		if F(C)<1 or F(C)>20:C=10
-		if F(D)<0 or F(D)>40:D=2
-		P=len(G);A=[];K=0
-		while len(sorted(L(A),key=lambda d:A.index(d)))<F(C):
-			E=N.choice(G)
-			if E.startswith(M)and K<F(D):K+=1;A.append(E)
-			elif not E.startswith(M):A.append(E)
-		B(', '.join(L(A))+'\n\n');return', '.join(L(A))
-	D=C.Blocks()
-	with D:
+		if D(C)<1 or D(C)>20:C=10
+		if D(E)<0 or D(E)>40:E=2
+		O=len(G);A=[];K=0
+		while len(sorted(R(A),key=lambda d:A.index(d)))<D(C):
+			F=M.choice(G)
+			if F.startswith(L)and K<D(E):K+=1;A.append(F)
+			elif not F.startswith(L):A.append(F)
+		B(', '.join(R(A))+'\n\n');return', '.join(R(A))
+	E=C.Blocks()
+	with E:
 		C.HTML('\n                <div style="text-align: center; margin: 0 auto;">\n                  <div style="display: inline-flex;align-items: center;gap: 0.8rem;font-size: 1.75rem;">\n                    <h1 style="font-weight: 900; margin-bottom: 7px;margin-top:5px">\n                      Simple Prompt Generator v0.6 (Gradio Demo)\n                    </h1>\n                  </div>\n                  <p style="margin-bottom: 10px; font-size: 94%; line-height: 23px;">\n                    Simple prompt generation script for Midjourney, DALLe, Stable and Disco diffusion and etc neural networks. <br> <p>More examples in <a class=\'link-info\' href="https://github.com/WiNE-iNEFF/Simple_Prompt_Generator" target="_blank">Github</a> and <a class=\'link-info\' href="https://wine-ineff.github.io/Simple_Prompt_Generator/" target="_blank">Project site</a></p>\n                  </p>\n                  <center>\n                    <img style="display: inline-block, margin-right: 1%;" src=\'https://visitor-badge.laobi.icu/badge?page_id=WiNE-iNEFF.Simple_Prompt_Generator&left_color=red&right_color=green&left_text=Visitors\' alt=\'visitor badge\'>\n                    <img style="display: inline-block, margin-right: 1%;" src=\'https://visitor-badge.laobi.icu/badge?page_id=WiNE-iNEFF.HF_Simple_Prompt_Generator&left_color=red&right_color=green&left_text=Visitors\' alt=\'visitor badge\'>\n                  </center>\n                </div>\n            ')
-		with C.Column():J=C.Radio([H,I],label='Model Variant',value=H);K=C.Number(value='10',label='Num of tag (MAX 20)',show_label=A);M=C.Number(value='2',label='Num of artist (Standart 2)',show_label=A);O=C.Textbox(lines=4,label='Generated Prompts')
-		P=C.Button('Generate');P.click(fn=E,inputs=[J,K,M],outputs=O,concurrency_limit=4);C.HTML('\n                <div class="footer">\n                    <div style=\'text-align: center;\'>Simple Prompt Generator by <a href=\'https://twitter.com/wine_ineff\' target=\'_blank\'>Artsem Holub (WiNE-iNEFF)</a><br>More information about this demo and script your can find in <a class=\'link-info\' href="https://github.com/WiNE-iNEFF/Simple_Prompt_Generator" target="_blank">Github</a> and <a class=\'link-info\' href="https://wine-ineff.github.io/Simple_Prompt_Generator/" target="_blank">Project site</a></div>\n               </div>\n           ')
-	D.queue();D.launch(server_name='127.0.0.1',server_port=7861,share=G)
-def e():
-	N='http://127.0.0.1:7862';L='disconnect';J='connect';C='/pty';D=K.Server(async_mode='eventlet');M=K.WSGIApp(D);E=K.Client();I={}
-	@D.on(J,namespace=C)
-	def P(sid,environ):
+		with C.Column():K=C.Radio([H,I],label='Model Variant',value=H);L=C.Number(value='10',label='Num of tag (MAX 20)',show_label=A);N=C.Number(value='2',label='Num of artist (Standart 2)',show_label=A);P=C.Textbox(lines=4,label='Generated Prompts')
+		Q=C.Button('Generate');Q.click(fn=J,inputs=[K,L,N],outputs=P,concurrency_limit=4);C.HTML('\n                <div class="footer">\n                    <div style=\'text-align: center;\'>Simple Prompt Generator by <a href=\'https://twitter.com/wine_ineff\' target=\'_blank\'>Artsem Holub (WiNE-iNEFF)</a><br>More information about this demo and script your can find in <a class=\'link-info\' href="https://github.com/WiNE-iNEFF/Simple_Prompt_Generator" target="_blank">Github</a> and <a class=\'link-info\' href="https://wine-ineff.github.io/Simple_Prompt_Generator/" target="_blank">Project site</a></div>\n               </div>\n           ')
+	E.queue();F=O();B(f"Starting Gradio on port {F}",flush=A);E.launch(server_name='127.0.0.1',server_port=F,share=G);return F
+def s():
+	N='disconnect';J='connect';C='/pty';E=M.Server(async_mode='eventlet');O=M.WSGIApp(E);F=M.Client();I={}
+	@E.on(J,namespace=C)
+	def R(sid,environ):
 		B(f"Client connected: {sid}")
-		if not E.connected:E.connect(N,namespaces=[C])
+		if not F.connected:F.connect('http://127.0.0.1:7862',namespaces=[C])
 		I[sid]=A
-	@D.on(L,namespace=C)
-	def Q(sid):
-		B(f"Client disconnected: {sid}");I.pop(sid,None)
-		if not I:E.disconnect()
-	@D.on('*',namespace=C)
-	def R(event,sid,*D):
-		A=event
-		if A not in[J,L]:B(f"Forward to ek: {A}");E.emit(A,*D,namespace=C)
+	@E.on(N,namespace=C)
+	def S(sid):
+		B(f"Client disconnected: {sid}");I.pop(sid,V)
+		if not I:F.disconnect()
 	@E.on('*',namespace=C)
-	def S(event,*E):
+	def T(event,sid,*D):
+		A=event
+		if A not in[J,N]:B(f"Forward to ek: {A}");F.emit(A,*D,namespace=C)
+	@F.on('*',namespace=C)
+	def U(event,*D):
 		A=event
-		if A not in[J,L]:B(f"Forward from ek: {A}");D.emit(A,*E,namespace=C)
-	def O(environ,start_response):
-		M='CONTENT_TYPE';B=environ;H=B['PATH_INFO']
-		if H.startswith(W):I=N
-		else:I='http://127.0.0.1:7861'
-		O=f"{I}{H}";E={}
-		for(J,P)in B.items():
-			if J.startswith('HTTP_'):
-				K=J[5:].replace('_','-').title()
-				if K.lower()not in['connection','upgrade','proxy-connection']:E[K]=P
-		C=B.get('CONTENT_LENGTH');L=None
+		if A not in[J,N]:B(f"Forward from ek: {A}");E.emit(A,*D,namespace=C)
+	def Q(environ,start_response):
+		B=environ;H=B[d]
+		if H.startswith(W):I=f"http://127.0.0.1:{K}"
+		else:I=f"http://127.0.0.1:{P}"
+		O=f"{I}{H}";F={}
+		for(J,Q)in B.items():
+			if J.startswith(e):
+				M=J[5:].replace('_','-').title()
+				if M.lower()not in[f,g,h]:F[M]=Q
+		C=B.get(i);N=V
 		if C:
-			C=F(C);L=B['wsgi.input'].read(C)
-			if B.get(M):E['Content-Type']=B[M]
-		D=Z.request(method=B['REQUEST_METHOD'],url=O,headers=E,data=L,stream=A,allow_redirects=G);start_response(f"{D.status_code} {D.reason}",list(D.headers.items()));return D.iter_content(chunk_size=4096)
-	M.wsgi_app=O;H.wsgi.server(H.listen(('',7860)),M)
+			C=D(C);N=B[j].read(C)
+			if B.get(L):F[k]=B[L]
+		E=Y.request(method=B[l],url=O,headers=F,data=N,stream=A,allow_redirects=G);start_response(f"{E.status_code} {E.reason}",list(E.headers.items()));return E.iter_content(chunk_size=4096)
+	O.wsgi_app=Q;H.wsgi.server(H.listen(('',7860)),O)
 if __name__=='__main__':
 	B('Setting up EK...',flush=A)
-	if not b():B('Failed to setup EK!',flush=A);I.exit(1)
-	S=R.Thread(target=d);S.daemon=A;S.start();T=R.Thread(target=lambda:D.run([V,'--port','7862','--prefix',W,'--public']));T.daemon=A;T.start();B('Starting proxy server...',flush=A);e()
+	if not p():B('Failed to setup EK!',flush=A);I.exit(1)
+	P=O();K=O();B(f"Using ports - Gradio: {P}, EK: {K}",flush=A);Z=X.Thread(target=lambda:r());Z.daemon=A;Z.start();a=X.Thread(target=lambda:E.run([c,'--port',str(K),'--prefix',W,'--public']));a.daemon=A;a.start()
+	def t(environ,start_response):
+		B=environ;H=B[d]
+		if H.startswith(W):I=f"http://127.0.0.1:{K}"
+		else:I=f"http://127.0.0.1:{P}"
+		O=f"{I}{H}";F={}
+		for(J,Q)in B.items():
+			if J.startswith(e):
+				M=J[5:].replace('_','-').title()
+				if M.lower()not in[f,g,h]:F[M]=Q
+		C=B.get(i);N=V
+		if C:
+			C=D(C);N=B[j].read(C)
+			if B.get(L):F[k]=B[L]
+		E=Y.request(method=B[l],url=O,headers=F,data=N,stream=A,allow_redirects=G);start_response(f"{E.status_code} {E.reason}",list(E.headers.items()));return E.iter_content(chunk_size=4096)
+	B('Starting proxy server on port 7860...',flush=A);s()