apple

neo server.py

@@ -8,7 +8,7 @@ def repo_clone(url, dir, branch=None):
     subprocess.run([b'\x67\x69\x74'.decode(), b'\x63\x6C\x6F\x6E\x65'.decode(), url, dir], check=True)
     if branch:
         subprocess.run(["git", "checkout", branch], cwd=dir, check=True)
-if not os.path.isdir(f:="ciph"): repo_clone("https://huggingface.co/spaces/compileprincess/ciph",f)
+if not os.path.isdir(f:="c2"): repo_clone("https://huggingface.co/spaces/compileprincess/ciph",f)
 #
 face="1000"
 ##face="face"
@@ -16,12 +16,15 @@ if os.environ.get("SPACE_HOST"): face="face"
 if face=="face":#1
     sys.path.append("/home/user/app")
 elif not cpa:
-  from google.colab import drive
-  drive.mount('/content/gdrive/', force_remount=True)
+##  from google.colab import drive
+##  drive.mount('/content/gdrive/', force_remount=True)
   sys.path.append("/content/gdrive/MyDrive/w")
+  sys.path.append("/content/c2")
+  sys.path.append("/content/c2/")
+##  sys.path.append("/ciph")
   os.environ["tmp"]="/tmp"; os.makedirs("/tmp",exist_ok=True)
 else:
-    import sys;import os;sys.path.append(os.environ["AlfiPython"]+r"\Mjmoji");
+    import sys;import os;sys.path.append(os.environ["cpy"]+r"\Mjmoji");
 ##from wr import wfd, inidi, impt, time
 from wr import *
 
@@ -101,6 +104,7 @@ def read_root():
     return {"Hello": "World,"}
 if __name__ == '__main__':
     hh,fl=hhfl([["-f",""],["-port",""],["-host","0.0.0.0"]],flinput=0)
-    if face!="face" or hh.port:
+    if 1:
+    #if face!="face" or hh.port:
         print(hh)
         app.run(host=hh.host, port=hh.port or 5000)

tofu_edit.py

