ZenModel.DataRoot

64 65 meta_type = portal_type = 'DataRoot' 66 67 manage_main = OrderedFolder.manage_main 68 69 manage_options = OrderedFolder.manage_options 70 71 #setTitle = DTMLFile('dtml/setTitle',globals()) 72 73 _rq = True 74 uuid = None 75 availableVersion = None 76 lastVersionCheck = 0 77 lastVersionCheckAttempt = 0 78 versionCheckOptIn = True 79 reportMetricsOptIn = True 80 acceptedTerms = True 81 smtpHost = 'localhost' 82 pageCommand = '$ZENHOME/bin/zensnpp localhost 444 $RECIPIENT' 83 smtpPort = 25 84 smtpUser = '' 85 smtpPass = '' 86 smtpUseTLS = 0 87 emailFrom = '' 88 iconMap = {} 89 geomapapikey = '' 90 geocache = '' 91 version = "" 92 93 _properties=( 94 {'id':'title', 'type': 'string', 'mode':'w'}, 95 {'id':'prodStateDashboardThresh','type':'int','mode':'w'}, 96 {'id':'prodStateConversions','type':'lines','mode':'w'}, 97 {'id':'priorityConversions','type':'lines','mode':'w'}, 98 {'id':'priorityDashboardThresh','type':'int','mode':'w'}, 99 {'id':'statusConversions','type':'lines','mode':'w'}, 100 {'id':'interfaceStateConversions','type':'lines','mode':'w'}, 101 {'id':'administrativeRoles','type':'lines','mode':'w'}, 102 {'id':'uuid', 'type': 'string', 'mode':'w'}, 103 {'id':'availableVersion', 'type': 'string', 'mode':'w'}, 104 {'id':'lastVersionCheck', 'type': 'long', 'mode':'w'}, 105 {'id':'lastVersionCheckAttempt', 'type': 'long', 'mode':'w'}, 106 {'id':'versionCheckOptIn', 'type': 'boolean', 'mode':'w'}, 107 {'id':'reportMetricsOptIn', 'type': 'boolean', 'mode':'w'}, 108 {'id':'smtpHost', 'type': 'string', 'mode':'w'}, 109 {'id':'smtpPort', 'type': 'int', 'mode':'w'}, 110 {'id':'pageCommand', 'type': 'string', 'mode':'w'}, 111 {'id':'smtpUser', 'type': 'string', 'mode':'w'}, 112 {'id':'smtpPass', 'type': 'string', 'mode':'w'}, 113 {'id':'smtpUseTLS', 'type': 'int', 'mode':'w'}, 114 {'id':'emailFrom', 'type': 'string', 'mode':'w'}, 115 {'id':'geomapapikey', 'type': 'string', 'mode':'w'}, 116 {'id':'geocache', 'type': 'string', 'mode':'w'}, 117 ) 118 119 _relations = ( 120 ('userCommands', ToManyCont(ToOne, 'Products.ZenModel.UserCommand', 'commandable')), 121 # packs is depracated. Has been moved to dmd.ZenPackManager.packs 122 # Should be removed post Zenoss 2.2 123 # TODO 124 ('packs', ToManyCont(ToOne, 'Products.ZenModel.ZenPack', 'root')), 125 ('zenMenus', ToManyCont( 126 ToOne, 'Products.ZenModel.ZenMenu', 'menuable')), 127 ) 128 129 # Screen action bindings (and tab definitions) 130 factory_type_information = ( 131 { 132 'id' : 'DataRoot', 133 'meta_type' : 'DataRoot', 134 'description' : """Arbitrary device grouping class""", 135 'icon' : 'DataRoot_icon.gif', 136 'product' : 'ZenModel', 137 'factory' : 'manage_addStatusMonitorconf', 138 'immediate_view' : 'Dashboard', 139 'actions' : 140 ( 141 { 'id' : 'settings' 142 , 'name' : 'Settings' 143 , 'action' : 'editSettings' 144 , 'permissions' : ( "Manage DMD", ) 145 }, 146 { 'id' : 'manage' 147 , 'name' : 'Commands' 148 , 'action' : 'dataRootManage' 149 , 'permissions' : ('Manage DMD',) 150 }, 151 { 'id' : 'users' 152 , 'name' : 'Users' 153 , 'action' : 'ZenUsers/manageUserFolder' 154 , 'permissions' : ( 'Manage DMD', ) 155 }, 156 { 'id' : 'packs' 157 , 'name' : 'ZenPacks' 158 , 'action' : 'ZenPackManager/viewZenPacks' 159 , 'permissions' : ( "Manage DMD", ) 160 }, 161 { 'id' : 'jobs' 162 , 'name' : 'Jobs' 163 , 'action' : 'joblist' 164 , 'permissions' : ( "Manage DMD", ) 165 }, 166 { 'id' : 'menus' 167 , 'name' : 'Menus' 168 , 'action' : 'editMenus' 169 , 'permissions' : ( "Manage DMD", ) 170 }, 171 { 'id' : 'portlets' 172 , 'name' : 'Portlets' 173 , 'action' : 'editPortletPerms' 174 , 'permissions' : ( "Manage DMD", ) 175 }, 176 { 'id' : 'daemons' 177 , 'name' : 'Daemons' 178 , 'action' : '../About/zenossInfo' 179 , 'permissions' : ( "Manage DMD", ) 180 }, 181 { 'id' : 'versions' 182 , 'name' : 'Versions' 183 , 'action' : '../About/zenossVersions' 184 , 'permissions' : ( "Manage DMD", ) 185 }, 186 { 'id' : 'backups' 187 , 'name' : 'Backups' 188 , 'action' : 'backupInfo' 189 , 'permissions' : ( "Manage DMD", ) 190 }, 191 ) 192 }, 193 ) 194 195 security = ClassSecurityInfo() 196 197 # production state threshold at which devices show on dashboard 198 prodStateDashboardThresh = 1000 199 200 # priority threshold at which devices show on dashboard 201 priorityDashboardThresh = 2 202 203 prodStateConversions = [ 204 'Production:1000', 205 'Pre-Production:500', 206 'Test:400', 207 'Maintenance:300', 208 'Decommissioned:-1', 209 ] 210 211 priorityConversions = [ 212 'Highest:5', 213 'High:4', 214 'Normal:3', 215 'Low:2', 216 'Lowest:1', 217 'Trivial:0', 218 ] 219 220 statusConversions = [ 221 'Up:0', 222 'None:-1', 223 'No DNS:-2', 224 ] 225 226 interfaceStateConversions = [ 227 'up:1', 228 'down:2', 229 'testing:3', 230 'unknown:4', 231 'dormant:5', 232 'notPresent:6', 233 'lowerLayerDown:7', 234 ] 235 236 administrativeRoles = ( 237 "Administrator", 238 "Analyst", 239 "Engineer", 240 "Tester", 241 ) 242 243 defaultDateRange = 129600 244 performanceDateRanges = [ 245 ('Hourly',129600,), 246 ('Daily',864000,), 247 ('Weekly',3628800,), 248 ('Monthly',41472000,), 249 ('Yearly',62208000,) 250 ] 251 252 253 # when calculating the primary path this will be its root 254 zPrimaryBasePath = ("", "zport") 255 256

