node.sync()
self.object_ids = [site['site_id'], node['node_id']]
+ self.message = "Node %s created" % node['node_id']
return node['node_id']
nodegroup = NodeGroup(self.api, nodegroup_fields)
nodegroup.sync()
+ # Logging variables
self.object_ids = [nodegroup['nodegroup_id']]
-
+ self.message = 'Node group %d created' % nodegroup['nodegroup_id']
+
return nodegroup['nodegroup_id']
if not node['nodenetwork_ids']:
nodenetwork['is_primary'] = True
nodenetwork.sync()
-
+
+ # Logging variables
self.object_ids = [node['node_id'], nodenetwork['nodenetwork_id']]
+ self.messgage = "Node network %d added" % nodenetwork['nodenetwork_id']
return nodenetwork['nodenetwork_id']
# add node to nodegroup
if node['node_id'] not in nodegroup['node_ids']:
nodegroup.add_node(node)
+
+ # Logging variables
self.object_ids = [nodegroup['nodegroup_id']]
-
+ self.message = 'Node %d added to node group %d' % \
+ (node['node_id'], nodegroup['nodegroup_id'])
return 1
pcu.add_node(node, port)
+ # Logging variables
self.object_ids = [node['node_id'], pcu['pcu_id']]
-
+ self.message = 'Node %d added to pcu %d on port %d' % \
+ (node['node_id'], pcu['pcu_id'], port)
return 1
pcu['site_id'] = site['site_id']
pcu.sync()
+ # Logging variables
self.object_ids = [site['site_id'], pcu['pcu_id']]
+ self.message = 'PCU %d added site %s' % \
+ (pcu['pcu_id'], site['site_id'])
return pcu['pcu_id']
person = Person(self.api, person_fields)
person.sync()
+ # Logging variables
self.object_ids = [person['person_id']]
+ self.message = 'Person %d added' % person['person_id']
return person['person_id']
key.sync(commit = False)
person.add_key(key, commit = True)
- self.object_ids = [person['person_id'], key['key_id']]
+ # Logging variables
+ self.object_ids = [person['person_id'], key['key_id']]
+ self.message = 'Key %d added to person %d' % \
+ (key['key_id'], person['person_id'])
return key['key_id']
if site['site_id'] not in person['site_ids']:
site.add_person(person)
- self.object_ids = [site['site_id']]
+ # Logging variables
+ self.object_ids = [site['site_id']]
+ self.message = 'Person %d added to site %d' % \
+ (person['person_id'], site['site_id'])
return 1
person.add_role(role_id)
self.object_ids = [person['person_id']]
+ self.message = "Role %d granted to person %d" % \
+ (role['role_id'], person['person_id'])
return 1
site_fields = dict(filter(can_update, site_fields.items()))
site = Site(self.api, site_fields)
site.sync()
-
+
+ # Logging variables
self.object_ids = [site['site_id']]
-
+ self.message = 'Site %d created' % site['site_id']
+
return site['site_id']
address.sync(commit = False)
site.add_address(address, commit = True)
+ # Logging variables
self.object_ids = [site['site_id'], address['address_id']]
+ self.message = 'Address %d assigned to Site %d' % \
+ (address['address_id'], site['site_id'])
return address['address_id']
PLCCheckLocalKey(key,"BlackListKey")
key.blacklist()
+
+ # Logging variables
self.object_ids = [key['key_id']]
+ self.message = 'Key %d blacklisted' % key['key_id']
return 1
else:
network[field] = ""
+ self.messge = "Node request boot_state (%s) and networks" % \
+ (details['boot_state'])
return details
recipients[person['email']] = person['first_name'] + " " + person['last_name']
# XXX Send mail
+ self.message = "Node sent message %s to contacts"
return 1
nodenetwork.sync(commit = False)
self.caller.sync(commit = True)
+ self.message = "Node updated: %s" % ", ".join(node_fields.keys())
return 1
raise PLCPermissionDenied, "Address must be associated with one of your sites"
address.delete()
+
+ # Logging variables
self.object_ids = [address['address_id']]
+ self.message = 'Address %d deleted' % address['address_id']
return 1
raise PLCPermissionDenied, "Key must be associated with your account"
key.delete()
+
+ # Logging variables
self.object_ids = [key['key_id']]
+ self.message = 'Key %d deleted' % key['key_id']
return 1
raise PLCPermissionDenied, "Not allowed to delete nodes from specified site"
node.delete()
+
+ # Logging variables
self.object_ids = [node['node_id']]
+ self.message = "Node %d deleted" % node['node_id']
return 1
if node['node_id'] in nodegroup['node_ids']:
nodegroup.remove_node(node)
+ # Logging variables
self.object_ids = [nodegroup['nodegroup_id']]
+ self.message = 'node %d deleted from node group %d' % \
+ (node['node_id'], nodegroup['nodegroup_id'])
return 1
raise PLCPermissionDenied, "Not allowed to update that PCU"
# Removed node from PCU
+
if node['node_id'] in pcu['node_ids']:
pcu.remove_node(node)
+ # Logging variables
self.object_ids = [pcu['pcu_id']]
-
+ self.message = 'Node %d removed from PCU %d' % \
+ (node['node_id'], pcu['pcu_id'])
+
return 1
nodegroup = nodegroups[0]
nodegroup.delete()
- self.object_ids = [nodegroup['nodegroup_id']]
+ # Logging variables
+ self.object_ids = [nodegroup['nodegroup_id']]
+ self.message = 'Node group %d deleted' % nodegroup['nodegroup_id']
+
return 1
raise PLCPermissionDenied, "Not allowed to delete this node network"
nodenetwork.delete()
+
+ # Logging variables
self.object_ids = [nodenetwork['nodenetwork_id']]
+ self.message = "Node network %d deleted" % nodenetwork['nodenetwork_id']
return 1
raise PLCPermissionDenied, "Not allowed to update that PCU"
pcu.delete()
+
+ # Logging variables
self.object_ids = [pcu['pcu_id']]
+ self.message = 'PCU %d deleted' % pcu['pcu_id']
return 1
raise PLCPermissionDenied, "Not allowed to delete specified account"
person.delete()
+
+ # Logging variables
self.object_ids = [person['person_id']]
+ self.message = 'Person %d deleted' % person['person_id']
return 1
if site['site_id'] in person['site_ids']:
site.remove_person(person)
+ # Logging variables
self.object_ids = [site['site_id']]
-
+ self.message = 'Person %d deleted from site %d ' % \
+ (person['person_id'], site['site_id'])
return 1
if role_id in person['role_ids']:
person.remove_role(role_id)
+ # Logging variables
self.object_ids = [person['person_id']]
-
+ self.message = 'Role %d revoked from person %d' \
+ (role['role_id'], person['person_id'])
return 1
PLCCheckLocalSite(site,"DeleteSite")
site.delete()
+
+ # Logging variables
self.object_ids = [site['site_id']]
+ self.message = 'Site %d deleted' % site['site_id']
return 1
address.update(address_fields)
address.sync()
+
+ # Logging variables
self.object_ids = [address['address_id']]
-
- return 1
+ self.message = 'Address %d updated: %s' % \
+ (address['address_id'], ", ".join(address_fields.keys()))
+
+ return 1
key.update(key_fields)
key.sync()
+
+ # Logging variables
self.object_ids = [key['key_id']]
-
+ self.message = 'key %d updated: %s' % \
+ (key['key_id'], ", ".join(key_fields.keys()))
return 1
node.update(node_fields)
node.sync()
+
+ # Logging variables
self.object_ids = [node['node_id']]
+ self.message = 'Node %d updated: %s.' % \
+ (node['node_id'], ", ".join(node_fields.keys()))
+ if 'boot_state' in node_fields.keys():
+ self.message += ' boot_state updated to %s' % node_fields['boot_state']
return 1
nodegroup.update(nodegroup_fields)
nodegroup.sync()
+
+ # Logging variables
self.object_ids = [nodegroup['nodegroup_id']]
-
+ self.message = 'Node group %d updated: %s' % \
+ (nodegroup['nodegroup_id'], ", ".join(nodegroup_fields.keys()))
return 1
# Update node network
nodenetwork.update(nodenetwork_fields)
nodenetwork.sync()
+
self.object_ids = [nodenetwork['nodenetwork_id']]
+ self.message = "Node network %d updated: %s " % \
+ (nodenetwork['nodenetwork_id'], ", ".join(nodenetwork_fields.keys()))
return 1
pcu.update(pcu_fields)
pcu.sync()
+
+ # Logging variables
self.object_ids = [pcu['pcu_id']]
-
+ self.message = 'PCU %d updated: %s' % \
+ (pcu['pcu_id'], ", ".join(pcu_fields.keys()))
return 1
person.update(person_fields)
person.sync()
+
+ # Logging variables
self.object_ids = [person['person_id']]
+ self.message = 'Person %d updated: %s.' % \
+ (person['person_id'], person_fields.keys())
+ if 'enabled' in person_fields:
+ self.message += ' Person enabled'
return 1
site.update(site_fields)
site.sync()
+
+ # Logging variables
self.object_ids = [site['site_id']]
+ self.message = 'Site %d updated: %s' % \
+ (site['site_id'], ", ".join(site_fields.keys()))
return 1