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
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
|
from Form import *
from Table import *
from Module import *
from consts import *
NOTE_SOURCE = 'The source can be either a local interpreter or a remote host acting as an application server.'
NOTE_BALANCER = 'Allow to select how the connections will be dispatched.'
class ModuleBalancerGeneric (Module, FormHelper):
def __init__ (self, cfg, prefix, submit_url, name):
FormHelper.__init__ (self, name, cfg)
Module.__init__ (self, name, cfg, prefix, submit_url)
# Set the initial values
self.default_type = 'interpreter'
self.allow_type_change = True
self._type = None
def _get_type (self, post=None):
# Post
if post:
new_type = post.get_val('%s!type'%(self._prefix))
if new_type:
return new_type
# Config
t = self._cfg.get_val ('%s!type'%(self._prefix))
if not t:
return self.default_type
return t
def _op_render (self):
txt = ''
# Get the host/interpreter list
try:
cfg = self._cfg[self._prefix]
hosts = filter (lambda x: x != 'type', cfg)
except:
hosts = []
# Read the type
if not self._type:
self._type = self._get_type()
# Options
if self.allow_type_change:
table = TableProps()
self.AddPropOptions_Reload (table, "Information sources",
"%s!type" % (self._prefix),
BALANCER_TYPES, NOTE_SOURCE)
txt += str(table)
if self._type == 'host':
# Host list
if hosts:
t1 = Table(2,1)
t1 += ('Host', '')
for host in hosts:
pre = '%s!%s' % (self._prefix, host)
e_host = self.InstanceEntry('%s!host'%(pre), 'text')
js = "post_del_key('/ajax/update', '%s');" % (pre)
link_del = self.InstanceImage ("bin.png", "Delete", border="0", onClick=js)
t1 += (e_host, link_del)
txt += str(t1)
# New host
t1 = Table(2,1)
t1 += ('New host', '')
en1 = self.InstanceEntry('new_host', 'text')
t1 += (en1, SUBMIT_ADD)
txt += str(t1)
elif self._type == 'interpreter':
# Interpreter list
if hosts:
for host in hosts:
pre = '%s!%s' % (self._prefix, host)
e_host = self.InstanceEntry('%s!host'%(pre), 'text')
e_inte = self.InstanceEntry('%s!interpreter'%(pre), 'text')
e_envs = self._render_envs('%s!env'%(pre))
t2 = Table(2, title_left=1)
t2 += ('Host', e_host)
t2 += ('Interpreter', e_inte)
t2 += ('Environment', e_envs)
txt += str(t2)
txt += "<hr />"
if txt.endswith("<hr />"):
txt = txt[:-6]
# New Interpreter
t2 = Table(3,1)
t2 += ('Host', 'Interpreter', '')
e_host = self.InstanceEntry('new_host', 'text', size=25)
e_inte = self.InstanceEntry('new_interpreter', 'text', size=25)
t2 += (e_host, e_inte, SUBMIT_ADD)
txt += str(t2)
else:
txt = 'UNKNOWN type: ' + str(self._type)
return txt
def _render_envs (self, cfg_key):
txt = ''
cfg = self._cfg[cfg_key]
# Current environment
if cfg and cfg.has_child():
table = Table(4)
for env in cfg:
host = cfg_key.split('!')[1]
cfg_key_env = "%s!%s" % (cfg_key, env)
js = "post_del_key('/ajax/update', '%s');" % (cfg_key_env)
link_del = self.InstanceImage ("bin.png", "Delete", border="0", onClick=js)
table += (env, '=', self._cfg[cfg_key_env].value, link_del)
txt += str(table)
# Add new environment variable
en_env = self.InstanceEntry('balancer_new_env', 'text', size=20)
en_val = self.InstanceEntry('balancer_new_env_val', 'text', size=20)
hidden = self.HiddenInput ('balancer_new_env_key', cfg_key)
table = Table(3,1)
table += ('Variable', 'Value', '')
table += (en_env, en_val, SUBMIT_ADD)
txt += str(table) + hidden
return txt
def __find_name (self):
i = 1
while True:
key = "%s!%d" % (self._prefix, i)
tmp = self._cfg[key]
if not tmp:
return str(i)
i += 1
def _op_apply_changes (self, uri, post):
# Type
if not self._type:
self._type = self._get_type (post)
self._cfg['%s!type'%(self._prefix)] = self._type
# Addind new host/interpreter
new_host = post.pop('new_host')
new_interpreter = post.pop('new_interpreter')
if new_host or new_interpreter:
num = self.__find_name()
if new_host:
key = "%s!%s!host" % (self._prefix, num)
self._cfg[key] = new_host
if new_interpreter and \
self._type == 'interpreter':
key = "%s!%s!interpreter" % (self._prefix, num)
self._cfg[key] = new_interpreter
# New environment variable
if self._type == 'interpreter':
env = post.pop('balancer_new_env')
val = post.pop('balancer_new_env_val')
key = post.pop('balancer_new_env_key')
if env and val and key:
self._cfg["%s!%s"%(key, env)] = val
# Everything else
self.ApplyChanges ([], post)
|
