From 8b09113eb40c39ada3dc902cb4e869c8f012c97d Mon Sep 17 00:00:00 2001 From: J08nY Date: Thu, 29 Jun 2017 23:51:47 +0200 Subject: Create mailman.workflows package. Move base Workflow there. - Also introduce IWorkflow, ISubscriptionWorkflow, IUnsubscriptionWorkflow. --- src/mailman/interfaces/workflow.py | 67 ------------------- src/mailman/interfaces/workflows.py | 128 ++++++++++++++++++++++++++++++++++++ 2 files changed, 128 insertions(+), 67 deletions(-) delete mode 100644 src/mailman/interfaces/workflow.py create mode 100644 src/mailman/interfaces/workflows.py (limited to 'src/mailman/interfaces') diff --git a/src/mailman/interfaces/workflow.py b/src/mailman/interfaces/workflow.py deleted file mode 100644 index 5b3582b58..000000000 --- a/src/mailman/interfaces/workflow.py +++ /dev/null @@ -1,67 +0,0 @@ -# Copyright (C) 2015-2017 by the Free Software Foundation, Inc. -# -# This file is part of GNU Mailman. -# -# GNU Mailman 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 (at your option) -# any later version. -# -# GNU Mailman 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 -# GNU Mailman. If not, see . - -"""Interfaces describing the state of a workflow.""" - -from public import public -from zope.interface import Attribute, Interface - - -@public -class IWorkflowState(Interface): - """The state of a workflow.""" - - token = Attribute('A unique key identifying the workflow instance.') - - step = Attribute("This workflow's next step.") - - data = Attribute('Additional data (may be JSON-encoded).') - - -@public -class IWorkflowStateManager(Interface): - """The workflow states manager.""" - - def save(token, step, data=None): - """Save the state of a workflow. - - :param token: A unique token identifying this workflow instance. - :type token: str - :param step: The next step for this workflow. - :type step: str - :param data: Additional data (workflow-specific). - :type data: str - """ - - def restore(token): - """Get the saved state for a workflow or None if nothing was saved. - - :param token: A unique token identifying this workflow instance. - :type token: str - :return: The saved state associated with this name/token pair, or None - if the pair isn't in the database. - :rtype: ``IWorkflowState`` - """ - - def discard(token): - """Throw away the saved state for a workflow. - - :param token: A unique token identifying this workflow instance. - :type token: str - """ - - count = Attribute('The number of saved workflows in the database.') diff --git a/src/mailman/interfaces/workflows.py b/src/mailman/interfaces/workflows.py new file mode 100644 index 000000000..b110a481e --- /dev/null +++ b/src/mailman/interfaces/workflows.py @@ -0,0 +1,128 @@ +# Copyright (C) 2015-2017 by the Free Software Foundation, Inc. +# +# This file is part of GNU Mailman. +# +# GNU Mailman 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 (at your option) +# any later version. +# +# GNU Mailman 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 +# GNU Mailman. If not, see . + +"""Interfaces describing the a workflow, it's state and it's state manager.""" + +from public import public +from zope.interface import Attribute, Interface + + +@public +class IWorkflowState(Interface): + """The state of a workflow.""" + + token = Attribute('A unique key identifying the workflow instance.') + + step = Attribute("This workflow's next step.") + + data = Attribute('Additional data (may be JSON-encoded).') + + +@public +class IWorkflowStateManager(Interface): + """The workflow states manager.""" + + def save(token, step, data=None): + """Save the state of a workflow. + + :param token: A unique token identifying this workflow instance. + :type token: str + :param step: The next step for this workflow. + :type step: str + :param data: Additional data (workflow-specific). + :type data: str + """ + + def restore(token): + """Get the saved state for a workflow or None if nothing was saved. + + :param token: A unique token identifying this workflow instance. + :type token: str + :return: The saved state associated with this name/token pair, or None + if the pair isn't in the database. + :rtype: ``IWorkflowState`` + """ + + def discard(token): + """Throw away the saved state for a workflow. + + :param token: A unique token identifying this workflow instance. + :type token: str + """ + + count = Attribute('The number of saved workflows in the database.') + + +@public +class IWorkflow(Interface): + """A workflow.""" + + name = Attribute('The name of the workflow, must be unique.') + description = Attribute('A brief description of the workflow.') + initial_state = Attribute('The state in which the workflow starts.') + save_attributes = Attribute('The sequence of attributes of the workflow, ' + 'which are saved.') + + def __iter__(): + """Return an iterator over the steps.""" + + def __next__(): + """Run the next step from the queue. + + :return: The result of the step run. + """ + + def push(step): + """Push a step to this workflows queue.""" + + def run_thru(stop_after): + """Run the state machine through and including the given step. + + :param stop_after: Name of method, sans prefix to run the + state machine through. In other words, the state machine runs + until the named method completes. + """ + + def run_until(stop_before): + """Run the state machine until (not including) the given step. + + :param stop_before: Name of method, sans prefix that the + state machine is run until the method is reached. Unlike + `run_thru()` the named method is not run. + """ + + def save(): + """Save the workflow in it's current state. + + Needs to have the `token` attribute set. + """ + + def restore(): + """Restore the workflow from the database. + + Needs to have the `token` attribute set. + """ + + +@public +class ISubscriptionWorkflow(IWorkflow): + """A workflow used for subscription.""" + + +@public +class IUnsubscriptionWorkflow(IWorkflow): + """A workflow used for unsubscription.""" -- cgit v1.3.1