from vigilo.turbogears import VigiloAppConfig

import vigiboard

import logging

LOGGER = logging.getLogger(__name__)

                plugin_class = ep.load(require=True)

                if issubclass(plugin_class, VigiboardRequestPlugin):

                    plugins.append((unicode(ep.name), plugin_class()))

                LOGGER.exception(u'Unable to import plugin %s', plugin_name)

        config['columns_plugins'] = plugins

"""Sample controller module"""

import logging

from datetime import datetime

from tg.controllers import CUSTOM_CONTENT_TYPE

from vigilo.turbogears.controllers import BaseController

        Cette méthode DEVRAIT être surchargée dans les classes dérivées.

            sur la page.

        @return: Dictionnaire associant à chaque identifiant

            d'évènement les données à afficher par le plugin.

        @rtype:  C{dict}

    def get_search_fields(self):

        return []

        pass

applications externes.

"""

from tg import config, url

from sqlalchemy.sql.expression import null as expr_null, union_all

from vigilo.models.tables.group import Group

from vigilo.models.tables.grouphierarchy import GroupHierarchy

from vigilo.models.tables.secondary_tables import SUPITEM_GROUP_TABLE

from sqlalchemy.orm import aliased

from sqlalchemy import or_

class GroupSelector(twf.InputField):

    params = ["choose_text", "text_value", "clear_text"]

    choose_text = l_('Choose')

"""

import tw.forms as twf

from pylons.i18n import lazy_ugettext as l_

from vigilo.models.tables import CorrEvent

from vigiboard.controllers.plugins import VigiboardRequestPlugin, ITEMS

from tw.forms.fields import ContainerMixin, FormField

class HorizontalBox(ContainerMixin, FormField):

    """

__all__ = ('RootController', 'get_last_modification_timestamp',

           'date_to_timestamp')

class RootController(AuthController):

    """

    Le controller général de vigiboard

        # On récupère la liste de tous les identifiants des événements

        # à mettre à jour.

        user = get_current_user()

        events = VigiboardRequest(user)

from repoze.what.predicates import in_group

from sqlalchemy import not_, and_, asc, desc

from sqlalchemy.orm import contains_eager

from vigilo.models.session import DBSession

from vigilo.models.tables import Event, CorrEvent, EventHistory, \

    Host, LowLevelService, StateName, UserSupItem

from vigiboard.widgets.edit_event import EditEventForm

from vigiboard.controllers.plugins import VigiboardRequestPlugin, INNER, ITEMS

                # On tire ici partie du fait que les listes sont passées

                # par référence dans les fonctions.

                subqueries = [lls_query, host_query]

                    instance.handle_search_fields(

                        self, search, INNER, subqueries)

                lls_query = subqueries[0]

                # On tire ici partie du fait que les listes sont passées

                # par référence dans les fonctions.

                subqueries = [items]

                    instance.handle_search_fields(

                        self, search, INNER, subqueries)

                items = subqueries[0]

        if search is not None:

            # 2nde passe pour les filtres : self.items est désormais défini.

                instance.handle_search_fields(self, search, ITEMS, subqueries)

        if mask_closed_events:

from formencode.api import FancyValidator, Invalid

from datetime import datetime

class DateFormatConverter(FancyValidator):

    """

            # TRANSLATORS: http://www.dynarch.com/static/jscalendar-1.0/doc/html/reference.html#node_sec_5.3.5

            # TRANSLATORS: http://docs.python.org/release/2.5/lib/module-time.html

            date = datetime.strptime(str_date, _('%Y-%m-%d %I:%M:%S %p').encode('utf8'))

            raise Invalid(self.message('invalid', state), value, state)

        return date

from vigiboard.tests import TestController

from vigilo.models.session import DBSession

from vigilo.models.demo import functions

def insert_deps(return_service):

    """

    correvent = DBSession.query(CorrEvent).first()

    event = DBSession.query(Event).first()

