Synnefo

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

# Copyright 2011 GRNET S.A. All rights reserved.

# 

# Redistribution and use in source and binary forms, with or

# without modification, are permitted provided that the following

# conditions are met:

# 

#   1. Redistributions of source code must retain the above

#      copyright notice, this list of conditions and the following

#      disclaimer.

# 

#   2. Redistributions in binary form must reproduce the above

#      copyright notice, this list of conditions and the following

#      disclaimer in the documentation and/or other materials

#      provided with the distribution.

# 

# THIS SOFTWARE IS PROVIDED BY GRNET S.A. ``AS IS'' AND ANY EXPRESS

# OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED

# WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR

# PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL GRNET S.A OR

# CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,

# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT

# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF

# USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED

# AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT

# LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN

# ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE

# POSSIBILITY OF SUCH DAMAGE.

# 

# The views and conclusions contained in the software and

# documentation are those of the authors and should not be

# interpreted as representing official policies, either expressed

# or implied, of GRNET S.A.

# 

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

#

# Queues, exchanges and bindings for AMQP

###########################################

# Rabbit work queue endpoint

RABBIT_HOST = "62.217.120.67:5672"

RABBIT_USERNAME = "okeanos"

RABBIT_PASSWORD = "0k3@n0s"

RABBIT_VHOST = "/"

EXCHANGE_GANETI = "ganeti"  # Messages from Ganeti

EXCHANGE_CRON = "cron"      # Messages from periodically triggered tasks

EXCHANGE_API = "api"        # Messages from the REST API

EXCHANGES = (EXCHANGE_GANETI, EXCHANGE_CRON, EXCHANGE_API)

def fix_amqp_settings(backend_prefix):

    """Configure AMQP-specific settings

    Configure AMQP-specific settings based on backend_prefix.

    This function *must* be called later in settings.py, with

    BACKEND_PREFIX_ID as argument.

    """

    global BINDINGS, QUEUES, QUEUE_DEBUG, BINDINGS_DEBUG

    BINDINGS = []

    QUEUES = []

    prefix = backend_prefix.split('-')[0]

    QUEUE_GANETI_EVENTS_OP = "%s-events-op" % prefix

    QUEUE_GANETI_EVENTS_NET = "%s-events-net" % prefix

    QUEUE_CRON_CREDITS = "credits"

    QUEUE_EMAIL = "%s-email" % prefix

    QUEUE_RECONC = "reconciliation"

    if DEBUG is True:

        QUEUE_DEBUG = "debug"       # Debug queue, retrieves all messages

    QUEUES = (QUEUE_GANETI_EVENTS_OP, QUEUE_GANETI_EVENTS_NET,

              QUEUE_CRON_CREDITS, QUEUE_EMAIL, QUEUE_RECONC)

    if DEBUG is True:

        BINDINGS_DEBUG = [

        # Queue         # Exchange          # RouteKey  # Handler

        (QUEUE_DEBUG,   EXCHANGE_GANETI,    '#',        'dummy_proc'),

        (QUEUE_DEBUG,   EXCHANGE_CRON,      '#',        'dummy_proc'),

        (QUEUE_DEBUG,   EXCHANGE_API,       '#',        'dummy_proc'),

        ]

        QUEUES += (QUEUE_DEBUG,)

    # notifications of type "ganeti-op-status"

    DB_HANDLER_KEY_OP ='ganeti.%s.event.op' % prefix 

    # notifications of type "ganeti-net-status"

    DB_HANDLER_KEY_NET ='ganeti.%s.event.net' % prefix

    # notifications of type "email"

    EMAIL_HANDLER_KEY = '*.email.%s.*' % prefix

    BINDINGS = [

    # Queue                     # Exchange          # RouteKey              # Handler

    (QUEUE_GANETI_EVENTS_OP,    EXCHANGE_GANETI,    'ganeti.*.event.op',    'update_db'),

    (QUEUE_GANETI_EVENTS_NET,   EXCHANGE_GANETI,    'ganeti.*.event.net',   'update_net'),

    (QUEUE_CRON_CREDITS,        EXCHANGE_CRON,      '*.credits.*',          'update_credits'),

    (QUEUE_EMAIL,               EXCHANGE_API,       '*.email.*',            'send_email'),

    (QUEUE_EMAIL,               EXCHANGE_CRON,      '*.email.*',            'send_email'),

    (QUEUE_RECONC,              EXCHANGE_CRON,      'reconciliation.*',     'trigger_status_update'),

    ]

# Fix up the AMQP-specific settings based on BACKEND_PREFIX_ID

# Make sure to call it again, if you modify it at some later point

fix_amqp_settings(BACKEND_PREFIX_ID)