Statistics
| Branch: | Tag: | Revision:

root / snf-astakos-app / astakos / im / project_xctx.py @ 469d0997

History | View | Annotate | Download (2.6 kB)

1
# Copyright 2013 GRNET S.A. All rights reserved.
2
#
3
# Redistribution and use in source and binary forms, with or
4
# without modification, are permitted provided that the following
5
# conditions are met:
6
#
7
#   1. Redistributions of source code must retain the above
8
#      copyright notice, this list of conditions and the following
9
#      disclaimer.
10
#
11
#   2. Redistributions in binary form must reproduce the above
12
#      copyright notice, this list of conditions and the following
13
#      disclaimer in the documentation and/or other materials
14
#      provided with the distribution.
15
#
16
# THIS SOFTWARE IS PROVIDED BY GRNET S.A. ``AS IS'' AND ANY EXPRESS
17
# OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
18
# WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
19
# PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL GRNET S.A OR
20
# CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
21
# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
22
# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
23
# USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
24
# AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
25
# LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
26
# ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
27
# POSSIBILITY OF SUCH DAMAGE.
28
#
29
# The views and conclusions contained in the software and
30
# documentation are those of the authors and should not be
31
# interpreted as representing official policies, either expressed
32
# or implied, of GRNET S.A.
33

    
34
from astakos.im.retry_xctx import RetryTransactionHandler
35
from astakos.im.notification_xctx import NotificationTransactionContext
36
from astakos.im.models import sync_projects
37
from astakos.im.project_error import project_error_view
38

    
39
# USAGE
40
# =====
41
# @project_transaction_context(sync=True)
42
# def a_view(args, ctx=None):
43
#     ...
44
#     if ctx:
45
#         ctx.mark_rollback()
46
#     ...
47
#     return http response
48
#
49
# OR (more cleanly)
50
#
51
# def a_view(args):
52
#     with project_transaction_context(sync=True) as ctx:
53
#         ...
54
#         ctx.mark_rollback()
55
#         ...
56
#         return http response
57

    
58
def project_transaction_context(**kwargs):
59
    return RetryTransactionHandler(ctx=ProjectTransactionContext,
60
                                   on_fail=project_error_view,
61
                                   **kwargs)
62

    
63
class ProjectTransactionContext(NotificationTransactionContext):
64
    def __init__(self, sync=False, **kwargs):
65
        self._sync = sync
66
        NotificationTransactionContext.__init__(self, **kwargs)
67

    
68
    def postprocess(self):
69
        if self._sync:
70
            sync_projects()
71
        NotificationTransactionContext.postprocess(self)