source: main/waeup.ikoba/trunk/src/waeup/ikoba/interfaces.py @ 13802

Last change on this file since 13802 was 13802, checked in by Henrik Bettermann, 9 years ago

Do only allow one running export job.
Add switch to disable all exports.

See r13198 - r13201 and r13211.

  • Property svn:eol-style set to native
  • Property svn:keywords set to Id
File size: 38.2 KB
Line 
1## $Id: interfaces.py 13802 2016-04-05 21:04:39Z henrik $
2##
3## Copyright (C) 2011 Uli Fouquet & Henrik Bettermann
4## This program is free software; you can redistribute it and/or modify
5## it under the terms of the GNU General Public License as published by
6## the Free Software Foundation; either version 2 of the License, or
7## (at your option) any later version.
8##
9## This program is distributed in the hope that it will be useful,
10## but WITHOUT ANY WARRANTY; without even the implied warranty of
11## MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
12## GNU General Public License for more details.
13##
14## You should have received a copy of the GNU General Public License
15## along with this program; if not, write to the Free Software
16## Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
17##
18import os
19import re
20import codecs
21import zc.async.interfaces
22import zope.i18nmessageid
23from datetime import datetime
24from hurry.file.interfaces import IFileRetrieval
25from hurry.workflow.interfaces import IWorkflowInfo
26from zc.sourcefactory.basic import BasicSourceFactory
27from zope import schema
28from zope.pluggableauth.interfaces import IPrincipalInfo
29from zope.security.interfaces import IGroupClosureAwarePrincipal as IPrincipal
30from zope.component import getUtility
31from zope.component.interfaces import IObjectEvent
32from zope.configuration.fields import Path
33from zope.container.interfaces import INameChooser, IContainer
34from zope.interface import Interface, Attribute
35from zope.schema.interfaces import IObject
36from zope.schema.vocabulary import SimpleVocabulary, SimpleTerm
37from waeup.ikoba.schema import PhoneNumber
38from waeup.ikoba.sourcefactory import SmartBasicContextualSourceFactory
39
40_ = MessageFactory = zope.i18nmessageid.MessageFactory('waeup.ikoba')
41
42DELETION_MARKER = 'XXX'
43IGNORE_MARKER = '<IGNORE>'
44WAEUP_KEY = 'waeup.ikoba'
45VIRT_JOBS_CONTAINER_NAME = 'jobs'
46
47# States for various workflows
48
49CREATED = 'created'
50
51STARTED = 'started'
52REQUESTED = 'requested'
53PROVISIONALLY = 'provisionally'
54APPROVED = 'approved'
55
56SUBMITTED = 'submitted'
57AWAITING = 'awaiting'
58REJECTED = 'rejected'
59EXPIRED = 'expired'
60
61VERIFIED = 'verified'
62PUBLISHED = 'published'
63
64
65#: A dict giving job status as tuple (<STRING>, <TRANSLATED_STRING>),
66#: the latter for UI purposes.
67JOB_STATUS_MAP = {
68    zc.async.interfaces.NEW: ('new', _('new')),
69    zc.async.interfaces.COMPLETED: ('completed', _('completed')),
70    zc.async.interfaces.PENDING: ('pending', _('pending')),
71    zc.async.interfaces.ACTIVE: ('active', _('active')),
72    zc.async.interfaces.ASSIGNED: ('assigned', _('assigned')),
73    zc.async.interfaces.CALLBACKS: ('callbacks', _('callbacks')),
74    }
75
76#default_rest_frontpage = u'' + codecs.open(os.path.join(
77#        os.path.dirname(__file__), 'frontpage.rst'),
78#        encoding='utf-8', mode='rb').read()
79
80default_html_frontpage = u'' + codecs.open(os.path.join(
81        os.path.dirname(__file__), 'frontpage.html'),
82        encoding='utf-8', mode='rb').read()
83
84def SimpleIkobaVocabulary(*terms):
85    """A well-buildt vocabulary provides terms with a value, token and
86       title for each term
87    """
88    return SimpleVocabulary([
89            SimpleTerm(value, value, title) for title, value in terms])
90
91class ContextualDictSourceFactoryBase(SmartBasicContextualSourceFactory):
92    """A base for contextual sources based on IkobaUtils dicts.
93
94    To create a real source, you have to set the `DICT_NAME` attribute
95    which should be the name of a dictionary in IkobaUtils.
96    """
97    def getValues(self, context):
98        utils = getUtility(IIkobaUtils)
99        sorted_items = sorted(getattr(utils, self.DICT_NAME).items(),
100                              key=lambda item: item[1])
101        return [item[0] for item in sorted_items]
102
103    def getToken(self, context, value):
104        return str(value)
105
106    def getTitle(self, context, value):
107        utils = getUtility(IIkobaUtils)
108        return getattr(utils, self.DICT_NAME)[value]
109
110# Define a validation method for email addresses
111class NotAnEmailAddress(schema.ValidationError):
112    __doc__ = u"Invalid email address"
113
114#: Regular expression to check email-address formats. As these can
115#: become rather complex (nearly everything is allowed by RFCs), we only
116#: forbid whitespaces, commas and dots following onto each other.
117check_email = re.compile(
118    r"^[^@\s,]+@[^@\.\s,]+(\.[^@\.\s,]+)*$").match
119
120def validate_email(value):
121    if not check_email(value):
122        raise NotAnEmailAddress(value)
123    return True
124
125# Define a validation method for ids
126class NotIdValue(schema.ValidationError):
127    __doc__ = u"Invalid id"
128
129#: Regular expressions to check id formats.
130check_id = re.compile(r"^[a-zA-Z0-9_-]{2,10}$").match
131check_uuid = re.compile( r"^[a-zA-Z0-9]{32}$").match
132
133def validate_id(value):
134    if not check_id(value):
135        raise NotIdValue(value)
136    return True
137
138def validate_uuid(value):
139    # We are using also short ids in tests
140    if not check_uuid(value) and not check_id(value):
141        raise NotIdValue(value)
142    return True
143
144# Define a validation method for international phone numbers
145class InvalidPhoneNumber(schema.ValidationError):
146    __doc__ = u"Invalid phone number"
147
148# represent format +NNN-NNNN-NNNN
149RE_INT_PHONE = re.compile(r"^\+?\d+\-\d+\-[\d\-]+$")
150
151def validate_phone(value):
152    if not RE_INT_PHONE.match(value):
153        raise InvalidPhoneNumber(value)
154    return True
155
156class FatalCSVError(Exception):
157    """Some row could not be processed.
158    """
159    pass
160
161class DuplicationError(Exception):
162    """An exception that can be raised when duplicates are found.
163
164    When raising :exc:`DuplicationError` you can, beside the usual
165    message, specify a list of objects which are duplicates. These
166    values can be used by catching code to print something helpful or
167    similar.
168    """
169    def __init__(self, msg, entries=[]):
170        self.msg = msg
171        self.entries = entries
172
173    def __str__(self):
174        return '%r' % self.msg
175
176class RoleSource(BasicSourceFactory):
177    """A source for site roles.
178    """
179    def getValues(self):
180        # late import: in interfaces we should not import local modules
181        from waeup.ikoba.permissions import get_waeup_role_names
182        return get_waeup_role_names()
183
184    def getTitle(self, value):
185        # late import: in interfaces we should not import local modules
186        from waeup.ikoba.permissions import get_all_roles
187        roles = dict(get_all_roles())
188        if value in roles.keys():
189            title = roles[value].title
190            if '.' in title:
191                title = title.split('.', 2)[1]
192        return title
193
194class CaptchaSource(BasicSourceFactory):
195    """A source for captchas.
196    """
197    def getValues(self):
198        captchas = ['No captcha', 'Testing captcha', 'ReCaptcha']
199        try:
200            # we have to 'try' because IConfiguration can only handle
201            # interfaces from w.k.interface.
202            from waeup.ikoba.browser.interfaces import ICaptchaManager
203        except:
204            return captchas
205        return sorted(getUtility(ICaptchaManager).getAvailCaptchas().keys())
206
207    def getTitle(self, value):
208        return value
209
210class CurrencySource(BasicSourceFactory):
211    """A source for currencies.
212    """
213    def getValues(self):
214        currencies = getUtility(IIkobaUtils).CURRENCIES
215        return currencies.keys()
216
217    def getToken(self, value):
218        return value
219
220    def getTitle(self, value):
221        currencies = getUtility(IIkobaUtils).CURRENCIES
222        return currencies[value][1]
223
224class IIkobaUtils(Interface):
225    """A collection of methods which are subject to customization.
226    """
227
228    PORTAL_LANGUAGE = Attribute("Dict of global language setting")
229    PREFERRED_LANGUAGES_DICT = Attribute("Dict of preferred languages")
230    SYSTEM_MAX_LOAD = Attribute("Dict of maximum system loads.")
231
232    def sendContactForm(
233          from_name,from_addr,rcpt_name,rcpt_addr,
234          from_username,usertype,portal,body,subject):
235        """Send an email with data provided by forms.
236        """
237
238    def fullname(firstname,lastname,middlename):
239        """Full name constructor.
240        """
241
242    def sendCredentials(user, password, url_info, msg):
243        """Send credentials as email.
244
245        Input is the customer for which credentials are sent and the
246        password.
247
248        Returns True or False to indicate successful operation.
249        """
250
251    def genPassword(length, chars):
252        """Generate a random password.
253        """
254
255class IIkobaObject(Interface):
256    """A Ikoba object.
257
258    This is merely a marker interface.
259    """
260
261class ICompany(IIkobaObject):
262    """Representation of an company.
263    """
264
265
266class IIkobaContainer(IIkobaObject):
267    """A container for Ikoba objects.
268    """
269
270class IIkobaContained(IIkobaObject):
271    """An item contained in an IIkobaContainer.
272    """
273
274class ICSVExporter(Interface):
275    """A CSV file exporter for objects.
276    """
277    fields = Attribute("""List of fieldnames in resulting CSV""")
278
279    title = schema.TextLine(
280        title = u'Title',
281        description = u'Description to be displayed in selections.',
282        )
283    def mangle_value(value, name, obj):
284        """Mangle `value` extracted from `obj` or suobjects thereof.
285
286        This is called by export before actually writing to the result
287        file.
288        """
289
290    def get_filtered(site, **kw):
291        """Get datasets in `site` to be exported.
292
293        The set of data is specified by keywords, which might be
294        different for any implementaion of exporter.
295
296        Returns an iterable.
297        """
298
299    def export(iterable, filepath=None):
300        """Export iterables as rows in a CSV file.
301
302        If `filepath` is not given, a string with the data should be
303        returned.
304
305        What kind of iterables are acceptable depends on the specific
306        exporter implementation.
307        """
308
309    def export_all(site, filepath=None):
310        """Export all items in `site` as CSV file.
311
312        if `filepath` is not given, a string with the data should be
313        returned.
314        """
315
316    def export_filtered(site, filepath=None, **kw):
317        """Export those items in `site` specified by `args` and `kw`.
318
319        If `filepath` is not given, a string with the data should be
320        returned.
321
322        Which special keywords are supported is up to the respective
323        exporter.
324        """
325
326class IIkobaExporter(Interface):
327    """An exporter for objects.
328    """
329    def export(obj, filepath=None):
330        """Export by pickling.
331
332        Returns a file-like object containing a representation of `obj`.
333
334        This is done using `pickle`. If `filepath` is ``None``, a
335        `cStringIO` object is returned, that contains the saved data.
336        """
337
338class IIkobaXMLExporter(Interface):
339    """An XML exporter for objects.
340    """
341    def export(obj, filepath=None):
342        """Export as XML.
343
344        Returns an XML representation of `obj`.
345
346        If `filepath` is ``None``, a StringIO` object is returned,
347        that contains the transformed data.
348        """
349
350class IIkobaXMLImporter(Interface):
351    """An XML import for objects.
352    """
353    def doImport(filepath):
354        """Create Python object from XML.
355
356        Returns a Python object.
357        """
358
359class IBatchProcessor(Interface):
360    """A batch processor that handles mass-operations.
361    """
362    name = schema.TextLine(
363        title = _(u'Processor name')
364        )
365
366    def doImport(path, headerfields, mode='create', user='Unknown',
367                 logger=None, ignore_empty=True):
368        """Read data from ``path`` and update connected object.
369
370        `headerfields` is a list of headerfields as read from the file
371        to import.
372
373        `mode` gives the import mode to use (``'create'``,
374        ``'update'``, or ``'remove'``.
375
376        `user` is a string describing the user performing the
377        import. Normally fetched from current principal.
378
379        `logger` is the logger to use during import.
380
381        `ignore_emtpy` in update mode ignores empty fields if true.
382        """
383
384class IContactForm(IIkobaObject):
385    """A contact form.
386    """
387
388    email_from = schema.TextLine(
389        title = _(u'Email Address:'),
390        default = None,
391        required = True,
392        constraint=validate_email,
393        )
394
395    email_to = schema.TextLine(
396        title = _(u'Email to:'),
397        default = None,
398        required = True,
399        constraint=validate_email,
400        )
401
402    subject = schema.TextLine(
403        title = _(u'Subject:'),
404        required = True,)
405
406    fullname = schema.TextLine(
407        title = _(u'Full Name:'),
408        required = True,)
409
410    body = schema.Text(
411        title = _(u'Text:'),
412        required = True,)
413
414class IIkobaPrincipalInfo(IPrincipalInfo):
415    """Infos about principals that are users of Ikoba Ikoba.
416    """
417    email = Attribute("The email address of a user")
418    phone = Attribute("The phone number of a user")
419    public_name = Attribute("The public name of a user")
420
421
422class IIkobaPrincipal(IPrincipal):
423    """A principle for Ikoba Ikoba.
424
425    This interface extends zope.security.interfaces.IPrincipal and
426    requires also an `id` and other attributes defined there.
427    """
428
429    email = schema.TextLine(
430        title = _(u'Email Address'),
431        description = u'',
432        required=False,)
433
434    phone = PhoneNumber(
435        title = _(u'Phone'),
436        description = u'',
437        required=False,)
438
439    public_name = schema.TextLine(
440        title = _(u'Public Name'),
441        required = False,)
442
443class IFailedLoginInfo(IIkobaObject):
444    """Info about failed logins.
445
446    Timestamps are supposed to be stored as floats using time.time()
447    or similar.
448    """
449    num = schema.Int(
450        title = _(u'Number of failed logins'),
451        description = _(u'Number of failed logins'),
452        required = True,
453        default = 0,
454        )
455
456    last = schema.Float(
457        title = _(u'Timestamp'),
458        description = _(u'Timestamp of last failed login or `None`'),
459        required = False,
460        default = None,
461        )
462
463    def as_tuple():
464        """Get login info as tuple ``<NUM>, <TIMESTAMP>``.
465        """
466
467    def set_values(num=0, last=None):
468        """Set number of failed logins and timestamp of last one.
469        """
470
471    def increase():
472        """Increase the current number of failed logins and set timestamp.
473        """
474
475    def reset():
476        """Set failed login counters back to zero.
477        """
478
479
480class IUserAccount(IIkobaObject):
481    """A user account.
482    """
483
484    failed_logins = Attribute("""FailedLoginInfo for this account""")
485
486    name = schema.TextLine(
487        title = _(u'User Id'),
488        description = u'Login name of user',
489        required = True,)
490
491    title = schema.TextLine(
492        title = _(u'Full Name'),
493        required = True,)
494
495    public_name = schema.TextLine(
496        title = _(u'Public Name'),
497        description = u"Substitute for officer's real name "
498                       "in object histories.",
499        required = False,)
500
501    description = schema.Text(
502        title = _(u'Description/Notice'),
503        required = False,)
504
505    email = schema.TextLine(
506        title = _(u'Email Address'),
507        default = None,
508        required = True,
509        constraint=validate_email,
510        )
511
512    phone = PhoneNumber(
513        title = _(u'Phone'),
514        default = None,
515        required = False,
516        )
517
518    roles = schema.List(
519        title = _(u'Portal Roles'),
520        value_type = schema.Choice(source=RoleSource()),
521        required = False,
522        )
523
524
525
526class IPasswordValidator(Interface):
527    """A password validator utility.
528    """
529
530    def validate_password(password, password_repeat):
531        """Validates a password by comparing it with
532        control password and checking some other requirements.
533        """
534
535
536class IUsersContainer(IIkobaObject):
537    """A container for users (principals).
538
539    These users are used for authentication purposes.
540    """
541
542    def addUser(name, password, title=None, description=None):
543        """Add a user.
544        """
545
546    def delUser(name):
547        """Delete a user if it exists.
548        """
549
550class ILocalRolesAssignable(Interface):
551    """The local roles assignable to an object.
552    """
553    def __call__():
554        """Returns a list of dicts.
555
556        Each dict contains a ``name`` referring to the role assignable
557        for the specified object and a `title` to describe the range
558        of users to which this role can be assigned.
559        """
560
561class IConfigurationContainer(IIkobaObject):
562    """A container for session configuration objects.
563    """
564
565    name = schema.TextLine(
566        title = _(u'Name of Company'),
567        default = _(u'Sample Company'),
568        required = True,
569        )
570
571    acronym = schema.TextLine(
572        title = _(u'Abbreviated Title of Company'),
573        default = u'WAeUP.Ikoba',
574        required = True,
575        )
576
577    frontpage = schema.Text(
578        title = _(u'Content in HTML format'),
579        required = False,
580        default = default_html_frontpage,
581        )
582
583    frontpage_dict = schema.Dict(
584        title = u'Content as language dictionary with values in html format',
585        required = False,
586        default = {},
587        )
588
589    name_admin = schema.TextLine(
590        title = _(u'Name of Administrator'),
591        default = u'Administrator',
592        required = True,
593        )
594
595    email_admin = schema.TextLine(
596        title = _(u'Email Address of Administrator'),
597        default = u'contact@waeup.org',
598        required = True,
599        constraint=validate_email,
600        )
601
602    email_subject = schema.TextLine(
603        title = _(u'Subject of Email to Administrator'),
604        default = _(u'Ikoba Contact'),
605        required = True,
606        )
607
608    smtp_mailer = schema.Choice(
609        title = _(u'SMTP mailer to use when sending mail'),
610        vocabulary = 'Mail Delivery Names',
611        default = 'No email service',
612        required = True,
613        )
614
615    email_notification = schema.Bool(
616        title = _(u'Notify customers by email'),
617        default = False,
618        )
619
620    captcha = schema.Choice(
621        title = _(u'Captcha used for public registration pages'),
622        source = CaptchaSource(),
623        default = u'No captcha',
624        required = True,
625        )
626
627    export_disabled_message = schema.Text(
628        title = _(u'Export disabled message'),
629        description = _(u'This message will show up if an officer tries '
630                         'to export data. Setting this field automatically '
631                         'disables all exporters.'),
632        required = False,
633        )
634
635
636class IDataCenter(IIkobaObject):
637    """A data center.
638
639    A data center manages files (uploads, downloads, etc.).
640
641    Beside providing the bare paths needed to keep files, it also
642    provides some helpers to put results of batch processing into
643    well-defined final locations (with well-defined filenames).
644
645    The main use-case is managing of site-related files, i.e. files
646    for import, export etc.
647
648    DataCenters are _not_ meant as storages for object-specific files
649    like passport photographs and similar.
650
651    It is up to the datacenter implementation how to organize data
652    (paths) inside its storage path.
653    """
654    storage = schema.Bytes(
655        title = u'Path to directory where everything is kept.'
656        )
657
658    deleted_path = schema.Bytes(
659        title = u'Path were data about deleted objects should be stored.'
660        )
661
662    def getPendingFiles(sort='name'):
663        """Get a list of files stored in `storage` sorted by basename.
664        """
665
666    def getFinishedFiles():
667        """Get a list of files stored in `finished` subfolder of `storage`.
668        """
669
670    def setStoragePath(path, move=False, overwrite=False):
671        """Set the path where to store files.
672
673        If `move` is True, move over files from the current location
674        to the new one.
675
676        If `overwrite` is also True, overwrite any already existing
677        files of same name in target location.
678
679        Triggers a DataCenterStorageMovedEvent.
680        """
681
682    def distProcessedFiles(successful, source_path, finished_file,
683                           pending_file, mode='create', move_orig=True):
684        """Distribute processed files over final locations.
685        """
686
687
688class IDataCenterFile(Interface):
689    """A data center file.
690    """
691
692    name = schema.TextLine(
693        title = u'Filename')
694
695    size = schema.TextLine(
696        title = u'Human readable file size')
697
698    uploaddate = schema.TextLine(
699        title = u'Human readable upload datetime')
700
701    lines = schema.Int(
702        title = u'Number of lines in file')
703
704    def getDate():
705        """Get creation timestamp from file in human readable form.
706        """
707
708    def getSize():
709        """Get human readable size of file.
710        """
711
712    def getLinesNumber():
713        """Get number of lines of file.
714        """
715
716class IDataCenterStorageMovedEvent(IObjectEvent):
717    """Emitted, when the storage of a datacenter changes.
718    """
719
720class IObjectUpgradeEvent(IObjectEvent):
721    """Can be fired, when an object shall be upgraded.
722    """
723
724class ILocalRoleSetEvent(IObjectEvent):
725    """A local role was granted/revoked for a principal on an object.
726    """
727    role_id = Attribute(
728        "The role id that was set.")
729    principal_id = Attribute(
730        "The principal id for which the role was granted/revoked.")
731    granted = Attribute(
732        "Boolean. If false, then the role was revoked.")
733
734class IQueryResultItem(Interface):
735    """An item in a search result.
736    """
737    url = schema.TextLine(
738        title = u'URL that links to the found item')
739    title = schema.TextLine(
740        title = u'Title displayed in search results.')
741    description = schema.Text(
742        title = u'Longer description of the item found.')
743
744class IIkobaPluggable(Interface):
745    """A component that might be plugged into a Ikoba Ikoba app.
746
747    Components implementing this interface are referred to as
748    'plugins'. They are normally called when a new
749    :class:`waeup.ikoba.app.Company` instance is created.
750
751    Plugins can setup and update parts of the central site without the
752    site object (normally a :class:`waeup.ikoba.app.Company` object)
753    needing to know about that parts. The site simply collects all
754    available plugins, calls them and the plugins care for their
755    respective subarea like the cutomers area or the datacenter
756    area.
757
758    Currently we have no mechanism to define an order of plugins. A
759    plugin should therefore make no assumptions about the state of the
760    site or other plugins being run before and instead do appropriate
761    checks if necessary.
762
763    Updates can be triggered for instance by the respective form in
764    the site configuration. You normally do updates when the
765    underlying software changed.
766    """
767    def setup(site, name, logger):
768        """Create an instance of the plugin.
769
770        The method is meant to be called by the central app (site)
771        when it is created.
772
773        `site`:
774           The site that requests a setup.
775
776        `name`:
777           The name under which the plugin was registered (utility name).
778
779        `logger`:
780           A standard Python logger for the plugins use.
781        """
782
783    def update(site, name, logger):
784        """Method to update an already existing plugin.
785
786        This might be called by a site when something serious
787        changes. It is a poor-man replacement for Zope generations
788        (but probably more comprehensive and better understandable).
789
790        `site`:
791           The site that requests an update.
792
793        `name`:
794           The name under which the plugin was registered (utility name).
795
796        `logger`:
797           A standard Python logger for the plugins use.
798        """
799
800class IAuthPluginUtility(Interface):
801    """A component that cares for authentication setup at site creation.
802
803    Utilities providing this interface are looked up when a Pluggable
804    Authentication Utility (PAU) for any
805    :class:`waeup.ikoba.app.Company` instance is created and put
806    into ZODB.
807
808    The setup-code then calls the `register` method of the utility and
809    expects a modified (or unmodified) version of the PAU back.
810
811    This allows to define any authentication setup modifications by
812    submodules or third-party modules/packages.
813    """
814
815    def register(pau):
816        """Register any plugins wanted to be in the PAU.
817        """
818
819    def unregister(pau):
820        """Unregister any plugins not wanted to be in the PAU.
821        """
822
823class IObjectConverter(Interface):
824    """Object converters are available as simple adapters, adapting
825       interfaces (not regular instances).
826
827    """
828
829    def fromStringDict(self, data_dict, context, form_fields=None):
830        """Convert values in `data_dict`.
831
832        Converts data in `data_dict` into real values based on
833        `context` and `form_fields`.
834
835        `data_dict` is a mapping (dict) from field names to values
836        represented as strings.
837
838        The fields (keys) to convert can be given in optional
839        `form_fields`. If given, form_fields should be an instance of
840        :class:`zope.formlib.form.Fields`. Suitable instances are for
841        example created by :class:`grok.AutoFields`.
842
843        If no `form_fields` are given, a default is computed from the
844        associated interface.
845
846        The `context` can be an existing object (implementing the
847        associated interface) or a factory name. If it is a string, we
848        try to create an object using
849        :func:`zope.component.createObject`.
850
851        Returns a tuple ``(<FIELD_ERRORS>, <INVARIANT_ERRORS>,
852        <DATA_DICT>)`` where
853
854        ``<FIELD_ERRORS>``
855           is a list of tuples ``(<FIELD_NAME>, <ERROR>)`` for each
856           error that happened when validating the input data in
857           `data_dict`
858
859        ``<INVARIANT_ERRORS>``
860           is a list of invariant errors concerning several fields
861
862        ``<DATA_DICT>``
863           is a dict with the values from input dict converted.
864
865        If errors happen, i.e. the error lists are not empty, always
866        an empty ``<DATA_DICT>`` is returned.
867
868        If ``<DATA_DICT>`` is non-empty, there were no errors.
869        """
870
871class IFieldConverter(Interface):
872    def request_data(name, value, schema_field, prefix='', mode='create'):
873        """Create a dict with key-value mapping as created by a request.
874
875        `name` and `value` are expected to be parsed from CSV or a
876        similar input and represent an attribute to be set to a
877        representation of value.
878
879        `mode` gives the mode of import.
880
881        :meth:`update_request_data` is then requested to turn this
882        name and value into vars as they would be sent by a regular
883        form submit. This means we do not create the real values to be
884        set but we only define the values that would be sent in a
885        browser request to request the creation of those values.
886
887        The returned dict should contain names and values of a faked
888        browser request for the given `schema_field`.
889
890        Field converters are normally registered as adapters to some
891        specific zope.schema field.
892        """
893
894class IObjectHistory(Interface):
895
896    messages = schema.List(
897        title = u'List of messages stored',
898        required = True,
899        )
900
901    def addMessage(message):
902        """Add a message.
903        """
904
905class IIkobaWorkflowInfo(IWorkflowInfo):
906    """A :class:`hurry.workflow.workflow.WorkflowInfo` with additional
907       methods for convenience.
908    """
909    def getManualTransitions():
910        """Get allowed manual transitions.
911
912        Get a sorted list of tuples containing the `transition_id` and
913        `title` of each allowed transition.
914        """
915
916class ISiteLoggers(Interface):
917
918    loggers = Attribute("A list or generator of registered IkobaLoggers")
919
920    def register(name, filename=None, site=None, **options):
921        """Register a logger `name` which logs to `filename`.
922
923        If `filename` is not given, logfile will be `name` with
924        ``.log`` as filename extension.
925        """
926
927    def unregister(name):
928        """Unregister a once registered logger.
929        """
930
931class ILogger(Interface):
932    """A logger cares for setup, update and restarting of a Python logger.
933    """
934
935    logger = Attribute("""A :class:`logging.Logger` instance""")
936
937
938    def __init__(name, filename=None, site=None, **options):
939        """Create a Ikoba logger instance.
940        """
941
942    def setup():
943        """Create a Python :class:`logging.Logger` instance.
944
945        The created logger is based on the params given by constructor.
946        """
947
948    def update(**options):
949        """Update the logger.
950
951        Updates the logger respecting modified `options` and changed
952        paths.
953        """
954
955class ILoggerCollector(Interface):
956
957    def getLoggers(site):
958        """Return all loggers registered for `site`.
959        """
960
961    def registerLogger(site, logging_component):
962        """Register a logging component residing in `site`.
963        """
964
965    def unregisterLogger(site, logging_component):
966        """Unregister a logger.
967        """
968
969#
970# External File Storage and relatives
971#
972class IFileStoreNameChooser(INameChooser):
973    """See zope.container.interfaces.INameChooser for base methods.
974    """
975    def checkName(name, attr=None):
976        """Check whether an object name is valid.
977
978        Raises a user error if the name is not valid.
979        """
980
981    def chooseName(name, attr=None):
982        """Choose a unique valid file id for the object.
983
984        The given name may be taken into account when choosing the
985        name (file id).
986
987        chooseName is expected to always choose a valid file id (that
988        would pass the checkName test) and never raise an error.
989
990        If `attr` is not ``None`` it might been taken into account as
991        well when generating the file id. Usual behaviour is to
992        interpret `attr` as a hint for what type of file for a given
993        context should be stored if there are several types
994        possible. For instance for a certain customer some file could
995        be the connected passport photograph or some certificate scan
996        or whatever. Each of them has to be stored in a different
997        location so setting `attr` to a sensible value should give
998        different file ids returned.
999        """
1000
1001class IExtFileStore(IFileRetrieval):
1002    """A file storage that stores files in filesystem (not as blobs).
1003    """
1004    root = schema.TextLine(
1005        title = u'Root path of file store.',
1006        )
1007
1008    def getFile(file_id):
1009        """Get raw file data stored under file with `file_id`.
1010
1011        Returns a file descriptor open for reading or ``None`` if the
1012        file cannot be found.
1013        """
1014
1015    def getFileByContext(context, attr=None):
1016        """Get raw file data stored for the given context.
1017
1018        Returns a file descriptor open for reading or ``None`` if no
1019        such file can be found.
1020
1021        Both, `context` and `attr` might be used to find (`context`)
1022        and feed (`attr`) an appropriate file name chooser.
1023
1024        This is a convenience method.
1025        """
1026
1027    def deleteFile(file_id):
1028        """Delete file stored under `file_id`.
1029
1030        Remove file from filestore so, that it is not available
1031        anymore on next call to getFile for the same file_id.
1032
1033        Should not complain if no such file exists.
1034        """
1035
1036    def deleteFileByContext(context, attr=None):
1037        """Delete file for given `context` and `attr`.
1038
1039        Both, `context` and `attr` might be used to find (`context`)
1040        and feed (`attr`) an appropriate file name chooser.
1041
1042        This is a convenience method.
1043        """
1044
1045    def createFile(filename, f):
1046        """Create file given by f with filename `filename`
1047
1048        Returns a hurry.file.File-based object.
1049        """
1050
1051class IFileStoreHandler(Interface):
1052    """Filestore handlers handle specific files for file stores.
1053
1054    If a file to store/get provides a specific filename, a file store
1055    looks up special handlers for that type of file.
1056
1057    """
1058    def pathFromFileID(store, root, filename):
1059        """Turn file id into path to store.
1060
1061        Returned path should be absolute.
1062        """
1063
1064    def createFile(store, root, filename, file_id, file):
1065        """Return some hurry.file based on `store` and `file_id`.
1066
1067        Some kind of callback method called by file stores to create
1068        file objects from file_id.
1069
1070        Returns a tuple ``(raw_file, path, file_like_obj)`` where the
1071        ``file_like_obj`` should be a HurryFile, a IkobaImageFile or
1072        similar. ``raw_file`` is the (maybe changed) input file and
1073        ``path`` the relative internal path to store the file at.
1074
1075        Please make sure the ``raw_file`` is opened for reading and
1076        the file descriptor set at position 0 when returned.
1077
1078        This method also gets the raw input file object that is about
1079        to be stored and is expected to raise any exceptions if some
1080        kind of validation or similar fails.
1081        """
1082
1083class IPDF(Interface):
1084    """A PDF representation of some context.
1085    """
1086
1087    def __call__(view=None, note=None):
1088        """Create a bytestream representing a PDF from context.
1089
1090        If `view` is passed in additional infos might be rendered into
1091        the document.
1092
1093        `note` is optional HTML rendered at bottom of the created
1094        PDF. Please consider the limited reportlab support for HTML,
1095        but using font-tags and friends you certainly can get the
1096        desired look.
1097        """
1098
1099class IMailService(Interface):
1100    """A mail service.
1101    """
1102
1103    def __call__():
1104        """Get the default mail delivery.
1105        """
1106
1107
1108class IDataCenterConfig(Interface):
1109    path = Path(
1110        title = u'Path',
1111        description = u"Directory where the datacenter should store "
1112                      u"files by default (adjustable in web UI).",
1113        required = True,
1114        )
1115
1116
1117class IPayPalConfig(Interface):
1118    path = Path(
1119        title = u'Path',
1120        description = u"Path to config file for PayPal REST API.",
1121        required = True,
1122        )
1123
1124
1125#
1126# Asynchronous job handling and related
1127#
1128class IJobManager(IIkobaObject):
1129    """A manager for asynchronous running jobs (tasks).
1130    """
1131    def put(job, site=None):
1132        """Put a job into task queue.
1133
1134        If no `site` is given, queue job in context of current local
1135        site.
1136
1137        Returns a job_id to identify the put job. This job_id is
1138        needed for further references to the job.
1139        """
1140
1141    def jobs(site=None):
1142        """Get an iterable of jobs stored.
1143        """
1144
1145    def get(job_id, site=None):
1146        """Get the job with id `job_id`.
1147
1148        For the `site` parameter see :meth:`put`.
1149        """
1150
1151    def remove(job_id, site=None):
1152        """Remove job with `job_id` from stored jobs.
1153        """
1154
1155    def start_test_job(site=None):
1156        """Start a test job.
1157        """
1158
1159class IProgressable(Interface):
1160    """A component that can indicate its progress status.
1161    """
1162    percent = schema.Float(
1163        title = u'Percent of job done already.',
1164        )
1165
1166class IJobContainer(IContainer):
1167    """A job container contains IJob objects.
1168    """
1169
1170class IExportJob(zc.async.interfaces.IJob):
1171    def __init__(site, exporter_name):
1172        pass
1173
1174    finished = schema.Bool(
1175        title = u'`True` if the job finished.`',
1176        default = False,
1177        )
1178
1179    failed = schema.Bool(
1180        title = u"`True` iff the job finished and didn't provide a file.",
1181        default = None,
1182        )
1183
1184class IExportJobContainer(IIkobaObject):
1185    """A component that contains (maybe virtually) export jobs.
1186    """
1187    def start_export_job(exporter_name, user_id, *args, **kwargs):
1188        """Start asynchronous export job.
1189
1190        `exporter_name` is the name of an exporter utility to be used.
1191
1192        `user_id` is the ID of the user that triggers the export.
1193
1194        `args` positional arguments passed to the export job created.
1195
1196        `kwargs` keyword arguments passed to the export job.
1197
1198        The job_id is stored along with exporter name and user id in a
1199        persistent list.
1200
1201        Returns the job ID of the job started.
1202        """
1203
1204    def get_running_export_jobs(user_id=None):
1205        """Get export jobs for user with `user_id` as list of tuples.
1206
1207        Each tuples holds ``<job_id>, <exporter_name>, <user_id>`` in
1208        that order. The ``<exporter_name>`` is the utility name of the
1209        used exporter.
1210
1211        If `user_id` is ``None``, all running jobs are returned.
1212        """
1213
1214    def get_export_jobs_status(user_id=None):
1215        """Get running/completed export jobs for `user_id` as list of tuples.
1216
1217        Each tuple holds ``<raw status>, <status translated>,
1218        <exporter title>`` in that order, where ``<status
1219        translated>`` and ``<exporter title>`` are translated strings
1220        representing the status of the job and the human readable
1221        title of the exporter used.
1222        """
1223
1224    def delete_export_entry(entry):
1225        """Delete the export denoted by `entry`.
1226
1227        Removes `entry` from the local `running_exports` list and also
1228        removes the regarding job via the local job manager.
1229
1230        `entry` is a tuple ``(<job id>, <exporter name>, <user id>)``
1231        as created by :meth:`start_export_job` or returned by
1232        :meth:`get_running_export_jobs`.
1233        """
1234
1235    def entry_from_job_id(job_id):
1236        """Get entry tuple for `job_id`.
1237
1238        Returns ``None`` if no such entry can be found.
1239        """
1240
1241class IExportContainerFinder(Interface):
1242    """A finder for the central export container.
1243    """
1244    def __call__():
1245        """Return the currently used global or site-wide IExportContainer.
1246        """
1247
1248class IFilteredQuery(IIkobaObject):
1249    """A query for objects.
1250    """
1251
1252    defaults = schema.Dict(
1253        title = u'Default Parameters',
1254        required = True,
1255        )
1256
1257    def __init__(**parameters):
1258        """Instantiate a filtered query by passing in parameters.
1259        """
1260
1261    def query():
1262        """Get an iterable of objects denoted by the set parameters.
1263
1264        The search should be applied to objects inside current
1265        site. It's the caller's duty to set the correct site before.
1266
1267        Result can be any iterable like a catalog result set, a list,
1268        or similar.
1269        """
1270
1271class IFilteredCatalogQuery(IFilteredQuery):
1272    """A catalog-based query for objects.
1273    """
1274
1275    cat_name = schema.TextLine(
1276        title = u'Registered name of the catalog to search.',
1277        required = True,
1278        )
1279
1280    def query_catalog(catalog):
1281        """Query catalog with the parameters passed to constructor.
1282        """
1283
1284
1285class IIDSource(Interface):
1286    """A source for unique IDs, according to RFC 4122.
1287    """
1288    def get_uuid():
1289        """Get a random unique ID.
1290
1291        Get a 'Universially Unique IDentifier'. The result string
1292        might contain any printable characters.
1293        """
1294
1295    def get_hex_uuid():
1296        """Get a random unique ID as a string representing a hex number.
1297        """
Note: See TracBrowser for help on using the repository browser.