257 - def __init__(self, id, title=None):

258 ZenModelRM.__init__(self, id, title) 259 from ZVersion import VERSION 260 self.version = "Zenoss " + VERSION

261 262 263 #def index_html(self): 264 # """ 265 # Override to force redirection to quickstart. 266 # """ 267 # if not self._rq: 268 # return self.unrestrictedTraverse('quickstart')() 269 # return self() 270

271 - def getEventCount(self, **kwargs):

272 """Return the current event list for this managed entity. 273 """ 274 return self.ZenEventManager.getEventCount(**kwargs)

275 276 277 security.declareProtected(ZEN_COMMON, 'getEventClassNames')

278 - def getEventClassNames(self):

279 """ 280 Get a list of all event class names within the permission scope. 281 """ 282 return self.Events.getOrganizerNames()

283 284

285 - def getDmdRoots(self):

286 return filter(lambda o: o.isInTree, self.objectValues())

287 288

289 - def exportXmlHook(self,ofile, ignorerels):

290 map(lambda x: x.exportXml(ofile, ignorerels), self.getDmdRoots())

291 292 293 security.declareProtected(ZEN_COMMON, 'getProdStateConversions')

294 - def getProdStateConversions(self):

295 """getProdStateConversions() -> return a list of tuples 296 for prodstat select edit box""" 297 return self.getConversions(self.prodStateConversions)