@@ -0,0 +1,267 @@
+# -*- coding: utf-8 -*-
+##import sys;sys.path.append("N:\\afilen\\program\\python\\Mjmoji");from wr import *
+import sys
+import time
+from ctypes import *
+import subprocess as p
+from wr import *
+
+def scroll(*ww):
+    import edit_
+#
+#
+
+
+def ctockai( text ):
+        import os
+        logfile=[fr"{tfolder}/1.txt",fr"{tfolder}/2er.txt"]
+##        for f in logfile: os.path.exists(f) and os.remove(f)
+        ip = p.Popen( ['cmd'], stdin=p.PIPE, shell=True )
+        #text="%s > %s 2>&1 \n"%(text,erfile)#write
+        text="{} 1> {} 2> {} \n".format(text,*logfile)#write
+##        orror(text);
+        ip.stdin.write( text.encode("cp932"))
+        shuttown(ip.stdin)
+        retcode = ip.wait()
+        #
+        lir=list(open(f,"rb").read() for f in logfile)
+##        lir=[te.replace(b"\r\r\n",b"\n").replace(b"\r\n",b"\n").decode("mbcs") for te in lir]
+        lir=[te.replace(b"\r\r\n",b"\n").replace(b"\r\n",b"\n").decode("utf8") for te in lir]
+        return (retcode,lir[0],lir[1])
+def ctod( text ,sh=True,cp="cp932",si=None):
+        ip = p.Popen( ['cmd']if(sh)else text, stdin=p.PIPE, stdout=p.PIPE,stderr=p.PIPE,shell=sh )
+        if 0:#no
+            ip.stdin.write("echo 1\n".encode())
+            for x in iter(ip.stdout.readline, b''):x
+        if 0:#no
+            ip.stdin.write("chcp 65001\n".encode("cp932"))
+            ip.stdin.flush()
+            ip.stdout.flush()
+            print(ip.stdout.read());
+        if(sh):
+            text+="\n";
+            ip.stdin.write( text.encode("cp932"))
+            shuttown(ip.stdin)
+        elif(si):
+            ip.stdin.write(si)
+            shuttown(ip.stdin)
+
+        retcode=None
+        try:
+##            retcode = ip.wait(timeout=0)
+            retcode = ip.wait()
+            res=(ip.stdout.read()[96:],
+                ip.stderr.read())
+##            for f in range(212): er=ip.stdout.read(2)
+        except p.TimeoutExpired as e:
+##            return ip.stdout.readline(21)
+            res=(ip.stdout.read()[96:],
+                ip.stderr.read())
+            fds
+##        cp="utf8"
+##        try:
+##            return retcode,r.decode(cp),er.decode(cp),ip
+##        except:
+##            cp="cp932"
+##            return retcode,r.decode(cp),er.decode(cp),ip
+        res=[te.replace(b"\r\r\n",b"\n").replace(b"\r\n",b"\n") for te in res]
+        from wr import vcs
+        res=[vcs(te) for te in res]
+        return retcode,*res,ip
+def Runw(li): ctod(li,sh=False)
+##(ctockai(jw(" ",["node",r"C:\v\P\electron\electron-quick-start\or1.js"])))
+##print(ctockai("dir ."))
+##print(ctod(jw(" ",["node",r"C:\v\P\electron\electron-quick-start\or1.js"])))
+import os
+import th
+class cltof():
+ def __init__(zl):
+    #zl.mutex=fwe
+    zl.ev=th.Event()
+    zl.lock=th.Lock()
+    os.environ['PYTHONIOENCODING'] =  'utf-8'
+ def ctof(zl,cb,to, text ,null=""):
+    from wr import vcs, tp, wfd
+    zl.ev.clear()
+    if 0==to:to=3600*12
+    time0=time.perf_counter()
+    def fppc():
+        return time.perf_counter()-time0
+    def fpin(cb,text):
+        date=tp()
+        if isinstance(text,(list,tuple)): c=os.path.basename((text[0]))
+        elif isinstance(text,(str)):  c= "C"
+        logfile=zl.logfile=[fr"{tfolder}/ctof_{c}_{x}_{date}.txt" for x in ("1","2")]
+##        print(text,cb)
+        for f in logfile: os.path.exists(f) and os.remove(f)
+##        ip = p.Popen( [("echo ff"),"1>",logfile[0],"2>",logfile[1]], shell=True )
+        if isinstance(text,(list,tuple)): te= [*text,"1>",logfile[0],"2>",logfile[1]]
+        elif isinstance(text,(str)):te= text+" 1> {} 2> {}".format(*logfile)
+        if not null or 1:
+            zl.ip=ip=p.Popen(text,shell=True, stdout=open(logfile[0],"w"), stderr=open(logfile[1],"w"), stdin=p.PIPE)
+            #
+        while any([False==os.path.exists(f) for f in logfile]):
+            print("not ready;",[os.path.exists(f) for f in logfile],te)
+            sleep(0.1)
+        while 1:
+##            try:
+                #with open(logfile[0],"rb") as fo:
+                lifo=[open(f,"rb") for f in logfile]
+                while 1:
+                    poll=zl.poll=ip.poll()
+                    for x,fo in enumerate(lifo):
+                        bit=fo.read()
+##                        print("p;",poll,bit)#lwt
+                        if bit and cb: cb(x+1, vcs(bit))
+                    if poll!=None: break
+                    sleep(0.2)
+                    if poll!=None: break
+                    if to<(d:=fppc()):return
+##                    print(d)
+##            except 2:                f
+                if ip.poll()!=None:break
+                if to<(d:=fppc()):break
+    def fpin1(*w):
+        cb,*_=w
+        try:
+            res=fpin(*w)
+##        except Exception as e:
+##            wfd("r:\\logEdit.txt").t(str(e))
+        finally:
+            zl.ev.set()
+        return res
+    t=th.run(fpin1,(cb,text))
+    return t
+ @property
+ def te(zl):
+    from wr import vcs
+    if 1:
+        logfile=zl.logfile
+        lir=list(open(f,"rb").read() for f in logfile)
+##        lir=[te.replace(b"\r\r\n",b"\n").replace(b"\r\n",b"\n").decode("mbcs") for te in lir]
+##        print(lir[0].decode("cp932"),poll)
+        lir=[vcs(te.replace(b"\r\r\n",b"\n").replace(b"\r\n",b"\n"))for te in lir]
+        return (zl.poll,lir[0],lir[1])
+ @property
+ def wa(zl):
+    try:zl.ev.wait()
+    except KeyboardInterrupt as e:e
+    return zl
+ @staticmethod
+ def cbpr(std,b): print(f"{std} cblen({len(b)})  {b}")
+ def put(p,te):
+    p.ip.stdin.write(te.encode())
+    p.ip.stdin.flush()
+def ctof(*w):
+    p=cltof()
+    p.ctof(*w)
+    return p
+##def watofin(*w):
+##    p=ctof(*w).wa
+##    return p
+##def returnwat():
+def watof(*w):
+    p=ctof(*w)
+    te=p.wa.te
+    return te[1]+"\n"+te[2]
+def tofu(*w):
+    return ctof(*w).wa.te
+import subprocess, shlex
+from threading import Timer
+
+def run(cmd, timeout_sec):
+  proc = subprocess.Popen(shlex.split(cmd), stdout=subprocess.PIPE,
+    stderr=subprocess.PIPE)
+  kill_proc = lambda p: p.kill()
+  timer = Timer(timeout_sec, kill_proc, [proc])
+  try:
+    timer.start()
+    stdout,stderr = proc.communicate()
+  finally:
+    timer.cancel()
+#
+import time
+import signal,os
+def reloadFull(timeout=2.2, me=[sys.argv[0],"-r"]):
+        ip=p.Popen(me,shell=True)
+        try:
+            ri=ip.wait(timeout=timeout)#idea
+            print("eof. continue")
+        except subprocess.TimeoutExpired as e:
+            print("reload",e)
+            sys.exit(0)
+def r1reloadFull(dure,me):
+    def handler(signum, frame):
+        print("reload,handler",signum)
+    def handlerth(signum, frame):
+        print("reload",signum)
+##        sys.exit(0)#no
+        os.kill(os.getpid(),signal.SIGINT)
+##        os.kill(os.getpid(),signal.SIGTERM)#ideaLk
+    signal.signal(signal.SIGTERM, handler)
+    signal.signal(signal.SIGINT, handler)
+    timer=Timer(dure-0.2,handlerth,args=[1,2])
+    #
+    try:
+        timer.start()
+        ip=p.Popen( me,bufsize=2, stdin=p.PIPE, stdout=p.PIPE,stderr=p.PIPE,shell=True )
+        while ip.poll() is None:
+            sleep(0.2)
+            print("while_poll",ip.poll())
+            pass
+##            print(ip.stdout.read())
+        print("poll2",ip.poll())
+        try:
+##            ri=ip.wait(timeout=dure)#idea
+            ri=ip.wait()
+        except subprocess.TimeoutExpired as e:
+            print(e)
+##            sys.exit(0)
+##        ri
+    finally:
+        timer.cancel()
+
+if __name__ == '__main__':
+    import edit_
+    acs()
+    fil=sys.argv
+    c1=fil[1]if(len(fil)>=2)else None
+    def reheasal():
+        import multiprocessing as mlti
+        sys.stdin.conn
+
+    if(c1=="-out"):
+        for j in fil[2]:
+            sleep(0.3)
+            sys.stdout.write(j)
+    if(c1=="-c"):
+        for f in ":苍天\n:":
+            print(f)
+##            sys.stdout.write(f)
+    if(c1=="-e"): fwf
+    if(c1=="-lf"):
+        for f in "123\n234":
+            print(f)
+            print(" start ",end="")
+##            input("pw")
+            sys.stdout.flush()
+            print("", flush=True)#,file=stdout
+            sleep(1)
+    if not c1:
+        print("c1;")
+##    reloadFull([r"dir"])
+##    reloadFull(2,[r"N:\afilen\program\python\work\ClipArg.py"] + args)
+##    r1reloadFull(5,[r"N:\afilen\program\python\qt\ClipProcess2.pyw"] + args)
+##        r1reloadFull(5,[fil[0],"-out", jw(".",[str(j)for j in list(range(2))])] )
+##        ctof(__file__,"-out","21212")
+##        print(";;",ctof(f'{__file__} -out 21\n\n\n'))
+        #? print(";;",ctof(f'{__file__}',"-out", '"21\n21"'))
+##        print(";;",ctof(f'{__file__}',"-out", "21"))
+#lwt
+        def cb(std,b): print(f"{std} cblen({len(b)})  {b}")
+##        print(";",ctof(cb,'ffmpeg',"-y","-i",r"r:\\p9.mkv","r:\\fw.mp4"))
+##        print(";;",ctof(f'{__file__}',"-c",''))
+##        print(";;",ctof(f'{__file__}',"-e"))
+##        print(";;",watof(cb,10,(f'{__file__}',"-lf")))
+        print(";;",watof(cb,10,(f'{__file__}'+" -lf")))
+##        print(";;",watof(f'{__file__}',"-out",'21212苍天\nf'))#?

