Produits Entr'ouvert » w.c.s.

import contextlib

def clean_drafts(publisher, job=None):

        with job.log_long_job(

            '%s %s' % (formdef.xml_root_node, formdef.url_name)

        ) if job else contextlib.ExitStack():

            removal_date = datetime.date.today() - datetime.timedelta(days=formdef.get_drafts_lifespan())

            for formdata in formdef.data_class().select(

                [st.Equal('status', 'draft'), st.Less('receipt_time', removal_date.timetuple())]

            ):

                formdata.remove_self()

from contextlib import ExitStack, contextmanager

    def apply_global_action_timeouts(self, job=None):

            with job.log_long_job('workflow %s' % workflow.url_name) if job else ExitStack():

                WorkflowGlobalActionTimeoutTrigger.apply(workflow)

import contextlib

def send_aggregation_emails(publisher, job=None):

        with job.log_long_job('aggregation email %s' % aggregate_id) if job else contextlib.ExitStack():

            aggregate = AggregationEmail.get(aggregate_id)

            aggregate.remove_self()

                role = get_publisher().role_class.get(aggregate_id)

            if not role.get_emails():

                continue

            if not aggregate.items:

                continue

            last_formdef = None

            body = []

            for item in sorted(

                aggregate.items, key=lambda x: (lax_int(x['formdef']), lax_int(x['formdata']))

            ):

                formdef_id = item.get('formdef')

                if formdef_id in cache:

                    formdef, formdata, workflow = cache[formdef_id]

                else:

                    try:

                        formdef = FormDef.get(formdef_id)

                    except KeyError:

                        # formdef has been deleted after AggregationEmail creation

                        continue

                    formdata = formdef.data_class()

                    workflow = formdef.workflow

                    cache[formdef_id] = (formdef, formdata, workflow)

                try:

                    data = formdata.get(item.get('formdata'))

                except KeyError:

                    continue

                status = data.get_status()

                url = item.get('formurl')

                if last_formdef != formdef:

                    if last_formdef is not None:

                        body.append('')  # blank line

                    last_formdef = formdef

                    body.append(formdef.name)

                    body.append('-' * len(formdef.name))

                    body.append('')

                body.append('- %sstatus (%s)' % (url, status.name))

            if not body:

                continue

            body = '\n'.join(body)

            mail_subject = _('New arrivals')

            if site_name:

                mail_subject += ' (%s)' % site_name

            emails.email(mail_subject, body, email_rcpt=role.get_emails())

import contextlib

def _apply_timeouts(publisher, job=None):

        with job.log_long_job(

            '%s %s' % (formdef.xml_root_node, formdef.url_name)

        ) if job else contextlib.ExitStack():

            formdata_class = formdef.data_class()

            for status_id in status_ids:

                if publisher.is_using_postgresql():

                    # get minimum delay for jumps in this status

                    delay = math.inf

                    for jump_action in wfs_status[str(formdef.workflow_id)][status_id]:

                        if Template.is_template_string(jump_action.timeout):

                            delay = 0

                            break

                        delay = min(delay, int(jump_action.timeout))

                    # limit delay to minimal delay

                    if delay < JUMP_TIMEOUT_INTERVAL * 60:

                        delay = JUMP_TIMEOUT_INTERVAL * 60

                    criterias = [

                        Equal('status', status_id),

                        LessOrEqual(

                            'last_update_time',

                            (datetime.datetime.now() - datetime.timedelta(seconds=delay)).timetuple(),

                        ),

                    ]

                    formdatas = formdata_class.select_iterator(criterias, ignore_errors=True)

                else:

                    formdatas = formdata_class.get_with_indexed_value('status', status_id, ignore_errors=True)

                for formdata in formdatas:

                    for jump_action in wfs_status[str(formdef.workflow_id)][formdata.status]:

                        get_publisher().substitutions.reset()

                        get_publisher().substitutions.feed(get_publisher())

                        get_publisher().substitutions.feed(formdef)

                        get_publisher().substitutions.feed(formdata)

                        if jump_action.must_jump(formdata):

                            jump_and_perform(formdata, jump_action, event=('timeout-jump', jump_action.id))

                            break