adding database schema to documentation.
# -*- coding: utf-8 -*-
#Copyright (C) 2009 Sandro Knauß <bugs@sandroknauss.de>
#This program is free software; you can redistribute it and/or modify it under the terms
#of the GNU General Public License as published by the Free Software Foundation;
#either version 3 of the License, or any later version.
#This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
#without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
#See the GNU General Public License for more details.
#You should have received a copy of the GNU General Public License
#along with this program; if not, see <http://www.gnu.org/licenses/>.
import logging
logger=logging.getLogger("iro.user")
class NotSupportedFeature (Exception):
def __init__(self,name):
self.name=name
def __str__(self):
return ("This is not a supported feature:", self.name)
class NoID(Exception):
def __init__(self,i):
self.i=i
def __str__(self):
return ("No Job with id:", self.i)
class User:
'''class for a xmlrpc user
'''
def __init__(self, name, jobqueue):
self.jobqueue=jobqueue
self.jobs={}
self.name=name
self.features=["mail", "sms", "fax", ]
def status(self,id=None,detailed=False):
'''Gibt den aktuellen Status eines Auftrages zurück.
Keywords:
id[hash]: Eine Auftragsnummer
detailed[boolean]: Details ausgeben
Return:
jobs[list]: Eine Liste der Aufträge.
job.name[string]: Angebener Name
job.status[string]: Status des Auftrages
'''
try:
jobs={}
if id==None:
jobs=self.jobs
else:
try:
jobs={id:self.jobs[id]}
except:
logger.error("No Job ID %s",id)
#raise NoID(id)
ret={}
if not jobs:
return {}
for key in jobs:
job=jobs[key]
ret[key]={"name":job.getName(),"status":job.getStatus(detailed)}
return ret
except:
logger.exception("Fehler in iro.user.status")
return {}
def stop(self,id):
'''Stoppt den angegeben Auftrag.
Keywords:
id[hash]: Eine Auftragsnummer
Return:
'''
try:
job=self.jobs[id]
job.stop()
except:
raise NoID(id)
job.stop()
def startSMS(self, message, recipients, provider="default"):
'''Versendet eine SMS.
Keywords:
message[string]: Nachricht
recipients[list]: eine Liste von Emfänger-Nummern (gemäß ITU-T E.123)
provider[string]: Provider über den geschickt werden soll
Return:
id[hash]: Die ID des Auftrages
'''
if not "sms" in self.features:
raise NotSupportedFeature("sms")
id = self.jobqueue.newSMS(message,recipients,provider,user=self.name)
self.jobs[id]=self.jobqueue[id]
return id
def startFAX(self, subject, fax, recipients, provider="default"):
'''Versendet ein FAX.
Keywords:
subject[string]: der Betreff
fax[string]: das pdf base64 kodiert
recipients[list]: eine Liste von Emfänger-Nummern (gemäß ITU-T E.123)
provider[string]: Provider über den geschickt werden soll
Return:
id[hash]: Die ID des Auftrages
'''
logger.debug("startFAX(%s,%s,%s,%s)"%(subject, fax, recipients, provider))
if not "fax" in self.features:
raise NotSupportedFeature("fax")
if type(fax) != list:
fax=[fax]
f=[i.data for i in fax]
id = self.jobqueue.newFAX(subject, f,recipients,provider,user=self.name)
self.jobs[id]=self.jobqueue[id]
return id
def startMail(self, subject, body, recipients, frm, provider="default"):
'''Versendet eine Email.
Keywords:
subject[string]: der Betreff
body[string]: der Email Body
recipients[list]: eine Liste von Emailadressen
frm[string]: Die Absender Emailadresse
provider[string]: Provider über den geschickt werden soll
Return:
id[hash]: Die ID des Auftrages
'''
if not "mail" in self.features:
raise NotSupportedFeature("mail")
logger.debug("startMail(%s,%s,%s,%s,%s)"%(subject, body, recipients, frm, provider))
id = self.jobqueue.newMail(subject, body, recipients, frm, provider,user=self.name)
self.jobs[id]=self.jobqueue[id]
return id
def getProvider(self, typ):
'''Gibt eine Liste aller verfügbaren Provider zurück.
Keywords:
typ[string]: Der Typ zu dem die Providerloste ausgeben werden soll
Einer der Liste ["sms","fax","mail"]
Return:
providerlist[list]: Eine Liste aller möglichen Provider
'''
if not typ in self.features:
raise NotSupportedFeature(typ)
return self.jobqueue.providerlist.getProviderlist(typ)
def getDefaultProvider(self, typ):
'''Gibt den Standardprovider zurück.
Keywords:
typ[string]: Der Typ zu dem die Providerloste ausgeben werden soll
Einer der Liste ["sms","fax","mail"]
Return:
provider[string]: Der Standardprovider für den angeben Typ
'''
if not typ in self.features:
raise NotSupportedFeature(typ)
return self.jobqueue.providerlist.getDefault(typ)["name"]
class Admin(User):
def __init__(self, name, jobqueue):
User.__init__(self, name, jobqueue)
self.jobs=jobqueue.jobs