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
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
|
# -*- coding: utf-8 -*-
"""
Import Modules
Configure the Database
Instantiate Classes
"""
import datetime
import os
import re
import time
import traceback
import uuid
from lxml import etree
import gluon.contrib.simplejson as json
from gluon.sql import SQLCustomType
# All dates should be stored in UTC for Sync to work reliably
request.utcnow = datetime.datetime.utcnow()
########################
# Database Configuration
########################
migrate = deployment_settings.get_base_migrate()
db_string = deployment_settings.get_database_string()
if db_string[0].find("sqlite") != -1:
db = DAL(db_string[0], check_reserved=["mysql", "postgres"])
# on SQLite 3.6.19+ this enables foreign key support (included in Python 2.7+)
# db.executesql("PRAGMA foreign_keys=ON")
else:
# Tuple (inc pool_size)
try:
if db_string[0].find("mysql") != -1:
# Use MySQLdb where available (pymysql has given broken pipes)
try:
import MySQLdb
from gluon.dal import MySQLAdapter
MySQLAdapter.adapter = MySQLdb
except importError:
# Fallback to pymysql
pass
db = DAL(db_string[0], check_reserved=["postgres"], pool_size=db_string[1])
else:
# PostgreSQL
db = DAL(db_string[0], check_reserved=["mysql"], pool_size=db_string[1])
except:
db_type = db_string[0].split(":", 1)[0]
db_location = db_string[0].split("@", 1)[1]
raise(HTTP(503, "Cannot connect to %s Database: %s" % (db_type, db_location)))
#if request.env.web2py_runtime_gae: # if running on Google App Engine
#session.connect(request, response, db=db) # Store sessions and tickets in DB
### or use the following lines to store sessions in Memcache (GAE-only)
# from gluon.contrib.memdb import MEMDB
# from google.appengine.api.memcache import Client
# session.connect(request, response, db=MEMDB(Client())
###################################
# Instantiate Classes from Modules
###################################
from gluon.tools import Mail
mail = Mail()
# AAA
auth = s3base.AuthS3(globals(), deployment_settings, db)
s3_audit = s3base.S3Audit(db, session, migrate=migrate)
aURL = auth.permission.accessible_url
ADMIN = 1
# Shortcuts
s3_has_role = auth.s3_has_role
s3_has_permission = auth.s3_has_permission
s3_accessible_query = auth.s3_accessible_query
# Custom classes which extend default Gluon
FieldS3 = s3base.FieldS3
MENUS3 = s3base.MENUS3
crud = s3base.CrudS3(globals(), db)
S3ReusableField = s3base.S3ReusableField
from gluon.tools import Service
service = Service(globals())
from gluon.tools import callback
# Keep all S3 framework-level elements stored off here, so as to avoid polluting global namespace & to make it clear which part of the framework is being interacted with
# Avoid using this where a method parameter could be used: http://en.wikipedia.org/wiki/Anti_pattern#Programming_anti-patterns
s3 = Storage()
# S3 Custom Validators,
# imported here into the global namespace in order
# to access them without the s3base namespace prefix
exec("from applications.%s.modules.s3.s3validators import *" % request.application)
# Faster for Production (where app-name won't change):
#from applications.eden.modules.s3.s3validators import *
# S3 Custom Utilities and Widgets
# imported here into the global namespace in order
# to access them without the s3base namespace prefix
exec("from applications.%s.modules.s3.s3utils import *" % request.application)
exec("from applications.%s.modules.s3.s3widgets import *" % request.application)
# Faster for Production (where app-name won't change):
#from applications.eden.modules.s3.s3utils import *
#from applications.eden.modules.s3.s3widgets import *
# GIS Module
gis = s3base.GIS(globals(), deployment_settings, db, auth, cache=cache)
# VITA
vita = s3base.S3Vita(globals(), db)
# S3XRC
s3.crud = Storage()
s3xrc = s3base.S3ResourceController(globals(), db)
# MSG
msg = s3base.S3Msg(globals(), deployment_settings, db, T, mail)
# Tracking System
s3tracker = s3base.S3Tracking(globals())
# -----------------------------------------------------------------------------
def shn_auth_on_login(form):
"""
Actions to be performed upon successful login (Do not redirect from here!)
"""
# S3XRC last seen records (rcvars)
s3xrc.clear_session()
# Session-owned records
if "owned_records" in session:
del session["owned_records"]
# -----------------------------------------------------------------------------
def shn_auth_on_logout(user):
"""
Actions to be performed after logout (Do not redirect from here!)
"""
# S3XRC last seen records (rcvars)
s3xrc.clear_session()
# END
# *****************************************************************************
|