""" 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__ = "c0787e027 (2021-05-20 13:00:51 +0200) fstagni <federico.stagni@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()