# -*- coding: utf-8 -*-

# Copyright (c) 2012 CoNWeT Lab., Universidad Politécnica de Madrid

# This file is part of Wirecloud.

# Wirecloud is free software: you can redistribute it and/or modify
# it under the terms of the GNU Affero General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.

# Wirecloud 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 Affero General Public License for more details.

# You should have received a copy of the GNU Affero General Public License
# along with Wirecloud.  If not, see <http://www.gnu.org/licenses/>.

from django.db.transaction import is_dirty, leave_transaction_management, rollback, commit, enter_transaction_management, managed
from django.db import DEFAULT_DB_ALIAS
from django.http import HttpResponse


def commit_on_http_success(func, using=None):
    """
    This decorator activates db commit on HTTP success response. This way, if the
    view function return a success reponse, a commit is made; if the viewfunc
    produces an exception or return an error response, a rollback is made.
    """
    if using is None:
        using = DEFAULT_DB_ALIAS

    def wrapped_func(*args, **kwargs):
        enter_transaction_management(using=using)
        managed(True, using=using)

        try:
            res = func(*args, **kwargs)
        except:
            if is_dirty(using=using):
                rollback(using=using)
            raise
        else:
            if is_dirty(using=using):

                if not isinstance(res, HttpResponse) or res.status_code < 200 or res.status_code >= 400:
                    rollback(using=using)
                else:
                    try:
                        commit(using=using)
                    except:
                        rollback(using=using)
                        raise
        finally:
            leave_transaction_management(using=using)

        return res

    return wrapped_func

# -*- coding: utf-8 -*-

# Copyright (c) 2012 CoNWeT Lab., Universidad Politécnica de Madrid

# This file is part of Wirecloud.

# Wirecloud is free software: you can redistribute it and/or modify
# it under the terms of the GNU Affero General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.

# Wirecloud 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 Affero General Public License for more details.

# You should have received a copy of the GNU Affero General Public License
# along with Wirecloud.  If not, see <http://www.gnu.org/licenses/>.

from django.db.transaction import is_dirty, leave_transaction_management, rollback, commit, enter_transaction_management, managed
from django.db import DEFAULT_DB_ALIAS
from django.http import HttpResponse

try:
    from django.db.transaction import atomic, set_rollback

    def commit_on_http_success(func, using=None):

        def wrapped_func(*args, **kwargs):

            with atomic(using=using):
                res = func(*args, **kwargs)

                if not isinstance(res, HttpResponse) or res.status_code < 200 or res.status_code >= 400:
                    set_rollback(True, using=using)

            return res

        return wrapped_func

except:

    def commit_on_http_success(func, using=None):
        """
        This decorator activates db commit on HTTP success response. This way, if the
        view function return a success reponse, a commit is made; if the viewfunc
        produces an exception or return an error response, a rollback is made.
        """
        if using is None:
            using = DEFAULT_DB_ALIAS

        def wrapped_func(*args, **kwargs):
            enter_transaction_management(using=using)
            managed(True, using=using)

            try:
                res = func(*args, **kwargs)
            except:
                if is_dirty(using=using):
                    rollback(using=using)
                raise
            else:
                if is_dirty(using=using):

                    if not isinstance(res, HttpResponse) or res.status_code < 200 or res.status_code >= 400:
                        rollback(using=using)
                    else:
                        try:
                            commit(using=using)
                        except:
                            rollback(using=using)
                            raise
            finally:
                leave_transaction_management(using=using)

            return res

        return wrapped_func

Make commit_on_http_success django 1.6 compatible