Produits Entr'ouvert » Corbo

default_app_config = 'hobo.agent.corbo.apps.CorboAgentConfig'

# hobo - portal to configure and deploy applications

# Copyright (C) 2015  Entr'ouvert

#

# This program 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.

#

# This program 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 this program.  If not, see <http://www.gnu.org/licenses/>.

from django.apps import AppConfig

class CorboAgentConfig(AppConfig):

    name = 'hobo.agent.corbo'

    label = 'corbo_agent'

    verbose_name = 'Corbo Agent'

# hobo - portal to configure and deploy applications

# Copyright (C) 2015  Entr'ouvert

#

# This program 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.

#

# This program 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 this program.  If not, see <http://www.gnu.org/licenses/>.

from django.db.transaction import atomic

from hobo.agent.common.management.commands.hobo_notify import Command as CommonCommand

from corbo.models import Subscription

class Command(CommonCommand):

    @classmethod

    def process_notification(cls, tenant, notification):

        super(CommonCommand, self).process_notification(cls, tenant, notification)

        action = notification['@type']

        data = notification['objects']['data']

        for o in data:

            for s in Subscription.objects.filter(uuid=o['uuid']):

                with atomic():

                    if action == 'provision':

                        if s.identifier.startswith('mailto:'):

                            s.identifier = 'mailto:%s' % o['email']

                        elif s.identifier.startswith('sms:'):

                            s.identifier = 'sms:%s' % o['mobile']

                        s.save()

                    elif action == 'deprovision':

                        s.delete()