X-Git-Url: http://dolda2000.com/gitweb/?a=blobdiff_plain;f=wrw%2Futil.py;h=ed32cc6a3f3de4a98a3ea00942c2065856ae97ca;hb=ca3dce3812e3fc65f4c021aa76ee1430b47ad3af;hp=bf78f8e9f6f48efe4b4b876a5d8bae820c72f137;hpb=a7a0908019bb95bb2be1c01e97e88f344807ccec;p=wrw.git diff --git a/wrw/util.py b/wrw/util.py index bf78f8e..ed32cc6 100644 --- a/wrw/util.py +++ b/wrw/util.py @@ -1,9 +1,10 @@ -import inspect -from . import req, dispatch, session, form +import inspect, math +from . import req, dispatch, session, form, resp, proto def wsgiwrap(callable): def wrapper(env, startreq): return dispatch.handleenv(env, startreq, callable) + wrapper.__wrapped__ = callable return wrapper def stringwrap(charset): @@ -25,9 +26,51 @@ def formparams(callable): for arg in list(args): if arg not in spec.args: del args[arg] + for i in range(len(spec.args) - len(spec.defaults)): + if spec.args[i] not in args: + raise resp.httperror(400, "Missing parameter", ("The query parameter `", resp.h.code(spec.args[i]), "' is required but not supplied.")) return callable(**args) + wrapper.__wrapped__ = callable return wrapper +class funplex(object): + def __init__(self, *funs, **nfuns): + self.dir = {} + self.dir.update(((self.unwrap(fun).__name__, fun) for fun in funs)) + self.dir.update(nfuns) + + @staticmethod + def unwrap(fun): + while hasattr(fun, "__wrapped__"): + fun = fun.__wrapped__ + return fun + + def __call__(self, req): + if req.pathinfo == "": + raise resp.redirect(req.uriname + "/") + if req.pathinfo[:1] != "/": + raise resp.notfound() + p = req.pathinfo[1:] + if p == "": + p = "__index__" + bi = 1 + else: + p = p.partition("/")[0] + bi = len(p) + 1 + if p in self.dir: + return self.dir[p](req.shift(bi)) + raise resp.notfound() + + def add(self, fun): + self.dir[self.unwrap(fun).__name__] = fun + return fun + + def name(self, name): + def dec(fun): + self.dir[name] = fun + return fun + return dec + def persession(data = None): def dec(callable): def wrapper(req): @@ -40,6 +83,7 @@ def persession(data = None): sess[data] = data() sess[callable] = callable(data) return sess[callable].handle(req) + wrapper.__wrapped__ = callable return wrapper return dec @@ -72,6 +116,7 @@ class preiter(object): def pregen(callable): def wrapper(*args, **kwargs): return preiter(callable(*args, **kwargs)) + wrapper.__wrapped__ = callable return wrapper class sessiondata(object): @@ -217,3 +262,10 @@ class specdirty(sessiondata, metaclass=specclass): ss[i] = specslot.unbound else: ss[i] = val + +def datecheck(req, mtime): + if "If-Modified-Since" in req.ihead: + rtime = proto.phttpdate(req.ihead["If-Modified-Since"]) + if rtime >= math.floor(mtime): + raise resp.unmodified() + req.ohead["Last-Modified"] = proto.httpdate(mtime)