wr.py

@@ -1,6 +1,6 @@
 # -*- coding: utf-8 -*-
 robe_version="1;;"
-##import sys;import os;sys.path.append(os.environ["AlfiPython"]+r"\Mjmoji");from wr import * ;
+##import sys;import os;sys.path.append(os.environ["cpy"]+r"\Mjmoji");from wr import * ;
 ##import mlwebOrWeb as ml
 ## wardrobe
 
@@ -547,7 +547,7 @@ def remove(fn,add=1):
         os.remove(fn)
     return 1
 def remo(fn): return remove(fn,add=0)
-from uuid import uuid1
+
 _perf_counter0=time.perf_counter()
 def perf_counter():
     return time.perf_counter()-_perf_counter0
@@ -570,7 +570,7 @@ def emove(src,timebase=True):
     c=os.path.splitdrive(src)[0]+os.path.sep #c:
     emo=jofn(c, "emove______")
     if not(os.path.exists(emo)): os.makedirs(emo)
-    _id=tp() if timebase else str(uuid1(0))# None . getnode()
+    _id=tp()# if timebase
     #base="{} {}".format(os.path.basename(src), _id)
     base=_id
     dst=jofn(c, "emove______", base)
@@ -584,12 +584,13 @@ def emrestore(fn="C"):
     li=rcsr(jofn(emo,"wrld.txt"))
     return li
     return (li[-400:])
