cfg-viewer.server Class Reference

Public Member Functions
def	__init__ (self, name)
def	printServer (self, name)

Detailed Description

Definition at line 1268 of file cfg-viewer.py.

Constructor & Destructor Documentation

def cfg-viewer.server.__init__	(		self,
			name
	)

Definition at line 1269 of file cfg-viewer.py.

References cfg-viewer.server.printServer().

  def __init__(self, name):
    self.printServer(name)

Member Function Documentation

def cfg-viewer.server.printServer	(		self,
			name
	)

Definition at line 1272 of file cfg-viewer.py.

Referenced by cfg-viewer.server.__init__().

  def printServer(self, name):
    with open(name, 'w') as f:
      f.write("""
#!/usr/bin/env python\nimport SimpleHTTPServer\nimport SocketServer
import shutil\nimport os\nimport cgi\nimport socket\nimport errno\n
#Right now cannot deal with SequenceTypes\nclass CfgConvert:
  def __init__(self, obj):\n    self._pName = obj["processName"]
    self._pFileN = obj["processFileName"]\n    obj.__delitem__("processName")
    obj.__delitem__("processFileName")\n    self._obj = obj
    self._func="cms.%s"
    self.header=\"""import FWCore.ParameterSet.Config as cms
process = cms.Process('%(n)s')\nfrom %(fileN)s import *\n%(changes)s\n\n\"""
  def _doConversion(self):\n    return self.header%(
    {"changes":self._doWork(self._obj),
     "n":self._pName,"fileN":self._pFileN})\n\n  def _doWork(self, obj):
    result =""\n    for key, value in obj.iteritems():
      _type = value["Type"]\n      _file = value["File"]
      _params = value["Parameters"]\n      _oType = value["oType"]
      if(_oType):\n        _oType= "'%s',"%(value["oType"])
      #f = eval(func%(_type))\n      if(type(_params)== list):
        if(len(_params)==0):
          result +="process.%s= cms.%s(%s)\\n"%(key,_type,_oType[:-1])
        else:\n          params = self._convert(_params)
          result+="process.%s= cms.%s(%s%s)\\n"%(key,_type,_oType, params)
      #elif(type(_params)== dict):
      #  return "Sorry path and endpaths can not currently be translated."
        #params = self._doWork(_params)\n      
      #obj = f("actualType", *parameters)\n    return result\n      
  def _convert(self,params):
    # NOTE: params do not take names inside functions
    # It is: name = cms.type(value)\n    # okay we have a list like 
    #[name,params, untracked,type]||[name,params,type]
    # 2 format options in the params\n    # 1. [["name", "value", "type"]]
    # 2. [["PsetName",[[as above or this]], "Pset"]]\n
    # At position 0 is name. list[0]==name or list[0]==list 
    # then that will be all
    # At position 1 is value or list. list[1]==value||list.
    # At position 2 is type. list[2] == type || untracked.
    # If there is a position 3 its type. list[3]== type.
    if(all(type(x) == list for x in params)):
      return ",".join([self._convert(x) for x in params])
    length = len(params)\n    if(length==1):
      if(type(params[0]) == list):\n        # wont have params[1]etc  
        # do inners\n        return  self._convert(params[0])
      #wrong format\n      print "Error 01 %s"%(str(params))\n      return ""
    if(length !=3 and length !=4):\n      #wrong format
      print "Error 02 len is %s"%(str(params))\n      return ""
    # okay get on with it.\n    name = params[0]
    if(type(params[1])==list):\n      # do listy things
      value = self._convert(params[1])\n    else:\n      value=params[1]
    ty = params[2]\n    if(name==ty):\n      name=""\n    if(length==4):
      ty+="."+params[3]\n      if(name== params[3]):\n        name=""
    if("vstring" in ty):\n      # split the value up by commas
      value = ",".join(["'%s'"%x for x in value.split(",")])
    elif("string" in ty):\n      #surround string with quotation marks
      value = "%s"%(value)\n    # okay now done with everything
    call= self._func%(ty)\n    if(name):
      return"%s=%s(%s)"%(name,call,value)\n    return"%s(%s)"%(call,value)\n
class ServerHandler(SimpleHTTPServer.SimpleHTTPRequestHandler):\n
  def do_GET(self):\n    if(self.path == "/index.html"):
      # find out what cfg html folders we have below
      # and add each main html page to the index\n      li = os.listdir(".")
      dEnd = "-cfghtml"
      dirs = [x for x in li if os.path.isdir(x) and x.endswith(dEnd)]
      name = "main.html"
      names = [os.path.join(x,name) for x in dirs if name in os.listdir(x)]
      tmpte = '<li><a href ="%(n)s">%(s)s</a></li>'
      lis = [tmpte%{"n":x,"s":os.path.split(x)[0].replace(dEnd, "")}
               for x in names]\n      with open("index.html", 'w') as f:
        f.write(\"""\n<!DOCTYPE html>\n<html>\n  <head>
    <meta http-equiv="Content-Type" content="text/html;charset=utf-8">
    <title>cfg-browser</title>\n  </head>\n  <body>
    <h4>Configuration files:</h4>\n    <ul>\n      %s\n    </ul>\n  </body>
</html>\n        \"""%("".join(lis)))\n      
    return SimpleHTTPServer.SimpleHTTPRequestHandler.do_GET(self)\n  
  def do_POST(self):
    ctype,pdict= cgi.parse_header(self.headers.getheader('content-type'))
    bdy = cgi.parse_multipart(self.rfile,pdict)
    ch= " ".join(bdy[bdy.keys()[0]])\n    self.conversion(eval(ch))
    self.writeFile()\n    print "finished writing"\n    
  def conversion(self, json):\n    # Need to convert my json into config
    result = CfgConvert(json)._doConversion()
    with open("changed_cfg.py", 'w')as f:\n      f.write(result)\n
  def writeFile(self):\n    with open("changed_cfg.py", 'rb') as f:
      self.send_response(200)
      self.send_header("Content-Type", 'text/html')
      self.send_header("Content-Disposition", 
                       'attachment; filename="changed_cfg.py"')
      fs = os.fstat(f.fileno())
      self.send_header("Content-Length", str(fs.st_size))
      self.end_headers()\n      shutil.copyfileobj(f, self.wfile)\n
def main(port=8000, reattempts=5):\n  if(port <1024):
    print \"""This port number may be refused permission.
It is better to use a port number > 1023.\"""\n  try:
    Handler = ServerHandler
    httpd = SocketServer.TCPServer(("", port), Handler)
    print "using port", port
    print "Open http://localhost:%s/index.html in your browser."%(port)
    httpd.serve_forever()\n  except socket.error as e:
    if(reattempts >0 and e[0] == errno.EACCES):
      print "Permission was denied."
    elif(reattempts >0 and e[0]== errno.EADDRINUSE):
      print "Address %s is in use."%(port)\n    else:\n      raise
    print "Trying again with a new port number."\n    if(port < 1024):
      port = 1024\n    else:\n      port = port +1
    main(port, reattempts-1)\n\nif __name__ == "__main__":\n  import sys
  if(len(sys.argv)>1):\n    try:\n      port = int(sys.argv[1])
      main(port)\n      sys.exit() \n    except ValueError:
      print "Integer not valid, using default port number."\n  main()
""")