class TestDetailsPlugin(TestController):

    """Teste le dialogue pour l'accès aux historiques."""

    def test_details_plugin_LLS_alert_when_allowed(self):

        """Dialogue des détails avec un LLS et les bons droits."""

        response = self.app.post('/plugin_json', {

                'idcorrevent': idcorrevent,

    def test_details_plugin_LLS_alert_when_manager(self):

        """Dialogue des détails avec un LLS en tant que manager."""

        response = self.app.post('/plugin_json', {

                'idcorrevent': idcorrevent,

    def test_details_plugin_host_alert_when_allowed(self):

        """Dialogue des détails avec un hôte et les bons droits."""

        response = self.app.post('/plugin_json', {

                'idcorrevent': idcorrevent,

    def test_details_plugin_host_alert_when_manager(self):

        """Dialogue des détails avec un hôte en tant que manager."""

        response = self.app.post('/plugin_json', {

                'idcorrevent': idcorrevent,

    def test_details_plugin_LLS_when_forbidden(self):

        """Dialogue des détails avec un LLS et des droits insuffisants."""

        # Le contrôleur renvoie une erreur 404 (HTTPNotFound)

        # lorsque l'utilisateur n'a pas les permissions nécessaires sur

    def test_details_plugin_host_when_forbidden(self):

        """Dialogue des détails avec un hôte et des droits insuffisants."""

        # Le contrôleur renvoie une erreur 404 (HTTPNotFound)

        # lorsque l'utilisateur n'a pas les permissions nécessaires sur

    def test_details_plugin_LLS_anonymous(self):

        """Dialogue des détails avec un LLS et en anonyme."""

        # Le contrôleur renvoie une erreur 401 (HTTPUnauthorized)

        # lorsque l'utilisateur n'est pas authentifié.

    def test_details_plugin_host_anonymous(self):

        """Dialogue des détails avec un hôte et en anonyme."""

        # Le contrôleur renvoie une erreur 401 (HTTPUnauthorized)

        # lorsque l'utilisateur n'est pas authentifié.

""" Test du plugin listant les services de haut niveau impactés. """

import transaction

from nose.tools import assert_equal

from vigilo.models.session import DBSession

from vigilo.models.demo import functions

from vigiboard.tests import TestController

def populate_DB():

Test du tableau d'événements de Vigiboard

"""

from nose.tools import assert_true, assert_equal

from vigiboard.tests import TestController

class TestEventTable(TestController):

    """

"""

Teste l'arbre de sélection des groupes du formulaire de recherche

"""

import transaction

from vigiboard.tests import TestController

from vigilo.models.session import DBSession

class TestGroupSelectionTree(TestController):

    """Teste l'arbre de sélection des groupes du formulaire de recherche."""

        # L'utilisateur n'est pas authentifié.

        # Il cherche à obtenir la liste des groupes fils d'un groupe donné.

            status=401)

    def test_get_group_when_not_allowed(self):

        """Récupération des groupes racines de l'arbre en anonyme"""

        # L'utilisateur n'est pas authentifié, et cherche

        # à obtenir la liste des groupes racines de l'arbre.

    def test_get_root_group_when_not_allowed(self):

        """Récupération des groupes racines de l'arbre sans les droits"""

        # Récupération du groupe utilisé lors de ce test.

        # Création d'un nouvel utilisateur et d'un nouveau groupe

        usergroup = UserGroup(group_name=u'new_users')

from vigilo.models.session import DBSession

from vigilo.models.demo import functions

from vigiboard.tests import TestController

def populate_DB():

        timestamp=datetime.now()))

    DBSession.flush()

    return event.idevent

        # On peuple la BDD avec un hôte, un service de bas niveau,

        # et un groupe d'hôtes et de services associés à ces items.

        # On ajoute un évènement corrélé causé par l'hôte

        idevent = add_correvent_caused_by(managerhost)

        # On peuple la BDD avec un hôte, un service de bas niveau,

        # et un groupe d'hôtes et de services associés à ces items.

        # On ajoute un évènement corrélé causé par le service

        idevent = add_correvent_caused_by(managerservice)

from vigilo.models.session import DBSession

from vigilo.models.demo import functions

from vigiboard.tests import TestController

def populate_accounts():

        # L'utilisateur n'est pas authentifié.

        # On s'attend à ce qu'une erreur 401 soit renvoyée,

        # demandant à l'utilisateur de s'authentifier.

            '/masked_events/%d' % idcorrevent,

            status = 401)

"""

from nose.tools import assert_true, assert_false, assert_equal

from datetime import datetime

from time import mktime

import transaction

from vigilo.models.session import DBSession

from vigilo.models.demo import functions

from vigiboard.tests import TestController

from tg import config

        # On peuple la BDD avec 2 hôtes, 2 services de bas niveau,

        # et un groupe d'hôtes et de services associés à ces items.

        # On ajoute 2 évènements corrélés causés par ces hôtes

        timestamp = datetime.now()

        # On peuple la BDD avec 2 hôtes, 2 services de bas niveau,

        # et un groupe d'hôtes et de services associés à ces items.

        # On ajoute 2 évènements corrélés causés par ces hôtes

        timestamp = datetime.now()

        # On peuple la BDD avec 2 hôtes, 2 services de bas niveau,

        # et un groupe d'hôtes et de services associés à ces items.

        # On ajoute 2 évènements corrélés causés par ces hôtes

        timestamp = datetime.now()

        # On peuple la BDD avec 2 hôtes, 2 services de bas niveau,

        # et un groupe d'hôtes et de services associés à ces items.

        # On ajoute 2 évènements corrélés causés par ces hôtes

        timestamp = datetime.now()

        # On peuple la BDD avec 2 hôtes, 2 services de bas niveau,

        # et un groupe d'hôtes et de services associés à ces items.

        # On ajoute 2 évènements corrélés causés par ces hôtes

        timestamp = datetime.now()

        correvent1_id = add_correvent_caused_by(services[0], timestamp)

        # Date de modification du premier évènement corrélé

        later_date = datetime.now()

"""

Teste le formulaire de recherche avec divers champs.

"""

from nose.tools import assert_true, assert_equal

from datetime import datetime

import transaction

from vigiboard.tests import TestController

from vigilo.models.session import DBSession

from vigilo.models.demo import functions

def insert_deps():

    """Insère les dépendances nécessaires aux tests."""

    DBSession.flush()

    event = functions.add_event(service, u'WARNING', u'Hello world', timestamp)

    return (hostgroup, servicegroup)

class TestSearchFormService(TestController):

    """Teste la récupération d'événements selon le groupe de services."""

    def setUp(self):

"""

Teste le formulaire de recherche avec un groupe d'hôtes.

"""

from nose.tools import assert_true, assert_equal

from vigiboard.tests import TestController

class TestSearchFormSupItemGroup(TestController):

    """Teste la récupération d'événements selon le supitemgroup."""

    def test_search_supitemgroup_when_disallowed(self):

        """Teste la recherche par supitemgroup SANS les droits d'accès."""

        group2 = SupItemGroup.by_group_name(u'group2')

        # L'utilisateur n'est pas authentifié.

Fonctions utilitaires réutilisables dans les différents tests.

"""

import transaction

from vigilo.models.session import DBSession

from vigilo.models.demo import functions

def populate_DB():

    """ Peuple la base de données. """

    DBSession.flush()

    # Création de 3 services de bas niveau (1 par hôte).

    group1_service = functions.add_lowlevelservice(

        group1_host, u'group1_service')

    group2_service = functions.add_lowlevelservice(

    # Ajout de 5 événements corrélés (1 pour chaque évènement,

    # sauf celui touchant le 'maingroup_service' qui sera rattaché

    # à l'évènement corrélé causé par le 'maingroup_host').

    transaction.commit()

"""Setup the vigiboard application"""

__all__ = ['setup_app', 'populate_db']

def setup_app(command, conf, variables):

"""Le formulaire de recherche/filtrage."""

from pylons.i18n import lazy_ugettext as l_

import tw.forms as twf

import tg