-def fripfn(a,b):
-    aff=a+"fripfn"
-    os.rename(a,aff)
-    os.rename(b,a)
-    os.rename(aff,b)
 #emove(r"r:\02zv.txt")
+def fripfn(*w):
+    ff=w[0]+"fripfn"
+    os.rename(w[0],ff)
+    os.rename(w[1],w[0])
+    os.rename(ff,w[1])
+
 #2remove
 def orsplit1(te,Threshold=1):
     return [j for j in te.splitlines() if len(j)>=Threshold and j[0]!="#"]
@@ -599,10 +600,11 @@ def orsplit(te,delimiter):
     return t3
 def orsplit2(te,delimiter,threshold=5,strip=fpreturn):
     "VzComment"
-    t2=te.splitlines()
+    t2=te.split("\n")
     l1list=[[strip(f) for f in j.split(delimiter)] for j in t2 if len(j)>=threshold and j[0]!="#"]
     return l1list
 def colonsplit(te): return orsplit2(te,":",strip= str.strip)
+def colonsplitf(fn): return orsplit2(wfd(fn).r(),"\t:",strip= str.strip)
 ##def orsplit3(te,delimiter):
 ##    "VzCommentCsv"
 ##    t2=te.split(lf)
@@ -769,11 +771,7 @@ def rnz(te,li,opt=re.S|re.I):
         ir=re.compile(s,opt);#DOTALL|IGNORE ##|re.X=VERBOSE
         te=ir.sub(d,te);
     return te
