""" RabbitMQSync service to synchronize the internal RabbitMQ database.
    according to CS content. The whole work is done by the RabbitMQSynchronizer
    that is activated when the CS was changed.
"""
from __future__ import absolute_import
from __future__ import division
from __future__ import print_function

__RCSID__ = "45ddde113 (2021-10-01 11:19:55 +0200) Chris Burr <christopher.burr@cern.ch>"

from DIRAC.Core.DISET.RequestHandler import RequestHandler
from DIRAC import S_OK
from DIRAC import gConfig
from DIRAC.FrameworkSystem.Utilities import RabbitMQSynchronizer


class RabbitMQSyncHandler(RequestHandler):
    """Service to synchronize the content of internal RabbitMQ database
    with the CS content. The work is done by the RabbitMQSynchronizer
    that acts when the CS is changed.
    """

    @classmethod
    def initializeHandler(cls, _serviceInfo):
        """Handler initialization"""
        syncObject = RabbitMQSynchronizer.RabbitMQSynchronizer()
        gConfig.addListenerToNewVersionEvent(syncObject.sync)
        return S_OK()