1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
|
import cherrypy
from .db import DBPoolManager
from .types import Site
from .imapplugin import ImapPlugin
class Server():
def __init__(self,dbpool:DBPoolManager,site:Site,imap:ImapPlugin):
cherrypy.engine.subscribe("newpage",self.registerpage)
self.dbpool=dbpool
self.site=site
self.imap=imap
def registerpage(self,path,content,regentoken=None):
with self.dbpool.get_connection() as conn, conn.cursor() as cur:
cur.execute("CREATE TABLE IF NOT EXISTS pagecache ("
"path VARCHAR(100) PRIMARY KEY,"
"content MEDIUMTEXT,"
"generate VARCHAR(40)"
")")
cur.execute("INSERT INTO pagecache VALUES (?,?,?) ON DUPLICATE KEY UPDATE content=?, generate=?",(path,content,regentoken,content,regentoken))
conn.commit()
def getpage(self,path,**kwargs):
with self.dbpool.get_connection() as conn, conn.cursor() as cur:
cur.execute("SELECT content,generate FROM pagecache WHERE path=? LIMIT 1",(path,))
data=cur.fetchone()
if not data:
return
page,generate=data
if kwargs:
results=cherrypy.engine.publish('generate::'+generate,path=path,**kwargs)
if results:
return results[0]
else:
return page
@cherrypy.expose
def index(self,quote="nothing"):
import threading
self.site.update_trackers()
cherrypy.log("Listing threads:")
for thread in threading.enumerate():
cherrypy.log(repr(thread))
cherrypy.log("Threads holding an IMAP connection:")
for thread in self.imap.mbpool.holding_threads:
cherrypy.log(repr(thread))
from os import getenv
raise cherrypy.HTTPRedirect(getenv("ACIT_HOME_REDIRECT","about:blank"),303)
@cherrypy.expose(["style.css"])
def style(self):
from .html import style_css
cherrypy.response.headers["Content-Type"]="text/css"
return style_css
@cherrypy.expose
def default(self,*pathlist,**kwargs):
from os.path import normpath
path=normpath("/".join(pathlist))
page=self.getpage(path,**kwargs)
if not page:
from .html import notfound
cherrypy.response.status=404
return notfound.format(path=path)
else:
return page
|
