Ignore:
Timestamp:
Aug 21, 2009, 4:57:55 PM (15 years ago)
Author:
quentin
Message:

Remove dependency on qweb framework

Location:
package_branches/invirt-web/cherrypy/code
Files:
1 deleted
1 edited

Legend:

Unmodified
Added
Removed
  • package_branches/invirt-web/cherrypy/code/ajaxterm.py

    r2454 r2455  
    33""" Ajaxterm """
    44
    5 import array,cgi,fcntl,glob,hashlib,mimetypes,optparse,os,pty,random,re,signal,select,sys,threading,time,termios,struct,pwd
    6 
    7 os.chdir(os.path.normpath(os.path.dirname(__file__)))
    8 # Optional: Add QWeb in sys path
    9 sys.path[0:0]=glob.glob('../../python')
    10 
    11 import qweb
     5import array,atexit,cgi,fcntl,glob,hashlib,mimetypes,optparse,os,pty,random,re,signal,select,sys,threading,time,termios,struct,pwd
    126
    137class Terminal:
     
    372366                self.thread.daemon=True
    373367                self.alive=1
     368                atexit.register(self.die)
    374369                # synchronize methods
    375370                for name in ['create','fds','proc_read','proc_write','dump','die','run']:
     
    454449                        except (IOError,OSError):
    455450                                pass
    456 
    457 class AjaxTerm:
    458         def __init__(self,cmd=None,index_file='ajaxterm.html'):
    459                 self.files={}
    460                 for i in ['css','html','js']:
    461                         for j in glob.glob('*.%s'%i):
    462                                 self.files[j]=file(j).read()
    463                 self.files['index']=file(index_file).read()
    464                 self.mime = mimetypes.types_map.copy()
    465                 self.mime['.html']= 'text/html; charset=UTF-8'
    466                 self.multi = Multiplex(cmd)
    467                 self.session = {}
    468         def __call__(self, environ, start_response):
    469                 req = qweb.QWebRequest(environ, start_response,session=None)
    470                 if req.PATH_INFO.endswith('/u'):
    471                         s=req.REQUEST["s"]
    472                         k=req.REQUEST["k"]
    473                         c=req.REQUEST["c"]
    474                         w=req.REQUEST.int("w")
    475                         h=req.REQUEST.int("h")
    476                         if s in self.session:
    477                                 term=self.session[s]
    478                         else:
    479                                 if not (w>2 and w<256 and h>2 and h<100):
    480                                         w,h=80,25
    481                                 term=self.session[s]=self.multi.create(w,h)
    482                         if k:
    483                                 self.multi.proc_write(term,k)
    484                         time.sleep(0.002)
    485                         dump=self.multi.dump(term,c)
    486                         req.response_headers['Content-Type']='text/xml'
    487                         if isinstance(dump,str):
    488                                 req.write(dump)
    489                                 req.response_gzencode=1
    490                         else:
    491                                 del self.session[s]
    492                                 req.write('<?xml version="1.0"?><idem></idem>')
    493 #                       print "sessions %r"%self.session
    494                 else:
    495                         n=os.path.basename(req.PATH_INFO)
    496                         if n in self.files:
    497                                 req.response_headers['Content-Type'] = self.mime.get(os.path.splitext(n)[1].lower(), 'application/octet-stream')
    498                                 req.write(self.files[n])
    499                         else:
    500                                 req.response_headers['Content-Type'] = 'text/html; charset=UTF-8'
    501                                 req.write(self.files['index'])
    502                 return req
    503 
    504 def main():
    505         parser = optparse.OptionParser()
    506         parser.add_option("-p", "--port", dest="port", default="8022", help="Set the TCP port (default: 8022)")
    507         parser.add_option("-c", "--command", dest="cmd", default=None,help="set the command (default: /bin/login or ssh localhost)")
    508         parser.add_option("-l", "--log", action="store_true", dest="log",default=0,help="log requests to stderr (default: quiet mode)")
    509         parser.add_option("-d", "--daemon", action="store_true", dest="daemon", default=0, help="run as daemon in the background")
    510         parser.add_option("-P", "--pidfile",dest="pidfile",default="/var/run/ajaxterm.pid",help="set the pidfile (default: /var/run/ajaxterm.pid)")
    511         parser.add_option("-i", "--index", dest="index_file", default="ajaxterm.html",help="default index file (default: ajaxterm.html)")
    512         parser.add_option("-u", "--uid", dest="uid", help="Set the daemon's user id")
    513         (o, a) = parser.parse_args()
    514         if o.daemon:
    515                 pid=os.fork()
    516                 if pid == 0:
    517                         #os.setsid() ?
    518                         os.setpgrp()
    519                         nullin = file('/dev/null', 'r')
    520                         nullout = file('/dev/null', 'w')
    521                         os.dup2(nullin.fileno(), sys.stdin.fileno())
    522                         os.dup2(nullout.fileno(), sys.stdout.fileno())
    523                         os.dup2(nullout.fileno(), sys.stderr.fileno())
    524                         if os.getuid()==0 and o.uid:
    525                                 try:
    526                                         os.setuid(int(o.uid))
    527                                 except:
    528                                         os.setuid(pwd.getpwnam(o.uid).pw_uid)
    529                 else:
    530                         try:
    531                                 file(o.pidfile,'w+').write(str(pid)+'\n')
    532                         except:
    533                                 pass
    534                         print 'AjaxTerm at http://localhost:%s/ pid: %d' % (o.port,pid)
    535                         sys.exit(0)
    536         else:
    537                 print 'AjaxTerm at http://localhost:%s/' % o.port
    538         at=AjaxTerm(o.cmd,o.index_file)
    539 #       f=lambda:os.system('firefox http://localhost:%s/&'%o.port)
    540 #       qweb.qweb_wsgi_autorun(at,ip='localhost',port=int(o.port),threaded=0,log=o.log,callback_ready=None)
    541         try:
    542                 qweb.QWebWSGIServer(at,ip='localhost',port=int(o.port),threaded=0,log=o.log).serve_forever()
    543         except KeyboardInterrupt,e:
    544                 sys.excepthook(*sys.exc_info())
    545         at.multi.die()
    546 
    547 if __name__ == '__main__':
    548         main()
    549 
Note: See TracChangeset for help on using the changeset viewer.