1 #--系统函数--
   2 def _charsetGB2312(fn):
   3     '''函数包装函数，将页面设为gb2312'''
   4     def _init(dgn,*args):
   5         dgn.set_charset('gb2312')
   6         return fn(dgn,*args)
   7     return _init
   8 def _baseAuth(dgn,func,realm='Protected'):
   9     '''权限函数，只有我能上'''
  10     t=dgn.get_baseauth()
  11     if t is not  None and t==('lihui','password'):
  12         result=None
  13     else:
  14         dgn.set_status(401)
  15         dgn.set_header('WWW-Authenticate', 'Basic realm="%s"' % realm)
  16         result=True
  17     return result
  18 #--web前端--
  19 def helloworld1(dgn):
  20     '''发布一个函数,dgn为数据api集中调用入口，为第一个参数,dgn使用的singlon模式，除系统内置定义外，可自行加入定义，比如dbpool,可定义为dgn.db.dbpool
  21 '''
  22     return 'helloworld1'
  23 
  24 def helloworld2(dgn):
  25     '''发布一个函数,加个权限'''
  26     return 'helloworld1'
  27 helloworld2._q_access=_baseAuth
  28 
  29 def helloworld3(dgn):
  30     '''发布一个函数,gb2312发布'''
  31     return 'helloworld1'
  32 helloworld3=_charsetGB2312(helloworld3)
  33 
  34 def helloworld4(dgn,*args):
  35     '''有args的支持default,比如这个函数url为http:/***/p,这个http:/***/p/1/1/1.html,则转为args=['1','1','1.html']'''
  36     return 'helloworld1'
  37 
  38 def helloworld5(dgn):
  39     '''发布一个图形文件'''
  40     return 图文件
  41 
  42 
  43 def images(dgn,*args):
  44     '''发布images子目录，静态目录'''
  45     return dgn.StaticDirectory(os.path.join(dgn.get_config().path_top,'images'),*args)
  46 
  47 #--发布函数
  48 def root():
  49     result=helloworld1
  50     result.images=images
  51     result.hl2=helloworld2
  52     result.hl3=helloworld3
  53     result.hl4=helloworld4
  54     result.hl5_jpg=helloworld5  #扩展名为jpg
  55     return result

   1 import urlparse
   2 import sys
   3 import os.path
   4 import os
   5 import time
   6 from cStringIO import StringIO
   7 import posixpath
   8 import urllib
   9 import string
  10 
  11 from quixote.publish import Publisher as _Publisher
  12 import quixote.publish
  13 from quixote.http_response import HTTPResponse as _HTTPResponse
  14 from quixote.util import FileStream
  15 from quixote.config import Config
  16 from quixote.http_response import HTTPResponse
  17 from quixote.logger import DefaultLogger
  18 
  19 
  20 
  21 #------------------------------------------------------
  22 
  23 my_k_config=dict(
  24     initFile='Karrigell.ini',
  25     PORT=8080,
  26     protectedDirs=['D:\\pythonMy\\KarrigellLib\\admin'],
  27     alias={'doc':'D:\\pythonMy\\KarrigellLib/doc','base':'D:\\pythonMy\\KarrigellLib'},
  28     globalScriptsList=['D:\\pythonMy\\KarrigellLib/myScript1.py','D:\\pythonMy\\KarrigellLib/myScript.py'],
  29     globalScripts=['myScript1','myScript'],
  30     extensions_map={'.gif':'image/gif','.jpg':'image/jpeg','.py':'text/html','.nwc':'application/nwc','.html':'text/html','.htm':'text/html'},
  31     debug=1,
  32     base='',
  33     persistentSession=False,
  34     silent=False,
  35     language='',
  36     ignore=['/favicon.ico'],
  37     serverDir=r'D:\pythonMy\KarrigellLib',
  38     #rootDir=r'D:\pythonMy\KarrigellLib',
  39     extensions=['gif','html','nwc','htm','py','jpg'],
  40     gzip=False,
  41     )
  42 
  43 
  44 import  KarrigellLib
  45 m=os.path.dirname(os.path.abspath(KarrigellLib.__file__))
  46 if m not in sys.path:
  47     sys.path.append(m)
  48 
  49 msave=sys.argv
  50 sys.argv=[]
  51 import k_config
  52 sys.argv=msave
  53 
  54 for k,v in my_k_config.items():
  55     setattr(k_config,k,v)
  56 k_config.serverDir=os.path.dirname(os.path.abspath(k_config.__file__))
  57 if  not  k_config.alias.has_key('debugger'):
  58     k_config.alias['debugger']=os.path.join(k_config.serverDir,'debugger')
  59 if not  k_config.alias.has_key('demo'):
  60     k_config.alias['demo']=os.path.join(k_config.serverDir,'demo')
  61 if not  k_config.alias.has_key('fckeditor'):
  62     k_config.alias['fckeditor']=os.path.join(k_config.serverDir,'fckeditor')
  63 if not  k_config.alias.has_key('doc'):
  64     k_config.alias['doc']=os.path.join(k_config.serverDir,'doc')
  65 if not  k_config.alias.has_key('instant_site'):
  66     k_config.alias['instant_site']=os.path.join(k_config.serverDir,'instant_site')
  67 if not  k_config.alias.has_key('components'):
  68     k_config.alias['components']=os.path.join(k_config.serverDir,'components')
  69 if not  k_config.alias.has_key('listDirectory.pih'):
  70     k_config.alias['listDirectory.pih']=os.path.join(k_config.serverDir,'listDirectory.pih')
  71 if not  k_config.alias.has_key('karrigell.css'):
  72     k_config.alias['karrigell.css']=os.path.join(k_config.serverDir,'karrigell.css')
  73 if  not  k_config.alias.has_key('admin'):
  74     k_config.alias['admin']=os.path.join(k_config.serverDir,'admin')
  75 
  76 
  77 
  78 paths=[]
  79 paths.append(os.path.join(k_config.serverDir,'databases'))
  80 for v in paths:
  81     if v not in sys.path:
  82         sys.path.append(v)
  83 
  84 
  85 import SimpleHTTPServer, KarrigellRequestHandler, URLResolution,Template
  86 
  87 
  88 
  89 def translate_path(path):
  90     """Overrides SimpleHTTPServer's translate_path to handle aliases
  91     Returns the path to a file name"""
  92     path = posixpath.normpath(urllib.unquote(path))
  93     path = path[len(k_config.base):]    # remove base beginning the url
  94     words = path.split('/')
  95     words = filter(None, words)
  96     # for ks scripts, path ends at the word ending with "ks"
  97     w1,w2=[],[]
  98     for i,word in enumerate(words):
  99         w1.append(word)
 100         if word.lower().endswith(".ks"):
 101             w2=words[i+1:]
 102             break
 103     words=w1
 104     m=words[-1]
 105     if m.endswith('.html') and '_' in m:
 106         words[-1]=m.split('_',1)[0]
 107     if words and words[0] in k_config.alias.keys():
 108         path=posixpath.normpath(k_config.alias[words[0]])
 109         path=os.path.join(k_config.alias[words[0]],string.join(words[1:],"/"))
 110     else:
 111         path=os.path.join(k_config.rootDir,string.join(words,"/"))
 112     return path
 113 
 114 def list_directory(path,dirName):
 115     script = Template.getScript(os.path.join(k_config.serverDir,'listDirectory.pih'))
 116     return script.render({'path':path,'dirName':dirName}).value
 117 
 118 setattr(Template,'list_directory',list_directory)
 119 setattr(URLResolution,'translate_path',translate_path)
 120 
 121 
 122 
 123 
 124 class QuixoteHandler(KarrigellRequestHandler.KarrigellRequestHandler,SimpleHTTPServer.SimpleHTTPRequestHandler):
 125     def __init__(self, request):
 126         self.response_status=(200,'OK')
 127         self.response_headers=[]
 128         self.request = request
 129         self.wfile = StringIO()
 130         fs=request.get_fields()
 131         self.headers=dict(request.environ.items())
 132         for item in self.headers.keys():
 133             if item.startswith("HTTP_"):
 134                 hd=item[5:]
 135                 self.headers[hd.lower()]=self.headers[item]
 136         self.command = self.headers['REQUEST_METHOD']
 137         self.body = {}
 138         if self.command == 'POST':
 139             self.body=fs
 140         self.client_address=(self.headers["REMOTE_ADDR"],0)
 141         self.path=self.path_without_qs=self.headers["PATH_INFO"]
 142         if self.headers.has_key("QUERY_STRING"):
 143             self.path+="?"+self.headers["QUERY_STRING"]
 144         self.request_version=self.headers["SERVER_PROTOCOL"]
 145         self.requestline="%s %s %s" %(self.headers["SERVER_PROTOCOL"],
 146             self.headers["REQUEST_METHOD"],self.path)
 147         try:
 148             self.handle_data()
 149         finally:
 150             sys.exc_traceback = None    # Help garbage collection
 151 
 152     def send_response(self,status, reason=None):
 153         self.response_status=(status, reason)
 154     def send_header(self,key,value):
 155         self.response_headers.append((key,value))
 156     def end_headers(self):
 157         pass
 158 
 159 
 160 
 161 class Publisher(_Publisher):
 162 
 163     def __init__(self, root_directory, logger=None, session_manager=None,config=None, **kwargs):
 164         if config is None:
 165             self.config = Config(**kwargs)
 166         else:
 167             if kwargs:
 168                 raise ValueError("cannot provide both 'config' object and"
 169                                  " config arguments")
 170             self.config = config
 171         for k in my_k_config.keys():
 172             if hasattr(self.config,k.lower()):
 173                 setattr(k_config,k,getattr(self.config,k.lower()))
 174         if logger is None:
 175             self.logger = DefaultLogger(error_log=self.config.error_log,
 176                                         access_log=self.config.access_log,
 177                                         error_email=self.config.error_email)
 178         else:
 179             self.logger = logger
 180         if session_manager is not None:
 181             self.session_manager = session_manager
 182         else:
 183             from quixote.session import NullSessionManager
 184             self.session_manager = NullSessionManager()
 185 
 186         if quixote.publish._publisher is not None:
 187             raise RuntimeError, "only one instance of Publisher allowed"
 188         quixote.publish._publisher = self
 189 
 190         self.root_directory = root_directory
 191         if hasattr(root_directory,'__file__'):
 192             k_config.rootDir=os.path.dirname(os.path.abspath(root_directory.__file__))
 193         self._request = None
 194 
 195 
 196     def try_publish(self, request):
 197         self.start_request()
 198         path = request.get_environ('PATH_INFO', '')
 199         assert path[:1] == '/'
 200         # split path into components
 201         path = path[1:].split('/')
 202         t=QuixoteHandler(request)
 203         request.response.set_status(t.response_status[0])
 204         for v in t.response_headers:
 205             request.response.set_header(v[0],v[1])
 206         output = t.wfile.getvalue()
 207         # The callable ran OK, commit any changes to the session
 208         self.finish_successful_request()
 209         return output