298 299 300 security.declareProtected(ZEN_COMMON, 'convertProdState')

301 - def convertProdState(self, prodState):

302 '''convert a numeric production state to a 303 textual representation using the prodStateConversions 304 map''' 305 return self.convertAttribute(prodState, self.prodStateConversions)

306 307 308 security.declareProtected(ZEN_COMMON, 'getStatusConversions')

309 - def getStatusConversions(self):

310 """get text strings for status field""" 311 return self.getConversions(self.statusConversions)

312 313 314 security.declareProtected(ZEN_COMMON, 'convertStatus')

315 - def convertStatus(self, status):

316 """get text strings for status field""" 317 return self.convertAttribute(status, self.statusConversions)

318 319 security.declareProtected(ZEN_COMMON, 'getPriorityConversions')

320 - def getPriorityConversions(self):

321 return self.getConversions(self.priorityConversions)

322 323 security.declareProtected(ZEN_COMMON, 'convertPriority')

324 - def convertPriority(self, priority):

325 return self.convertAttribute(priority, self.priorityConversions)

326 327 security.declareProtected(ZEN_COMMON, 'getInterfaceStateConversions')

328 - def getInterfaceStateConversions(self):

329 """get text strings for interface status""" 330 if hasattr(self, 'interfaceStateConversions'): 331 return self.getConversions(self.interfaceStateConversions)

332 333 334 security.declareProtected(ZEN_COMMON, 'convertAttribute')

335 - def convertAttribute(self, numbValue, conversions):

336 '''convert a numeric production state to a 337 textual representation using the prodStateConversions 338 map''' 339 numbValue = int(numbValue) 340 for line in conversions: 341 line = line.rstrip() 342 (name, number) = line.split(':') 343 if int(number) == numbValue: 344 return name 345 return numbValue

346 347 security.declareProtected(ZEN_COMMON, 'convertStatusToDot')

348 - def convertStatusToDot(self, status):

349 colors = ['green', 'yellow', 'orange', 'red'] 350 try: 351 return colors[status] 352 except IndexError: 353 return 'grey'

354 355 security.declareProtected(ZEN_COMMON, 'getConversions')

356 - def getConversions(self, attribute):

357 """get the text list of itmes that convert to ints""" 358 convs = [] 359 for item in attribute: 360 tup = item.split(':') 361 try: 362 tup[1] = int(tup[1]) 363 except (IndexError, ValueError): 364 continue 365 convs.append(tup) 366 return convs

367 368 security.declarePublic('filterObjectsRegex')

369 - def filterObjectsRegex(self, filter, objects, 370 filteratt='id', negatefilter=0):

371 """filter a list of objects based on a regex""" 372 filter = re.compile(filter).search 373 filteredObjects = [] 374 for obj in objects: 375 value = getattr(obj, filteratt, None) 376 if callable(value): 377 value = value() 378 fvalue = filter(value) 379 if (fvalue and not negatefilter) or (not fvalue and negatefilter): 380 filteredObjects.append(obj) 381 return filteredObjects

382 383 384 security.declareProtected('View', 'myUserGroups')

385 - def myUserGroups(self):

386 user = self.REQUEST.get('AUTHENTICATED_USER') 387 if hasattr(user, 'getGroups'): 388 return user.getGroups() 389 else: 390 return ()

391 392 393 security.declareProtected('View', 'getAllUserGroups')

394 - def getAllUserGroups(self):

395 return self.acl_users.getGroups()

396 397 398 security.declareProtected(ZEN_VIEW, 'zenoss_error_message')

399 - def zenoss_error_message(self,error_type,error_value, 400 error_traceback,error_message):