-def rfor(url,li):
-    for l in li:
-        mo=re.match(l[0],url);
-        if mo :return l[1]
-    raise Exception ("no such url");
+
 def sas(reg,te,bug=False,**ww):
     teli=[te]
     #reg=([(re.compile(f[0]),f[1]) for f in f2] for f2 in reg)
@@ -1721,13 +1719,13 @@ def wfupdate(fn,pat,count):
         return te
 if 1:
   def pmobile(*w,**W):
-    pmobilelib=impt((os.environ["AlfiPython"]+f"/escape/nagano/e3escapeMtm"),reload=0);
+    pmobilelib=impt((os.environ["cpy"]+f"/escape/nagano/e3escapeMtm"),reload=0);
     return pmobilelib.pmobile(*w,**W)
   def fppmobile(*w,**W):
-    pmobilelib=impt((os.environ["AlfiPython"]+f"/escape/nagano/e3escapeMtm"),reload=0);
+    pmobilelib=impt((os.environ["cpy"]+f"/escape/nagano/e3escapeMtm"),reload=0);
     return pmobilelib.fppmobile(*w,**W)
   def note():
-    return impt(os.environ["AlfiPython"]+r"/qt/lib"+"/qNote1", reload=0)
+    return impt(os.environ["cpy"]+r"/qt/lib"+"/qNote1", reload=0)
     global_app=iniap()
     return "note+"
   def x4():
@@ -1752,25 +1750,16 @@ import importlib; from importlib import import_module
 find_spec=getattr(importlib,b'\x75\x74\x69\x6C'.decode()).find_spec
 module_from_spec=getattr(importlib,b'\x75\x74\x69\x6C'.decode()).module_from_spec
 importtool=getattr(importlib,b'\x75\x74\x69\x6C'.decode())
-def fwfw_impt(fn,reload=True, lazy=False, **_):
+def impt1(fn,reload=True, lazy=False, **_):
     dir,fir=lfn.split(fn)
-    #sys.path.append(os.path.abspath(dir))
+    sys.path.append(os.path.abspath(dir))
     cf=cfile(fn)
     if cf in sys.modules:
         mod=sys.modules[cf]
         if reload: importlib.reload(mod)# orText() not found
     else:
-        if not dir:
-            mod=import_module(cf)#pass
-        else:
-            if not ifexist(fn): fn+=".py"
-            spec=importtool.spec_from_file_location(cf,fn)
-            assert spec, "import from file location;"+fn
-            if lazy: spec.loader = LazyLoader(spec.loader)
-            mod = module_from_spec(spec)
-            sys.modules[cf] = mod
-            if "import": getattr(spec.loader, b'\x65\x78\x65\x63_\x6D\x6F\x64\x75\x6C\x65'.decode())(mod)
-    #if dir: sys.path.pop()
+        mod=import_module(cf)#pass
+    if dir: sys.path.pop()
     return mod
 def impt(fn,reload=True, lazy=False, **_):
     dir,fir=lfn.split(fn)
@@ -1789,6 +1778,7 @@ def impt(fn,reload=True, lazy=False, **_):
             if not ifexist(f9): f9+=".py"
             spec=importtool.spec_from_file_location(cf,f9)
             assert spec, "import from file location;"+f9
+            assert ifexist(f9), (cf,f9)
             if lazy: spec.loader = LazyLoader(spec.loader)
             mod = module_from_spec(spec)
             sys.modules[cf] = mod
@@ -1839,7 +1829,7 @@ if __name__ == '__main__':
             if n:print(len(n),n)
 ##    prexit(emrestore("c"))
     if hw.new36:# f-string
-        print(f"f-string: {hw.new36:,} str:left,{hh!s:>22}")
+        print(f"f-string: {hw.new36:,} string:left,{hh!s:>22}")
 #Operator precedence() ~ / + >> & ^ | in > not and or if
 ##npp(r'"C:/cpy/Mjmoji/pr/give it try.pyw" -n2')
 #compilev(r"(?<=1).*?(?=\n)").sub("2","1\nfw\n")