401 """Return an error page that is more friendly then the standard stack 402 trace + feedback page for ConflictErrors and MySQL errors (we need to 403 add out of disk space errors). If one of these is not found we return 404 the old stacktrace page 405 """ 406 from ZODB.POSException import ConflictError 407 from Products.ZenEvents.Exceptions import MySQLConnectionError 408 from _mysql_exceptions import MySQLError 409 if isinstance(error_value, ConflictError): 410 return self.zenoss_conflict_error_message() 411 elif isinstance(error_value, MySQLConnectionError) \ 412 or isinstance(error_value, MySQLError): 413 return self.zenoss_mysql_error_message(error_value=error_value) 414 return self.zenoss_feedback_error_message(error_type=error_type, 415 error_value=error_value, 416 error_traceback=error_traceback)

417 418

419 - def reportError(self):

420 ''' send an email to the zenoss error email address 421 then send user to a thankyou page or an email error page. 422 ''' 423 if self.smtpHost: host = self.smtpHost 424 else: host = None 425 port = self.smtpPort and self.smtpPort or 25 426 usetls = self.smtpUseTLS 427 usr = self.smtpUser 428 pwd = self.smtpPass 429 430 mailSent = SiteError.sendErrorEmail( 431 self.REQUEST.errorType, 432 self.REQUEST.errorValue, 433 self.REQUEST.errorTrace, 434 self.REQUEST.errorUrl, 435 self.About.getZenossRevision(), 436 self.About.getZenossVersionShort(), 437 self.REQUEST.contactName, 438 self.REQUEST.contactEmail, 439 self.REQUEST.comments, 440 host, port, usetls, usr, pwd) 441 if not mailSent: 442 body = SiteError.createReport( 443 self.REQUEST.errorType, 444 self.REQUEST.errorValue, 445 self.REQUEST.errorTrace, 446 self.REQUEST.errorUrl, 447 self.About.getZenossRevision(), 448 self.About.getZenossVersionShort(), 449 True, 450 self.REQUEST.contactName, 451 self.REQUEST.contactEmail, 452 self.REQUEST.comments) 453 return self.errorEmailFailure(toAddress=SiteError.ERRORS_ADDRESS, 454 body=body) 455 return self.errorEmailThankYou()

456 457 458 #security.declareProtected('View', 'writeExportRows')

459 - def writeExportRows(self, fieldsAndLabels, objects, out=None):

460 '''Write out csv rows with the given objects and fields. 461 If out is not None then call out.write() with the result and return None 462 otherwise return the result. 463 Each item in fieldsAndLabels is either a string representing a 464 field/key/index (see getDataField) or it is a tuple of (field, label) 465 where label is the string to be used in the first row as label 466 for that column. 467 Objects can be either dicts, lists/tuples or other objects. Field 468 is interpreted as a key, index or attribute depending on what 469 object is. 470 Method names can be passed instead of attribute/key/indices as field. 471 In this case the method is called and the return value is used in 472 the export. 473 ''' 474 import csv 475 import StringIO 476 if out: 477 buffer = out 478 else: 479 buffer = StringIO.StringIO() 480 fields = [] 481 labels = [] 482 if not fieldsAndLabels: 483 fieldsAndLabels = [] 484 if not objects: 485 objects = [] 486 for p in fieldsAndLabels: 487 if isinstance(p, tuple): 488 fields.append(p[0]) 489 labels.append(p[1]) 490 else: 491 fields.append(p) 492 labels.append(p) 493 writer = csv.writer(buffer) 494 writer.writerow(labels) 495 def getDataField(thing, field): 496 if isinstance(thing, dict): 497 value = thing.get(field, '') 498 elif isinstance(thing, list) or isinstance(thing, tuple): 499 value = thing[int(field)] 500 else: 501 value = getattr(thing, field, '') 502 if isinstance(value, ZenModelBase): 503 value = value.id 504 elif callable(value): 505 value = value() 506 if value == None: 507 value = '' 508 return str(value)

509 for o in objects: 510 writer.writerow([getDataField(o,f) for f in fields]) 511 if out: 512 result = None 513 else: 514 result = buffer.getvalue() 515 return result

Source Code for Module ZenModel.DataRoot